[
https://issues.apache.org/jira/browse/FLINK-19536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-19536.
-------------------------------
Resolution: Duplicate
FLINK-20145 seems to be the manifestation of the inconsistencies.
> Fix inconsistent priority notification
> --------------------------------------
>
> Key: FLINK-19536
> URL: https://issues.apache.org/jira/browse/FLINK-19536
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Network
> Affects Versions: 1.12.0
> Reporter: Arvid Heise
> Assignee: Arvid Heise
> Priority: Major
> Labels: pull-request-available
>
> 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)
