[jira] [Issue Comment Deleted] (FLINK-4233) Simplify leader election / leader session ID assignment

[ https://issues.apache.org/jira/browse/FLINK-4233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-4233: Comment: was deleted (was: Further, if it is assumed that there are never too many contenders, in

[jira] [Commented] (FLINK-4233) Simplify leader election / leader session ID assignment

[ https://issues.apache.org/jira/browse/FLINK-4233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933899#comment-16933899 ] TisonKun commented on FLINK-4233: - Further, if it is assumed that there are never too many contenders, in

[jira] [Commented] (FLINK-4233) Simplify leader election / leader session ID assignment

[ https://issues.apache.org/jira/browse/FLINK-4233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933879#comment-16933879 ] TisonKun commented on FLINK-4233: - Thanks for picking up this topic! I'm thinking of something similar to

[jira] [Assigned] (FLINK-14096) Merge NewClusterClient into ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14096: Assignee: TisonKun > Merge NewClusterClient into ClusterClient >

[jira] [Assigned] (FLINK-14113) Remove class JobWithJars

[ https://issues.apache.org/jira/browse/FLINK-14113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14113: Assignee: TisonKun > Remove class JobWithJars > > >

[jira] [Commented] (FLINK-14130) Remove ClusterClient.run() methods

[ https://issues.apache.org/jira/browse/FLINK-14130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933494#comment-16933494 ] TisonKun commented on FLINK-14130: -- Great to have! I ever thought it is not easily to achieve but if

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933184#comment-16933184 ] TisonKun commented on FLINK-14112: -- Thanks for your insights [~trohrmann]. Sounds reasonable to me.

[jira] [Updated] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-14010: - Affects Version/s: (was: 1.8.1) 1.8.2 > Dispatcher & JobManagers don't give

[jira] [Assigned] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14010: Assignee: TisonKun > Dispatcher & JobManagers don't give up leadership when AM is shut down >

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933140#comment-16933140 ] TisonKun commented on FLINK-14010: -- Will send a pull request in hours :-) > Dispatcher & JobManagers

[jira] [Assigned] (FLINK-14093) Java8 lambdas and exceptions lead to compile error

[ https://issues.apache.org/jira/browse/FLINK-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14093: Assignee: zzsmdfj > Java8 lambdas and exceptions lead to compile error >

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933131#comment-16933131 ] TisonKun commented on FLINK-14112: -- [~trohrmann] is its function duplicated by heartbeat mechanism? If

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933030#comment-16933030 ] TisonKun commented on FLINK-14010: -- [~trohrmann] Technically I agree that it is a valid solution. Give

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933022#comment-16933022 ] TisonKun commented on FLINK-14112: -- I agree with [~trohrmann]'s comments. Another question I notice is

[jira] [Commented] (FLINK-14109) Improve javadocs and tests for high-availability backend

[ https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932959#comment-16932959 ] TisonKun commented on FLINK-14109: -- [~bremac] aha, nice to hear :-) > Improve javadocs and tests for

[jira] [Commented] (FLINK-14113) Remove class JobWithJars

[ https://issues.apache.org/jira/browse/FLINK-14113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932491#comment-16932491 ] TisonKun commented on FLINK-14113: -- Thanks for your insights! I will create a pull request tomorrow. >

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932423#comment-16932423 ] TisonKun commented on FLINK-14010: -- I have thought of this. The problem is that when the situation

[jira] [Comment Edited] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932423#comment-16932423 ] TisonKun edited comment on FLINK-14010 at 9/18/19 1:06 PM: --- I have thought of

[jira] [Commented] (FLINK-14114) Shift down ClusterClient#timeout to RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932275#comment-16932275 ] TisonKun commented on FLINK-14114: -- I've assigned the issue to you [~zhuzh] :-) > Shift down

[jira] [Assigned] (FLINK-14114) Shift down ClusterClient#timeout to RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14114: Assignee: Zhu Zhu > Shift down ClusterClient#timeout to RestClusterClient >

[jira] [Commented] (FLINK-14114) Shift down ClusterClient#timeout to RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932256#comment-16932256 ] TisonKun commented on FLINK-14114: -- Hi [~zhuzh] if you'd like to work on this coordinate with

[jira] [Created] (FLINK-14114) Shift down ClusterClient#timeout to RestClusterClient

TisonKun created FLINK-14114: Summary: Shift down ClusterClient#timeout to RestClusterClient Key: FLINK-14114 URL: https://issues.apache.org/jira/browse/FLINK-14114 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14070) Use TimeUtils to parse duration configs

[ https://issues.apache.org/jira/browse/FLINK-14070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932133#comment-16932133 ] TisonKun commented on FLINK-14070: -- Hi [~zhuzh] did you start working on this thread? I'd like to

[jira] [Commented] (FLINK-14093) Java8 lambdas and exceptions lead to compile error

[ https://issues.apache.org/jira/browse/FLINK-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932061#comment-16932061 ] TisonKun commented on FLINK-14093: -- [~zhaoshijie] We cannot just introduce the workaround without any

[jira] [Commented] (FLINK-14111) Flink should be robust to a non-leader Zookeeper host going down

[ https://issues.apache.org/jira/browse/FLINK-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932059#comment-16932059 ] TisonKun commented on FLINK-14111: -- Yes I think it is a duplication of FLINK-10052. Could you check it

[jira] [Comment Edited] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932058#comment-16932058 ] TisonKun edited comment on FLINK-14112 at 9/18/19 4:56 AM: --- Hi [~aaronlevin]

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932058#comment-16932058 ] TisonKun commented on FLINK-14112: -- Hi [~aaronlevin] thanks for creating this JIRA. Generally I think

[jira] [Commented] (FLINK-14109) Improve javadocs and tests for high-availability backend

[ https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932053#comment-16932053 ] TisonKun commented on FLINK-14109: -- Hi [~bremac] thanks for reporting this! There are two topics under

[jira] [Commented] (FLINK-14096) Merge NewClusterClient into ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931962#comment-16931962 ] TisonKun commented on FLINK-14096: -- FYI

[jira] [Created] (FLINK-14113) Remove class JobWithJars

TisonKun created FLINK-14113: Summary: Remove class JobWithJars Key: FLINK-14113 URL: https://issues.apache.org/jira/browse/FLINK-14113 Project: Flink Issue Type: Sub-task Components:

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931490#comment-16931490 ] TisonKun commented on FLINK-14010: -- Well, it's reasonable we try to gracefully shut down. I start to

[jira] [Closed] (FLINK-14051) Deploy job cluster in attached mode

[ https://issues.apache.org/jira/browse/FLINK-14051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun closed FLINK-14051. Fix Version/s: (was: 1.10.0) Resolution: Later Follow the discussion it seems that we cannot

[jira] [Commented] (FLINK-14051) Deploy job cluster in attached mode

[ https://issues.apache.org/jira/browse/FLINK-14051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931426#comment-16931426 ] TisonKun commented on FLINK-14051: -- > If the execution environment could also deploy a cluster (in case

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931424#comment-16931424 ] TisonKun commented on FLINK-13417: -- [~till.rohrmann] thanks for your advice. For the tools issue I

[jira] [Commented] (FLINK-14070) Use TimeUtils to parse duration configs

[ https://issues.apache.org/jira/browse/FLINK-14070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931413#comment-16931413 ] TisonKun commented on FLINK-14070: -- Thanks for your confirmation [~till.rohrmann]. FYI FLINK-14105.

[jira] [Created] (FLINK-14105) Make flink-runtime scala-free

TisonKun created FLINK-14105: Summary: Make flink-runtime scala-free Key: FLINK-14105 URL: https://issues.apache.org/jira/browse/FLINK-14105 Project: Flink Issue Type: Task Components:

[jira] [Assigned] (FLINK-14096) Merge NewClusterClient into ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14096: Assignee: (was: TisonKun) > Merge NewClusterClient into ClusterClient >

[jira] [Commented] (FLINK-14096) Merge NewClusterClient into ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931400#comment-16931400 ] TisonKun commented on FLINK-14096: -- Thanks for your attention [~kkl0u]! I will start a discussion

[jira] [Created] (FLINK-14096) Merge NewClusterClient into ClusterClient

TisonKun created FLINK-14096: Summary: Merge NewClusterClient into ClusterClient Key: FLINK-14096 URL: https://issues.apache.org/jira/browse/FLINK-14096 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-14096) Merge NewClusterClient into ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-14096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14096: Assignee: TisonKun > Merge NewClusterClient into ClusterClient >

[jira] [Assigned] (FLINK-14050) Refactor YarnClusterDescriptor inheritance

[ https://issues.apache.org/jira/browse/FLINK-14050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14050: Assignee: TisonKun > Refactor YarnClusterDescriptor inheritance >

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931287#comment-16931287 ] TisonKun commented on FLINK-14010: -- [~till.rohrmann] Thanks to your explanation, I learn where the

[jira] [Commented] (FLINK-14051) Deploy job cluster in attached mode

[ https://issues.apache.org/jira/browse/FLINK-14051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931275#comment-16931275 ] TisonKun commented on FLINK-14051: -- Thanks for your explanation [~till.rohrmann]. I think the problem

[jira] [Commented] (FLINK-14070) Use TimeUtils to parse duration configs

[ https://issues.apache.org/jira/browse/FLINK-14070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931169#comment-16931169 ] TisonKun commented on FLINK-14070: -- An instance is {{AkkaUtils.getClientTimeout}} and its use points

[jira] [Commented] (FLINK-14050) Refactor YarnClusterDescriptor inheritance

[ https://issues.apache.org/jira/browse/FLINK-14050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931142#comment-16931142 ] TisonKun commented on FLINK-14050: -- I will start progress in hours if there is no other concerns here.

[jira] [Comment Edited] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931131#comment-16931131 ] TisonKun edited comment on FLINK-13417 at 9/17/19 6:47 AM: --- Updates: Manually

[jira] [Comment Edited] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931131#comment-16931131 ] TisonKun edited comment on FLINK-13417 at 9/17/19 6:45 AM: --- Updates: Manually

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931131#comment-16931131 ] TisonKun commented on FLINK-13417: -- Updates: Manually apply the diff and go through. Maybe there is

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930355#comment-16930355 ] TisonKun commented on FLINK-13992: -- Thanks for your clarification [~azagrebin]! Now I understand the

[jira] [Assigned] (FLINK-14041) Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils

[ https://issues.apache.org/jira/browse/FLINK-14041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-14041: Assignee: TisonKun > Refactor LeaderRetrievalServiceHostnameResolutionTest and remove >

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930336#comment-16930336 ] TisonKun commented on FLINK-13992: -- Thank [~azagrebin] for your updates. Now it works as expected. For

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930183#comment-16930183 ] TisonKun commented on FLINK-13992: -- Thanks for your imformation [~azagrebin]. I think we can also mark

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928459#comment-16928459 ] TisonKun commented on FLINK-13417: -- Hi [~till.rohrmann] I met a NOTICE-binary issue and cannot resolve

[jira] [Created] (FLINK-14068) Use Java's Duration instead of Flink's Time

TisonKun created FLINK-14068: Summary: Use Java's Duration instead of Flink's Time Key: FLINK-14068 URL: https://issues.apache.org/jira/browse/FLINK-14068 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928384#comment-16928384 ] TisonKun commented on FLINK-10333: -- Yes that's it. For implementation details it is an alternative

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928342#comment-16928342 ] TisonKun commented on FLINK-10333: -- I revoke the statement {{LeaderServer}} is a prerequisite for new

[jira] [Comment Edited] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928316#comment-16928316 ] TisonKun edited comment on FLINK-13417 at 9/12/19 7:43 AM: --- [~StephanEwen] I

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928316#comment-16928316 ] TisonKun commented on FLINK-13417: -- [~StephanEwen] I figured out that it is because since 3.5.3

[jira] [Commented] (FLINK-14054) Enable checkpointing via job configuration

[ https://issues.apache.org/jira/browse/FLINK-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928259#comment-16928259 ] TisonKun commented on FLINK-14054: -- I might mistake that we are already able to configure parallelism

[jira] [Commented] (FLINK-14054) Enable checkpointing via job configuration

[ https://issues.apache.org/jira/browse/FLINK-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928235#comment-16928235 ] TisonKun commented on FLINK-14054: -- Hi [~qinjunjerry]! Thanks for reporting your requirement. I agree

[jira] [Updated] (FLINK-14054) Enable checkpointing via job configuration

[ https://issues.apache.org/jira/browse/FLINK-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-14054: - Description: Currently enabling checkpointing can only be done via the job code, see the following

[jira] [Commented] (FLINK-14051) Deploy job cluster in attached mode

[ https://issues.apache.org/jira/browse/FLINK-14051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927442#comment-16927442 ] TisonKun commented on FLINK-14051: -- Thanks for your information [~till.rohrmann]. I have two questions

[jira] [Commented] (FLINK-14048) Flink client hangs after trying to kill Yarn Job during deployment

[ https://issues.apache.org/jira/browse/FLINK-14048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927372#comment-16927372 ] TisonKun commented on FLINK-14048: -- [~gyfora] also it looks like a duplication of FLINK-13895. Could

[jira] [Updated] (FLINK-14051) Deploy job cluster in attached mode

[ https://issues.apache.org/jira/browse/FLINK-14051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-14051: - Description: While working on FLINK-14048 I revisit the problem we handle deploy logic in a

[jira] [Created] (FLINK-14051) Deploy job cluster in attached mode

TisonKun created FLINK-14051: Summary: Deploy job cluster in attached mode Key: FLINK-14051 URL: https://issues.apache.org/jira/browse/FLINK-14051 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14050) Refactor YarnClusterDescriptor inheritance

TisonKun created FLINK-14050: Summary: Refactor YarnClusterDescriptor inheritance Key: FLINK-14050 URL: https://issues.apache.org/jira/browse/FLINK-14050 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-14048) Flink client hangs after trying to kill Yarn Job during deployment

[ https://issues.apache.org/jira/browse/FLINK-14048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927350#comment-16927350 ] TisonKun commented on FLINK-14048: -- I try to refactor the code for a proper exception handling. Could

[jira] [Updated] (FLINK-14048) Flink client hangs after trying to kill Yarn Job during deployment

[ https://issues.apache.org/jira/browse/FLINK-14048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-14048: - Attachment: patch.diff > Flink client hangs after trying to kill Yarn Job during deployment >

[jira] [Commented] (FLINK-14048) Flink client hangs after trying to kill Yarn Job during deployment

[ https://issues.apache.org/jira/browse/FLINK-14048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927308#comment-16927308 ] TisonKun commented on FLINK-14048: -- [~gyfora] did you notice this problem when deploy per-job cluster?

[jira] [Created] (FLINK-14041) Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils

TisonKun created FLINK-14041: Summary: Refactor LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils Key: FLINK-14041 URL: https://issues.apache.org/jira/browse/FLINK-14041 Project:

[jira] [Closed] (FLINK-11664) Pass leadership information by LeaderAddressAndId

[ https://issues.apache.org/jira/browse/FLINK-11664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun closed FLINK-11664. Resolution: Won't Do > Pass leadership information by LeaderAddressAndId >

[jira] [Updated] (FLINK-13961) Remove obsolete abstraction JobExecutor(Service)

[ https://issues.apache.org/jira/browse/FLINK-13961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-13961: - Affects Version/s: (was: 1.10.0) > Remove obsolete abstraction JobExecutor(Service) >

[jira] [Closed] (FLINK-13961) Remove obsolete abstraction JobExecutor(Service)

[ https://issues.apache.org/jira/browse/FLINK-13961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun closed FLINK-13961. Fix Version/s: (was: 1.10.0) Resolution: Not A Problem There are still users of this

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16925460#comment-16925460 ] TisonKun commented on FLINK-14010: -- CC [~StephanEwen] [~till.rohrmann] [~xiaogang.shi] Here comes a

[jira] [Created] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

TisonKun created FLINK-14010: Summary: Dispatcher & JobManagers don't give up leadership when AM is shut down Key: FLINK-14010 URL: https://issues.apache.org/jira/browse/FLINK-14010 Project: Flink

[jira] [Created] (FLINK-13997) Remove legacy LeaderAddressAndId

TisonKun created FLINK-13997: Summary: Remove legacy LeaderAddressAndId Key: FLINK-13997 URL: https://issues.apache.org/jira/browse/FLINK-13997 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-13992: - Issue Type: Improvement (was: Bug) > Refactor Optional parameter in InputGateWithMetrics#updateMetrics

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924408#comment-16924408 ] TisonKun commented on FLINK-13992: -- Hi [~zjwang], do you think this issue valid? If so, could you help

[jira] [Commented] (FLINK-13961) Remove obsolete abstraction JobExecutor(Service)

[ https://issues.apache.org/jira/browse/FLINK-13961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924273#comment-16924273 ] TisonKun commented on FLINK-13961: -- I've opened a pull request #9643 to this issue. Feel free to give

[jira] [Commented] (FLINK-13961) Remove obsolete abstraction JobExecutor(Service)

[ https://issues.apache.org/jira/browse/FLINK-13961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924256#comment-16924256 ] TisonKun commented on FLINK-13961: -- Thanks for your update [~kkl0u]! I will set the state to "In

[jira] [Created] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

TisonKun created FLINK-13992: Summary: Refactor Optional parameter in InputGateWithMetrics#updateMetrics Key: FLINK-13992 URL: https://issues.apache.org/jira/browse/FLINK-13992 Project: Flink

[jira] [Comment Edited] (FLINK-13990) Remove JobModificationException

[ https://issues.apache.org/jira/browse/FLINK-13990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924104#comment-16924104 ] TisonKun edited comment on FLINK-13990 at 9/6/19 10:09 AM: --- In fact,

[jira] [Commented] (FLINK-13990) Remove JobModificationException

[ https://issues.apache.org/jira/browse/FLINK-13990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924104#comment-16924104 ] TisonKun commented on FLINK-13990: -- In fact, {{JobMasterException}} referred above is

[jira] [Commented] (FLINK-13990) Remove JobModificationException

[ https://issues.apache.org/jira/browse/FLINK-13990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924101#comment-16924101 ] TisonKun commented on FLINK-13990: -- Also its base class {{JobMasterException}} that has none of outside

[jira] [Created] (FLINK-13990) Remove JobModificationException

TisonKun created FLINK-13990: Summary: Remove JobModificationException Key: FLINK-13990 URL: https://issues.apache.org/jira/browse/FLINK-13990 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13989) Remove legacy ClassloadingProps

TisonKun created FLINK-13989: Summary: Remove legacy ClassloadingProps Key: FLINK-13989 URL: https://issues.apache.org/jira/browse/FLINK-13989 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13988) Remove legacy JobManagerMode

TisonKun created FLINK-13988: Summary: Remove legacy JobManagerMode Key: FLINK-13988 URL: https://issues.apache.org/jira/browse/FLINK-13988 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-13970) Remove LifoSetQueue and SetQueue

[ https://issues.apache.org/jira/browse/FLINK-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923602#comment-16923602 ] TisonKun commented on FLINK-13970: -- With another pass I find {{SetQueue}} is quite similar with

[jira] [Updated] (FLINK-13970) Remove LifoSetQueue and SetQueue

[ https://issues.apache.org/jira/browse/FLINK-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-13970: - Summary: Remove LifoSetQueue and SetQueue (was: Remove or move LifoSetQueue) > Remove LifoSetQueue

[jira] [Commented] (FLINK-13964) Remove usage of deprecated methods from MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-13964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923244#comment-16923244 ] TisonKun commented on FLINK-13964: -- Technically the proposal is valid and there isn't too much effort

[jira] [Created] (FLINK-13970) Remove or move LifoSetQueue

TisonKun created FLINK-13970: Summary: Remove or move LifoSetQueue Key: FLINK-13970 URL: https://issues.apache.org/jira/browse/FLINK-13970 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923170#comment-16923170 ] TisonKun commented on FLINK-10333: -- Details and implementation of {{LeaderServer}} is regarded as a

[jira] [Comment Edited] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923170#comment-16923170 ] TisonKun edited comment on FLINK-10333 at 9/5/19 8:17 AM: -- {{LeaderServer}} is

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923156#comment-16923156 ] TisonKun commented on FLINK-10333: -- Hi [~till.rohrmann] [~xiaogang.shi] [~StephanEwen], I'd like to

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923109#comment-16923109 ] TisonKun commented on FLINK-10333: -- Thanks for your information [~till.rohrmann]. I think it is about

[jira] [Commented] (FLINK-13500) RestClusterClient requires S3 access when HA is configured

[ https://issues.apache.org/jira/browse/FLINK-13500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923010#comment-16923010 ] TisonKun commented on FLINK-13500: -- Hi [~till.rohrmann] & [~Zentol], with FLINK-13750 resolved I think

[jira] [Commented] (FLINK-13961) Remove obsolete abstraction JobExecutor(Service)

[ https://issues.apache.org/jira/browse/FLINK-13961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923003#comment-16923003 ] TisonKun commented on FLINK-13961: -- Hi [~kkl0u] I'd like to work on this issue. Please assign the issue

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922970#comment-16922970 ] TisonKun commented on FLINK-13417: -- Yes [~till.rohrmann]. I locally build with zk 3.5 and no compile

[jira] [Created] (FLINK-13961) Remove obsolete abstraction JobExecutor(Service)

TisonKun created FLINK-13961: Summary: Remove obsolete abstraction JobExecutor(Service) Key: FLINK-13961 URL: https://issues.apache.org/jira/browse/FLINK-13961 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13946) Remove deactivated JobSession-related code.

[ https://issues.apache.org/jira/browse/FLINK-13946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921951#comment-16921951 ] TisonKun commented on FLINK-13946: -- Good to hear. I'm volunteer to review your patch :-) > Remove

  1   2   3   4   5   6   >