You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/10/08 12:33:00 UTC
[jira] [Updated] (FLINK-19536) Fix inconsistent priority
notification
[ https://issues.apache.org/jira/browse/FLINK-19536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Arvid Heise updated FLINK-19536:
--------------------------------
Component/s: Runtime / Network
> 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
>
> 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)