[jira] [Created] (FLINK-31124) Add it case for HiveTableSink speculative execution

2023-02-17 Thread Biao Liu (Jira)
Biao Liu created FLINK-31124: Summary: Add it case for HiveTableSink speculative execution Key: FLINK-31124 URL: https://issues.apache.org/jira/browse/FLINK-31124 Project: Flink Issue Type:

[jira] [Created] (FLINK-31123) Add it case for FileSink speculative execution

2023-02-17 Thread Biao Liu (Jira)
Biao Liu created FLINK-31123: Summary: Add it case for FileSink speculative execution Key: FLINK-31123 URL: https://issues.apache.org/jira/browse/FLINK-31123 Project: Flink Issue Type:

[jira] [Created] (FLINK-30842) Add document for sink supports speculative execution

2023-01-30 Thread Biao Liu (Jira)
Biao Liu created FLINK-30842: Summary: Add document for sink supports speculative execution Key: FLINK-30842 URL: https://issues.apache.org/jira/browse/FLINK-30842 Project: Flink Issue Type:

[jira] [Created] (FLINK-30823) Enable speculative execution for some of the typical built-in sinks

2023-01-30 Thread Biao Liu (Jira)
Biao Liu created FLINK-30823: Summary: Enable speculative execution for some of the typical built-in sinks Key: FLINK-30823 URL: https://issues.apache.org/jira/browse/FLINK-30823 Project: Flink

[jira] [Created] (FLINK-30799) Make SinkFunction support speculative execution for batch jobs

2023-01-26 Thread Biao Liu (Jira)
Biao Liu created FLINK-30799: Summary: Make SinkFunction support speculative execution for batch jobs Key: FLINK-30799 URL: https://issues.apache.org/jira/browse/FLINK-30799 Project: Flink

[jira] [Created] (FLINK-30798) Make OutputFormat support speculative execution for batch jobs

2023-01-26 Thread Biao Liu (Jira)
Biao Liu created FLINK-30798: Summary: Make OutputFormat support speculative execution for batch jobs Key: FLINK-30798 URL: https://issues.apache.org/jira/browse/FLINK-30798 Project: Flink

[jira] [Created] (FLINK-30755) Make SinkV2 support speculative execution for batch jobs

2023-01-19 Thread Biao Liu (Jira)
Biao Liu created FLINK-30755: Summary: Make SinkV2 support speculative execution for batch jobs Key: FLINK-30755 URL: https://issues.apache.org/jira/browse/FLINK-30755 Project: Flink Issue Type:

[jira] [Created] (FLINK-30725) FLIP-281: Sink Supports Speculative Execution For Batch Job

2023-01-17 Thread Biao Liu (Jira)
Biao Liu created FLINK-30725: Summary: FLIP-281: Sink Supports Speculative Execution For Batch Job Key: FLINK-30725 URL: https://issues.apache.org/jira/browse/FLINK-30725 Project: Flink Issue

[jira] [Created] (FLINK-16945) Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

2020-04-02 Thread Biao Liu (Jira)
Biao Liu created FLINK-16945: Summary: Execute CheckpointFailureManager.FailJobCallback directly in main thread executor Key: FLINK-16945 URL: https://issues.apache.org/jira/browse/FLINK-16945 Project:

[jira] [Created] (FLINK-16561) Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure

2020-03-11 Thread Biao Liu (Jira)
Biao Liu created FLINK-16561: Summary: Resuming Externalized Checkpoint (rocks, incremental, no parallelism change) end-to-end test fails on Azure Key: FLINK-16561 URL:

[jira] [Created] (FLINK-14971) Move ACK and declined message handling in the same thread with triggering

2019-11-27 Thread Biao Liu (Jira)
Biao Liu created FLINK-14971: Summary: Move ACK and declined message handling in the same thread with triggering Key: FLINK-14971 URL: https://issues.apache.org/jira/browse/FLINK-14971 Project: Flink

[jira] [Created] (FLINK-14344) Snapshot master hook state asynchronously

2019-10-08 Thread Biao Liu (Jira)
Biao Liu created FLINK-14344: Summary: Snapshot master hook state asynchronously Key: FLINK-14344 URL: https://issues.apache.org/jira/browse/FLINK-14344 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13905) Separate checkpoint triggering into stages

2019-08-30 Thread Biao Liu (Jira)
Biao Liu created FLINK-13905: Summary: Separate checkpoint triggering into stages Key: FLINK-13905 URL: https://issues.apache.org/jira/browse/FLINK-13905 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13904) Avoid competition between different rounds of checkpoint triggering

2019-08-30 Thread Biao Liu (Jira)
Biao Liu created FLINK-13904: Summary: Avoid competition between different rounds of checkpoint triggering Key: FLINK-13904 URL: https://issues.apache.org/jira/browse/FLINK-13904 Project: Flink

[jira] [Created] (FLINK-13848) Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor

