[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] [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] [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=17129018#comment-17129018 ] Zhijiang edited comment on FLINK-18136 at 6/10/20, 5:27 AM: Merged in

[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: 

[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:

[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: 

[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

[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.

[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=17129065#comment-17129065 ] Zhijiang commented on FLINK-17260: -- another instance 

[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

[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] [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=17128958#comment-17128958 ] Zhijiang edited comment on FLINK-18050 at 6/9/20, 7:36 AM: --- Merged in master: 

[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, 

[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 >

[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> >

[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] [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] [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] [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] [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] [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] [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] [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=17128092#comment-17128092 ] Zhijiang commented on FLINK-18009: -- After syncing with [~nicholasjiang],  i will close this issue now

[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] [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: - Fix Version/s: 1.12.0 > Add documentation for real-time hive > > >

[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=17128067#comment-17128067 ] Zhijiang commented on FLINK-16375: -- [~aljoscha] [~dwysakowicz]  [~lzljs3620320] Could you sync who can

[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] [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) >

[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] [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:

[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] [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:

[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] [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=17120851#comment-17120851 ] Zhijiang edited comment on FLINK-17994 at 6/4/20, 2:36 AM: --- Merged in

[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] [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] [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

[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

[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-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: FLINK-18088 Issue Type: Sub-task (was: Test) > Manually test application mode for

[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

[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] [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

[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

[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-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

[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

[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] [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 > - > >

[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] [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-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

[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

[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

[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] [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=17119309#comment-17119309 ] Zhijiang edited comment on FLINK-17992 at 6/3/20, 2:33 AM: --- Merged 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:

[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] [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

[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=17113714#comment-17113714 ] Zhijiang edited comment on FLINK-17823 at 6/2/20, 8:03 AM: --- Merged in

[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=17123475#comment-17123475 ] Zhijiang commented on FLINK-17823: -- Merged in master: 8c7c7267be95cddd7122d2b97e5334f5db4cc37c >

[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] [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

[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] [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] [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

[jira] [Updated] (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 updated FLINK-17994: - Affects Version/s: 1.11.0 > Fix the race condition between CheckpointBarrierUnaligner#processBarrier

[jira] [Updated] (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 updated FLINK-17994: - Fix Version/s: 1.12.0 > Fix the race condition between CheckpointBarrierUnaligner#processBarrier and >

[jira] [Updated] (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:all-tabpanel ] Zhijiang updated FLINK-17992: - Affects Version/s: 1.11.0 > Exception from RemoteInputChannel#onBuffer should not fail the whole >

[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=17119309#comment-17119309 ] Zhijiang edited comment on FLINK-17992 at 5/29/20, 6:42 AM: Merged in

[jira] [Closed] (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:all-tabpanel ] Zhijiang closed FLINK-17992. Resolution: Fixed Merged in release-1.11: 34e6d22bdd179796daf6df46738d85303a839704 Pick it to master

[jira] [Updated] (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:all-tabpanel ] Zhijiang updated FLINK-17992: - Fix Version/s: 1.12.0 > Exception from RemoteInputChannel#onBuffer should not fail the whole >

[jira] [Comment Edited] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118789#comment-17118789 ] Zhijiang edited comment on FLINK-17230 at 5/28/20, 3:11 PM: I think it makes

[jira] [Commented] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118789#comment-17118789 ] Zhijiang commented on FLINK-17230: -- I think it makes sense to cover it in release-1.11 and i changed

[jira] [Updated] (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 updated FLINK-17994: - Description: The race condition issue happens as follow: * ch1 is received from network for one input

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

Zhijiang created FLINK-17994: Summary: Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived Key: FLINK-17994 URL: https://issues.apache.org/jira/browse/FLINK-17994

[jira] [Updated] (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:all-tabpanel ] Zhijiang updated FLINK-17869: - Description: On ChannelStateWriter side, the lifecycle of checkpoint should be as follows: start -> in

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

Zhijiang created FLINK-17992: Summary: Exception from RemoteInputChannel#onBuffer should not fail the whole NetworkClientHandler Key: FLINK-17992 URL: https://issues.apache.org/jira/browse/FLINK-17992

[jira] [Assigned] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-15507: Assignee: Zakelly Lan (was: Zhijiang) > Activate local recovery for RocksDB backends by default

[jira] [Assigned] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-15507: Assignee: Zhijiang (was: Zakelly Lan) > Activate local recovery for RocksDB backends by default

[jira] [Closed] (FLINK-17820) Memory threshold is ignored for channel state

[ https://issues.apache.org/jira/browse/FLINK-17820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17820. Merged in release-1.11: 05b97924572594ef244236a2f328177a2ec84fc4 Merged in master: 

[jira] [Commented] (FLINK-17572) Remove checkpoint alignment buffered metric from webui

[ https://issues.apache.org/jira/browse/FLINK-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116388#comment-17116388 ] Zhijiang commented on FLINK-17572: -- Already assigned to you, welcome to contribute! > Remove

[jira] [Assigned] (FLINK-17572) Remove checkpoint alignment buffered metric from webui

[ https://issues.apache.org/jira/browse/FLINK-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17572: Assignee: Nicholas Jiang > Remove checkpoint alignment buffered metric from webui >

[jira] [Commented] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.2

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116373#comment-17116373 ] Zhijiang commented on FLINK-17565: -- Since this fix can resolve some known bugs, it is in compliance

[jira] [Assigned] (FLINK-17916) Provide API to separate KafkaShuffle's Producer and Consumer to different jobs

[ https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17916: Assignee: Yuan Mei > Provide API to separate KafkaShuffle's Producer and Consumer to different

[jira] [Updated] (FLINK-15670) Kafka Shuffle: uses Kafka as a message bus to shuffle and persist data at the same time

[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-15670: - Summary: Kafka Shuffle: uses Kafka as a message bus to shuffle and persist data at the same time (was:

[jira] [Updated] (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:all-tabpanel ] Zhijiang updated FLINK-17869: - Description: On ChannelStateWriter side, the lifecycle of checkpoint should be as follows: start -> in

[jira] [Assigned] (FLINK-17873) Add check for max concurrent checkpoints under UC mode

[ https://issues.apache.org/jira/browse/FLINK-17873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17873: Assignee: Yuan Mei > Add check for max concurrent checkpoints under UC mode >

[jira] [Resolved] (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 resolved FLINK-17823. -- Resolution: Fixed Merged in release-1.11: 3eb1075ded64da20e6f7a5bc268f455eaf6573eb Will merge to

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

Zhijiang created FLINK-17869: Summary: Fix the race condition of aborting unaligned checkpoint Key: FLINK-17869 URL: https://issues.apache.org/jira/browse/FLINK-17869 Project: Flink Issue Type:

[jira] [Closed] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17315. Resolution: Duplicate > UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel >

[jira] [Commented] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112838#comment-17112838 ] Zhijiang commented on FLINK-17315: -- I close this ticket and try to resolve all the issues in

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112398#comment-17112398 ] Zhijiang commented on FLINK-17826: -- If it is regarded as a bug fix, then it fits the rule to make it in

<    1   2   3   4   5   6   7   8   9   10   >