This is an automated email from the ASF dual-hosted git repository.

jonvex 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 45486bfa55f [HUDI-7081] Enable fg reader for tests with enum typed 
data (#12609)
45486bfa55f is described below

commit 45486bfa55f4a2717d3bdcc6f58744ddd3b41739
Author: Lin Liu <[email protected]>
AuthorDate: Fri Jan 10 08:45:40 2025 -0800

    [HUDI-7081] Enable fg reader for tests with enum typed data (#12609)
---
 .../java/org/apache/hudi/utilities/sources/TestHoodieIncrSource.java   | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestHoodieIncrSource.java
 
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestHoodieIncrSource.java
index 7a487182710..dc6540eebe4 100644
--- 
a/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestHoodieIncrSource.java
+++ 
b/hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestHoodieIncrSource.java
@@ -21,7 +21,6 @@ package org.apache.hudi.utilities.sources;
 import org.apache.hudi.client.SparkRDDWriteClient;
 import org.apache.hudi.client.WriteStatus;
 import org.apache.hudi.common.config.HoodieMetadataConfig;
-import org.apache.hudi.common.config.HoodieReaderConfig;
 import org.apache.hudi.common.config.TypedProperties;
 import org.apache.hudi.common.model.HoodieAvroPayload;
 import org.apache.hudi.common.model.HoodieRecord;
@@ -608,8 +607,6 @@ public class TestHoodieIncrSource extends 
SparkClientFunctionalTestHarness {
     }
     properties.setProperty("hoodie.streamer.source.hoodieincr.path", 
basePath());
     
properties.setProperty("hoodie.streamer.source.hoodieincr.missing.checkpoint.strategy",
 missingCheckpointStrategy.name());
-    // TODO: [HUDI-7081] get rid of this
-    properties.setProperty(HoodieReaderConfig.FILE_GROUP_READER_ENABLED.key(), 
"false");
     properties.putAll(extraProps);
     snapshotCheckPointImplClassOpt.map(className ->
         
properties.setProperty(SnapshotLoadQuerySplitter.Config.SNAPSHOT_LOAD_QUERY_SPLITTER_CLASS_NAME,
 className));

Reply via email to