openinx commented on PR #4553:
URL: https://github.com/apache/iceberg/pull/4553#issuecomment-1107692125
```patch
diff --git
a/v1.14/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java
b/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java
index b0041c3bc..d73363395 100644
---
a/v1.14/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java
+++
b/v1.15/flink/src/test/java/org/apache/iceberg/flink/source/BoundedTableFactory.java
@@ -34,6 +34,7 @@ import
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.SourceFunction;
import org.apache.flink.table.api.TableSchema;
import org.apache.flink.table.connector.ChangelogMode;
+import org.apache.flink.table.connector.ProviderContext;
import org.apache.flink.table.connector.source.DataStreamScanProvider;
import org.apache.flink.table.connector.source.DynamicTableSource;
import org.apache.flink.table.connector.source.ScanTableSource;
@@ -133,8 +134,10 @@ public class BoundedTableFactory implements
DynamicTableSourceFactory {
@Override
public ScanRuntimeProvider getScanRuntimeProvider(ScanContext
runtimeProviderContext) {
return new DataStreamScanProvider() {
+ // UPDATED
@Override
- public DataStream<RowData>
produceDataStream(StreamExecutionEnvironment env) {
+ public DataStream<RowData> produceDataStream(
+ ProviderContext providerContext, StreamExecutionEnvironment
env) {
boolean checkpointEnabled =
env.getCheckpointConfig().isCheckpointingEnabled();
SourceFunction<Row> source = new
BoundedTestSource<>(elementsPerCheckpoint, checkpointEnabled);
```
Ditto.
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
