Skip to content

Commit

Permalink
SDC-12760. upgrade.test_pipelines_upgrade.test_pipeline_upgrade[pipel…
Browse files Browse the repository at this point in the history
…ine_full_path=/root/tests/upgrade/pipelines/sdc_1.6.0.0/Source_Destination/sdc_1.6.0.0_pipeline_Source_Destination.json] failing on Bifocals

Change-Id: I021eb6d79965dfd372795b4b051128826488dd21
Reviewed-on: https://review.streamsets.net/c/datacollector/+/27223
Tested-by: StreamSets CI <streamsets-ci-spam@streamsets.com>
Reviewed-by: Junwei Yu <junwei@streamsets.com>
(cherry picked from commit c1bf962)
Reviewed-on: https://review.streamsets.net/c/datacollector/+/27278
Reviewed-by: Keith Burns <keith@streamsets.com>
  • Loading branch information
Ji Sun committed Nov 5, 2019
1 parent 5b21c62 commit eb7a86f
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
import com.streamsets.pipeline.stage.destination.hdfs.HdfsTarget;

@StageDef(
version = 3,
version = 4,
label = "Local FS",
description = "Writes to the local file system",
icon = "localfilesystem.png",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
upgraderVersion: 1

upgrades:
- toVersion: 3
- toVersion: 4
actions:
- setConfig:
name: configs.dataGeneratorFormatConfig.basicAuthUserInfo
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@

public class TestLocalFileSystemTargetUpgrader {
@Test
public void testV2ToV3() {
public void testV3ToV4() {
List<Config> configs = new ArrayList<>();

final URL yamlResource = ClassLoader.getSystemClassLoader().getResource("upgrader/LocalFileSystemDTarget.yaml");
Expand All @@ -39,8 +39,8 @@ public void testV2ToV3() {
);

StageUpgrader.Context context = Mockito.mock(StageUpgrader.Context.class);
Mockito.doReturn(2).when(context).getFromVersion();
Mockito.doReturn(3).when(context).getToVersion();
Mockito.doReturn(3).when(context).getFromVersion();
Mockito.doReturn(4).when(context).getToVersion();

configs = upgrader.upgrade(configs, context);

Expand Down

0 comments on commit eb7a86f

Please sign in to comment.