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)
