JIN SUN created FLINK-10205:
---
Summary: Batch Job: InputSplit Fault tolerant for DataSourceTask
Key: FLINK-10205
URL: https://issues.apache.org/jira/browse/FLINK-10205
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591066#comment-16591066
]
JIN SUN commented on FLINK-10205:
-
I would like to work on this issue
> Batch Job: InputSplit Fault
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16593082#comment-16593082
]
JIN SUN commented on FLINK-10205:
-
Great Stephan, i actually has the same idea, for the batch failover,
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591472#comment-16591472
]
JIN SUN commented on FLINK-10205:
-
Thanks Vinoyang,
I cannot assign the bug to myself, I've send a
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591489#comment-16591489
]
JIN SUN commented on FLINK-10205:
-
In my opinion we need deterministic, especially when a task rerun,
JIN SUN created FLINK-10288:
---
Summary: Failover Strategy improvement
Key: FLINK-10288
URL: https://issues.apache.org/jira/browse/FLINK-10288
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10289:
Description:
We need to classify exceptions and treat them with different strategies. To do
this, we
JIN SUN created FLINK-10298:
---
Summary: Batch Job Failover Strategy
Key: FLINK-10298
URL: https://issues.apache.org/jira/browse/FLINK-10298
Project: Flink
Issue Type: Sub-task
Components:
[
https://issues.apache.org/jira/browse/FLINK-10298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10298:
Description:
The new failover strategy needs to consider handling failures according to
different
JIN SUN created FLINK-10289:
---
Summary: Classify Exceptions to different category for apply
different failover strategy
Key: FLINK-10289
URL: https://issues.apache.org/jira/browse/FLINK-10289
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN closed FLINK-10494.
---
Resolution: Won't Fix
closed as suggestion
> Rename 'JobManager' to 'JobMaster' for some classes in
[
https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647372#comment-16647372
]
JIN SUN commented on FLINK-10534:
-
session can have the semantic of expire time. we probably can add a
JIN SUN created FLINK-10573:
---
Summary: Support task revocation
Key: FLINK-10573
URL: https://issues.apache.org/jira/browse/FLINK-10573
Project: Flink
Issue Type: Sub-task
Components:
[
https://issues.apache.org/jira/browse/FLINK-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16652542#comment-16652542
]
JIN SUN commented on FLINK-10575:
-
[~till.rohrmann] does this sound reasonable?
> Remove deprecated
JIN SUN created FLINK-10575:
---
Summary: Remove deprecated ExecutionGraphBuilder.buildGraph method
Key: FLINK-10575
URL: https://issues.apache.org/jira/browse/FLINK-10575
Project: Flink
Issue Type:
JIN SUN created FLINK-10572:
---
Summary: Enable Per-job level failover strategy.
Key: FLINK-10572
URL: https://issues.apache.org/jira/browse/FLINK-10572
Project: Flink
Issue Type: Sub-task
JIN SUN created FLINK-10576:
---
Summary: Introduce Machine/Node/TM health management
Key: FLINK-10576
URL: https://issues.apache.org/jira/browse/FLINK-10576
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN reassigned FLINK-10574:
---
Assignee: JIN SUN
> Update documents of new batch job failover strategy
>
JIN SUN created FLINK-10574:
---
Summary: Update documents of new batch job failover strategy
Key: FLINK-10574
URL: https://issues.apache.org/jira/browse/FLINK-10574
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16659782#comment-16659782
]
JIN SUN commented on FLINK-10573:
-
Thanks Zhijiang, i would like use this exception, i see the Jira is
JIN SUN created FLINK-10643:
---
Summary: Bubble execution: Resource aware job execution
Key: FLINK-10643
URL: https://issues.apache.org/jira/browse/FLINK-10643
Project: Flink
Issue Type: New Feature
JIN SUN created FLINK-10644:
---
Summary: Batch Job: Speculative execution
Key: FLINK-10644
URL: https://issues.apache.org/jira/browse/FLINK-10644
Project: Flink
Issue Type: New Feature
JIN SUN created FLINK-10656:
---
Summary: Refactor
org.apache.flink.runtime.io.network.api.reader.ReaderBase
Key: FLINK-10656
URL: https://issues.apache.org/jira/browse/FLINK-10656
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-9953:
---
Description:
This is the umbrella issue tracking Flink's active Kubernetes integration.
Active means in
JIN SUN created FLINK-10657:
---
Summary: TPCHQuery3 fail with IllegalAccessException
Key: FLINK-10657
URL: https://issues.apache.org/jira/browse/FLINK-10657
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10657:
Issue Type: Bug (was: Improvement)
> TPCHQuery3 fail with IllegalAccessException
>
[
https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10644:
Description:
Strugglers/outlier are tasks that run slower than most of the all tasks in a
Batch Job,
[
https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10644:
Description:
Strugglers/outlier are tasks that run slower than most of the all tasks in a
Batch Job,
[
https://issues.apache.org/jira/browse/FLINK-10392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638539#comment-16638539
]
JIN SUN commented on FLINK-10392:
-
+1, can we also do the refactor by move the code to a folder "legacy"
[
https://issues.apache.org/jira/browse/FLINK-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10494:
Summary: Rename 'JobManager' to 'JobMaster' for some classes in JobMaster
folder (was: Rename
[
https://issues.apache.org/jira/browse/FLINK-10392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16638905#comment-16638905
]
JIN SUN commented on FLINK-10392:
-
Sounds good, i will try my best. :)
> Remove legacy mode
>
JIN SUN created FLINK-10494:
---
Summary: Rename 'JobManager' to J'obMaster' for some classes in
JobMaster folder
Key: FLINK-10494
URL: https://issues.apache.org/jira/browse/FLINK-10494
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16642635#comment-16642635
]
JIN SUN commented on FLINK-10498:
-
this seems related to
[
https://issues.apache.org/jira/browse/FLINK-10404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16642640#comment-16642640
]
JIN SUN commented on FLINK-10404:
-
Glad to see the design document, will take a look and comment.
>
[
https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643757#comment-16643757
]
JIN SUN commented on FLINK-9953:
Thanks Till.
> Active Kubernetes integration
>
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10205:
Fix Version/s: 1.7.0
> Batch Job: InputSplit Fault tolerant for DataSourceTask
>
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10205:
Affects Version/s: 1.7.0
> Batch Job: InputSplit Fault tolerant for DataSourceTask
>
[
https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16636387#comment-16636387
]
JIN SUN commented on FLINK-10481:
-
seems like a intermittent issue, might be docker repository issue,
[
https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN reassigned FLINK-9953:
--
Assignee: JIN SUN
> Active Kubernetes integration
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10205:
Description:
Today DataSource Task pull InputSplits from JobManager to achieve better
performance,
[
https://issues.apache.org/jira/browse/FLINK-9955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632652#comment-16632652
]
JIN SUN commented on FLINK-9955:
[~till.rohrmann], is there anyone working on this? i would like to
[
https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632653#comment-16632653
]
JIN SUN commented on FLINK-9953:
[~till.rohrmann], is there anyone working on this? i would like to
[
https://issues.apache.org/jira/browse/FLINK-10298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16624217#comment-16624217
]
JIN SUN commented on FLINK-10298:
-
Hi Tison,
Thanks for point this. Yes, i know there is a
[
https://issues.apache.org/jira/browse/FLINK-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10289:
Fix Version/s: 1.7.0
> Classify Exceptions to different category for apply different failover
> strategy
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10205:
Affects Version/s: 1.6.2
1.6.1
> Batch Job: InputSplit Fault tolerant for
[
https://issues.apache.org/jira/browse/FLINK-10288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10288:
Fix Version/s: 1.7.0
> Failover Strategy improvement
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN updated FLINK-10298:
Fix Version/s: 1.7.0
> Batch Job Failover Strategy
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-10429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629571#comment-16629571
]
JIN SUN commented on FLINK-10429:
-
+1
I like the proposal, have put some comments in the document.
[
https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622387#comment-16622387
]
JIN SUN commented on FLINK-10205:
-
Hi Stephan,
I have the FLIP, and the pull request ready for this
JIN SUN created FLINK-10968:
---
Summary: Implement TaskManager Entrypoint
Key: FLINK-10968
URL: https://issues.apache.org/jira/browse/FLINK-10968
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN reassigned FLINK-10934:
---
Assignee: JIN SUN
> Implement KubernetesJobClusterEntrypoint
>
JIN SUN created FLINK-10938:
---
Summary: Enable Flink on native k8s E2E Tests in Travis CI
Key: FLINK-10938
URL: https://issues.apache.org/jira/browse/FLINK-10938
Project: Flink
Issue Type:
JIN SUN created FLINK-10939:
---
Summary: Add documents for Flink on native k8s
Key: FLINK-10939
URL: https://issues.apache.org/jira/browse/FLINK-10939
Project: Flink
Issue Type: Sub-task
JIN SUN created FLINK-10934:
---
Summary: Implement KubernetesJobClusterEntrypoint
Key: FLINK-10934
URL: https://issues.apache.org/jira/browse/FLINK-10934
Project: Flink
Issue Type: Sub-task
JIN SUN created FLINK-10933:
---
Summary: Implement KubernetesSessionClusterEntrypoint
Key: FLINK-10933
URL: https://issues.apache.org/jira/browse/FLINK-10933
Project: Flink
Issue Type: Sub-task
JIN SUN created FLINK-10937:
---
Summary: Add scripts to create docker image for k8s
Key: FLINK-10937
URL: https://issues.apache.org/jira/browse/FLINK-10937
Project: Flink
Issue Type: Sub-task
JIN SUN created FLINK-10935:
---
Summary: Implement KubeClient with Faric8 Kubernetes clients
Key: FLINK-10935
URL: https://issues.apache.org/jira/browse/FLINK-10935
Project: Flink
Issue Type:
JIN SUN created FLINK-10936:
---
Summary: Implement Command line tools
Key: FLINK-10936
URL: https://issues.apache.org/jira/browse/FLINK-10936
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN reassigned FLINK-10935:
---
Assignee: JIN SUN
> Implement KubeClient with Faric8 Kubernetes clients
>
[
https://issues.apache.org/jira/browse/FLINK-10968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700812#comment-16700812
]
JIN SUN commented on FLINK-10968:
-
Yes, it will extend from TaskManagerRunner and handle
[
https://issues.apache.org/jira/browse/FLINK-9955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN reassigned FLINK-9955:
--
Assignee: JIN SUN
> Kubernetes ClusterDescriptor
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-9495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JIN SUN reassigned FLINK-9495:
--
Assignee: JIN SUN
> Implement ResourceManager for Kubernetes
>
JIN SUN created FLINK-10932:
---
Summary: Initial flink-kubernetes module with empty implementation
Key: FLINK-10932
URL: https://issues.apache.org/jira/browse/FLINK-10932
Project: Flink
Issue Type:
63 matches
Mail list logo
