zixiao144
zixiao144
 it is always pending, no result
2022-09-20 21:15:43,205 INFO org.apache.flink.api.java.typeutils.TypeExtractor [] - class org.apache.iceberg.flink.source.FlinkInputSplit does not contain a getter for field task 2022-09-20 21:15:43,206 INFO org.apache.flink.api.java.typeutil
@stevenzwu I use flink1.15.2's sqlclient.sh .Do simple test. SET execution.runtime-mode = streaming; SET table.dynamic-table-options.enabled=true; or (SET table.exec.iceberg.use-flip27-source = true;) select * from test /*+ OPTIONS('streaming'='true', 'monitor-interval'='1s')*/ ; streaming result: ...
I must be use sql,I use pyflink。How to do deal with it. Thanks
thanks @stevenzwu I use hadoop catelog . step1 stream read step2 appended data not work,no result.
begin :   and   
[jobmanager_log.txt](https://github.com/apache/iceberg/files/9643722/jobmanager_log.txt) [flink-root-taskexecutor-0-violet.log](https://github.com/apache/iceberg/files/9643725/flink-root-taskexecutor-0-violet.log) [flink--sql-client-violet.log](https://github.com/apache/iceberg/files/9643728/flink--sql-client-violet.log) [taskmanager_localhost_44203-b19935_log.txt](https://github.com/apache/iceberg/files/9643731/taskmanager_localhost_44203-b19935_log.txt) I use flink1.15.2 ,iceberg 0.14.1 Flink 1.15 runtime Jar
[flink-root-sql-client-violet.log](https://github.com/apache/iceberg/files/9650453/flink-root-sql-client-violet.log) [jobmanager_log (1).txt](https://github.com/apache/iceberg/files/9650457/jobmanager_log.1.txt) [flink-root-taskexecutor-0-violet (1).log](https://github.com/apache/iceberg/files/9650458/flink-root-taskexecutor-0-violet.1.log)
in [flink-root-taskexecutor](https://github.com/apache/iceberg/files/9650458/flink-root-taskexecutor-0-violet.1.log) log lines from org.apache.iceberg . 2022-09-27 00:19:28,670 DEBUG org.apache.flink.streaming.runtime.tasks.StreamTask [] - Legacy source Source: Iceberg table (iotCatalog.iotdw.test) monitor (1/1)#0 (d77ec0c3c3c1493cb4a6a506b8648be3) skip execution since the task is finished on...
 I opened debug