Cai Liuyang created FLINK-38192:
---
Summary: Improve DynamicSourceUtils exception msg
Key: FLINK-38192
URL: https://issues.apache.org/jira/browse/FLINK-38192
Project: Flink
Issue Type: Improvemen
Cai Liuyang created FLINK-33934:
---
Summary: Flink SQL Source use raw format maybe lead to data lost
Key: FLINK-33934
URL: https://issues.apache.org/jira/browse/FLINK-33934
Project: Flink
Issue T
Cai Liuyang created FLINK-33759:
---
Summary: flink parquet writer support write nested array or map
type
Key: FLINK-33759
URL: https://issues.apache.org/jira/browse/FLINK-33759
Project: Flink
Is
Cai Liuyang created FLINK-32362:
---
Summary: SourceAlignment announceCombinedWatermark period task
maybe lost
Key: FLINK-32362
URL: https://issues.apache.org/jira/browse/FLINK-32362
Project: Flink
Cai Liuyang created FLINK-32316:
---
Summary: Duplicated announceCombinedWatermark task maybe scheduled
if jobmanager failover
Key: FLINK-32316
URL: https://issues.apache.org/jira/browse/FLINK-32316
Projec
Cai Liuyang created FLINK-29577:
---
Summary: Disable rocksdb wal when restore from full snapshot
Key: FLINK-29577
URL: https://issues.apache.org/jira/browse/FLINK-29577
Project: Flink
Issue Type:
Cai Liuyang created FLINK-26080:
---
Summary: PartitionRequest client use Netty's IdleStateHandler to
monitor channel's status
Key: FLINK-26080
URL: https://issues.apache.org/jira/browse/FLINK-26080
Projec
Cai Liuyang created FLINK-25664:
---
Summary: Notify will be not triggered for PipelinedSubpartition if
more than one buffer is added during isBlocked == true
Key: FLINK-25664
URL: https://issues.apache.org/jira/browse
