Hi all,
I tested the previous PoC with the current tests and I found some new
issues that might cause divergence, and sorry for there might also be some
reversal for some previous problems:
1. Which operators should wait for one more checkpoint before close ?
One
Jun Zhang created FLINK-20767:
-
Summary: add nested field support for SupportsFilterPushDown
Key: FLINK-20767
URL: https://issues.apache.org/jira/browse/FLINK-20767
Project: Flink
Issue Type:
Wenlong Lyu created FLINK-20766:
---
Summary: Separate the implementation of stream sort nodes
Key: FLINK-20766
URL: https://issues.apache.org/jira/browse/FLINK-20766
Project: Flink
Issue Type:
Rui Li created FLINK-20765:
--
Summary: ScalarOperatorGens doesn't set proper nullability for
result type of generated expressions
Key: FLINK-20765
URL: https://issues.apache.org/jira/browse/FLINK-20765
Hi, Yufei.
Can you reproduce this issue in 1.10.0? The deterministic slot sharing
introduced in 1.12.0 is one possible reason. Before 1.12.0, the
distribution of tasks in slots is not determined. Even if the network
buffers are enough from the perspective of the cluster. Bad
distribution of tasks
Hey,
I’ve found that job will throw “java.io.IOException: Insufficient number of
network buffers: required 51, but only 1 available” after job retstart, and
I’ve observed TM use much more network buffers than before.
My internal branch is under 1.10.0 can easily reproduce, but I use 1.12.0
WangRuoQi created FLINK-20763:
-
Summary: canal format parse update record with null value get
wrong result
Key: FLINK-20763
URL: https://issues.apache.org/jira/browse/FLINK-20763
Project: Flink
Liu created FLINK-20762:
---
Summary: Remove unused checkpointStorage path after job finished
Key: FLINK-20762
URL: https://issues.apache.org/jira/browse/FLINK-20762
Project: Flink
Issue Type:
Rui Li created FLINK-20761:
--
Summary: Cannot read hive table/partition whose location path
contains comma
Key: FLINK-20761
URL: https://issues.apache.org/jira/browse/FLINK-20761
Project: Flink
