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));