From 1e1d9e1d345a104d6f873403ef2826778ac114d3 Mon Sep 17 00:00:00 2001 From: Pratyaksh Sharma Date: Sun, 22 Mar 2020 19:49:47 +0530 Subject: [PATCH] [HUDI-616] Fixed parquet files getting created on local FS (#1434) --- .../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 9224be094..92daf3a56 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 @@ -102,7 +102,7 @@ public class TestHoodieDeltaStreamer extends UtilitiesTestBase { private static final String PROPS_FILENAME_TEST_INVALID = "test-invalid.properties"; private static final String PROPS_FILENAME_TEST_CSV = "test-csv-dfs-source.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 int CSV_NUM_RECORDS = 3; private static final Logger LOG = LogManager.getLogger(TestHoodieDeltaStreamer.class); @@ -112,6 +112,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");