zixiao144

Results 16 comments of zixiao144

![image](https://user-images.githubusercontent.com/21092977/191221949-f47d6871-12a3-4282-8eac-91c427bd7b71.png) 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: ![image](https://user-images.githubusercontent.com/21092977/191388640-e3c461df-ff87-4836-89fb-a3bd75614a76.png)...

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 : ![image](https://user-images.githubusercontent.com/21092977/191412497-b2cd9994-89e6-4dcd-aaa5-cd771316c8c6.png) ![image](https://user-images.githubusercontent.com/21092977/191412570-24962e96-985d-40cb-9946-73352da7f74e.png) and ![image](https://user-images.githubusercontent.com/21092977/191412654-7719b07d-8201-43a2-8798-c6d9ffbec9a2.png) ![image](https://user-images.githubusercontent.com/21092977/191412696-70e88fd5-2d96-4655-a79d-17a6af818dd8.png) ![image](https://user-images.githubusercontent.com/21092977/191412733-68b00e20-3d61-4708-b9c3-4d9779a9f66a.png)

[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...

![image](https://user-images.githubusercontent.com/21092977/192405038-3a35bcad-0977-4167-9180-a8cde9b034ed.png) I opened debug