mirror of
https://github.com/apache/sqoop.git
synced 2025-05-16 08:51:02 +08:00
SQOOP-1447: Sqoop2: From/To: Change DirectionError messages
(Abraham Elmahrek via Jarek Jarcec Cecho)
This commit is contained in:
parent
1ebf1b89b3
commit
b69f4aca3b
@ -20,7 +20,7 @@
|
||||
public enum DirectionError implements ErrorCode {
|
||||
|
||||
/** An unknown error has occurred. */
|
||||
CONNECTOR_TYPE_0000("Unknown connector type")
|
||||
DIRECTION_0000("Unknown direction")
|
||||
|
||||
;
|
||||
|
||||
|
@ -72,7 +72,7 @@ public Validation getConnectorValidation(Direction type) {
|
||||
return toConnectorValidation;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -128,7 +128,7 @@ public MJobForms getJobForms(Direction type) {
|
||||
return toJobForms;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -142,7 +142,7 @@ public long getConnectionId(Direction type) {
|
||||
return toConnectionId;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
@ -155,7 +155,7 @@ public long getConnectorId(Direction type) {
|
||||
return toConnectorId;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
@ -168,7 +168,7 @@ public MJobForms getConnectorPart(Direction type) {
|
||||
return toConnectorPart;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -168,7 +168,7 @@ public SqoopConnector getConnector(Direction type) {
|
||||
return toConnector;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
@ -181,7 +181,7 @@ public void setConnector(Direction type, SqoopConnector connector) {
|
||||
toConnector = connector;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
@ -230,7 +230,7 @@ public Object getConnectorConnectionConfig(Direction type) {
|
||||
return toConnectorConnectionConfig;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
@ -243,7 +243,7 @@ public void setConnectorConnectionConfig(Direction type, Object config) {
|
||||
toConnectorConnectionConfig = config;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
@ -256,7 +256,7 @@ public Object getConnectorJobConfig(Direction type) {
|
||||
return toConnectorJobConfig;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
@ -269,7 +269,7 @@ public void setConnectorJobConfig(Direction type, Object config) {
|
||||
toConnectorJobConfig = config;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
@ -282,7 +282,7 @@ public Object getFrameworkConnectionConfig(Direction type) {
|
||||
return toFrameworkConnectionConfig;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
@ -295,7 +295,7 @@ public void setFrameworkConnectionConfig(Direction type, Object config) {
|
||||
toFrameworkConnectionConfig = config;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
@ -316,7 +316,7 @@ public MutableMapContext getConnectorContext(Direction type) {
|
||||
return toConnectorContext;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -2167,7 +2167,7 @@ public void loadConnectorForms(List<MForm> connectionForms,
|
||||
break;
|
||||
|
||||
default:
|
||||
throw new SqoopException(DirectionError.CONNECTOR_TYPE_0000, "Connector type: " + type);
|
||||
throw new SqoopException(DirectionError.DIRECTION_0000, "Direction: " + type);
|
||||
}
|
||||
|
||||
if (jobForms.size() != formIndex) {
|
||||
|
Loading…
Reference in New Issue
Block a user