[jira] [Closed] (FLINK-17994) Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

[ https://issues.apache.org/jira/browse/FLINK-17994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17994. Resolution: Fixed Merged in release-1.11 : 64ca88ac989ee7525cb821670f293404b7b30d2d Will cherry-pick to m

[jira] [Created] (FLINK-18050) Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch

Zhijiang created FLINK-18050: Summary: Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch Key: FLINK-18050 URL: https://issues.apache.org/jira/browse/FLINK-18050

[jira] [Updated] (FLINK-18050) Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch

[ https://issues.apache.org/jira/browse/FLINK-18050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18050: - Description: When task finishes, the `CheckpointBarrierUnaligner` will decline the current checkpoint,

[jira] [Updated] (FLINK-17182) RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure

[ https://issues.apache.org/jira/browse/FLINK-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17182: - Priority: Major (was: Critical) > RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail o

[jira] [Assigned] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

[ https://issues.apache.org/jira/browse/FLINK-18056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18056: Assignee: Yun Gao > Hive file sink throws exception when the target in-progress file exists. > --

[jira] [Commented] (FLINK-17823) Resolve the race condition while releasing RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-17823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123475#comment-17123475 ] Zhijiang commented on FLINK-17823: -- Merged in master: 8c7c7267be95cddd7122d2b97e5334f5d

[jira] [Comment Edited] (FLINK-17823) Resolve the race condition while releasing RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-17823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113714#comment-17113714 ] Zhijiang edited comment on FLINK-17823 at 6/2/20, 8:03 AM: --- Me

[jira] [Issue Comment Deleted] (FLINK-17823) Resolve the race condition while releasing RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-17823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17823: - Comment: was deleted (was: Merged in master: 8c7c7267be95cddd7122d2b97e5334f5db4cc37c) > Resolve the ra

[jira] [Assigned] (FLINK-18050) Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch

[ https://issues.apache.org/jira/browse/FLINK-18050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18050: Assignee: Arvid Heise (was: Zhijiang) > Fix the bug of recycling buffer twice once exception in

[jira] [Created] (FLINK-18063) Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner#processEndOfPartition

Zhijiang created FLINK-18063: Summary: Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner#processEndOfPartition Key: FLINK-18063 URL: https://issues.apache.org/jira/browse/FLINK-18063

[jira] [Comment Edited] (FLINK-17992) Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler

[ https://issues.apache.org/jira/browse/FLINK-17992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119309#comment-17119309 ] Zhijiang edited comment on FLINK-17992 at 6/3/20, 2:33 AM: --- Me

[jira] [Created] (FLINK-18088) Umbrella for features testing in release-1.11.0

Zhijiang created FLINK-18088: Summary: Umbrella for features testing in release-1.11.0 Key: FLINK-18088 URL: https://issues.apache.org/jira/browse/FLINK-18088 Project: Flink Issue Type: Test

[jira] [Updated] (FLINK-17813) Manually test unaligned checkpoints on a cluster

[ https://issues.apache.org/jira/browse/FLINK-17813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17813: - Parent: (was: FLINK-14551) Issue Type: Test (was: Sub-task) > Manually test unaligned check

[jira] [Updated] (FLINK-18088) Umbrella for testing features in release-1.11.0

[ https://issues.apache.org/jira/browse/FLINK-18088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18088: - Summary: Umbrella for testing features in release-1.11.0 (was: Umbrella for features testing in releas

[jira] [Updated] (FLINK-17813) Manually test unaligned checkpoints on a cluster

[ https://issues.apache.org/jira/browse/FLINK-17813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17813: - Parent: FLINK-18088 Issue Type: Sub-task (was: Test) > Manually test unaligned checkpoints on a

[jira] [Updated] (FLINK-18079) KafkaShuffle Manual Tests

[ https://issues.apache.org/jira/browse/FLINK-18079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18079: - Parent: FLINK-18088 Issue Type: Sub-task (was: Improvement) > KafkaShuffle Manual Tests > -

[jira] [Updated] (FLINK-17813) Manually test unaligned checkpoints on a cluster

[ https://issues.apache.org/jira/browse/FLINK-17813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17813: - Labels: release-testing (was: ) > Manually test unaligned checkpoints on a cluster > --

[jira] [Assigned] (FLINK-18079) KafkaShuffle Manual Tests

[ https://issues.apache.org/jira/browse/FLINK-18079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18079: Assignee: Yuan Mei > KafkaShuffle Manual Tests > - > > Ke

[jira] [Updated] (FLINK-18077) E2E tests manually for Hive streaming source

[ https://issues.apache.org/jira/browse/FLINK-18077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18077: - Parent: (was: FLINK-18021) Issue Type: Test (was: Sub-task) > E2E tests manually for Hive s

[jira] [Updated] (FLINK-18077) E2E tests manually for Hive streaming source

[ https://issues.apache.org/jira/browse/FLINK-18077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18077: - Labels: release-testing (was: ) > E2E tests manually for Hive streaming source > --

[jira] [Updated] (FLINK-18077) E2E tests manually for Hive streaming source

[ https://issues.apache.org/jira/browse/FLINK-18077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18077: - Parent: FLINK-18088 Issue Type: Sub-task (was: Test) > E2E tests manually for Hive streaming so

[jira] [Updated] (FLINK-18078) E2E tests manually for Hive streaming dim join

[ https://issues.apache.org/jira/browse/FLINK-18078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18078: - Parent: (was: FLINK-18021) Issue Type: Test (was: Sub-task) > E2E tests manually for Hive s

[jira] [Updated] (FLINK-18078) E2E tests manually for Hive streaming dim join

[ https://issues.apache.org/jira/browse/FLINK-18078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18078: - Labels: release-testing (was: ) > E2E tests manually for Hive streaming dim join >

[jira] [Updated] (FLINK-18078) E2E tests manually for Hive streaming dim join

[ https://issues.apache.org/jira/browse/FLINK-18078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18078: - Parent: FLINK-18088 Issue Type: Sub-task (was: Test) > E2E tests manually for Hive streaming di

[jira] [Updated] (FLINK-18085) Manually test application mode for standalone, Yarn, K8s

[ https://issues.apache.org/jira/browse/FLINK-18085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18085: - Labels: release-testing (was: ) > Manually test application mode for standalone, Yarn, K8s > --

[jira] [Updated] (FLINK-18085) Manually test application mode for standalone, Yarn, K8s

[ https://issues.apache.org/jira/browse/FLINK-18085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18085: - Parent: (was: FLINK-16654) Issue Type: Test (was: Sub-task) > Manually test application mod

[jira] [Updated] (FLINK-18085) Manually test application mode for standalone, Yarn, K8s

[ https://issues.apache.org/jira/browse/FLINK-18085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18085: - Parent: FLINK-18088 Issue Type: Sub-task (was: Test) > Manually test application mode for stand

[jira] [Assigned] (FLINK-18085) Manually test application mode for standalone, Yarn, K8s

[ https://issues.apache.org/jira/browse/FLINK-18085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18085: Assignee: Yang Wang > Manually test application mode for standalone, Yarn, K8s >

[jira] [Assigned] (FLINK-18089) Add the zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18089: Assignee: Yun Gao > Add the zero-copy test into the azure E2E pipeline >

[jira] [Updated] (FLINK-18089) Add the zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18089: - Labels: release-testing (was: ) > Add the zero-copy test into the azure E2E pipeline >

[jira] [Updated] (FLINK-18089) Add the zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18089: - Priority: Blocker (was: Major) > Add the zero-copy test into the azure E2E pipeline > -

[jira] [Updated] (FLINK-18089) Add the network zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18089: - Summary: Add the network zero-copy test into the azure E2E pipeline (was: Add the zero-copy test into t

[jira] [Updated] (FLINK-18089) Add the zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18089: - Parent: FLINK-18088 Issue Type: Sub-task (was: Test) > Add the zero-copy test into the azure E2

[jira] [Updated] (FLINK-18088) Umbrella for testing features in release-1.11.0

[ https://issues.apache.org/jira/browse/FLINK-18088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18088: - Labels: release-testing (was: ) > Umbrella for testing features in release-1.11.0 > --

[jira] [Assigned] (FLINK-18088) Umbrella for testing features in release-1.11.0

[ https://issues.apache.org/jira/browse/FLINK-18088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18088: Assignee: Zhijiang > Umbrella for testing features in release-1.11.0 > -

[jira] [Comment Edited] (FLINK-17994) Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

[ https://issues.apache.org/jira/browse/FLINK-17994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120851#comment-17120851 ] Zhijiang edited comment on FLINK-17994 at 6/4/20, 2:36 AM: --- Me

[jira] [Assigned] (FLINK-18112) Single Task Failure Recovery Prototype

[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18112: Assignee: Yuan Mei > Single Task Failure Recovery Prototype > ---

[jira] [Assigned] (FLINK-18116) E2E performance test

[ https://issues.apache.org/jira/browse/FLINK-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18116: Assignee: Aihua Li > E2E performance test > > > Key: FLINK-1

[jira] [Updated] (FLINK-18115) StabilityTest

[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18115: - Affects Version/s: (was: 1.10.0) 1.11.0 > StabilityTest > - > >

[jira] [Updated] (FLINK-18115) StabilityTest

[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18115: - Priority: Blocker (was: Major) > StabilityTest > - > > Key: FLINK-18115 >

[jira] [Assigned] (FLINK-18115) StabilityTest

[ https://issues.apache.org/jira/browse/FLINK-18115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18115: Assignee: Aihua Li > StabilityTest > - > > Key: FLINK-18115 >

[jira] [Updated] (FLINK-18116) E2E performance test

[ https://issues.apache.org/jira/browse/FLINK-18116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18116: - Priority: Blocker (was: Major) > E2E performance test > > > Key: F

[jira] [Assigned] (FLINK-17769) Wrong order of log events on a task failure

[ https://issues.apache.org/jira/browse/FLINK-17769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17769: Assignee: Yuan Mei > Wrong order of log events on a task failure > --

[jira] [Assigned] (FLINK-18057) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2>

[ https://issues.apache.org/jira/browse/FLINK-18057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18057: Assignee: Ying Cao > SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3>

[jira] [Assigned] (FLINK-18057) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2>

[ https://issues.apache.org/jira/browse/FLINK-18057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18057: Assignee: Yingjie Cao (was: Ying Cao) > SingleInputGateTest.testConcurrentReadStateAndProcessAnd

[jira] [Assigned] (FLINK-18071) CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI

[ https://issues.apache.org/jira/browse/FLINK-18071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18071: Assignee: Yun Gao > CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI > --

[jira] [Commented] (FLINK-16375) Remove references to registerTableSource/Sink methods from documentation

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128067#comment-17128067 ] Zhijiang commented on FLINK-16375: -- [~aljoscha] [~dwysakowicz]  [~lzljs3620320] Could y

[jira] [Updated] (FLINK-17733) Add documentation for real-time hive

[ https://issues.apache.org/jira/browse/FLINK-17733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17733: - Fix Version/s: 1.12.0 > Add documentation for real-time hive > > >

[jira] [Assigned] (FLINK-17733) Add documentation for real-time hive

[ https://issues.apache.org/jira/browse/FLINK-17733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17733: Assignee: Jingsong Lee > Add documentation for real-time hive > -

[jira] [Updated] (FLINK-17733) Add documentation for real-time hive

[ https://issues.apache.org/jira/browse/FLINK-17733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17733: - Affects Version/s: 1.11.0 > Add documentation for real-time hive >

[jira] [Commented] (FLINK-18009) Select an invalid column crashes the SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-18009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128092#comment-17128092 ] Zhijiang commented on FLINK-18009: -- After syncing with [~nicholasjiang],  i will close

[jira] [Closed] (FLINK-18009) Select an invalid column crashes the SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-18009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18009. Resolution: Duplicate > Select an invalid column crashes the SQL CLI > ---

[jira] [Updated] (FLINK-18089) Add the network zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18089: - Priority: Major (was: Blocker) > Add the network zero-copy test into the azure E2E pipeline > -

[jira] [Assigned] (FLINK-18109) Manually test external resource framework with GPUDriver

[ https://issues.apache.org/jira/browse/FLINK-18109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18109: Assignee: Yangze Guo > Manually test external resource framework with GPUDriver > ---

[jira] [Assigned] (FLINK-18173) Bundle flink-csv,flink-json,flink-avro jars in lib

[ https://issues.apache.org/jira/browse/FLINK-18173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18173: Assignee: Jingsong Lee > Bundle flink-csv,flink-json,flink-avro jars in lib > ---

[jira] [Closed] (FLINK-17768) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel is instable

[ https://issues.apache.org/jira/browse/FLINK-17768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17768. Resolution: Fixed There are at-least 5-6 bugs causing this unstable issue, and most of them were already

[jira] [Closed] (FLINK-18118) Some SQL Jobs with two input operators are loosing data with unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18118. Resolution: Fixed After syncing with [~AHeise], all the blocker issues for two inputs in UC were already

[jira] [Assigned] (FLINK-17978) Test Hadoop dependency change

[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17978: Assignee: Yang Wang > Test Hadoop dependency change > - > >

[jira] [Updated] (FLINK-18057) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2>

[ https://issues.apache.org/jira/browse/FLINK-18057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18057: - Affects Version/s: (was: 1.12.0) 1.11.0 > SingleInputGateTest.testConcurrentR

[jira] [Updated] (FLINK-18057) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2>

[ https://issues.apache.org/jira/browse/FLINK-18057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18057: - Fix Version/s: 1.12.0 > SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> > b

[jira] [Closed] (FLINK-18050) Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch

[ https://issues.apache.org/jira/browse/FLINK-18050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18050. Resolution: Fixed Merged in master: ed7b0b1bea84a10ee45d10343f239cd183659a74,  f2dd4b8500a82532dae17087c2

[jira] [Comment Edited] (FLINK-18050) Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch

[ https://issues.apache.org/jira/browse/FLINK-18050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128958#comment-17128958 ] Zhijiang edited comment on FLINK-18050 at 6/9/20, 7:36 AM: --- Me

[jira] [Closed] (FLINK-18136) Don't start channel state writing for savepoints (RPC)

[ https://issues.apache.org/jira/browse/FLINK-18136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18136. Resolution: Fixed Merged in master: 6dc624d931858e0ee5da14bc6b41b834c94cbba7 > Don't start channel state

[jira] [Updated] (FLINK-18136) Don't start channel state writing for savepoints (RPC)

[ https://issues.apache.org/jira/browse/FLINK-18136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18136: - Description: ChannelStateWriter#start should be only called for unaligned checkpoint. While source trigg

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129065#comment-17129065 ] Zhijiang commented on FLINK-17260: -- another instance  [https://dev.azure.com/apache-fli

[jira] [Updated] (FLINK-18063) Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner#processEndOfPartition

[ https://issues.apache.org/jira/browse/FLINK-18063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18063: - Description: There are three aborting scenarios which might encounter race condition:     1. Checkpoint

[jira] [Closed] (FLINK-18063) Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner#processEndOfPartition

[ https://issues.apache.org/jira/browse/FLINK-18063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18063. Resolution: Fixed Merged in master: f672ae53596aa26f1e3ed4b3d24aff2197be749d Merged in release-1.11: 2fe8

[jira] [Updated] (FLINK-18063) Fix the race condition for aborting checkpoint in CheckpointBarrierUnaligner

[ https://issues.apache.org/jira/browse/FLINK-18063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18063: - Summary: Fix the race condition for aborting checkpoint in CheckpointBarrierUnaligner (was: Fix the rac

[jira] [Updated] (FLINK-18063) Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner

[ https://issues.apache.org/jira/browse/FLINK-18063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18063: - Summary: Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner (was: Fix

[jira] [Closed] (FLINK-18057) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2>

[ https://issues.apache.org/jira/browse/FLINK-18057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18057. Resolution: Fixed Merged in release-1.11 : fe229a319fff73512953ea1b55391b29e48db129 Merged in master: 9a7

[jira] [Comment Edited] (FLINK-18136) Don't start channel state writing for savepoints (RPC)

[ https://issues.apache.org/jira/browse/FLINK-18136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129018#comment-17129018 ] Zhijiang edited comment on FLINK-18136 at 6/10/20, 5:27 AM:

[jira] [Assigned] (FLINK-18238) RemoteChannelThroughputBenchmark deadlocks

[ https://issues.apache.org/jira/browse/FLINK-18238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18238: Assignee: Yingjie Cao > RemoteChannelThroughputBenchmark deadlocks >

[jira] [Updated] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16821: - Priority: Major (was: Blocker) > Run Kubernetes test failed with invalid named "minikube" > ---

[jira] [Reopened] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reopened FLINK-16821: -- > Run Kubernetes test failed with invalid named "minikube" > -

[jira] [Commented] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17130833#comment-17130833 ] Zhijiang commented on FLINK-16821: -- The same issue seems happen again in release-1.11 b

[jira] [Comment Edited] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17130833#comment-17130833 ] Zhijiang edited comment on FLINK-16821 at 6/10/20, 4:05 PM:

[jira] [Updated] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-16821: - Affects Version/s: 1.11.0 > Run Kubernetes test failed with invalid named "minikube" > -

[jira] [Commented] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17132871#comment-17132871 ] Zhijiang commented on FLINK-16821: -- Thanks for the feedback. I have not found other fai

[jira] [Closed] (FLINK-16821) Run Kubernetes test failed with invalid named "minikube"

[ https://issues.apache.org/jira/browse/FLINK-16821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-16821. Resolution: Fixed > Run Kubernetes test failed with invalid named "minikube" > ---

[jira] [Commented] (FLINK-17869) Fix the race condition of aborting unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-17869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17132873#comment-17132873 ] Zhijiang commented on FLINK-17869: -- Merged in release-1.11: 7bb3ffa91a9916348d2f0a6a2e6

[jira] [Commented] (FLINK-17182) RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure

[ https://issues.apache.org/jira/browse/FLINK-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17132997#comment-17132997 ] Zhijiang commented on FLINK-17182: -- I think I should review this PR today to save some

[jira] [Created] (FLINK-18552) Update migration tests in master to cover migration from release-1.11

Zhijiang created FLINK-18552: Summary: Update migration tests in master to cover migration from release-1.11 Key: FLINK-18552 URL: https://issues.apache.org/jira/browse/FLINK-18552 Project: Flink

[jira] [Assigned] (FLINK-18552) Update migration tests in master to cover migration from release-1.11

[ https://issues.apache.org/jira/browse/FLINK-18552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18552: Assignee: Yun Gao > Update migration tests in master to cover migration from release-1.11 > -

[jira] [Created] (FLINK-18591) Fix the format issue for metrics web page

Zhijiang created FLINK-18591: Summary: Fix the format issue for metrics web page Key: FLINK-18591 URL: https://issues.apache.org/jira/browse/FLINK-18591 Project: Flink Issue Type: Bug C

[jira] [Closed] (FLINK-18591) Fix the format issue for metrics web page

[ https://issues.apache.org/jira/browse/FLINK-18591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18591. Resolution: Fixed Merged in release-1.11: d6473f32aa159c6242e4293a60be179135f0e1f2 Merged in master: ba006

[jira] [Updated] (FLINK-17636) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read from released RecoveredInputChannel

[ https://issues.apache.org/jira/browse/FLINK-17636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17636: - Fix Version/s: 1.11.0 > SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read >

[jira] [Closed] (FLINK-17636) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read from released RecoveredInputChannel

[ https://issues.apache.org/jira/browse/FLINK-17636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17636. Resolution: Fixed Merged in release-1.11: 57e57624deded5594749cbccf17a5878c6dc81b8 Merged in master: a9cce

[jira] [Updated] (FLINK-17636) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to read from released RecoveredInputChannel

[ https://issues.apache.org/jira/browse/FLINK-17636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17636: - Affects Version/s: 1.11.0 > SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: Trying to rea

[jira] [Assigned] (FLINK-18595) Deadlock during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-18595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18595: Assignee: Zhijiang > Deadlock during job shutdown > > >

[jira] [Commented] (FLINK-18595) Deadlock during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-18595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157944#comment-17157944 ] Zhijiang commented on FLINK-18595: -- Thanks for reporting this [~dian.fu]. It is caused

[jira] [Created] (FLINK-18612) WordCount example failure when using relative output path

Zhijiang created FLINK-18612: Summary: WordCount example failure when using relative output path Key: FLINK-18612 URL: https://issues.apache.org/jira/browse/FLINK-18612 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18612) WordCount example failure when setting relative output path

[ https://issues.apache.org/jira/browse/FLINK-18612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18612: - Summary: WordCount example failure when setting relative output path (was: WordCount example failure wh

[jira] [Assigned] (FLINK-18612) WordCount example failure when setting relative output path

[ https://issues.apache.org/jira/browse/FLINK-18612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18612: Assignee: Yun Gao > WordCount example failure when setting relative output path > ---

[jira] [Updated] (FLINK-18595) Deadlock during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-18595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18595: - Affects Version/s: 1.11.0 > Deadlock during job shutdown > > >

[jira] [Updated] (FLINK-18595) Deadlock during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-18595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18595: - Fix Version/s: 1.11.2 1.12.0 > Deadlock during job shutdown > ---

[jira] [Updated] (FLINK-18595) Deadlock during job shutdown

[ https://issues.apache.org/jira/browse/FLINK-18595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18595: - Affects Version/s: 1.11.1 > Deadlock during job shutdown > > >

[jira] [Assigned] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17073: Assignee: Etienne Chauchot > Slow checkpoint cleanup causing OOMs > -

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161704#comment-17161704 ] Zhijiang commented on FLINK-17073: -- I have assigned it to [~echauchot] > Slow checkpoi

[jira] [Closed] (FLINK-11035) Notify data available to network stack immediately after finishing BufferBuilder

[ https://issues.apache.org/jira/browse/FLINK-11035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-11035. Resolution: Won't Fix As discussed before, it seems no evidence/necessary to improve it ATM. So close it

[jira] [Commented] (FLINK-13126) Construct special test/benchmark to verify the backlog effect

[ https://issues.apache.org/jira/browse/FLINK-13126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161790#comment-17161790 ] Zhijiang commented on FLINK-13126: -- Close it temporarily for cleanup since it seems not

<    5   6   7   8   9   10   11   12   >