2019-08-25 Thread Biao Liu (Jira)
Biao Liu created FLINK-13848: Summary: Support “scheduleAtFixedRate/scheduleAtFixedDelay” in RpcEndpoint#MainThreadExecutor Key: FLINK-13848 URL: https://issues.apache.org/jira/browse/FLINK-13848

[jira] [Created] (FLINK-13732) Enhance JobManagerMetricGroup with FLIP-6 architecture

2019-08-14 Thread Biao Liu (JIRA)
Biao Liu created FLINK-13732: Summary: Enhance JobManagerMetricGroup with FLIP-6 architecture Key: FLINK-13732 URL: https://issues.apache.org/jira/browse/FLINK-13732 Project: Flink Issue Type:

[jira] [Created] (FLINK-13635) Unexpectedly interrupted in AsyncFunction#timeout

2019-08-07 Thread Biao Liu (JIRA)
Biao Liu created FLINK-13635: Summary: Unexpectedly interrupted in AsyncFunction#timeout Key: FLINK-13635 URL: https://issues.apache.org/jira/browse/FLINK-13635 Project: Flink Issue Type:

[jira] [Created] (FLINK-13101) Introduce "blocking after chaining off" property of StreamGraph

2019-07-04 Thread Biao Liu (JIRA)
Biao Liu created FLINK-13101: Summary: Introduce "blocking after chaining off" property of StreamGraph Key: FLINK-13101 URL: https://issues.apache.org/jira/browse/FLINK-13101 Project: Flink

[jira] [Created] (FLINK-13099) Add a new type UNDEFINED of shuffle mode

2019-07-04 Thread Biao Liu (JIRA)
Biao Liu created FLINK-13099: Summary: Add a new type UNDEFINED of shuffle mode Key: FLINK-13099 URL: https://issues.apache.org/jira/browse/FLINK-13099 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13098) Add a new type UNDEFINED of shuffle mode

2019-07-04 Thread Biao Liu (JIRA)
Biao Liu created FLINK-13098: Summary: Add a new type UNDEFINED of shuffle mode Key: FLINK-13098 URL: https://issues.apache.org/jira/browse/FLINK-13098 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-13042) Make slot sharing configurable on ExecutionConfig

2019-07-01 Thread Biao Liu (JIRA)
Biao Liu created FLINK-13042: Summary: Make slot sharing configurable on ExecutionConfig Key: FLINK-13042 URL: https://issues.apache.org/jira/browse/FLINK-13042 Project: Flink Issue Type:

[jira] [Created] (FLINK-12974) Bump checkstyle version to 8.14

2019-06-25 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12974: Summary: Bump checkstyle version to 8.14 Key: FLINK-12974 URL: https://issues.apache.org/jira/browse/FLINK-12974 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12961) StreamExecutionEnvironment supports executing job with StreamGraph

2019-06-24 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12961: Summary: StreamExecutionEnvironment supports executing job with StreamGraph Key: FLINK-12961 URL: https://issues.apache.org/jira/browse/FLINK-12961 Project: Flink

[jira] [Created] (FLINK-12866) Connectors module failed on Travis checking

2019-06-16 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12866: Summary: Connectors module failed on Travis checking Key: FLINK-12866 URL: https://issues.apache.org/jira/browse/FLINK-12866 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-12823) PartitionTransformation supports DataExchangeMode property

2019-06-12 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12823: Summary: PartitionTransformation supports DataExchangeMode property Key: FLINK-12823 URL: https://issues.apache.org/jira/browse/FLINK-12823 Project: Flink Issue

[jira] [Created] (FLINK-12686) StreamGraph Supports Blink Batch Mode

2019-05-30 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12686: Summary: StreamGraph Supports Blink Batch Mode Key: FLINK-12686 URL: https://issues.apache.org/jira/browse/FLINK-12686 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12332) Cancel running tasks if exist before shutting down TM

2019-04-25 Thread Biao Liu (JIRA)
Biao Liu created FLINK-12332: Summary: Cancel running tasks if exist before shutting down TM Key: FLINK-12332 URL: https://issues.apache.org/jira/browse/FLINK-12332 Project: Flink Issue Type:

[jira] [Created] (FLINK-11312) The link to Zookeeper is broken in "jobmanager_high_availability" document

2019-01-13 Thread Biao Liu (JIRA)
Biao Liu created FLINK-11312: Summary: The link to Zookeeper is broken in "jobmanager_high_availability" document Key: FLINK-11312 URL: https://issues.apache.org/jira/browse/FLINK-11312 Project: Flink

[jira] [Created] (FLINK-11185) StreamSourceOperatorWatermarksTest failed with InterruptedException

2018-12-17 Thread Biao Liu (JIRA)
Biao Liu created FLINK-11185: Summary: StreamSourceOperatorWatermarksTest failed with InterruptedException Key: FLINK-11185 URL: https://issues.apache.org/jira/browse/FLINK-11185 Project: Flink

