[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 FLINK

[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&focusedCommentId=16933899#comment-16933899 ] TisonKun commented on FLINK-4233: - Further, if it is assumed that there are never

[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&focusedCommentId=16933879#comment-16933879 ] TisonKun commented on FLINK-4233: - Thanks for picking up this topic! I'm th

[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 ClusterCli

[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&focusedCommentId=16933494#comment-16933494 ] TisonKun commented on FLINK-14130: -- Great to have! I ever thought it is not easil

[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&focusedCommentId=16933184#comment-16933184 ] TisonKun commented on FLINK-14112: -- Thanks for your insights [~trohrmann]. So

[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

[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

[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&focusedCommentId=16933140#comment-16933140 ] TisonKun commented on FLINK-14010: -- Will send a pull request in h

[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 er

[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&focusedCommentId=16933131#comment-16933131 ] TisonKun commented on FLINK-14112: -- [~trohrmann] is its function duplicate

[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&focusedCommentId=16933030#comment-16933030 ] TisonKun commented on FLINK-14010: -- [~trohrmann] Technically I agree that it

[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&focusedCommentId=16933022#comment-16933022 ] TisonKun commented on FLINK-14112: -- I agree with [~trohrmann]'s comments.

[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&focusedCommentId=16932959#comment-16932959 ] TisonKun commented on FLINK-14109: -- [~bremac] aha, nice to hear :-) >

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

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

[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&focusedCommentId=16932423#comment-16932423 ] TisonKun commented on FLINK-14010: -- I have thought of this. The problem is that

[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&focusedCommentId=16932423#comment-16932423 ] TisonKun edited comment on FLINK-14010 at 9/18/19 1:06 PM: --

[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&focusedCommentId=16932275#comment-16932275 ] TisonKun commented on FLINK-14114: -- I've assigned the issue to yo

[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 RestClusterCli

[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&focusedCommentId=16932256#comment-16932256 ] TisonKun commented on FLINK-14114: -- Hi [~zhuzh] if you'd like to wor

[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&focusedCommentId=16932133#comment-16932133 ] TisonKun commented on FLINK-14070: -- Hi [~zhuzh] did you start working on this th

[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&focusedCommentId=16932061#comment-16932061 ] TisonKun commented on FLINK-14093: -- [~zhaoshijie] We cannot just introduce

[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&focusedCommentId=16932059#comment-16932059 ] TisonKun commented on FLINK-14111: -- Yes I think it is a duplication of FLINK-1

[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&focusedCommentId=16932058#comment-16932058 ] TisonKun edited comment on FLINK-14112 at 9/18/19 4:5

[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&focusedCommentId=16932058#comment-16932058 ] TisonKun commented on FLINK-14112: -- Hi [~aaronlevin] thanks for creating this

[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&focusedCommentId=16932053#comment-16932053 ] TisonKun commented on FLINK-14109: -- Hi [~bremac] thanks for reporting this! There

[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&focusedCommentId=16931962#comment-16931962 ] TisonKun commented on FLINK-14096: -- FYI https://lists.apache.org/x/thread.

[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&focusedCommentId=16931490#comment-16931490 ] TisonKun commented on FLINK-14010: -- Well, it's reasonable we try to gracef

[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&focusedCommentId=16931426#comment-16931426 ] TisonKun commented on FLINK-14051: -- > If the execution environment could also d

[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&focusedCommentId=16931424#comment-16931424 ] TisonKun commented on FLINK-13417: -- [~till.rohrmann] thanks for your advice. For

[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&focusedCommentId=16931413#comment-16931413 ] TisonKun commented on FLINK-14070: -- Thanks for your confirmation [~till.rohrmann].

[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 ClusterCli

[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&focusedCommentId=16931400#comment-16931400 ] TisonKun commented on FLINK-14096: -- Thanks for your attention [~kkl0u]! I will sta

[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 ClusterCli

[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 inherita

[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&focusedCommentId=16931287#comment-16931287 ] TisonKun commented on FLINK-14010: -- [~till.rohrmann] Thanks to your explanatio

[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&focusedCommentId=16931275#comment-16931275 ] TisonKun commented on FLINK-14051: -- Thanks for your explanation [~till.rohrmann]

[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&focusedCommentId=16931169#comment-16931169 ] TisonKun commented on FLINK-14070: -- An instance is {{AkkaUtils.getClientTimeout}}

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

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

[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&focusedCommentId=16931131#comment-16931131 ] TisonKun edited comment on FLINK-13417 at 9/17/19 6:4

[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&focusedCommentId=16931131#comment-16931131 ] TisonKun edited comment on FLINK-13417 at 9/17/19 6:4

[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&focusedCommentId=16931131#comment-16931131 ] TisonKun commented on FLINK-13417: -- Updates: Manually apply the diff and go thr

[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&focusedCommentId=16930355#comment-16930355 ] TisonKun commented on FLINK-13992: -- Thanks for your clarification [~azagrebin]! N

[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 rem

[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&focusedCommentId=16930336#comment-16930336 ] TisonKun commented on FLINK-13992: -- Thank [~azagrebin] for your updates. Now it w

[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&focusedCommentId=16930183#comment-16930183 ] TisonKun commented on FLINK-13992: -- Thanks for your imformation [~azagrebin]. I t

[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&focusedCommentId=16928459#comment-16928459 ] TisonKun commented on FLINK-13417: -- Hi [~till.rohrmann] I met a NOTICE-binary i

[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

[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&focusedCommentId=16928384#comment-16928384 ] TisonKun commented on FLINK-10333: -- Yes that's it. For implementation deta

[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&focusedCommentId=16928342#comment-16928342 ] TisonKun commented on FLINK-10333: -- I revoke the statement {{LeaderServer}}

[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&focusedCommentId=16928316#comment-16928316 ] TisonKun edited comment on FLINK-13417 at 9/12/19 7:4

[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&focusedCommentId=16928316#comment-16928316 ] TisonKun commented on FLINK-13417: -- [~StephanEwen] I figured out that it is bec

[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&focusedCommentId=16928259#comment-16928259 ] TisonKun commented on FLINK-14054: -- I might mistake that we are already abl

[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&focusedCommentId=16928235#comment-16928235 ] TisonKun commented on FLINK-14054: -- Hi [~qinjunjerry]! Thanks for reporting

[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&focusedCommentId=16927442#comment-16927442 ] TisonKun commented on FLINK-14051: -- Thanks for your information [~till.rohrmann]

[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&focusedCommentId=16927372#comment-16927372 ] TisonKun commented on FLINK-14048: -- [~gyfora] also it looks like a duplicatio

[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&focusedCommentId=16927350#comment-16927350 ] TisonKun commented on FLINK-14048: -- I try to refactor the code for a proper excep

[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 deploym

[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&focusedCommentId=16927308#comment-16927308 ] TisonKun commented on FLINK-14048: -- [~gyfora] did you notice this problem when de

[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 LeaderAddr

[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(Serv

[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&focusedCommentId=16925460#comment-16925460 ] TisonKun commented on FLINK-14010: -- CC [~StephanEwen] [~till.rohrmann] [~xiaogang

[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 Proje

[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#updateMetr

[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&focusedCommentId=16924408#comment-16924408 ] TisonKun commented on FLINK-13992: -- Hi [~zjwang], do you think this issue valid? I

[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&focusedCommentId=16924273#comment-16924273 ] TisonKun commented on FLINK-13961: -- I've opened a pull request #9643 to t

[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&focusedCommentId=16924256#comment-16924256 ] TisonKun commented on FLINK-13961: -- Thanks for your update [~kkl0u]! I will set

[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&focusedCommentId=16924104#comment-16924104 ] TisonKun edited comment on FLINK-13990 at 9/6/19 10:0

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

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

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

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

[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&focusedCommentId=16923602#comment-16923602 ] TisonKun commented on FLINK-13970: -- With another pass I find {{SetQueue}} is q

[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 LifoSetQu

[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&focusedCommentId=16923244#comment-16923244 ] TisonKun commented on FLINK-13964: -- Technically the proposal is valid and there i

[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&focusedCommentId=16923170#comment-16923170 ] TisonKun commented on FLINK-10333: -- Details and implementation of {{LeaderServer}

[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&focusedCommentId=16923170#comment-16923170 ] TisonKun edited comment on FLINK-10333 at 9/5/19 8:1

[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&focusedCommentId=16923156#comment-16923156 ] TisonKun commented on FLINK-10333: -- Hi [~till.rohrmann] [~xiaogang.shi] [~Stephan

[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&focusedCommentId=16923109#comment-16923109 ] TisonKun commented on FLINK-10333: -- Thanks for your information [~till.rohrmann

[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&focusedCommentId=16923010#comment-16923010 ] TisonKun commented on FLINK-13500: -- Hi [~till.rohrmann] & [~Zentol], with FLI

[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&focusedCommentId=16923003#comment-16923003 ] TisonKun commented on FLINK-13961: -- Hi [~kkl0u] I'd like to work on this issu

[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&focusedCommentId=16922970#comment-16922970 ] TisonKun commented on FLINK-13417: -- Yes [~till.rohrmann]. I locally build with zk

[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: Sub

[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&focusedCommentId=16921951#comment-16921951 ] TisonKun commented on FLINK-13946: -- Good to hear. I'm volunteer to review y

  1   2   3   4   5   6   >