[jira] [Commented] (FLINK-12683) Provide task manager's location information for checkpoint coordinator specific log messages

[ https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852658#comment-16852658 ] Congxian Qiu(klion26) commented on FLINK-12683: --- In my opinion, the jm log of current

[jira] [Commented] (FLINK-12683) Provide task manager's location information for checkpoint acknowledge message to improve the checkpoint log message

[ https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852572#comment-16852572 ] Congxian Qiu(klion26) commented on FLINK-12683: --- Please have a look at FLINK-1165.:) >

[jira] [Comment Edited] (FLINK-12683) Provide task manager's location information for checkpoint acknowledge message to improve the checkpoint log message

[ https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852572#comment-16852572 ] Congxian Qiu(klion26) edited comment on FLINK-12683 at 5/31/19 2:03 AM:

[jira] [Commented] (FLINK-12683) Provide task manager's location information for checkpoint acknowledge message to improve the checkpoint log message

[ https://issues.apache.org/jira/browse/FLINK-12683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16851694#comment-16851694 ] Congxian Qiu(klion26) commented on FLINK-12683: --- I think we can find the host and

[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=16851503#comment-16851503 ] Congxian Qiu(klion26) commented on FLINK-11947: --- hi, [~cre...@gmail.com]  I've filed a pr

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

[ https://issues.apache.org/jira/browse/FLINK-11947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16850497#comment-16850497 ] Congxian Qiu(klion26) commented on FLINK-11947: --- [~cresny] I'm interested in this issue,

[jira] [Commented] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16850490#comment-16850490 ] Congxian Qiu(klion26) commented on FLINK-12296: --- Thanks for the reminder [~sunjincheng121]

[jira] [Comment Edited] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16850320#comment-16850320 ] Congxian Qiu(klion26) edited comment on FLINK-12296 at 5/29/19 2:42 AM:

[jira] [Resolved] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) resolved FLINK-12296. --- Resolution: Fixed Since the commits have been merged in master,

[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=16849589#comment-16849589 ] Congxian Qiu(klion26) commented on FLINK-12619: --- [~aljoscha] thanks for you reply. For

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

Congxian Qiu(klion26) created FLINK-12619: - Summary: Support TERMINATE/SUSPEND Job with Checkpoint Key: FLINK-12619 URL: https://issues.apache.org/jira/browse/FLINK-12619 Project: Flink

[jira] [Commented] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847179#comment-16847179 ] Congxian Qiu(klion26) commented on FLINK-12607: --- Thanks for filing the issue, I like this

[jira] [Commented] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

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

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

[ https://issues.apache.org/jira/browse/FLINK-12536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-12536: - Assignee: Congxian Qiu(klion26) > Make BufferOrEventSequence#getNext()

[jira] [Commented] (FLINK-11634) Translate "State Backends" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845702#comment-16845702 ] Congxian Qiu(klion26) commented on FLINK-11634: --- [~zxhe] I can't find your id for 

[jira] [Commented] (FLINK-11560) Translate "Flink Applications" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845437#comment-16845437 ] Congxian Qiu(klion26) commented on FLINK-11560: --- thanks for your contribution. I'll review

[jira] [Commented] (FLINK-11637) Translate "Checkpoints" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844658#comment-16844658 ] Congxian Qiu(klion26) commented on FLINK-11637: --- [~guanghui] If there is no assignee yet,

[jira] [Comment Edited] (FLINK-12400) NullpointerException using SimpleStringSchema with Kafka

[ https://issues.apache.org/jira/browse/FLINK-12400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833187#comment-16833187 ] Congxian Qiu(klion26) edited comment on FLINK-12400 at 5/5/19 1:52 AM:

[jira] [Commented] (FLINK-12400) NullpointerException using SimpleStringSchema with Kafka

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

[jira] [Commented] (FLINK-11637) Translate "Checkpoints" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16832987#comment-16832987 ] Congxian Qiu(klion26) commented on FLINK-11637: --- [~lsy] I'm not working on this now, if

[jira] [Comment Edited] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827806#comment-16827806 ] Congxian Qiu(klion26) edited comment on FLINK-12296 at 4/28/19 4:44 AM:

[jira] [Commented] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827806#comment-16827806 ] Congxian Qiu(klion26) commented on FLINK-12296: --- After discussed offline with [~srichter],

[jira] [Commented] (FLINK-11635) Translate "Checkpointing" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825674#comment-16825674 ] Congxian Qiu(klion26) commented on FLINK-11635: --- [~pengyang] Please feel free to take it.

[jira] [Commented] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825199#comment-16825199 ] Congxian Qiu(klion26) commented on FLINK-12296: --- [~srichter] I first implemented as you

[jira] [Commented] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825034#comment-16825034 ] Congxian Qiu(klion26) commented on FLINK-12296: --- [~srichter]  from what [~ningshi] have

[jira] [Updated] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12296: -- Description: As the mail list said[1], there may be a problem when more than

[jira] [Commented] (FLINK-11636) Translate "State Schema Evolution" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824762#comment-16824762 ] Congxian Qiu(klion26) commented on FLINK-11636: --- [~yangfei] Now I'm not working on it,

[jira] [Updated] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

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

[jira] [Updated] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12296: -- Priority: Critical (was: Major) > Data loss silently in RocksDBStateBackend

[jira] [Comment Edited] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16823998#comment-16823998 ] Congxian Qiu(klion26) edited comment on FLINK-12296 at 4/23/19 11:46 AM:

[jira] [Commented] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16823998#comment-16823998 ] Congxian Qiu(klion26) commented on FLINK-12296: --- I think this is a long existing issue

[jira] [Updated] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12296: -- Summary: Data loss silently in RocksDBStateBackend when more than one

[jira] [Updated] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12296: -- Description: As the mail list said[1], there may be a problem when more than

[jira] [Updated] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-12296: -- Issue Type: Bug (was: Test) > Data loss silently in RocksDBStateBackend when

[jira] [Created] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator chained in a single task

Congxian Qiu(klion26) created FLINK-12296: - Summary: Data loss silently in RocksDBStateBackend when more than one operator chained in a single task Key: FLINK-12296 URL:

[jira] [Assigned] (FLINK-11633) Translate "Working with State" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-11633: - Assignee: Congxian Qiu(klion26) > Translate "Working with State" into

[jira] [Created] (FLINK-12281) SortDistinctAggregateITCase>DistinctAggregateITCaseBase.testSomeColumnsBothInDistinctAggAndGroupBy Failed

Congxian Qiu(klion26) created FLINK-12281: - Summary: SortDistinctAggregateITCase>DistinctAggregateITCaseBase.testSomeColumnsBothInDistinctAggAndGroupBy Failed Key: FLINK-12281 URL:

[jira] [Assigned] (FLINK-11635) Translate "Checkpointing" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-11635: - Assignee: (was: Congxian Qiu(klion26)) > Translate "Checkpointing"

[jira] [Assigned] (FLINK-11636) Translate "State Schema Evolution" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-11636: - Assignee: (was: Congxian Qiu(klion26)) > Translate "State Schema

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

[ https://issues.apache.org/jira/browse/FLINK-11638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-11638: - Assignee: (was: Congxian Qiu(klion26)) > Translate "Savepoints"

[jira] [Assigned] (FLINK-11634) Translate "State Backends" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-11634: - Assignee: (was: Congxian Qiu(klion26)) > Translate "State

[jira] [Assigned] (FLINK-11637) Translate "Checkpoints" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-11637: - Assignee: (was: Congxian Qiu(klion26)) > Translate "Checkpoints"

[jira] [Assigned] (FLINK-11633) Translate "Working with State" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-11633: - Assignee: (was: Congxian Qiu(klion26)) > Translate "Working with

[jira] [Commented] (FLINK-11561) Translate "Flink Architecture" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822475#comment-16822475 ] Congxian Qiu(klion26) commented on FLINK-11561: --- [~jark]  thanks for reminder, I do not

[jira] [Assigned] (FLINK-11561) Translate "Flink Architecture" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-11561: - Assignee: (was: Congxian Qiu(klion26)) > Translate "Flink

[jira] [Commented] (FLINK-11948) When kafka sink parallelism

[ https://issues.apache.org/jira/browse/FLINK-11948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794775#comment-16794775 ] Congxian Qiu(klion26) commented on FLINK-11948: --- As the doc said, {noformat} To avoid such

[jira] [Updated] (FLINK-11939) Adjust components that need be modified for support FSCSOS

[ https://issues.apache.org/jira/browse/FLINK-11939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11939: -- Summary: Adjust components that need be modified for support FSCSOS (was:

[jira] [Updated] (FLINK-11939) Adjust components that need be modified to support FSCSOS

[ https://issues.apache.org/jira/browse/FLINK-11939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11939: -- Summary: Adjust components that need be modified to support FSCSOS (was:

[jira] [Updated] (FLINK-11938) Introduce all the new components to support FSCSOS

[ https://issues.apache.org/jira/browse/FLINK-11938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11938: -- Summary: Introduce all the new components to support FSCSOS (was: Introduce

[jira] [Updated] (FLINK-11939) Adjust components that need be modified for support FS

[ https://issues.apache.org/jira/browse/FLINK-11939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11939: -- Summary: Adjust components that need be modified for support FS (was: Adjust

[jira] [Created] (FLINK-11941) Reuse single FileSegmentCheckpointStateOutputStream for multiple checkpoints

Congxian Qiu(klion26) created FLINK-11941: - Summary: Reuse single FileSegmentCheckpointStateOutputStream for multiple checkpoints Key: FLINK-11941 URL: https://issues.apache.org/jira/browse/FLINK-11941

[jira] [Created] (FLINK-11940) Reduce storage amplification for FSCSOS

Congxian Qiu(klion26) created FLINK-11940: - Summary: Reduce storage amplification for FSCSOS Key: FLINK-11940 URL: https://issues.apache.org/jira/browse/FLINK-11940 Project: Flink

[jira] [Created] (FLINK-11939) Adjust components that need be modified

Congxian Qiu(klion26) created FLINK-11939: - Summary: Adjust components that need be modified Key: FLINK-11939 URL: https://issues.apache.org/jira/browse/FLINK-11939 Project: Flink

[jira] [Created] (FLINK-11938) Introduce all the new components

Congxian Qiu(klion26) created FLINK-11938: - Summary: Introduce all the new components Key: FLINK-11938 URL: https://issues.apache.org/jira/browse/FLINK-11938 Project: Flink Issue

[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: -- Description: Currently when incremental checkpoint is enabled in

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

Congxian Qiu(klion26) created FLINK-11937: - Summary: Resolve small file problem in RocksDB incremental checkpoint Key: FLINK-11937 URL: https://issues.apache.org/jira/browse/FLINK-11937

[jira] [Created] (FLINK-11904) Improve MemoryStateBackendTest by using JUnit's Parameterized

Congxian Qiu(klion26) created FLINK-11904: - Summary: Improve MemoryStateBackendTest by using JUnit's Parameterized Key: FLINK-11904 URL: https://issues.apache.org/jira/browse/FLINK-11904

[jira] [Created] (FLINK-11903) Improve FileStateBackendTest by using JUnit's Parameterized

Congxian Qiu(klion26) created FLINK-11903: - Summary: Improve FileStateBackendTest by using JUnit's Parameterized Key: FLINK-11903 URL: https://issues.apache.org/jira/browse/FLINK-11903

[jira] [Assigned] (FLINK-11850) ZooKeeperHaServicesTest#testSimpleCloseAndCleanupAllData fails on Travis

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

[jira] [Commented] (FLINK-11850) ZooKeeperHaServicesTest#testSimpleCloseAndCleanupAllData fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-11850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786680#comment-16786680 ] Congxian Qiu(klion26) commented on FLINK-11850: --- Sorry for the reassign, I just hit the

[jira] [Assigned] (FLINK-11850) ZooKeeperHaServicesTest#testSimpleCloseAndCleanupAllData fails on Travis

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

[jira] [Created] (FLINK-11850) ZooKeeperHaServicesTest#testSimpleCloseAndCleanupAllData fails on Travis

Congxian Qiu(klion26) created FLINK-11850: - Summary: ZooKeeperHaServicesTest#testSimpleCloseAndCleanupAllData fails on Travis Key: FLINK-11850 URL: https://issues.apache.org/jira/browse/FLINK-11850

[jira] [Commented] (FLINK-11825) Resolve name clash of StateTTL TimeCharacteristic class

[ https://issues.apache.org/jira/browse/FLINK-11825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785553#comment-16785553 ] Congxian Qiu(klion26) commented on FLINK-11825: --- Thank you [~azagrebin], I'll give a patch

[jira] [Commented] (FLINK-11825) Resolve name clash of StateTTL TimeCharacteristic class

[ https://issues.apache.org/jira/browse/FLINK-11825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785282#comment-16785282 ] Congxian Qiu(klion26) commented on FLINK-11825: --- [~fhueske] If you do not mind, I could

[jira] [Updated] (FLINK-11797) Implement empty unit tests in CheckpointCoordinatorMasterHooksTest

[ https://issues.apache.org/jira/browse/FLINK-11797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11797: -- Description: Current, there are some empty tests(no implementation) such as

[jira] [Updated] (FLINK-11797) Implement empty unit tests in CheckpointCoordinatorMasterHooksTest

[ https://issues.apache.org/jira/browse/FLINK-11797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11797: -- Summary: Implement empty unit tests in CheckpointCoordinatorMasterHooksTest

[jira] [Updated] (FLINK-11797) Implementation empty unit tests in CheckpointCoordinatorMasterHooksTest

[ https://issues.apache.org/jira/browse/FLINK-11797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11797: -- Description: Current, there are some empty tests(no implementation) such as

[jira] [Updated] (FLINK-11797) Implementation empty unit tests in CheckpointCoordinatorMasterHooksTest

[ https://issues.apache.org/jira/browse/FLINK-11797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11797: -- Affects Version/s: 1.8.0 > Implementation empty unit tests in

[jira] [Created] (FLINK-11797) Implementation empty unit tests in CheckpointCoordinatorMasterHooksTest

Congxian Qiu(klion26) created FLINK-11797: - Summary: Implementation empty unit tests in CheckpointCoordinatorMasterHooksTest Key: FLINK-11797 URL: https://issues.apache.org/jira/browse/FLINK-11797

[jira] [Comment Edited] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16780426#comment-16780426 ] Congxian Qiu(klion26) edited comment on FLINK-11774 at 2/28/19 11:46 AM:

[jira] [Commented] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16780426#comment-16780426 ] Congxian Qiu(klion26) commented on FLINK-11774: --- Running the given code on master branch

[jira] [Assigned] (FLINK-11141) Key generation for RocksDBMapState can theoretically be ambiguous

[ https://issues.apache.org/jira/browse/FLINK-11141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) reassigned FLINK-11141: - Assignee: (was: Congxian Qiu(klion26)) > Key generation for

[jira] [Resolved] (FLINK-11483) Improve StreamOperatorSnapshotRestoreTest with Parameterized

[ https://issues.apache.org/jira/browse/FLINK-11483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) resolved FLINK-11483. --- Resolution: Fixed > Improve StreamOperatorSnapshotRestoreTest with

[jira] [Commented] (FLINK-11738) Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/dispatcher15e85f5d-a55d-4773-8197-f0db5658f55b#1335897563]] after [10000 ms]. Se

[ https://issues.apache.org/jira/browse/FLINK-11738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16776596#comment-16776596 ] Congxian Qiu(klion26) commented on FLINK-11738: --- Hi, [~thinktothings] , I think 11690 has

[jira] [Commented] (FLINK-10481) Wordcount end-to-end test in docker env unstable

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

[jira] [Created] (FLINK-11704) Improve AbstractCheckpointStateOutputStreamTestBase with Parameterized

Congxian Qiu(klion26) created FLINK-11704: - Summary: Improve AbstractCheckpointStateOutputStreamTestBase with Parameterized Key: FLINK-11704 URL: https://issues.apache.org/jira/browse/FLINK-11704

<    1   2   3   4