[jira] [Created] (FLINK-11137) Unexpected RegistrationTimeoutException of TaskExecutor

2018-12-11 Thread Biao Liu (JIRA)
Biao Liu created FLINK-11137: Summary: Unexpected RegistrationTimeoutException of TaskExecutor Key: FLINK-11137 URL: https://issues.apache.org/jira/browse/FLINK-11137 Project: Flink Issue Type:

[jira] [Created] (FLINK-9315) TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated

2018-05-07 Thread Biao Liu (JIRA)
Biao Liu created FLINK-9315: --- Summary: TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated Key: FLINK-9315 URL: https://issues.apache.org/jira/browse/FLINK-9315 Project: Flink

[jira] [Created] (FLINK-8369) Port SubtaskExecutionAttemptAccumulatorsHandler to new REST endpoint

2018-01-05 Thread Biao Liu (JIRA)
Biao Liu created FLINK-8369: --- Summary: Port SubtaskExecutionAttemptAccumulatorsHandler to new REST endpoint Key: FLINK-8369 URL: https://issues.apache.org/jira/browse/FLINK-8369 Project: Flink

[jira] [Created] (FLINK-8368) Port SubtaskExecutionAttemptDetailsHandler to new REST endpoint

2018-01-05 Thread Biao Liu (JIRA)
Biao Liu created FLINK-8368: --- Summary: Port SubtaskExecutionAttemptDetailsHandler to new REST endpoint Key: FLINK-8368 URL: https://issues.apache.org/jira/browse/FLINK-8368 Project: Flink Issue

[jira] [Created] (FLINK-8367) Port SubtaskCurrentAttemptDetailsHandler to new REST endpoint

2018-01-05 Thread Biao Liu (JIRA)
Biao Liu created FLINK-8367: --- Summary: Port SubtaskCurrentAttemptDetailsHandler to new REST endpoint Key: FLINK-8367 URL: https://issues.apache.org/jira/browse/FLINK-8367 Project: Flink Issue

[jira] [Created] (FLINK-5980) Expose max-parallelism value in RuntimeContext

2017-03-07 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5980: --- Summary: Expose max-parallelism value in RuntimeContext Key: FLINK-5980 URL: https://issues.apache.org/jira/browse/FLINK-5980 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5879) ExecutionAttemptID should invoke super() in constructor

2017-02-22 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5879: --- Summary: ExecutionAttemptID should invoke super() in constructor Key: FLINK-5879 URL: https://issues.apache.org/jira/browse/FLINK-5879 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5862) When JobManager fails, TaskManagers do not cancel tasks, but attempt to reconnect to the JobManager, and report states of tasks deployed in

2017-02-21 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5862: --- Summary: When JobManager fails, TaskManagers do not cancel tasks, but attempt to reconnect to the JobManager, and report states of tasks deployed in Key: FLINK-5862 URL:

[jira] [Created] (FLINK-5861) TaskManager's components support updating JobManagerGateway

2017-02-20 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5861: --- Summary: TaskManager's components support updating JobManagerGateway Key: FLINK-5861 URL: https://issues.apache.org/jira/browse/FLINK-5861 Project: Flink Issue Type:

[jira] [Created] (FLINK-5784) TaskExecutor may register JobManagerLeaderListener in LeaderRetrievalService multiple times

2017-02-13 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5784: --- Summary: TaskExecutor may register JobManagerLeaderListener in LeaderRetrievalService multiple times Key: FLINK-5784 URL: https://issues.apache.org/jira/browse/FLINK-5784

[jira] [Created] (FLINK-5141) Implement MiniClusterStreamEnvironment to run new mini cluster in flip-6 branch

2016-11-23 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5141: --- Summary: Implement MiniClusterStreamEnvironment to run new mini cluster in flip-6 branch Key: FLINK-5141 URL: https://issues.apache.org/jira/browse/FLINK-5141 Project: Flink

[jira] [Created] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job

2016-11-22 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5140: --- Summary: NoResourceAvailableException is thrown while starting a new job Key: FLINK-5140 URL: https://issues.apache.org/jira/browse/FLINK-5140 Project: Flink Issue

[jira] [Created] (FLINK-5093) java.util.ConcurrentModificationException is thrown when stopping TimerService

2016-11-18 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5093: --- Summary: java.util.ConcurrentModificationException is thrown when stopping TimerService Key: FLINK-5093 URL: https://issues.apache.org/jira/browse/FLINK-5093 Project: Flink

[jira] [Created] (FLINK-5076) Shutting down TM when shutting down new mini cluster

2016-11-15 Thread Biao Liu (JIRA)
Biao Liu created FLINK-5076: --- Summary: Shutting down TM when shutting down new mini cluster Key: FLINK-5076 URL: https://issues.apache.org/jira/browse/FLINK-5076 Project: Flink Issue Type: