[jira] [Created] (FLINK-17458) TaskExecutorSubmissionTest#testFailingScheduleOrUpdateConsumers

Congxian Qiu(klion26) created FLINK-17458: - Summary: TaskExecutorSubmissionTest#testFailingScheduleOrUpdateConsumers Key: FLINK-17458 URL: https://issues.apache.org/jira/browse/FLINK-17458

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

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

[jira] [Commented] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084492#comment-17084492 ] Congxian Qiu(klion26) commented on FLINK-17170: --- Hi, [~cvasii] from the description, seems

[jira] [Created] (FLINK-17043) Putting more information into accounting when failing a job in FailureManager

Congxian Qiu(klion26) created FLINK-17043: - Summary: Putting more information into accounting when failing a job in FailureManager Key: FLINK-17043 URL: https://issues.apache.org/jira/browse/FLINK-17043

[jira] [Created] (FLINK-17007) Add section "How to handle application parameters" in DataStream documentation

Congxian Qiu(klion26) created FLINK-17007: - Summary: Add section "How to handle application parameters" in DataStream documentation Key: FLINK-17007 URL: https://issues.apache.org/jira/browse/FLINK-17007

[jira] [Commented] (FLINK-16724) ListSerializer cannot serialize list which containers null

[ https://issues.apache.org/jira/browse/FLINK-16724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074991#comment-17074991 ] Congxian Qiu(klion26) commented on FLINK-16724: --- [~nppoly] What do you think about my

[jira] [Commented] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

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

[jira] [Updated] (FLINK-16916) The logic of NullableSerializer#copy is wrong

[ https://issues.apache.org/jira/browse/FLINK-16916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-16916: -- Fix Version/s: 1.10.2 1.9.3 1.8.4 > The

[jira] [Commented] (FLINK-16724) ListSerializer cannot serialize list which containers null

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

[jira] [Commented] (FLINK-16916) The logic of NullableSerializer#copy is wrong

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

[jira] [Created] (FLINK-16916) The logic of NullableSerializer#copy is wrong

Congxian Qiu(klion26) created FLINK-16916: - Summary: The logic of NullableSerializer#copy is wrong Key: FLINK-16916 URL: https://issues.apache.org/jira/browse/FLINK-16916 Project: Flink

[jira] [Commented] (FLINK-16576) State inconsistency on restore with memory state backends

[ https://issues.apache.org/jira/browse/FLINK-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17069428#comment-17069428 ] Congxian Qiu(klion26) commented on FLINK-16576: --- The reason why the restore failed here

[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

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

[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027476#comment-17027476 ] Congxian Qiu(klion26) commented on FLINK-13632: --- I'm on

[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17026454#comment-17026454 ] Congxian Qiu(klion26) commented on FLINK-13632: --- I'm on

[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020738#comment-17020738 ] Congxian Qiu(klion26) commented on FLINK-13632: --- I'm on

[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020734#comment-17020734 ] Congxian Qiu(klion26) commented on FLINK-13632: --- I'm on

[jira] [Created] (FLINK-15699) FirstValueAggFunctionWithoutOrderTest failed on Traivs

Congxian Qiu(klion26) created FLINK-15699: - Summary: FirstValueAggFunctionWithoutOrderTest failed on Traivs Key: FLINK-15699 URL: https://issues.apache.org/jira/browse/FLINK-15699 Project:

[jira] [Commented] (FLINK-15699) FirstValueAggFunctionWithoutOrderTest failed on Traivs

[ https://issues.apache.org/jira/browse/FLINK-15699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019799#comment-17019799 ] Congxian Qiu(klion26) commented on FLINK-15699: --- cc [~godfreyhe] >

[jira] [Commented] (FLINK-13632) Port serializer upgrade tests to TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019532#comment-17019532 ] Congxian Qiu(klion26) commented on FLINK-13632: --- I'm porting

[jira] [Commented] (FLINK-15637) For RocksDBStateBackend, make RocksDB the default store for timers

[ https://issues.apache.org/jira/browse/FLINK-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019463#comment-17019463 ] Congxian Qiu(klion26) commented on FLINK-15637: --- [~gjy] Yes, I'm working on this, please

[jira] [Updated] (FLINK-15685) org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs

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

[jira] [Commented] (FLINK-15685) org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs

[ https://issues.apache.org/jira/browse/FLINK-15685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019365#comment-17019365 ] Congxian Qiu(klion26) commented on FLINK-15685: --- >From the exception log, it was thrown in

[jira] [Created] (FLINK-15685) org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs

Congxian Qiu(klion26) created FLINK-15685: - Summary: org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs Key: FLINK-15685 URL: https://issues.apache.org/jira/browse/FLINK-15685

[jira] [Commented] (FLINK-15247) Closing (Testing)MiniCluster may cause ConcurrentModificationException

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

[jira] [Comment Edited] (FLINK-15637) For RocksDBStateBackend, make RocksDB the default store for timers

[ https://issues.apache.org/jira/browse/FLINK-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019194#comment-17019194 ] Congxian Qiu(klion26) edited comment on FLINK-15637 at 1/20/20 4:07 AM:

[jira] [Comment Edited] (FLINK-15637) For RocksDBStateBackend, make RocksDB the default store for timers

[ https://issues.apache.org/jira/browse/FLINK-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019194#comment-17019194 ] Congxian Qiu(klion26) edited comment on FLINK-15637 at 1/20/20 4:07 AM:

[jira] [Comment Edited] (FLINK-15637) For RocksDBStateBackend, make RocksDB the default store for timers

[ https://issues.apache.org/jira/browse/FLINK-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019194#comment-17019194 ] Congxian Qiu(klion26) edited comment on FLINK-15637 at 1/20/20 3:00 AM:

[jira] [Commented] (FLINK-15637) For RocksDBStateBackend, make RocksDB the default store for timers

[ https://issues.apache.org/jira/browse/FLINK-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019194#comment-17019194 ] Congxian Qiu(klion26) commented on FLINK-15637: --- Ran the benchmark of

[jira] [Created] (FLINK-15661) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed because of Could not find Flink job

Congxian Qiu(klion26) created FLINK-15661: - Summary: JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed because of Could not find Flink job Key: FLINK-15661 URL:

[jira] [Commented] (FLINK-13632) Update serializer upgrade tests to restore from 1.8 and beyond

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018075#comment-17018075 ] Congxian Qiu(klion26) commented on FLINK-13632: --- I'm currently porting

[jira] [Created] (FLINK-15619) GroupWindowTableAggregateITCase.testAllProcessingTimeTumblingGroupWindowOverCount failed on Azure

Congxian Qiu(klion26) created FLINK-15619: - Summary: GroupWindowTableAggregateITCase.testAllProcessingTimeTumblingGroupWindowOverCount failed on Azure Key: FLINK-15619 URL:

[jira] [Commented] (FLINK-15603) Show "barrier lag" in checkpoint statistics

[ https://issues.apache.org/jira/browse/FLINK-15603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016484#comment-17016484 ] Congxian Qiu(klion26) commented on FLINK-15603: --- And we may add some debug log in

[jira] [Commented] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012786#comment-17012786 ] Congxian Qiu(klion26) commented on FLINK-12785: --- Already added the release not, closing

[jira] [Closed] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) closed FLINK-12785. - Resolution: Fixed > RocksDB savepoint recovery can use a lot of unmanaged

[jira] [Updated] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12785: -- Release Note: Before FLINK-12785, user may encounter OOM if there are huge KV

[jira] [Updated] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12785: -- Release Note: Before FLINK-12785, user may encounter OOM if there are huge KV

[jira] [Commented] (FLINK-15529) Update upgrade compatibility table (docs/ops/upgrading.md) for 1.10.0

[ https://issues.apache.org/jira/browse/FLINK-15529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012748#comment-17012748 ] Congxian Qiu(klion26) commented on FLINK-15529: --- Currently. I've tested using Pojo

[jira] [Commented] (FLINK-15424) Make all AppendingState#add respect the java doc

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

[jira] [Commented] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

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

[jira] [Commented] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006650#comment-17006650 ] Congxian Qiu(klion26) commented on FLINK-15152: --- [~pnowojski] thanks for your reply. Yes,

[jira] [Commented] (FLINK-15247) Closing (Testing)MiniCluster may cause ConcurrentModificationException

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

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006540#comment-17006540 ] Congxian Qiu(klion26) commented on FLINK-15447: --- FYI, the Jaas files will locate in

[jira] [Updated] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on azure

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

[jira] [Created] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure

Congxian Qiu(klion26) created FLINK-15451: - Summary: TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure Key: FLINK-15451 URL: https://issues.apache.org/jira/browse/FLINK-15451

[jira] [Commented] (FLINK-15247) Closing (Testing)MiniCluster may cause ConcurrentModificationException

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

[jira] [Commented] (FLINK-15427) State TTL RocksDb backend end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17004461#comment-17004461 ] Congxian Qiu(klion26) commented on FLINK-15427: --- This test itself passed, but failed when

[jira] [Commented] (FLINK-15427) State TTL RocksDb backend end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17004128#comment-17004128 ] Congxian Qiu(klion26) commented on FLINK-15427: --- I'll  take a look at this issue > State

[jira] [Updated] (FLINK-15424) Make all AppendingState#add respect the java doc

[ https://issues.apache.org/jira/browse/FLINK-15424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-15424: -- Component/s: Runtime / State Backends > Make all AppendingState#add respect

[jira] [Created] (FLINK-15424) Make all AppendingState#add respect the java doc

Congxian Qiu(klion26) created FLINK-15424: - Summary: Make all AppendingState#add respect the java doc Key: FLINK-15424 URL: https://issues.apache.org/jira/browse/FLINK-15424 Project: Flink

[jira] [Commented] (FLINK-15403) 'State Migration end-to-end test from 1.6' is unstable on travis.

[ https://issues.apache.org/jira/browse/FLINK-15403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003840#comment-17003840 ] Congxian Qiu(klion26) commented on FLINK-15403: --- The exception in the description is an

[jira] [Commented] (FLINK-15406) The savepoint is writted by "State Processor API" can't be restore by map or flatmap

[ https://issues.apache.org/jira/browse/FLINK-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003837#comment-17003837 ] Congxian Qiu(klion26) commented on FLINK-15406: --- Hi, [~lintingbin]  From the description,

[jira] [Comment Edited] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003427#comment-17003427 ] Congxian Qiu(klion26) edited comment on FLINK-15152 at 12/26/19 2:27 AM:

[jira] [Commented] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003427#comment-17003427 ] Congxian Qiu(klion26) commented on FLINK-15152: ---  After having a look at the code, I think

[jira] [Commented] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003193#comment-17003193 ] Congxian Qiu(klion26) commented on FLINK-15152: --- Thanks for reporting the issue, from the

[jira] [Commented] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999881#comment-16999881 ] Congxian Qiu(klion26) commented on FLINK-13553: --- Currently, can't reproduce it and not

[jira] [Closed] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) closed FLINK-13553. - Resolution: Cannot Reproduce > KvStateServerHandlerTest.readInboundBlocking

[jira] [Commented] (FLINK-15280) Checkpoint end-to-end test failed

[ https://issues.apache.org/jira/browse/FLINK-15280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16997279#comment-16997279 ] Congxian Qiu(klion26) commented on FLINK-15280: --- FYI FLINK-15105 wants to disable the

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995375#comment-16995375 ] Congxian Qiu(klion26) commented on FLINK-13808: --- [~sewen] FYI, create an issue to track

[jira] [Updated] (FLINK-15236) Add a safety net to limit the number of concurrent checkpoints on TM side

[ https://issues.apache.org/jira/browse/FLINK-15236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-15236: -- Summary: Add a safety net to limit the number of concurrent checkpoints on TM

[jira] [Created] (FLINK-15236) Add a safety net for concurrent checkpoints on TM side

Congxian Qiu(klion26) created FLINK-15236: - Summary: Add a safety net for concurrent checkpoints on TM side Key: FLINK-15236 URL: https://issues.apache.org/jira/browse/FLINK-15236 Project:

[jira] [Commented] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994704#comment-16994704 ] Congxian Qiu(klion26) commented on FLINK-15105: --- Agree that {{disable the exception

[jira] [Comment Edited] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993554#comment-16993554 ] Congxian Qiu(klion26) edited comment on FLINK-15105 at 12/11/19 1:52 PM:

[jira] [Comment Edited] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993554#comment-16993554 ] Congxian Qiu(klion26) edited comment on FLINK-15105 at 12/11/19 1:46 PM:

[jira] [Commented] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993554#comment-16993554 ] Congxian Qiu(klion26) commented on FLINK-15105: --- First, answer the last question: we can't

[jira] [Comment Edited] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992673#comment-16992673 ] Congxian Qiu(klion26) edited comment on FLINK-15105 at 12/10/19 4:09 PM:

[jira] [Comment Edited] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992673#comment-16992673 ] Congxian Qiu(klion26) edited comment on FLINK-15105 at 12/10/19 3:49 PM:

[jira] [Commented] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992673#comment-16992673 ] Congxian Qiu(klion26) commented on FLINK-15105: --- [~trohrmann]  In the previous comment,

[jira] [Created] (FLINK-15150) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on Travis

Congxian Qiu(klion26) created FLINK-15150: - Summary: ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on Travis Key: FLINK-15150 URL:

[jira] [Commented] (FLINK-15097) flink can not use user specified hdfs conf when submitting app in client node

[ https://issues.apache.org/jira/browse/FLINK-15097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991192#comment-16991192 ] Congxian Qiu(klion26) commented on FLINK-15097: --- If these two are truly the same, could we

[jira] [Comment Edited] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991179#comment-16991179 ] Congxian Qiu(klion26) edited comment on FLINK-15105 at 12/9/19 6:38 AM:

[jira] [Commented] (FLINK-15105) Resuming Externalized Checkpoint after terminal failure (rocks, incremental) end-to-end test stalls on travis

[ https://issues.apache.org/jira/browse/FLINK-15105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991179#comment-16991179 ] Congxian Qiu(klion26) commented on FLINK-15105: --- The test complete checkpoint successfully

[jira] [Commented] (FLINK-14898) Enable background cleanup of state with TTL by default

[ https://issues.apache.org/jira/browse/FLINK-14898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991103#comment-16991103 ] Congxian Qiu(klion26) commented on FLINK-14898: --- [~azagrebin] have created FLINK-15136 for

[jira] [Commented] (FLINK-15136) Update the Chinese version of "Working with state"

[ https://issues.apache.org/jira/browse/FLINK-15136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991070#comment-16991070 ] Congxian Qiu(klion26) commented on FLINK-15136: --- As I translated the original "Working

[jira] [Updated] (FLINK-15136) Update the Chinese version of "Working with state"

[ https://issues.apache.org/jira/browse/FLINK-15136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-15136: -- Affects Version/s: 1.10.0 > Update the Chinese version of "Working with

[jira] [Created] (FLINK-15136) Update the Chinese version of "Working with state"

Congxian Qiu(klion26) created FLINK-15136: - Summary: Update the Chinese version of "Working with state" Key: FLINK-15136 URL: https://issues.apache.org/jira/browse/FLINK-15136 Project: Flink

[jira] [Commented] (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:comment-tabpanel=16986861#comment-16986861 ] Congxian Qiu(klion26) commented on FLINK-11937: --- Retarget to 1.11.0 to give more time for

[jira] [Commented] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16986855#comment-16986855 ] Congxian Qiu(klion26) commented on FLINK-13553: --- I'll take a look at this issue, currently

[jira] [Commented] (FLINK-13861) No new checkpoint will be trigged when canceling an expired checkpoint failed

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

[jira] [Updated] (FLINK-13861) No new checkpoint will be trigged when canceling an expired checkpoint failed

[ https://issues.apache.org/jira/browse/FLINK-13861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13861: -- Fix Version/s: (was: 1.10.0) > No new checkpoint will be trigged when

[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.10.0) 1.11.0 > Resolve small

[jira] [Comment Edited] (FLINK-14966) one error in document

[ https://issues.apache.org/jira/browse/FLINK-14966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983411#comment-16983411 ] Congxian Qiu(klion26) edited comment on FLINK-14966 at 11/27/19 11:12 AM:

[jira] [Commented] (FLINK-14966) one error in document

[ https://issues.apache.org/jira/browse/FLINK-14966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983411#comment-16983411 ] Congxian Qiu(klion26) commented on FLINK-14966: --- I think this is a typo as you described.

[jira] [Commented] (FLINK-14110) Deleting state.backend.rocksdb.localdir causes silent failure

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

[jira] [Commented] (FLINK-14892) Add documentation for checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16980652#comment-16980652 ] Congxian Qiu(klion26) commented on FLINK-14892: --- [~pnowojski] thanks for the reply and

[jira] [Commented] (FLINK-14928) Documentation links check nightly run failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16980151#comment-16980151 ] Congxian Qiu(klion26) commented on FLINK-14928: --- FLINK-14866 fixed much of them, but there

[jira] [Commented] (FLINK-14928) Documentation links check nightly run failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979973#comment-16979973 ] Congxian Qiu(klion26) commented on FLINK-14928: --- the reason here is FLINK-14638 moved some

[jira] [Commented] (FLINK-14928) Documentation links check nightly run failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979967#comment-16979967 ] Congxian Qiu(klion26) commented on FLINK-14928: --- I'll take a look at this issue. >

[jira] [Updated] (FLINK-14892) Add documentation for checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-14892: -- Summary: Add documentation for checkpoint directory layout (was: Add

[jira] [Commented] (FLINK-14892) Add description for checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-14892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979239#comment-16979239 ] Congxian Qiu(klion26) commented on FLINK-14892: --- [~sewen] as you're the owner of

[jira] [Created] (FLINK-14892) Add description for checkpoint directory layout

Congxian Qiu(klion26) created FLINK-14892: - Summary: Add description for checkpoint directory layout Key: FLINK-14892 URL: https://issues.apache.org/jira/browse/FLINK-14892 Project: Flink

[jira] [Commented] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI

[ https://issues.apache.org/jira/browse/FLINK-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16977991#comment-16977991 ] Congxian Qiu(klion26) commented on FLINK-14264: --- kindly ping [~aljoscha] > Expose

[jira] [Commented] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975905#comment-16975905 ] Congxian Qiu(klion26) commented on FLINK-14830: --- [~jark], I agree that changing all the

[jira] [Commented] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975901#comment-16975901 ] Congxian Qiu(klion26) commented on FLINK-14830: --- [~jark] I think this is a little tricky,

[jira] [Commented] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

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

[jira] [Created] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

Congxian Qiu(klion26) created FLINK-14830: - Summary: Correct the link for chinese version stream_checkpointing page Key: FLINK-14830 URL: https://issues.apache.org/jira/browse/FLINK-14830

[jira] [Commented] (FLINK-14776) Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions

[ https://issues.apache.org/jira/browse/FLINK-14776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16974892#comment-16974892 ] Congxian Qiu(klion26) commented on FLINK-14776: --- [~dwysakowicz] Can I help to do this

[jira] [Commented] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI

[ https://issues.apache.org/jira/browse/FLINK-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973360#comment-16973360 ] Congxian Qiu(klion26) commented on FLINK-14264: --- [~aljoscha] thanks for your reply, first

[jira] [Comment Edited] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI

[ https://issues.apache.org/jira/browse/FLINK-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973360#comment-16973360 ] Congxian Qiu(klion26) edited comment on FLINK-14264 at 11/13/19 1:57 PM:

[jira] [Commented] (FLINK-14433) Move generated Jaas conf file from /tmp directory to Job specific directory

[ https://issues.apache.org/jira/browse/FLINK-14433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16973211#comment-16973211 ] Congxian Qiu(klion26) commented on FLINK-14433: --- [~aljoscha] thanks for your reply, will

<    1   2   3   4   >