This is an automated email from the ASF dual-hosted git repository. sivabalan pushed a commit to branch release-0.5.3 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 77d7500d3bbcedda81fa182908984e658d6689e5 Author: Pratyaksh Sharma <[email protected]> AuthorDate: Sun Mar 22 19:49:47 2020 +0530 [HUDI-616] Fixed parquet files getting created on local FS (#1434) --- .../test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java b/hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java index 1435faa..606b6bb 100644 --- a/hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java +++ b/hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieDeltaStreamer.java @@ -99,7 +99,7 @@ public class TestHoodieDeltaStreamer extends UtilitiesTestBase { private static final String PROPS_FILENAME_TEST_SOURCE = "test-source.properties"; private static final String PROPS_FILENAME_TEST_INVALID = "test-invalid.properties"; private static final String PROPS_FILENAME_TEST_PARQUET = "test-parquet-dfs-source.properties"; - private static final String PARQUET_SOURCE_ROOT = dfsBasePath + "/parquetFiles"; + private static String PARQUET_SOURCE_ROOT; private static final int PARQUET_NUM_RECORDS = 5; private static final Logger LOG = LogManager.getLogger(TestHoodieDeltaStreamer.class); @@ -108,6 +108,7 @@ public class TestHoodieDeltaStreamer extends UtilitiesTestBase { @BeforeClass public static void initClass() throws Exception { UtilitiesTestBase.initClass(true); + PARQUET_SOURCE_ROOT = dfsBasePath + "/parquetFiles"; // prepare the configs. UtilitiesTestBase.Helpers.copyToDFS("delta-streamer-config/base.properties", dfs, dfsBasePath + "/base.properties");
