This is an automated email from the ASF dual-hosted git repository.
sivabalan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 37d3d8ef504 [HUDI-6530] Fixing the correct resource path (#9202)
37d3d8ef504 is described below
commit 37d3d8ef504794d64fb87c838bf58bafa8acaa16
Author: lokesh-lingarajan-0310
<[email protected]>
AuthorDate: Fri Jul 14 18:58:51 2023 -0700
[HUDI-6530] Fixing the correct resource path (#9202)
Co-authored-by: Lokesh Lingarajan
<[email protected]>
---
.../java/org/apache/hudi/utilities/sources/TestGcsEventsSource.java | 2 +-
.../test/java/org/apache/hudi/utilities/sources/TestS3EventsSource.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestGcsEventsSource.java
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestGcsEventsSource.java
index 653cb823233..83108ee0c7e 100644
---
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestGcsEventsSource.java
+++
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestGcsEventsSource.java
@@ -63,7 +63,7 @@ public class TestGcsEventsSource extends UtilitiesTestBase {
@BeforeEach
public void beforeEach() throws Exception {
- schemaProvider = new
FilebasedSchemaProvider(Helpers.setupSchemaOnDFS("delta-streamer-config",
"gcs-metadata.avsc"), jsc);
+ schemaProvider = new
FilebasedSchemaProvider(Helpers.setupSchemaOnDFS("streamer-config",
"gcs-metadata.avsc"), jsc);
MockitoAnnotations.initMocks(this);
props = new TypedProperties();
diff --git
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestS3EventsSource.java
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestS3EventsSource.java
index 4db47c76784..5ed332a142d 100644
---
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestS3EventsSource.java
+++
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestS3EventsSource.java
@@ -51,7 +51,7 @@ public class TestS3EventsSource extends
AbstractCloudObjectsSourceTestBase {
this.dfsRoot = basePath + "/parquetFiles";
this.fileSuffix = ".parquet";
fs.mkdirs(new Path(dfsRoot));
- schemaProvider = new
FilebasedSchemaProvider(Helpers.setupSchemaOnDFS("delta-streamer-config",
"s3-metadata.avsc"), jsc);
+ schemaProvider = new
FilebasedSchemaProvider(Helpers.setupSchemaOnDFS("streamer-config",
"s3-metadata.avsc"), jsc);
}
@AfterEach