[jira] [Commented] (FLINK-19381) Fix docs about relocatable savepoints

[ https://issues.apache.org/jira/browse/FLINK-19381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201481#comment-17201481 ] Congxian Qiu(klion26) commented on FLINK-19381: --- Ah, the doc wasn't updated when

[jira] [Commented] (FLINK-19359) Restore from Checkpoint fails if checkpoint folders is corrupt/partial

[ https://issues.apache.org/jira/browse/FLINK-19359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17200040#comment-17200040 ] Congxian Qiu(klion26) commented on FLINK-19359: --- There is not {{_metadata}} means that the

[jira] [Commented] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17200033#comment-17200033 ] Congxian Qiu(klion26) commented on FLINK-19249: --- For the client side, we can add a

[jira] [Commented] (FLINK-19300) Timer loss after restoring from savepoint

[ https://issues.apache.org/jira/browse/FLINK-19300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199331#comment-17199331 ] Congxian Qiu(klion26) commented on FLINK-19300: --- [~xianggao] thanks for reporting the

[jira] [Created] (FLINK-19325) Optimize the consumed time for checkpoint completion

Congxian Qiu(klion26) created FLINK-19325: - Summary: Optimize the consumed time for checkpoint completion Key: FLINK-19325 URL: https://issues.apache.org/jira/browse/FLINK-19325 Project: Flink

[jira] [Commented] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199167#comment-17199167 ] Congxian Qiu(klion26) commented on FLINK-19249: --- [~sewen] thanks for the reply. IIUC, a

[jira] [Created] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

Congxian Qiu(klion26) created FLINK-19249: - Summary: Job would wait sometime(~10 min) before failover if some connection broken Key: FLINK-19249 URL: https://issues.apache.org/jira/browse/FLINK-19249

[jira] [Closed] (FLINK-18744) resume from modified savepoint dirctionary: No such file or directory

[ https://issues.apache.org/jira/browse/FLINK-18744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) closed FLINK-18744. - Resolution: Duplicate Close this one as duplicate, please ref to FLINK-14942

[jira] [Commented] (FLINK-19126) Failed to run job in yarn-cluster mode due to No Executor found.

[ https://issues.apache.org/jira/browse/FLINK-19126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189788#comment-17189788 ] Congxian Qiu(klion26) commented on FLINK-19126: --- Hi [~Tang Yan] As the exception said,

[jira] [Commented] (FLINK-14942) State Processing API: add an option to make deep copy

[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173767#comment-17173767 ] Congxian Qiu(klion26) commented on FLINK-14942: --- After savepoint relocatable, I think we

[jira] [Commented] (FLINK-18744) resume from modified savepoint dirctionary: No such file or directory

[ https://issues.apache.org/jira/browse/FLINK-18744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173766#comment-17173766 ] Congxian Qiu(klion26) commented on FLINK-18744: --- The problem here exists, it was caused by

[jira] [Updated] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-18675: -- Fix Version/s: 1.11.2 1.12.0 > Checkpoint not maintaining

[jira] [Commented] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173755#comment-17173755 ] Congxian Qiu(klion26) commented on FLINK-18675: --- Seems there is a similar issue 

[jira] [Commented] (FLINK-18856) CheckpointCoordinator ignores checkpointing.min-pause

[ https://issues.apache.org/jira/browse/FLINK-18856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173754#comment-17173754 ] Congxian Qiu(klion26) commented on FLINK-18856: --- Seems this issue is similar with 

[jira] [Commented] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170497#comment-17170497 ] Congxian Qiu(klion26) commented on FLINK-18675: --- [~raviratnakar] I think the problem here

[jira] [Commented] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168357#comment-17168357 ] Congxian Qiu(klion26) commented on FLINK-18748: --- [~roman_khachatryan] could you please

[jira] [Commented] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167912#comment-17167912 ] Congxian Qiu(klion26) commented on FLINK-18748: --- [~wayland] Do you want to fix this

[jira] [Commented] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167598#comment-17167598 ] Congxian Qiu(klion26) commented on FLINK-18748: --- Hi [~roman_khachatryan] thanks for your

[jira] [Updated] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-18748: -- Summary: Savepoint would be queued unexpected if pendingCheckpoints less than

[jira] [Updated] (FLINK-18748) Savepoint would be queued unexpected

[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-18748: -- Description: Inspired by a [user-zh

[jira] [Updated] (FLINK-18748) Savepoint would be queued unexpected

[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-18748: -- Description: Inspired by an [user-zh

[jira] [Commented] (FLINK-18748) Savepoint would be queued unexpected

[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166877#comment-17166877 ] Congxian Qiu(klion26) commented on FLINK-18748: --- [~pnowojski] [~roman_khachatryan] What do

[jira] [Created] (FLINK-18748) Savepoint would be queued unexpected

Congxian Qiu(klion26) created FLINK-18748: - Summary: Savepoint would be queued unexpected Key: FLINK-18748 URL: https://issues.apache.org/jira/browse/FLINK-18748 Project: Flink Issue

[jira] [Commented] (FLINK-18744) resume from modified savepoint dirctionary: No such file or directory

[ https://issues.apache.org/jira/browse/FLINK-18744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166808#comment-17166808 ] Congxian Qiu(klion26) commented on FLINK-18744: --- [~wayland]  Thanks for reporting this

[jira] [Commented] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints

[ https://issues.apache.org/jira/browse/FLINK-18675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165387#comment-17165387 ] Congxian Qiu(klion26) commented on FLINK-18675: --- Hi [~raviratnakar] from the git history,

[jira] [Commented] (FLINK-18665) Filesystem connector should use TableSchema exclude computed columns

[ https://issues.apache.org/jira/browse/FLINK-18665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163229#comment-17163229 ] Congxian Qiu(klion26) commented on FLINK-18665: --- [~Leonard Xu] thanks for the update :) >

[jira] [Commented] (FLINK-18665) Filesystem connector should use TableSchema exclude computed columns

[ https://issues.apache.org/jira/browse/FLINK-18665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162493#comment-17162493 ] Congxian Qiu(klion26) commented on FLINK-18665: --- Which versions will this issue affect? >

[jira] [Comment Edited] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161719#comment-17161719 ] Congxian Qiu(klion26) edited comment on FLINK-17571 at 7/21/20, 5:33 AM:

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the

[jira] [Comment Edited] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161719#comment-17161719 ] Congxian Qiu(klion26) edited comment on FLINK-17571 at 7/21/20, 5:33 AM:

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the

[jira] [Commented] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161719#comment-17161719 ] Congxian Qiu(klion26) commented on FLINK-17571: --- [~pnowojski] could you please assign this

[jira] [Commented] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17160919#comment-17160919 ] Congxian Qiu(klion26) commented on FLINK-18637: --- [~oripwk] thanks for report this problem,

[jira] [Commented] (FLINK-18582) Add title anchor link for file event_driven.zh.md

[ https://issues.apache.org/jira/browse/FLINK-18582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157881#comment-17157881 ] Congxian Qiu(klion26) commented on FLINK-18582: --- [~temper] thanks for creating this

[jira] [Updated] (FLINK-18523) Advance watermark if there is no data in all of the partitions after some time

[ https://issues.apache.org/jira/browse/FLINK-18523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-18523: -- Description: In the case of window calculations and eventTime scenarios,

[jira] [Commented] (FLINK-18493) Make target home directory used to store yarn files configurable

[ https://issues.apache.org/jira/browse/FLINK-18493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151770#comment-17151770 ] Congxian Qiu(klion26) commented on FLINK-18493: --- +1 for this feature. > Make target home

[jira] [Commented] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17150754#comment-17150754 ] Congxian Qiu(klion26) commented on FLINK-18196: --- Seems another report about the similar

[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147142#comment-17147142 ] Congxian Qiu(klion26) commented on FLINK-18433: --- Thanks for running these tests [~AHeise].

[jira] [Commented] (FLINK-18433) From the end-to-end performance test results, 1.11 has a regression

[ https://issues.apache.org/jira/browse/FLINK-18433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17144611#comment-17144611 ] Congxian Qiu(klion26) commented on FLINK-18433: --- [~Aihua] thanks for the work, maybe the

[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks

[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142686#comment-17142686 ] Congxian Qiu(klion26) commented on FLINK-5601: -- Seems another affected user(user-zh mail

[jira] [Commented] (FLINK-18264) Translate the "External Resource Framework" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141840#comment-17141840 ] Congxian Qiu(klion26) commented on FLINK-18264: --- [~karmagyz] assigned to you > Translate

[jira] [Assigned] (FLINK-18264) Translate the "External Resource Framework" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-18264: - Assignee: Yangze Guo > Translate the "External Resource Framework"

[jira] [Closed] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) closed FLINK-18091. - Resolution: Fixed > Test Relocatable Savepoints > --- >

[jira] [Commented] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134092#comment-17134092 ] Congxian Qiu(klion26) commented on FLINK-18091: --- close this issue as we have tested in a

[jira] [Commented] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132837#comment-17132837 ] Congxian Qiu(klion26) commented on FLINK-18091: --- The logic of manual test for savepoint

[jira] [Commented] (FLINK-18165) When savingpoint is restored, select the checkpoint directory and stateBackend

[ https://issues.apache.org/jira/browse/FLINK-18165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129148#comment-17129148 ] Congxian Qiu(klion26) commented on FLINK-18165: --- [~liyu] I agree that we could switch

[jira] [Commented] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129144#comment-17129144 ] Congxian Qiu(klion26) commented on FLINK-18091: --- [~aljoscha] We have an IT case for this

[jira] [Commented] (FLINK-17479) Occasional checkpoint failure due to null pointer exception in Flink version 1.10

[ https://issues.apache.org/jira/browse/FLINK-17479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128948#comment-17128948 ] Congxian Qiu(klion26) commented on FLINK-17479: --- [~nobleyd] thanks for tracking it down,

[jira] [Commented] (FLINK-18196) flink throws `NullPointerException` when executeCheckpointing

[ https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128947#comment-17128947 ] Congxian Qiu(klion26) commented on FLINK-18196: --- [~yuchuanchen] thanks for creating this

[jira] [Commented] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-17468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128945#comment-17128945 ] Congxian Qiu(klion26) commented on FLINK-17468: --- Kindly ping [~qqibrow]  > Provide more

[jira] [Comment Edited] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126778#comment-17126778 ] Congxian Qiu(klion26) edited comment on FLINK-18091 at 6/6/20, 5:13 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-18112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127206#comment-17127206 ] Congxian Qiu(klion26) commented on FLINK-18112: --- [~ym] Thanks for creating the ticket, I

[jira] [Comment Edited] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126778#comment-17126778 ] Congxian Qiu(klion26) edited comment on FLINK-18091 at 6/5/20, 1:52 PM:

[jira] [Commented] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126778#comment-17126778 ] Congxian Qiu(klion26) commented on FLINK-18091: --- I'll close this issue in 6.10(Wednesday)

[jira] [Comment Edited] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126769#comment-17126769 ] Congxian Qiu(klion26) edited comment on FLINK-18091 at 6/5/20, 1:43 PM:

[jira] [Comment Edited] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126769#comment-17126769 ] Congxian Qiu(klion26) edited comment on FLINK-18091 at 6/5/20, 1:43 PM:

[jira] [Comment Edited] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126769#comment-17126769 ] Congxian Qiu(klion26) edited comment on FLINK-18091 at 6/5/20, 1:40 PM:

[jira] [Comment Edited] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126769#comment-17126769 ] Congxian Qiu(klion26) edited comment on FLINK-18091 at 6/5/20, 1:40 PM:

[jira] [Commented] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126769#comment-17126769 ] Congxian Qiu(klion26) commented on FLINK-18091: --- Test on a real cluster, Result excepted.

[jira] [Commented] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126428#comment-17126428 ] Congxian Qiu(klion26) commented on FLINK-17571: --- [~wind_ljy] The reason don't want to add

[jira] [Commented] (FLINK-18091) Test Relocatable Savepoints

[ https://issues.apache.org/jira/browse/FLINK-18091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125483#comment-17125483 ] Congxian Qiu(klion26) commented on FLINK-18091: --- [~liyu] thanks for the notice, please

[jira] [Commented] (FLINK-18038) StateBackendLoader logs application-defined state before it is fully configured

[ https://issues.apache.org/jira/browse/FLINK-18038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120765#comment-17120765 ] Congxian Qiu(klion26) commented on FLINK-18038: --- I think logging the final used

[jira] [Commented] (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:comment-tabpanel=17119388#comment-17119388 ] Congxian Qiu(klion26) commented on FLINK-15507: --- First, enable local recovery for

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118239#comment-17118239 ] Congxian Qiu(klion26) commented on FLINK-16572: --- seems another instance 

[jira] [Commented] (FLINK-17926) Can't build flink-web docker image because of EOL of Ubuntu:18.10

[ https://issues.apache.org/jira/browse/FLINK-17926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115992#comment-17115992 ] Congxian Qiu(klion26) commented on FLINK-17926: --- [~rmetzger] what do you think about this,

[jira] [Created] (FLINK-17926) Can't build flink-web docker image because of EOL of Ubuntu:18.10

Congxian Qiu(klion26) created FLINK-17926: - Summary: Can't build flink-web docker image because of EOL of Ubuntu:18.10 Key: FLINK-17926 URL: https://issues.apache.org/jira/browse/FLINK-17926

[jira] [Commented] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots th

[ https://issues.apache.org/jira/browse/FLINK-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115896#comment-17115896 ] Congxian Qiu(klion26) commented on FLINK-13009: --- [~fly_in_gis] Thanks for the analysis and

[jira] [Commented] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-17468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113726#comment-17113726 ] Congxian Qiu(klion26) commented on FLINK-17468: --- [~qqibrow]  How's it going? do you need

[jira] [Commented] (FLINK-17351) CheckpointCoordinator and CheckpointFailureManager ignores checkpoint timeouts

[ https://issues.apache.org/jira/browse/FLINK-17351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113095#comment-17113095 ] Congxian Qiu(klion26) commented on FLINK-17351: --- Attach another issue which wants to

[jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11937: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Resolve small

[jira] [Updated] (FLINK-16077) Translate "Custom State Serialization" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-16077: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Translate

[jira] [Updated] (FLINK-15747) Enable setting RocksDB log level from configuration

[ https://issues.apache.org/jira/browse/FLINK-15747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-15747: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Enable setting

[jira] [Updated] (FLINK-16074) Translate the "Overview" page for "State & Fault Tolerance" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-16074: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Translate the

[jira] [Commented] (FLINK-5763) Make savepoints self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109933#comment-17109933 ] Congxian Qiu(klion26) commented on FLINK-5763: -- Add a release note. > Make savepoints

[jira] [Updated] (FLINK-5763) Make savepoints self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-5763: - Release Note: After FLINK-5763, we made savepoint self-contained and relocatable

[jira] [Commented] (FLINK-17487) Do not delete old checkpoints when stop the job.

[ https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109386#comment-17109386 ] Congxian Qiu(klion26) commented on FLINK-17487: --- [~nobleyd] Do you mean the stop command

[jira] [Comment Edited] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108387#comment-17108387 ] Congxian Qiu(klion26) edited comment on FLINK-16383 at 5/15/20, 3:12 PM:

[jira] [Commented] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108387#comment-17108387 ] Congxian Qiu(klion26) commented on FLINK-16383: --- seems another instance

[jira] [Commented] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106088#comment-17106088 ] Congxian Qiu(klion26) commented on FLINK-17571: --- [~pnowojski] the directory of checkpoint

[jira] [Commented] (FLINK-13678) Translate "Code Style - Preamble" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104190#comment-17104190 ] Congxian Qiu(klion26) commented on FLINK-13678: --- [~WangHW] Do you still working on this? I

[jira] [Commented] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-17468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104165#comment-17104165 ] Congxian Qiu(klion26) commented on FLINK-17468: --- [~qqibrow] please let me if you need any

[jira] [Commented] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104131#comment-17104131 ] Congxian Qiu(klion26) commented on FLINK-17571: --- sorry for the late replay, seems lost

[jira] [Commented] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-17468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102397#comment-17102397 ] Congxian Qiu(klion26) commented on FLINK-17468: --- Hi [~qqibrow] from your previous reply,

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the

[jira] [Commented] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102356#comment-17102356 ] Congxian Qiu(klion26) commented on FLINK-17571: --- [~pnowojski] what do you think about this

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the [usermail|#directory-structure]]  Currently,

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the [usermail|#directory-structure] Currently,

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the [usermail|#directory-structure] Currently,

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the [user

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the [user

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the [user

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the [user

[jira] [Created] (FLINK-17571) A better way to show the files used in currently checkpoints

Congxian Qiu(klion26) created FLINK-17571: - Summary: A better way to show the files used in currently checkpoints Key: FLINK-17571 URL: https://issues.apache.org/jira/browse/FLINK-17571

[jira] [Updated] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17571: -- Description: Inspired by the [[user

[jira] [Commented] (FLINK-17479) Occasional checkpoint failure due to null pointer exception in Flink version 1.10

[ https://issues.apache.org/jira/browse/FLINK-17479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101355#comment-17101355 ] Congxian Qiu(klion26) commented on FLINK-17479: --- [~nobleyd] thanks for reporting this

[jira] [Updated] (FLINK-17342) Schedule savepoint if max-inflight-checkpoints limit is reached instead of forcing (in UC mode)

[ https://issues.apache.org/jira/browse/FLINK-17342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-17342: -- Summary: Schedule savepoint if max-inflight-checkpoints limit is reached

[jira] [Commented] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-17468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096430#comment-17096430 ] Congxian Qiu(klion26) commented on FLINK-17468: --- Hi, [~qqibrow], there may so many 

  1   2   3   4   >