[
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"
> ---
[
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
>
[
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:
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
> -
>
>
[
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
[
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
[
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
> ---
[
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
> ---
[
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
> -
[
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
> ---
[
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
[
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
>
[
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
>
>
>
[
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
> -
[
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
[
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
> --
[
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>
[
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
[
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
> --
[
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
> -
>
>
[
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
>
[
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
>
[
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
[
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
[
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
> ---
[
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
[
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
> -
[
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
> --
[
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
[
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
> -
[
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
[
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
>
[
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
>
[
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
> --
[
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
[
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
[
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
>
[
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
[
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
[
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
>
[
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
[
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
[
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
> --
[
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
[
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
> --
[
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
> -
[
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
[
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
[
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
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
[
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
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
[
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
[
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
[
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
[
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
[
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.
> --
[
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
[
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,
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
[
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
[
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 and
[
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
>
[
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
> Netw
[
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 5/29/20, 6:42 AM:
[
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 late
[
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
> NetworkC
[
https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118789#comment-17118789
]
Zhijiang edited comment on FLINK-17230 at 5/28/20, 3:11 PM:
[
https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118789#comment-17118789
]
Zhijiang commented on FLINK-17230:
--
I think it makes sense to cover it in release-1.11
[
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 c
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
[
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
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
Pro
[
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
[
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
[
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: 8b4fe87a74d3ec631350ebac4d
[
https://issues.apache.org/jira/browse/FLINK-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116388#comment-17116388
]
Zhijiang commented on FLINK-17572:
--
Already assigned to you, welcome to contribute!
>
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116373#comment-17116373
]
Zhijiang commented on FLINK-17565:
--
Since this fix can resolve some known bugs, it is i
[
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 jo
[
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:
[
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
[
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
> ---
[
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 mast
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: B
[
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
> fai
[
https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112838#comment-17112838
]
Zhijiang commented on FLINK-17315:
--
I close this ticket and try to resolve all the issu
[
https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112398#comment-17112398
]
Zhijiang commented on FLINK-17826:
--
If it is regarded as a bug fix, then it fits the ru
201 - 300 of 1163 matches
Mail list logo