ZHANG YINGHONG

[Bug] DorisSource createEnumerator error when has filter condition(pushDown)

4

### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-doris/issues?q=is%3Aissue) and found no similar issues. ### Version 1.6.0 ### What's Wrong? my sql exsit filter query but column...

### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-doris/issues?q=is%3Aissue) and found no similar issues. ### Version connectro 1.6.0 ### What's Wrong? `Caused by: java.lang.NullPointerException at org.apache.flink.connector.base.source.reader.SourceReaderBase.finishCurrentFetch(SourceReaderBase.java:194) at...

[Bug] NPE occurred while using the table join operation. Cause by: Unknown checkpoint

1

### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-doris/issues?q=is%3Aissue) and found no similar issues. ### Version flink-doris-connector-1.17(1.6.0) ### What's Wrong? 2024-05-09 18:05:19 org.apache.flink.runtime.JobException: Recovery is suppressed by...

[Bug] [Source]DorisSplitRecords.finishedSplits()返回的集合有null对象导致的整个flink作业发生NullPointerException

7

### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-doris/issues?q=is%3Aissue) and found no similar issues. ### Version 1.6.0 ### What's Wrong? DorisSplitRecords.finishSplits()返回的集合里有且仅有一个null对象 1、第一个图里添加分片后是正常的； 2、第二个图的日志显示FetcheTask里的callBack打印出来的finishSplits里仅有一个null对象   ### What...

[Improvement-17057][Master] Check if the WorkflowGrapth is a dag at constructor

9

## Purpose of the pull request Check if the WorkflowGrapth is a dag close #17057 ## Brief change log Conclusion: A graph is not a DAG if its task length...