wwj6591812 commented on code in PR #8117:
URL: https://github.com/apache/paimon/pull/8117#discussion_r3458877362
##########
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/FlinkConnectorOptions.java:
##########
@@ -274,6 +274,16 @@ public class FlinkConnectorOptions {
+ "normal source, the max partition(s)
will be determined before job running "
+ "without refreshing even for streaming
jobs.");
+ public static final ConfigOption<Integer> SCAN_BUCKET =
Review Comment:
Good point — scan.bucket is a core scan option, not Flink-specific. I moved
SCAN_BUCKET to CoreOptions and let ReadBuilderImpl apply it automatically from
table options (via withBucket()), so Flink no longer needs ScanBucketUtils or
connector-level handling. Validation tests were moved to ReadBuilderImplTest,
and the existing Flink ITCase still covers end-to-end behavior through SQL
hints.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
