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:
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:
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:
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
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
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
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:
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
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:
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:
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
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
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
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
Biao Liu created FLINK-13848:
Summary: Support “scheduleAtFixedRate/scheduleAtFixedDelay” in
RpcEndpoint#MainThreadExecutor
Key: FLINK-13848
URL: https://issues.apache.org/jira/browse/FLINK-13848
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:
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:
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
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
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
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:
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
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
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
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
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
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:
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
Biao Liu created FLINK-11185:
Summary: StreamSourceOperatorWatermarksTest failed with
InterruptedException
Key: FLINK-11185
URL: https://issues.apache.org/jira/browse/FLINK-11185
Project: Flink
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:
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
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
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
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
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
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
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:
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:
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
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
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
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
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:
43 matches
Mail list logo