[jira] [Created] (FLINK-19536) Fix inconsistent priority notification

[Shang Yuanchun (Jira)]

Arvid Heise created FLINK-19536:
-----------------------------------

             Summary: Fix inconsistent priority notification
                 Key: FLINK-19536
                 URL: https://issues.apache.org/jira/browse/FLINK-19536
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.12.0
            Reporter: Arvid Heise
            Assignee: Arvid Heise


Some blink tests fail with unaligned checkpoint enabled


{noformat}
[ERROR]   JoinITCase.testFullJoinWithPkNonEqui[StateBackend=ROCKSDB] » JobExecution Job ...
[ERROR]   JoinITCase.testJoinRetractionWithSameRecord[StateBackend=ROCKSDB] » JobExecution
[ERROR]   JoinITCase.testLeftJoinWithPk[StateBackend=HEAP] » JobExecution Job execution ...
[ERROR]   JoinITCase.testLeftOuterJoinWithoutPrimaryKey[StateBackend=HEAP] » JobExecution
[ERROR] org.apache.flink.table.planner.runtime.stream.sql.AggregateITCase.testCountDistinctWithBinaryRowSource[LocalGlobal=OFF, MiniBatch=OFF, StateBackend=HEAP](org.apache.flink.table.planner.runtime.stream.sql.AggregateITCase)
[ERROR] org.apache.flink.table.planner.runtime.stream.sql.AggregateITCase.testCountDistinctWithBinaryRowSource[LocalGlobal=OFF, MiniBatch=ON, StateBackend=HEAP](org.apache.flink.table.planner.runtime.stream.sql.AggregateITCase)
[ERROR] org.apache.flink.table.planner.runtime.stream.sql.AggregateITCase.testCountDistinctWithBinaryRowSource[LocalGlobal=ON, MiniBatch=ON, StateBackend=HEAP](org.apache.flink.table.planner.runtime.stream.sql.AggregateITCase)
[ERROR] org.apache.flink.table.planner.runtime.stream.sql.AggregateITCase.testCountDistinctWithBinaryRowSource[LocalGlobal=ON, MiniBatch=ON, StateBackend=ROCKSDB](org.apache.flink.table.planner.runtime.stream.sql.AggregateITCase)
[ERROR] org.apache.flink.table.planner.runtime.stream.sql.SetOperatorsITCase.testMinusAll[StateBackend=HEAP](org.apache.flink.table.planner.runtime.stream.sql.SetOperatorsITCase)
[ERROR] org.apache.flink.table.planner.runtime.stream.sql.SetOperatorsITCase.testMinusAll[StateBackend=ROCKSDB](org.apache.flink.table.planner.runtime.stream.sql.SetOperatorsITCase)
[ERROR] org.apache.flink.table.planner.runtime.stream.sql.SplitAggregateITCase.testCountDistinctWithBinaryRowSource[PartialAgg=ON, LocalGlobal=OFF, StateBackend=HEAP](org.apache.flink.table.planner.runtime.stream.sql.SplitAggregateITCase)
[ERROR] org.apache.flink.table.planner.runtime.stream.sql.SplitAggregateITCase.testCountDistinctWithBinaryRowSource[PartialAgg=ON, LocalGlobal=OFF, StateBackend=ROCKSDB](org.apache.flink.table.planner.runtime.stream.sql.SplitAggregateITCase)
[ERROR] org.apache.flink.table.planner.runtime.stream.sql.SplitAggregateITCase.testCountDistinctWithBinaryRowSource[PartialAgg=ON, LocalGlobal=ON, StateBackend=HEAP](org.apache.flink.table.planner.runtime.stream.sql.SplitAggregateITCase)
[ERROR] org.apache.flink.table.planner.runtime.stream.sql.SplitAggregateITCase.testCountDistinctWithBinaryRowSource[PartialAgg=ON, LocalGlobal=ON, StateBackend=ROCKSDB](org.apache.flink.table.planner.runtime.stream.sql.SplitAggregateITCase)
[ERROR] org.apache.flink.table.planner.runtime.stream.table.JoinITCase.testLeftOuterJoinWithTwoSideJoinKeyContainPrimaryKey[StateBackend=ROCKSDB](org.apache.flink.table.planner.runtime.stream.table.JoinITCase){noformat}
The root cause seems to be inconsistent priority notifications.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)