You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/10/08 12:33:00 UTC
[jira] [Created] (FLINK-19536) Fix inconsistent priority
notification
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)