[jira] [Commented] (FLINK-9925) ClientTest.testSimpleRequests fails on Travis

2018-07-29 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561036#comment-16561036 ] Congxian Qiu commented on FLINK-9925: - I run the test locally ~ 100 times, but can produce this

[jira] [Commented] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-07-29 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561045#comment-16561045 ] Congxian Qiu commented on FLINK-8163: - When I got stuck, I got the jstack message as below

[jira] [Commented] (FLINK-9116) Introduce getAll and removeAll for MapState

2018-08-01 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565056#comment-16565056 ] Congxian Qiu commented on FLINK-9116: - Hi, [~sihuazhou], I didn't see putAll(List) in MapState in

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

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

[jira] [Updated] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-08-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10065: - Description: Now, the implementation of  (InputStream in, ClassLoader cl, boolean

[jira] [Assigned] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-08-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-10065: Assignee: Congxian Qiu > InstantiationUtil.deserializeObject(InputStream in, ClassLoader

[jira] [Updated] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-08-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10065: - Description: Now, the implementation of  > InstantiationUtil.deserializeObject(InputStream in,

[jira] [Created] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-08-06 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-10065: Summary: InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream Key: FLINK-10065 URL:

[jira] [Updated] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-08-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10065: - Description: Now, the implementation of InstantiationUtil.deserializeObject(InputStream in,

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

2018-07-19 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550174#comment-16550174 ] Congxian Qiu commented on FLINK-8058: - Hi, [~Zentol] could I check the state type and type of

[jira] [Commented] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

2018-07-20 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550288#comment-16550288 ] Congxian Qiu commented on FLINK-8163: - I ran the 

[jira] [Commented] (FLINK-5611) Add QueryableStateException type

2018-07-20 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550767#comment-16550767 ] Congxian Qiu commented on FLINK-5611: - Hi, [~kkl0u] is this issue still needed? I could take over it,

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

2018-07-17 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547316#comment-16547316 ] Congxian Qiu commented on FLINK-8058: - Hi, [~Zentol] is this issues still needed? If yes, can I  do 

[jira] [Commented] (FLINK-6799) PojoSerializer does not check field types when being deserialized

2018-07-17 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16547311#comment-16547311 ] Congxian Qiu commented on FLINK-6799: - Hi, [~tzulitai] is this issue still needed?  If you do not

[jira] [Commented] (FLINK-9847) OneInputStreamTaskTest.testWatermarksNotForwardedWithinChainWhenIdle unstable

2018-07-13 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543957#comment-16543957 ] Congxian Qiu commented on FLINK-9847: - I just gotten the following error message as I run the test on

[jira] [Commented] (FLINK-9847) OneInputStreamTaskTest.testWatermarksNotForwardedWithinChainWhenIdle unstable

2018-07-13 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16543965#comment-16543965 ] Congxian Qiu commented on FLINK-9847: - Could this be   {noformat} int

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

2018-07-21 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551703#comment-16551703 ] Congxian Qiu commented on FLINK-8058: - Hi, [~kkl0u], is this issues needed in Queryable State, if it

[jira] [Comment Edited] (FLINK-9906) Flink Job not running with no resource

2018-07-21 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551887#comment-16551887 ] Congxian Qiu edited comment on FLINK-9906 at 7/22/18 3:41 AM: -- >From the

[jira] [Commented] (FLINK-9906) Flink Job not running with no resource

2018-07-21 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551887#comment-16551887 ] Congxian Qiu commented on FLINK-9906: - >From the given log, it seems your application can't gotten

[jira] [Assigned] (FLINK-8995) Add a test operator with keyed state that uses custom, stateful serializer

2018-07-14 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-8995: --- Assignee: Congxian Qiu > Add a test operator with keyed state that uses custom, stateful

[jira] [Commented] (FLINK-9847) OneInputStreamTaskTest.testWatermarksNotForwardedWithinChainWhenIdle unstable

2018-07-16 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16545119#comment-16545119 ] Congxian Qiu commented on FLINK-9847: - Hi, [~till.rohrmann] thank you for your reply.  After I debug

[jira] [Commented] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

2018-07-14 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16544221#comment-16544221 ] Congxian Qiu commented on FLINK-9764: - I ran the test in my laptop more than 1,000 times, but didn't

[jira] [Assigned] (FLINK-8995) Add a test operator with keyed state that uses custom, stateful serializer

2018-07-14 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-8995: --- Assignee: (was: Congxian Qiu) > Add a test operator with keyed state that uses custom,

[jira] [Commented] (FLINK-7344) Migrate usage of joda-time to the Java 8 DateTime API

2018-07-05 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533442#comment-16533442 ] Congxian Qiu commented on FLINK-7344: - Hi, [~yew1eb], are you still working on this, If you don't

[jira] [Created] (FLINK-9807) Improve EventTimeWindowCheckpointITCase with parameterized

2018-07-11 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-9807: --- Summary: Improve EventTimeWindowCheckpointITCase with parameterized Key: FLINK-9807 URL: https://issues.apache.org/jira/browse/FLINK-9807 Project: Flink

[jira] [Commented] (FLINK-5860) Replace all the file creating from java.io.tmpdir with TemporaryFolder

2018-07-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16534785#comment-16534785 ] Congxian Qiu commented on FLINK-5860: - Hi,  [~maheshsenni], are you still working on this. If you

[jira] [Commented] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky

2018-07-07 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535993#comment-16535993 ] Congxian Qiu commented on FLINK-5125: - I run into the same problem also while run the test in my

[jira] [Assigned] (FLINK-8994) Add a test operator with keyed state that uses Avro serializer (from schema/by reflection)

2018-07-13 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-8994: --- Assignee: Congxian Qiu > Add a test operator with keyed state that uses Avro serializer

[jira] [Commented] (FLINK-7391) Normalize release entries

2018-04-26 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16454008#comment-16454008 ] Congxian Qiu commented on FLINK-7391: - Hi, [~Zentol], Could you tell me where does the source code of

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

2018-10-13 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16649234#comment-16649234 ] Congxian Qiu commented on FLINK-2491: - Hi all, what's the status of the issue, is it still needed?

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-05 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10794: - Description: In `StreamTask#invoke` will create CheckpointStore by

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-05 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10794: - Description: In `StreamTask#invoke` will create CheckpointStore by

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-05 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10794: - Description: In `StreamTask#invoke` will create CheckpointStore by

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-05 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10794: - Description: In `StreamTask#invoke` will create CheckpointStore by

[jira] [Created] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-05 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-10794: Summary: Do not create checkpointStorage when checkpoint is disabled Key: FLINK-10794 URL: https://issues.apache.org/jira/browse/FLINK-10794 Project: Flink

[jira] [Assigned] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-05 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-10794: Assignee: Congxian Qiu > Do not create checkpointStorage when checkpoint is disabled >

[jira] [Comment Edited] (FLINK-10346) MemoryStateBackend does not clean up checkpoint directory

2018-11-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679274#comment-16679274 ] Congxian Qiu edited comment on FLINK-10346 at 11/8/18 3:46 AM: --- It sounds

[jira] [Commented] (FLINK-10346) MemoryStateBackend does not clean up checkpoint directory

2018-11-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679274#comment-16679274 ] Congxian Qiu commented on FLINK-10346: -- It sounds good that if these subdirectories in HA directory

[jira] [Commented] (FLINK-9702) Improvement in (de)serialization of keys and values for RocksDB state

2018-11-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16679657#comment-16679657 ] Congxian Qiu commented on FLINK-9702: - Hi, [~srichter], is this issue still needed, if yes, I'll

[jira] [Assigned] (FLINK-9702) Improvement in (de)serialization of keys and values for RocksDB state

2018-11-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-9702: --- Assignee: Congxian Qiu > Improvement in (de)serialization of keys and values for RocksDB

[jira] [Commented] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-11 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683298#comment-16683298 ] Congxian Qiu commented on FLINK-10794: -- hi, [~till.rohrmann], how do you think about this? > Do

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-11 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10794: - Description: In `StreamTask#invoke` will create CheckpointStore by

[jira] [Assigned] (FLINK-10461) Speed up download file procedure when restore

2018-09-28 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-10461: Assignee: Congxian Qiu > Speed up download file procedure when restore >

[jira] [Created] (FLINK-10461) Speed up download file procedure when restore

2018-09-28 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-10461: Summary: Speed up download file procedure when restore Key: FLINK-10461 URL: https://issues.apache.org/jira/browse/FLINK-10461 Project: Flink Issue Type:

[jira] [Created] (FLINK-11254) Unify serialization format of savepoint for switching state backends

2019-01-02 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11254: Summary: Unify serialization format of savepoint for switching state backends Key: FLINK-11254 URL: https://issues.apache.org/jira/browse/FLINK-11254 Project: Flink

[jira] [Commented] (FLINK-11254) Unify serialization format of savepoint for switching state backends

2019-01-03 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732839#comment-16732839 ] Congxian Qiu commented on FLINK-11254: -- Thanks for the quick response [~till.rohrmann]. We had some

[jira] [Commented] (FLINK-11254) Unify serialization format of savepoint for switching state backends

2019-01-03 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732948#comment-16732948 ] Congxian Qiu commented on FLINK-11254: -- Thanks for your quick response [~tzulitai], I'll first

[jira] [Assigned] (FLINK-11361) Check and port RecoveryITCase to new code base if necessary

2019-01-16 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11361: Assignee: Congxian Qiu > Check and port RecoveryITCase to new code base if necessary >

[jira] [Assigned] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

2019-01-16 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11352: Assignee: Congxian Qiu > Check and port JobManagerHACheckpointRecoveryITCase to new code

[jira] [Commented] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

2019-01-18 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746210#comment-16746210 ] Congxian Qiu commented on FLINK-11352: -- I'm looking into it, will update soon. [~till.rohrmann]  >

[jira] [Commented] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

2019-01-17 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16745699#comment-16745699 ] Congxian Qiu commented on FLINK-11352: -- #testCheckpointedStreamingProgramIncrementalRocksDB is

[jira] [Comment Edited] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

2019-01-23 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749776#comment-16749776 ] Congxian Qiu edited comment on FLINK-11352 at 1/23/19 10:26 AM: Hi,

[jira] [Comment Edited] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

2019-01-23 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749776#comment-16749776 ] Congxian Qiu edited comment on FLINK-11352 at 1/23/19 10:25 AM: Hi,

[jira] [Commented] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

2019-01-23 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749776#comment-16749776 ] Congxian Qiu commented on FLINK-11352: -- Hi, [~till.rohrmann]  I did not find any existing test case

[jira] [Assigned] (FLINK-11167) Optimize RocksDBList#put for no empty input

2018-12-14 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11167: Assignee: Congxian Qiu > Optimize RocksDBList#put for no empty input >

[jira] [Created] (FLINK-11167) Optimize RocksDBList#put for no empty input

2018-12-14 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11167: Summary: Optimize RocksDBList#put for no empty input Key: FLINK-11167 URL: https://issues.apache.org/jira/browse/FLINK-11167 Project: Flink Issue Type:

[jira] [Updated] (FLINK-11008) Speed up upload checkpoint files using multi-thread

2018-12-23 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-11008: - Issue Type: New Feature (was: Improvement) > Speed up upload checkpoint files using

[jira] [Updated] (FLINK-11167) Optimize RocksDBList#put for no empty input

2018-12-14 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-11167: - Component/s: State Backends, Checkpointing > Optimize RocksDBList#put for no empty input >

[jira] [Updated] (FLINK-11008) Speed up upload checkpoint files using multi-thread

2018-11-26 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-11008: - Component/s: State Backends, Checkpointing > Speed up upload checkpoint files using

[jira] [Created] (FLINK-11008) Speed up upload checkpoint files using multi-thread

2018-11-26 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11008: Summary: Speed up upload checkpoint files using multi-thread Key: FLINK-11008 URL: https://issues.apache.org/jira/browse/FLINK-11008 Project: Flink Issue

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

2019-01-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11141: Assignee: Congxian Qiu > Key generation for RocksDBMapState can theoretically be

[jira] [Comment Edited] (FLINK-11531) Translate the Home Page of flink docs into Chinese

2019-02-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761642#comment-16761642 ] Congxian Qiu edited comment on FLINK-11531 at 2/6/19 10:33 AM: --- After 

[jira] [Commented] (FLINK-11531) Translate the Home Page of flink docs into Chinese

2019-02-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761642#comment-16761642 ] Congxian Qiu commented on FLINK-11531: -- After 

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

2019-02-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761678#comment-16761678 ] Congxian Qiu edited comment on FLINK-11428 at 2/6/19 11:39 AM: --- Hi,

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

2019-02-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761678#comment-16761678 ] Congxian Qiu edited comment on FLINK-11428 at 2/6/19 11:37 AM: --- Hi,

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

2019-02-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761678#comment-16761678 ] Congxian Qiu commented on FLINK-11428: -- After running a couple times of

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

2019-02-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761678#comment-16761678 ] Congxian Qiu edited comment on FLINK-11428 at 2/6/19 11:36 AM: --- Hi,

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

2019-02-06 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761678#comment-16761678 ] Congxian Qiu edited comment on FLINK-11428 at 2/6/19 11:38 AM: --- Hi,

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

2019-02-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763680#comment-16763680 ] Congxian Qiu commented on FLINK-11428: -- thank you for pointing this out. [~aljoscha]. I'll keep

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

2019-02-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763680#comment-16763680 ] Congxian Qiu edited comment on FLINK-11428 at 2/8/19 3:05 PM: -- thank you

[jira] [Commented] (FLINK-10819) The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail.

2019-02-14 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769016#comment-16769016 ] Congxian Qiu commented on FLINK-10819: -- Another instance: 

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

2019-02-15 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769076#comment-16769076 ] Congxian Qiu commented on FLINK-10481: -- Is the problem relevant to this issue? - Travis log link: 

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

2019-02-17 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11634: Assignee: Congxian Qiu (was: hanfei) > Translate "State Backends" page into Chinese >

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

2019-02-17 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770755#comment-16770755 ] Congxian Qiu commented on FLINK-11634: -- Hi, [~hanfeio] , Please reassign ticket to yourself before

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

2019-02-17 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11634: Assignee: Congxian Qiu (was: hanfei) > Translate "State Backends" page into Chinese >

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

2019-02-17 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770755#comment-16770755 ] Congxian Qiu edited comment on FLINK-11634 at 2/18/19 3:28 AM: --- Hi,

[jira] [Assigned] (FLINK-11588) Migrate CopyableValueSerializer to use new serialization compatibility abstractions

2019-02-12 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11588: Assignee: Congxian Qiu > Migrate CopyableValueSerializer to use new serialization

[jira] [Commented] (FLINK-11334) Migrate enum serializers to use new serialization compatibility abstractions

2019-02-13 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767771#comment-16767771 ] Congxian Qiu commented on FLINK-11334: -- Hi,  [~kisimple], What's the status of this issue, I have

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

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11633: Summary: Translate "Working with State" into Chinese Key: FLINK-11633 URL: https://issues.apache.org/jira/browse/FLINK-11633 Project: Flink Issue Type: New

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

2019-02-15 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-11633: - Issue Type: Sub-task (was: New Feature) Parent: FLINK-11529 > Translate "Working with

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

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11634: Summary: Translate "State Backends" page into Chinese Key: FLINK-11634 URL: https://issues.apache.org/jira/browse/FLINK-11634 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-11529) Support Chinese Documents for Apache Flink

2019-02-15 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11529: Assignee: Congxian Qiu (was: Jark Wu) > Support Chinese Documents for Apache Flink >

[jira] [Assigned] (FLINK-11529) Support Chinese Documents for Apache Flink

2019-02-15 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11529: Assignee: Jark Wu (was: Congxian Qiu) > Support Chinese Documents for Apache Flink >

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

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11635: Summary: Translate "Checkpointing" page into Chinese Key: FLINK-11635 URL: https://issues.apache.org/jira/browse/FLINK-11635 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-11567) Translate "How to Review a Pull Request" page into Chinese

2019-02-15 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11567: Assignee: xulinjie (was: Congxian Qiu) > Translate "How to Review a Pull Request" page

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

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11637: Summary: Translate "Checkpoints" page into Chinese Key: FLINK-11637 URL: https://issues.apache.org/jira/browse/FLINK-11637 Project: Flink Issue Type:

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

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11638: Summary: Translate "Savepoints" page into Chinese Key: FLINK-11638 URL: https://issues.apache.org/jira/browse/FLINK-11638 Project: Flink Issue Type:

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

2019-02-15 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11636: Summary: Translate "State Schema Evolution" into Chinese Key: FLINK-11636 URL: https://issues.apache.org/jira/browse/FLINK-11636 Project: Flink Issue Type:

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

2019-02-16 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11638: Assignee: Congxian Qiu (was: Xin Ma) > Translate "Savepoints" page into Chinese >

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

2019-02-16 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770053#comment-16770053 ] Congxian Qiu commented on FLINK-11634: -- Hi [~hanfeio] I'm working on this issue, maybe you could

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

2019-02-16 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770052#comment-16770052 ] Congxian Qiu commented on FLINK-11638: -- Hi [~iluvex] I'm working on this issue, maybe you could

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

2019-02-16 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11634: Assignee: Congxian Qiu (was: hanfei) > Translate "State Backends" page into Chinese >

[jira] [Commented] (FLINK-11662) job restart when CheckpointCoordinator drop checkpointDirectory as a whole

2019-02-19 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772545#comment-16772545 ] Congxian Qiu commented on FLINK-11662: -- Hi [~framst] , I think there are some other issues about

[jira] [Assigned] (FLINK-11567) Translate "How to Review a Pull Request" page into Chinese

2019-02-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11567: Assignee: Congxian Qiu > Translate "How to Review a Pull Request" page into Chinese >

[jira] [Assigned] (FLINK-11554) Translate the "Community & Project Info" page into Chinese

2019-02-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11554: Assignee: Congxian Qiu > Translate the "Community & Project Info" page into Chinese >

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

2019-02-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11561: Assignee: Congxian Qiu > Translate "Flink Architecture" page into Chinese >

[jira] [Assigned] (FLINK-11565) Translate "Improving the Website" page into Chinese

2019-02-08 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11565: Assignee: Congxian Qiu > Translate "Improving the Website" page into Chinese >

[jira] [Assigned] (FLINK-11361) Check and port RecoveryITCase to new code base if necessary

2019-01-28 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-11361: Assignee: (was: Congxian Qiu) > Check and port RecoveryITCase to new code base if

[jira] [Commented] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

2019-01-28 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754685#comment-16754685 ] Congxian Qiu commented on FLINK-11352: -- Hi [~till.rohrmann] Update for

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

2019-01-24 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-11428: Summary: BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis Key: FLINK-11428 URL: https://issues.apache.org/jira/browse/FLINK-11428 Project: Flink

  1   2   >