stevenzwu commented on code in PR #10331:
URL: https://github.com/apache/iceberg/pull/10331#discussion_r1625080773
##########
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/AggregatedStatisticsTracker.java:
##########
@@ -30,71 +42,99 @@
* {@link AggregatedStatistics} received from {@link DataStatisticsOperator}
subtasks for specific
* checkpoint.
*/
-class AggregatedStatisticsTracker<D extends DataStatistics<D, S>, S> {
+class AggregatedStatisticsTracker {
private static final Logger LOG =
LoggerFactory.getLogger(AggregatedStatisticsTracker.class);
private static final double ACCEPT_PARTIAL_AGGR_THRESHOLD = 90;
private final String operatorName;
- private final TypeSerializer<DataStatistics<D, S>> statisticsSerializer;
private final int parallelism;
+ private final TypeSerializer<DataStatistics> statisticsSerializer;
+ private final int downstreamParallelism;
+ private final StatisticsType statisticsType;
Review Comment:
good catch. the variable is needed but missed as you pointed out in the
other comment below on coordinator migration from Map to Sketch
--
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: issues-unsubscr...@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org
