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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

2020-01-19 Thread Congxian Qiu(klion26) (Jira)
Congxian Qiu(klion26) created FLINK-15661: - Summary: JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed because of Could not find Flink job Key: FLINK-15661 URL: https://issues.

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

2020-01-16 Thread Congxian Qiu(klion26) (Jira)
Congxian Qiu(klion26) created FLINK-15619: - Summary: GroupWindowTableAggregateITCase.testAllProcessingTimeTumblingGroupWindowOverCount failed on Azure Key: FLINK-15619 URL: https://issues.apache.org/jira

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

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

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

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

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

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

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

2019-12-09 Thread Congxian Qiu(klion26) (Jira)
Congxian Qiu(klion26) created FLINK-15150: - Summary: ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on Travis Key: FLINK-15150 URL: https://issues.apache.org/jira/browse/FL

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

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

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

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

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

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

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

2019-10-17 Thread Congxian Qiu(klion26) (Jira)
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] [Created] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

2019-10-07 Thread Congxian Qiu(klion26) (Jira)
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] [Created] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI

2019-09-27 Thread Congxian Qiu(klion26) (Jira)
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] [Created] (FLINK-14035) Introduce/Change some log for snapshot to better analysis checkpoint problem

2019-09-09 Thread Congxian Qiu(klion26) (Jira)
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] [Created] (FLINK-13861) No new checkpoint trigged when canceling an expired checkpoint failed

2019-08-26 Thread Congxian Qiu(klion26) (Jira)
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] [Created] (FLINK-13164) Add a putAndGet benchmark for StateBenchmark

2019-07-09 Thread Congxian Qiu(klion26) (JIRA)
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] [Created] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

2019-07-08 Thread Congxian Qiu(klion26) (JIRA)
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] [Created] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots

2019-06-26 Thread Congxian Qiu(klion26) (JIRA)
Congxian Qiu(klion26) created FLINK-13009: - Summary: YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots Key:

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

2019-06-26 Thread Congxian Qiu(klion26) (JIRA)
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] [Created] (FLINK-12880) Support triggering checkpoint automatically when cancel a job

2019-06-18 Thread Congxian Qiu(klion26) (JIRA)
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] [Created] (FLINK-12733) Expose Rest API for TERMINATE/SUSPEND Job with Checkpoint

2019-06-04 Thread Congxian Qiu(klion26) (JIRA)
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

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

2019-05-24 Thread Congxian Qiu(klion26) (JIRA)
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] [Created] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator chained in a single task

2019-04-22 Thread Congxian Qiu(klion26) (JIRA)
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: https://issues.apache.org/jira/bro

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

2019-04-20 Thread Congxian Qiu(klion26) (JIRA)
Congxian Qiu(klion26) created FLINK-12281: - Summary: SortDistinctAggregateITCase>DistinctAggregateITCaseBase.testSomeColumnsBothInDistinctAggAndGroupBy Failed Key: FLINK-12281 URL: https://issues.apache.o

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

2019-03-16 Thread Congxian Qiu(klion26) (JIRA)
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

2019-03-16 Thread Congxian Qiu(klion26) (JIRA)
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 Iss

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

2019-03-16 Thread Congxian Qiu(klion26) (JIRA)
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 Iss

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

2019-03-16 Thread Congxian Qiu(klion26) (JIRA)
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 Type

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

2019-03-16 Thread Congxian Qiu(klion26) (JIRA)
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 Projec

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

2019-03-13 Thread Congxian Qiu(klion26) (JIRA)
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 Proje

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

2019-03-13 Thread Congxian Qiu(klion26) (JIRA)
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 Project

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

2019-03-07 Thread Congxian Qiu(klion26) (JIRA)
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] [Created] (FLINK-11797) Implementation empty unit tests in CheckpointCoordinatorMasterHooksTest

2019-03-02 Thread Congxian Qiu(klion26) (JIRA)
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] [Created] (FLINK-11704) Improve AbstractCheckpointStateOutputStreamTestBase with Parameterized

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