You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@sqoop.apache.org by "Veena Basavaraj (JIRA)" <ji...@apache.org> on 2014/10/22 22:38:34 UTC
[jira] [Assigned] (SQOOP-1605) Sqoop2: Misc From/to cleanups
[ https://issues.apache.org/jira/browse/SQOOP-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Veena Basavaraj reassigned SQOOP-1605:
--------------------------------------
Assignee: Abraham Elmahrek (was: Qian Xu)
> Sqoop2: Misc From/to cleanups
> ------------------------------
>
> Key: SQOOP-1605
> URL: https://issues.apache.org/jira/browse/SQOOP-1605
> Project: Sqoop
> Issue Type: Bug
> Affects Versions: 1.99.4
> Reporter: Veena Basavaraj
> Assignee: Abraham Elmahrek
>
> MRConfigurationUtils.setDriverConfig(job, request.getDriverConfig());
> // @TODO(Abe): Persist TO schema.
> MRConfigurationUtils.setConnectorSchema(Direction.FROM, job, request.getSummary().getFromSchema());
> MRConfigurationUtils.setConnectorSchema(Direction.TO, job, request.getSummary().getToSchema());
> upgraderOrder.verify(connectorUpgraderMock, times(1)).upgradeToJobConfig(any(MToConfig.class), any(MToConfig.class));
> upgraderOrder.verifyNoMoreInteractions();
> validatorOrder.verify(validatorMock, times(2)).validateConfigForLink(anyObject());
> // @TODO(Abe): Re-enable job validation?
> validatorOrder.verify(validatorMock, times(0)).validateConfigForJob(anyObject());
> ConsoleReader reader = new ConsoleReader();
> MJob job = client.createJob(fromLinkId, toLinkId);
> // @TODO(Abe): From/To.
> ResourceBundle fromConfigBundle = client.getConnectorConfigBundle(
> job.getConnectorId(Direction.FROM));
> upgraderOrder.verifyNoMoreInteractions();
> validatorOrder.verify(validatorMock, times(2)).validateConfigForLink(anyObject());
> // @TODO(Abe): Re-enable job validation?
> validatorOrder.verify(validatorMock, times(0)).validateConfigForJob(anyObject());
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)