[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969155#comment-16969155 ] Congxian Qiu(klion26) commented on FLINK-14653: --- Is fail job when any chec

[jira] [Comment Edited] (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&focusedCommentId=16969033#comment-16969033 ] Congxian Qiu(klion26) edited comment on FLINK-14433 at 11/7/19 8:27 AM: --

[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&focusedCommentId=16969033#comment-16969033 ] Congxian Qiu(klion26) commented on FLINK-14433: --- Since you introduced/modi

[jira] [Commented] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16966591#comment-16966591 ] Congxian Qiu(klion26) commented on FLINK-13969: --- Yes, I agree that this is

[jira] [Comment Edited] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963560#comment-16963560 ] Congxian Qiu(klion26) edited comment on FLINK-13969 at 10/31/19 2:26 AM: -

[jira] [Commented] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963560#comment-16963560 ] Congxian Qiu(klion26) commented on FLINK-13969: --- Hi, [~trohrmann], from th

[jira] [Commented] (FLINK-13969) Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962064#comment-16962064 ] Congxian Qiu(klion26) commented on FLINK-13969: --- After thinking it a littl

[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&focusedCommentId=16962017#comment-16962017 ] Congxian Qiu(klion26) commented on FLINK-13861: --- [~pnowojski] what do you

[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&focusedCommentId=16962015#comment-16962015 ] Congxian Qiu(klion26) commented on FLINK-14433: --- [~aljoscha] As you're the

[jira] [Commented] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961953#comment-16961953 ] Congxian Qiu(klion26) commented on FLINK-13856: --- [~andrew_lin]  I think re

[jira] [Comment Edited] (FLINK-13856) Reduce the delete file api when the checkpoint is completed

[ https://issues.apache.org/jira/browse/FLINK-13856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961953#comment-16961953 ] Congxian Qiu(klion26) edited comment on FLINK-13856 at 10/29/19 12:28 PM:

[jira] [Comment Edited] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961638#comment-16961638 ] Congxian Qiu(klion26) edited comment on FLINK-14544 at 10/29/19 3:36 AM: -

[jira] [Commented] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961638#comment-16961638 ] Congxian Qiu(klion26) commented on FLINK-14544: --- from the log, found that

[jira] [Comment Edited] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961208#comment-16961208 ] Congxian Qiu(klion26) edited comment on FLINK-14544 at 10/28/19 4:47 PM: -

[jira] [Commented] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961208#comment-16961208 ] Congxian Qiu(klion26) commented on FLINK-14544: --- >From the given log,  If

[jira] [Comment Edited] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961208#comment-16961208 ] Congxian Qiu(klion26) edited comment on FLINK-14544 at 10/28/19 4:14 PM: -

[jira] [Issue Comment Deleted] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13148: -- Comment: was deleted (was: Hi, [~kkl0u] do you think we can have this feature

[jira] [Commented] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960793#comment-16960793 ] Congxian Qiu(klion26) commented on FLINK-13148: --- kindly ping [~kkl0u] > E

[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&focusedCommentId=16960752#comment-16960752 ] Congxian Qiu(klion26) commented on FLINK-14264: --- Kindly ping [~aljoscha].

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

Congxian Qiu(klion26) created FLINK-14433: - Summary: Move generated Jaas conf file from /tmp directory to Job specific directory Key: FLINK-14433 URL: https://issues.apache.org/jira/browse/FLINK-14433

[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&focusedCommentId=16949354#comment-16949354 ] Congxian Qiu(klion26) edited comment on FLINK-14264 at 10/11/19 10:35 AM:

[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&focusedCommentId=16949354#comment-16949354 ] Congxian Qiu(klion26) commented on FLINK-14264: --- [~aljoscha] what do you t

[jira] [Commented] (FLINK-14339) The checkpoint ID count wrong on restore savepoint log

[ https://issues.apache.org/jira/browse/FLINK-14339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947311#comment-16947311 ] Congxian Qiu(klion26) commented on FLINK-14339: --- This logs the next checkp

[jira] [Commented] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

[ https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946472#comment-16946472 ] Congxian Qiu(klion26) commented on FLINK-14340: --- [~sewen] as you introduce

[jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

[ https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-14340: -- Description: Currently, when Flink read/write to HDFS, we do not set the DFSCl

[jira] [Created] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

Congxian Qiu(klion26) created FLINK-14340: - Summary: Specify an unique DFSClient name for Hadoop FileSystem Key: FLINK-14340 URL: https://issues.apache.org/jira/browse/FLINK-14340 Project: Flin

[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&focusedCommentId=16946458#comment-16946458 ] Congxian Qiu(klion26) commented on FLINK-13808: --- Thanks for the reply [~se

[jira] [Commented] (FLINK-14336) Exceptions in AsyncCheckpointRunnable#run are never logged

[ https://issues.apache.org/jira/browse/FLINK-14336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946404#comment-16946404 ] Congxian Qiu(klion26) commented on FLINK-14336: --- For now, we only have com

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

[ https://issues.apache.org/jira/browse/FLINK-14264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-14264: -- Fix Version/s: 1.10.0 Affects Version/s: (was: 1.9.0) > Expose Che

[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&focusedCommentId=16939837#comment-16939837 ] Congxian Qiu(klion26) commented on FLINK-14264: --- [~Zentol] What do you thi

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

Congxian Qiu(klion26) created FLINK-14264: - Summary: Expose CheckpointBackend in checkpoint config RestAPI Key: FLINK-14264 URL: https://issues.apache.org/jira/browse/FLINK-14264 Project: Flink

[jira] [Commented] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937332#comment-16937332 ] Congxian Qiu(klion26) commented on FLINK-14159: --- [~jackylau] Yes, When we

[jira] [Commented] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937329#comment-16937329 ] Congxian Qiu(klion26) commented on FLINK-2491: -- [~tomas.witzany] Currently,

[jira] [Commented] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936536#comment-16936536 ] Congxian Qiu(klion26) commented on FLINK-14159: --- [~jackylau] ah, I've misu

[jira] [Commented] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935785#comment-16935785 ] Congxian Qiu(klion26) commented on FLINK-14159: --- hi, [~jackylau] Do you wa

[jira] [Commented] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935323#comment-16935323 ] Congxian Qiu(klion26) commented on FLINK-13148: --- Hi, [~kkl0u] do you think

[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&focusedCommentId=16933940#comment-16933940 ] Congxian Qiu(klion26) commented on FLINK-14110: --- [~aaronlevin] thanks for

[jira] [Closed] (FLINK-14035) Introduce/Change some log for snapshot to better analysis checkpoint problem

[ https://issues.apache.org/jira/browse/FLINK-14035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) closed FLINK-14035. - Resolution: Won't Fix > Introduce/Change some log for snapshot to better analysi

[jira] [Commented] (FLINK-14035) Introduce/Change some log for snapshot to better analysis checkpoint problem

[ https://issues.apache.org/jira/browse/FLINK-14035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932201#comment-16932201 ] Congxian Qiu(klion26) commented on FLINK-14035: --- [~StephanEwen] Thanks for

[jira] [Comment Edited] (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&focusedCommentId=16932165#comment-16932165 ] Congxian Qiu(klion26) edited comment on FLINK-14110 at 9/18/19 7:44 AM: --

[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&focusedCommentId=16932165#comment-16932165 ] Congxian Qiu(klion26) commented on FLINK-14110: --- [~aaronlevin] thank you f

[jira] [Created] (FLINK-14035) Introduce/Change some log for snapshot to better analysis checkpoint problem

Congxian Qiu(klion26) created FLINK-14035: - Summary: Introduce/Change some log for snapshot to better analysis checkpoint problem Key: FLINK-14035 URL: https://issues.apache.org/jira/browse/FLINK-14035

[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&focusedCommentId=16923874#comment-16923874 ] Congxian Qiu(klion26) commented on FLINK-13808: --- After analysis with [~Cae

[jira] [Updated] (FLINK-13612) StateDescriptor Loading Error NPE at FlinkKafkaProducer011 with High Concurrency Initialization

[ https://issues.apache.org/jira/browse/FLINK-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13612: -- Fix Version/s: (was: 1.9.1) 1.9.0 > StateDescriptor Loa

[jira] [Commented] (FLINK-13612) StateDescriptor Loading Error NPE at FlinkKafkaProducer011 with High Concurrency Initialization

[ https://issues.apache.org/jira/browse/FLINK-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921400#comment-16921400 ] Congxian Qiu(klion26) commented on FLINK-13612: --- [~Vow] As this has been f

[jira] [Commented] (FLINK-13612) StateDescriptor Loading Error NPE at FlinkKafkaProducer011 with High Concurrency Initialization

[ https://issues.apache.org/jira/browse/FLINK-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921384#comment-16921384 ] Congxian Qiu(klion26) commented on FLINK-13612: --- [~Vow] The line 264 of {{

[jira] [Commented] (FLINK-13612) StateDescriptor Loading Error NPE at FlinkKafkaProducer011 with High Concurrency Initialization

[ https://issues.apache.org/jira/browse/FLINK-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921133#comment-16921133 ] Congxian Qiu(klion26) commented on FLINK-13612: --- [~Vow] could you please s

[jira] [Commented] (FLINK-13612) StateDescriptor Loading Error NPE at FlinkKafkaProducer011 with High Concurrency Initialization

[ https://issues.apache.org/jira/browse/FLINK-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920844#comment-16920844 ] Congxian Qiu(klion26) commented on FLINK-13612: --- [~Vow] Does this problem

[jira] [Commented] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920614#comment-16920614 ] Congxian Qiu(klion26) commented on FLINK-13148: --- [~kkl0u] thanks for your

[jira] [Commented] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919543#comment-16919543 ] Congxian Qiu(klion26) commented on FLINK-13148: --- Kindly ping [~kkl0u], wha

[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&focusedCommentId=16918254#comment-16918254 ] Congxian Qiu(klion26) commented on FLINK-13808: --- Thanks for the ping [~car

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

Congxian Qiu(klion26) created FLINK-13861: - Summary: No new checkpoint trigged when canceling an expired checkpoint failed Key: FLINK-13861 URL: https://issues.apache.org/jira/browse/FLINK-13861

[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: -- Summary: No new checkpoint will be trigged when canceling an expired checkpoin

[jira] [Commented] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900582#comment-16900582 ] Congxian Qiu(klion26) commented on FLINK-13148: --- [~JaryZhen] thanks for th

[jira] [Commented] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894711#comment-16894711 ] Congxian Qiu(klion26) commented on FLINK-9900: -- Another instance https://tra

[jira] [Closed] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis

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

[jira] [Commented] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885950#comment-16885950 ] Congxian Qiu(klion26) commented on FLINK-11428: --- I've run this test locall

[jira] [Commented] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883601#comment-16883601 ] Congxian Qiu(klion26) commented on FLINK-13148: --- Hi,  [~kkl0u] what do you

[jira] [Updated] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13148: -- Description: As FLINK-10050 supported {{alloedLateness}}, but we can not get t

[jira] [Updated] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13148: -- Description: As FLINK-10050 supported {{alloedLateness}}, but we can not get t

[jira] [Updated] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13148: -- Description: As FLINK-10050 supported {{alloedLateness}}, but we can not get t

[jira] [Updated] (FLINK-13164) Add a listState#putAndGet benchmark for StateBenchmark

[ https://issues.apache.org/jira/browse/FLINK-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13164: -- Summary: Add a listState#putAndGet benchmark for StateBenchmark (was: Add a p

[jira] [Created] (FLINK-13164) Add a putAndGet benchmark for StateBenchmark

Congxian Qiu(klion26) created FLINK-13164: - Summary: Add a putAndGet benchmark for StateBenchmark Key: FLINK-13164 URL: https://issues.apache.org/jira/browse/FLINK-13164 Project: Flink

[jira] [Updated] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13148: -- Description: As FLINK-10050 supported {{alloedLateness}}, but we can not get t

[jira] [Commented] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880239#comment-16880239 ] Congxian Qiu(klion26) commented on FLINK-10050: --- Thanks for your reply [~k

[jira] [Created] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

Congxian Qiu(klion26) created FLINK-13148: - Summary: Expose WindowedStream.sideOutputLateData() from CoGroupedStreams Key: FLINK-13148 URL: https://issues.apache.org/jira/browse/FLINK-13148 Pr

[jira] [Comment Edited] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880113#comment-16880113 ] Congxian Qiu(klion26) edited comment on FLINK-10050 at 7/8/19 8:30 AM: ---

[jira] [Commented] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880113#comment-16880113 ] Congxian Qiu(klion26) commented on FLINK-10050: --- Thanks for your reply and

[jira] [Commented] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879986#comment-16879986 ] Congxian Qiu(klion26) commented on FLINK-10050: --- [~aljoscha] [~kkl0u] As w

[jira] [Commented] (FLINK-9095) Add metrics for Cassandra Connector

[ https://issues.apache.org/jira/browse/FLINK-9095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879069#comment-16879069 ] Congxian Qiu(klion26) commented on FLINK-9095: -- Hi, [~jparkie] what's the st

[jira] [Updated] (FLINK-11529) Support Chinese Documentation for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-11529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11529: -- Description: This issue is an umbrella issue for tracking fully support Chines

[jira] [Commented] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878957#comment-16878957 ] Congxian Qiu(klion26) commented on FLINK-12619: --- There is a discussion abo

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

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

[jira] [Comment Edited] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877656#comment-16877656 ] Congxian Qiu(klion26) edited comment on FLINK-13072 at 7/3/19 9:03 AM: ---

[jira] [Commented] (FLINK-13072) RocksDBStateBachend is not thread safe and data loss silently

[ https://issues.apache.org/jira/browse/FLINK-13072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877656#comment-16877656 ] Congxian Qiu(klion26) commented on FLINK-13072: --- I think currently we assu

[jira] [Commented] (FLINK-11638) Translate "Savepoints" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877415#comment-16877415 ] Congxian Qiu(klion26) commented on FLINK-11638: --- [~guanghui] I'm not worki

[jira] [Updated] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots thro

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

[jira] [Assigned] (FLINK-12994) Improve the buffer processing performance in SpilledBufferOrEventSequence#getNext

[ https://issues.apache.org/jira/browse/FLINK-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-12994: - Assignee: (was: Congxian Qiu(klion26)) > Improve the buffer process

[jira] [Assigned] (FLINK-8058) Queryable state should check types

[ https://issues.apache.org/jira/browse/FLINK-8058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-8058: Assignee: (was: Congxian Qiu(klion26)) > Queryable state should check

[jira] [Updated] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots thro

[ https://issues.apache.org/jira/browse/FLINK-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13009: -- Description: The test {{YARNSessionCapacitySchedulerITCase#testVCoresAreSetCo

[jira] [Updated] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots thro

[ https://issues.apache.org/jira/browse/FLINK-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13009: -- Description: The test {{YARNSessionCapacitySchedulerITCase#testVCoresAreSetCo

[jira] [Updated] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots thro

[ https://issues.apache.org/jira/browse/FLINK-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13009: -- Description: The test {{YARNSessionCapacitySchedulerITCase#testVCoresAreSetCo

[jira] [Updated] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots thro

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

[jira] [Created] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots

Congxian Qiu(klion26) created FLINK-13009: - Summary: YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots Key:

[jira] [Commented] (FLINK-12536) Make BufferOrEventSequence#getNext() non-blocking

[ https://issues.apache.org/jira/browse/FLINK-12536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873088#comment-16873088 ] Congxian Qiu(klion26) commented on FLINK-12536: --- As discussed with [~pnowo

[jira] [Created] (FLINK-12994) Improve the buffer processing performance in SpilledBufferOrEventSequence#getNext

Congxian Qiu(klion26) created FLINK-12994: - Summary: Improve the buffer processing performance in SpilledBufferOrEventSequence#getNext Key: FLINK-12994 URL: https://issues.apache.org/jira/browse/FLINK-1299

[jira] [Updated] (FLINK-12880) Support triggering checkpoint automatically when cancel a job

[ https://issues.apache.org/jira/browse/FLINK-12880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12880: -- Component/s: Runtime / State Backends > Support triggering checkpoint automati

[jira] [Created] (FLINK-12880) Support triggering checkpoint automatically when cancel a job

Congxian Qiu(klion26) created FLINK-12880: - Summary: Support triggering checkpoint automatically when cancel a job Key: FLINK-12880 URL: https://issues.apache.org/jira/browse/FLINK-12880 Proje

[jira] [Commented] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16864111#comment-16864111 ] Congxian Qiu(klion26) commented on FLINK-12619: --- Thanks for the doc [~carp

[jira] [Commented] (FLINK-12829) jobmaster log taskmanger address when task transition state to failed with error

[ https://issues.apache.org/jira/browse/FLINK-12829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16863623#comment-16863623 ] Congxian Qiu(klion26) commented on FLINK-12829: --- Hi, do you think FLINK-11

[jira] [Commented] (FLINK-12836) Allow retained checkpoints to be persisted on success

[ https://issues.apache.org/jira/browse/FLINK-12836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16863613#comment-16863613 ] Congxian Qiu(klion26) commented on FLINK-12836: --- Hi [~andreweduffy], Could

[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&focusedCommentId=16861675#comment-16861675 ] Congxian Qiu(klion26) commented on FLINK-12785: --- [~mikekap] thanks for the

[jira] [Assigned] (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) reassigned FLINK-12785: - Assignee: Congxian Qiu(klion26) > RocksDB savepoint recovery can use a

[jira] [Commented] (FLINK-11947) Support MapState value schema evolution for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-11947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860524#comment-16860524 ] Congxian Qiu(klion26) commented on FLINK-11947: --- [~cre...@gmail.com] thank

[jira] [Comment Edited] (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&focusedCommentId=16860481#comment-16860481 ] Congxian Qiu(klion26) edited comment on FLINK-12785 at 6/11/19 2:34 AM: --

[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&focusedCommentId=16860481#comment-16860481 ] Congxian Qiu(klion26) commented on FLINK-12785: --- I think your analysis is

[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&focusedCommentId=16859657#comment-16859657 ] Congxian Qiu(klion26) commented on FLINK-12785: --- Thanks for filing the iss

[jira] [Commented] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857800#comment-16857800 ] Congxian Qiu(klion26) commented on FLINK-12619: --- In my opinion, the checkp

[jira] [Commented] (FLINK-6755) Allow triggering Checkpoints through command line client

[ https://issues.apache.org/jira/browse/FLINK-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16856860#comment-16856860 ] Congxian Qiu(klion26) commented on FLINK-6755: -- The two issues are indeed re

[jira] [Created] (FLINK-12733) Expose Rest API for TERMINATE/SUSPEND Job with Checkpoint

Congxian Qiu(klion26) created FLINK-12733: - Summary: Expose Rest API for TERMINATE/SUSPEND Job with Checkpoint Key: FLINK-12733 URL: https://issues.apache.org/jira/browse/FLINK-12733 Project: F

<    1   2   3   4   >