You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by pr...@apache.org on 2022/03/19 06:35:29 UTC
[hudi] 01/01: checkstyle fix
This is an automated email from the ASF dual-hosted git repository.
pratyakshsharma pushed a commit to branch HUDI-1881-async-delta
in repository https://gitbox.apache.org/repos/asf/hudi.git
commit fcababc128496e5f8fecc9026e0432a0f43337cf
Author: Pratyaksh Sharma <pr...@gmail.com>
AuthorDate: Sat Mar 19 12:04:47 2022 +0530
checkstyle fix
---
.../hudi/utilities/functional/TestHoodieMultiTableDeltaStreamer.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieMultiTableDeltaStreamer.java b/hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieMultiTableDeltaStreamer.java
index 17e45da..c5815fd 100644
--- a/hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieMultiTableDeltaStreamer.java
+++ b/hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieMultiTableDeltaStreamer.java
@@ -264,7 +264,8 @@ public class TestHoodieMultiTableDeltaStreamer extends HoodieDeltaStreamerTestBa
}
}
- private void syncAndVerify(HoodieMultiTableDeltaStreamer streamer, String targetBasePath1, String targetBasePath2, long table1ExpectedRecords, long table2ExpectedRecords) throws InterruptedException {
+ private void syncAndVerify(HoodieMultiTableDeltaStreamer streamer, String targetBasePath1, String targetBasePath2, long table1ExpectedRecords, long table2ExpectedRecords)
+ throws InterruptedException {
streamer.sync();
TestHoodieDeltaStreamer.TestHelpers.assertRecordCount(table1ExpectedRecords, targetBasePath1 + "/*/*.parquet", sqlContext);
TestHoodieDeltaStreamer.TestHelpers.assertRecordCount(table2ExpectedRecords, targetBasePath2 + "/*/*.parquet", sqlContext);