[jira] [Comment Edited] (FLINK-14816) Add thread dump feature for taskmanager

[ https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17001312#comment-17001312 ] lamber-ken edited comment on FLINK-14816 at 12/21/19 12:33 AM: --- Thanks,

[jira] [Commented] (FLINK-14816) Add thread dump feature for taskmanager

[ https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17001312#comment-17001312 ] lamber-ken commented on FLINK-14816: Thanks, done. > Add thread dump feature for taskmanager >

[jira] [Commented] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000645#comment-17000645 ] lamber-ken commented on FLINK-14177: It took me a long time to care about this pr(opened at on

[jira] [Closed] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken closed FLINK-14177. -- Resolution: Won't Fix > Bump Curator From 2.12.0 to 4.2.0 > - > >

[jira] [Commented] (FLINK-15087) JobManager is forced to shutdown JVM due to temporary loss of zookeeper connection

[ https://issues.apache.org/jira/browse/FLINK-15087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989515#comment-16989515 ] lamber-ken commented on FLINK-15087: (y) > JobManager is forced to shutdown JVM due to temporary

[jira] [Commented] (FLINK-15087) JobManager is forced to shutdown JVM due to temporary loss of zookeeper connection

[ https://issues.apache.org/jira/browse/FLINK-15087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16989482#comment-16989482 ] lamber-ken commented on FLINK-15087: hi, this may be is a duplicate of FLINK-10052. > JobManager is

[jira] [Comment Edited] (FLINK-14984) Remove old WebUI

[ https://issues.apache.org/jira/browse/FLINK-14984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985263#comment-16985263 ] lamber-ken edited comment on FLINK-14984 at 11/30/19 5:18 AM: -- hi,

[jira] [Commented] (FLINK-14984) Remove old WebUI

[ https://issues.apache.org/jira/browse/FLINK-14984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16985263#comment-16985263 ] lamber-ken commented on FLINK-14984: hi, [~chesnay] I think I can do it. Could anyon assign it to

[jira] [Commented] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar

[ https://issues.apache.org/jira/browse/FLINK-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979864#comment-16979864 ] lamber-ken commented on FLINK-3158: --- [~rmetzger]  (y) > Shading does not remove google guava from

[jira] [Created] (FLINK-14827) Add thread dump feature for jobmanager

lamber-ken created FLINK-14827: -- Summary: Add thread dump feature for jobmanager Key: FLINK-14827 URL: https://issues.apache.org/jira/browse/FLINK-14827 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-14816) Add thread dump feature for taskmanager

[ https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14816: --- Summary: Add thread dump feature for taskmanager (was: Add thread dump feature for jobmanager and

[jira] [Updated] (FLINK-14816) Add thread dump feature for jobmanager and taskmanager

[ https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14816: --- Summary: Add thread dump feature for jobmanager and taskmanager (was: Add thread dump feature for

[jira] [Updated] (FLINK-14816) Add thread dump feature for taskmanager

[ https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14816: --- Attachment: screenshot-1.png > Add thread dump feature for taskmanager >

[jira] [Updated] (FLINK-14816) Add thread dump feature for taskmanager

[ https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14816: --- Description: Add thread dump feature for taskmanager, so use can get thread information easily.

[jira] [Updated] (FLINK-14816) Add thread dump feature for taskmanager

[ https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14816: --- Attachment: (was: image-2019-11-15-17-41-12-576.png) > Add thread dump feature for taskmanager

[jira] [Created] (FLINK-14816) Add thread dump feature for taskmanager

lamber-ken created FLINK-14816: -- Summary: Add thread dump feature for taskmanager Key: FLINK-14816 URL: https://issues.apache.org/jira/browse/FLINK-14816 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-14614) add annotation location javastyle rule

lamber-ken created FLINK-14614: -- Summary: add annotation location javastyle rule Key: FLINK-14614 URL: https://issues.apache.org/jira/browse/FLINK-14614 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Description: According to FLINK-10052 and FLINK-13417, we needs to upgrade the version of

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Description: According to FLINK-10052 and FLINK-14117, we needs to upgrade the version of

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Description: According to FLINK-10052 and FLINK-14177, we needs to upgrade the version of

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Description: According to FLINK-10052 and FLINK-14177, we needs to upgrade the version of

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Description: **According to FLINK-10052 and FLINK-14177 > Bump Curator From 2.12.0 to 4.2.0 >

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Component/s: Runtime / Checkpointing Connectors / Hadoop Compatibility > Bump

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Fix Version/s: 1.9.1 > Bump Curator From 2.12.0 to 4.2.0 > - > >

[jira] [Created] (FLINK-14177) Bump Curator to 3.5.5

lamber-ken created FLINK-14177: -- Summary: Bump Curator to 3.5.5 Key: FLINK-14177 URL: https://issues.apache.org/jira/browse/FLINK-14177 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Affects Version/s: 1.8.1 1.9.0 > Bump Curator From 2.12.0 to 4.2.0 >

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Summary: Bump Curator From 2.12.0 to 4.2.0 (was: Bump Curator to 3.5.5) > Bump Curator From 2.12.0

[jira] [Commented] (FLINK-11420) Serialization of case classes containing a Map[String, Any] sometimes throws ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-11420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928298#comment-16928298 ] lamber-ken commented on FLINK-11420: (y) > Serialization of case classes containing a Map[String,

[jira] [Commented] (FLINK-11218) fix the default restart stragegy delay value

[ https://issues.apache.org/jira/browse/FLINK-11218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919579#comment-16919579 ] lamber-ken commented on FLINK-11218: ok > fix the default restart stragegy delay value >

[jira] [Commented] (FLINK-11218) fix the default restart stragegy delay value

[ https://issues.apache.org/jira/browse/FLINK-11218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919574#comment-16919574 ] lamber-ken commented on FLINK-11218: Hi, [~till.rohrmann]. It's no problem. > fix the default

[jira] [Commented] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919417#comment-16919417 ] lamber-ken commented on FLINK-13787: [~fly_in_gis] [~kaibo.zhou] Hi，you can use this[1] fork. [1] 

[jira] [Commented] (FLINK-11457) PrometheusPushGatewayReporter does not cleanup its metrics

[ https://issues.apache.org/jira/browse/FLINK-11457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911889#comment-16911889 ] lamber-ken commented on FLINK-11457: hi, [~opwvhk] In our product env, we also met the same

[jira] [Commented] (FLINK-13787) PrometheusPushGatewayReporter does not cleanup TM metrics when run on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911888#comment-16911888 ] lamber-ken commented on FLINK-13787: hi, [~kaibo.zhou]. In our product env, we also met the same

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891015#comment-16891015 ] lamber-ken commented on FLINK-10052: Hi [~quan] This main point of this issue is about how

[jira] [Closed] (FLINK-13189) Fix the impact of zookeeper network disconnect temporarily on flink long running jobs

[ https://issues.apache.org/jira/browse/FLINK-13189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken closed FLINK-13189. -- Resolution: Duplicate Fix Version/s: (was: 1.9.0) Release Note: duplicate to

[jira] [Issue Comment Deleted] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-10052: --- Comment: was deleted (was: [~Tison], btw, which way is better? update PR#9066 or create a new pr

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887276#comment-16887276 ] lamber-ken commented on FLINK-10052: [~Tison], btw, which way is better? update PR#9066 or create a

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887268#comment-16887268 ] lamber-ken edited comment on FLINK-10052 at 7/17/19 5:28 PM: - [~Tison] yes,

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887268#comment-16887268 ] lamber-ken commented on FLINK-10052: [~Tison] yes, I checke the shaded class file by +javap -v+

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886815#comment-16886815 ] lamber-ken commented on FLINK-10052: [~Tison]，Ok, I see. I had read the doc before , your ideas and

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886699#comment-16886699 ] lamber-ken edited comment on FLINK-10052 at 7/17/19 6:01 AM: - [~Tison] (y),

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886699#comment-16886699 ] lamber-ken commented on FLINK-10052: [~Tison] (y), I have some points need to talk with you. First,

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1688#comment-1688 ] lamber-ken commented on FLINK-10052: hi, [~Tison] We can learn about the difference between

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886663#comment-16886663 ] lamber-ken edited comment on FLINK-10052 at 7/17/19 4:06 AM: - [~Tison],

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886663#comment-16886663 ] lamber-ken commented on FLINK-10052: [~Tison], right, it's a better way to upgrate curator dependcy

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884567#comment-16884567 ] lamber-ken edited comment on FLINK-10052 at 7/14/19 5:30 AM: - Hi, all. 

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884567#comment-16884567 ] lamber-ken edited comment on FLINK-10052 at 7/14/19 5:29 AM: - Hi, all. 

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884567#comment-16884567 ] lamber-ken commented on FLINK-10052: Hi, all.  BTW, if we upgrade curator dependency to 4.x,

[jira] [Updated] (FLINK-13189) Fix the impact of zookeeper network disconnect temporarily on flink long running jobs

[ https://issues.apache.org/jira/browse/FLINK-13189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-13189: --- Component/s: (was: Runtime / Network) Runtime / Coordination > Fix the impact

[jira] [Updated] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-10052: --- Affects Version/s: 1.8.1 > Tolerate temporarily suspended ZooKeeper connections >

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882859#comment-16882859 ] lamber-ken commented on FLINK-10052: Hi, all, I'm glad to fix this issue, when more and more jobs

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882303#comment-16882303 ] lamber-ken edited comment on FLINK-10052 at 7/10/19 5:46 PM: - Thanks for

[jira] [Commented] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882303#comment-16882303 ] lamber-ken commented on FLINK-10052: Hi all, I'm very sorry that I created a duplicated jira

[jira] [Commented] (FLINK-13189) Fix the impact of zookeeper network disconnect temporarily on flink long running jobs

[ https://issues.apache.org/jira/browse/FLINK-13189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882289#comment-16882289 ] lamber-ken commented on FLINK-13189: Thanks for remind me that [~elevy]. We met this problem in

[jira] [Updated] (FLINK-13189) Fix the impact of zookeeper network disconnect temporarily on flink long running jobs

[ https://issues.apache.org/jira/browse/FLINK-13189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-13189: --- Description: *Issue detail info* We deploy flink streaming jobs on hadoop cluster on per-job model

[jira] [Created] (FLINK-13189) Fix the impact of zookeeper network disconnect temporarily on flink long running jobs

lamber-ken created FLINK-13189: -- Summary: Fix the impact of zookeeper network disconnect temporarily on flink long running jobs Key: FLINK-13189 URL: https://issues.apache.org/jira/browse/FLINK-13189

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852775#comment-16852775 ] lamber-ken commented on FLINK-12302: Thanks very match! > Fixed the wrong finalStatus of yarn

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849540#comment-16849540 ] lamber-ken edited comment on FLINK-12302 at 5/28/19 9:47 AM: - [~gjy] By the

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849540#comment-16849540 ] lamber-ken commented on FLINK-12302: By the way, can you help me to review my another pr if you have

[jira] [Assigned] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken reassigned FLINK-12302: -- Assignee: (was: lamber-ken) > Fixed the wrong finalStatus of yarn application when

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849537#comment-16849537 ] lamber-ken edited comment on FLINK-12302 at 5/28/19 9:43 AM: - Hi [~gjy],

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849537#comment-16849537 ] lamber-ken edited comment on FLINK-12302 at 5/28/19 9:42 AM: - Hi [~gjy],

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849537#comment-16849537 ] lamber-ken commented on FLINK-12302: Hi [~gjy], Thanks for your detail explain. I use 

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken edited comment on FLINK-12302 at 5/27/19 4:53 PM: - [~gjy], from

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849080#comment-16849080 ] lamber-ken commented on FLINK-12302: So, when the unexcepted scene happens, it displays wrong

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: image-2019-05-28-00-50-13-500.png > Fixed the wrong finalStatus of yarn application

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken edited comment on FLINK-12302 at 5/27/19 4:47 PM: - [~gjy], from

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken edited comment on FLINK-12302 at 5/27/19 4:43 PM: - [~gjy], from

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken edited comment on FLINK-12302 at 5/27/19 4:42 PM: - [~gjy], from

[jira] [Comment Edited] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken edited comment on FLINK-12302 at 5/27/19 4:34 PM: - [~gjy], from

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849071#comment-16849071 ] lamber-ken commented on FLINK-12302: [~gjy], from another side, we can analysis this issue only from

[jira] [Issue Comment Deleted] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Comment: was deleted (was: [~gjy], hi, can you show me your +flink-conf.yaml+ file? thanks) >

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849038#comment-16849038 ] lamber-ken commented on FLINK-12302: [~gjy], here my env files. 1,test jars --> [^test.jar]

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: jobmanager-1.log > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: jobmanager-2.log > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: flink-conf.yaml > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: (was: jobmanager-1.log) > Fixed the wrong finalStatus of yarn application when

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: test.jar > Fixed the wrong finalStatus of yarn application when application finished >

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: (was: flink-conf.yaml) > Fixed the wrong finalStatus of yarn application when

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: (was: jobmanager-2.log) > Fixed the wrong finalStatus of yarn application when

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: (was: test.jar) > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: test.jar jobmanager-2.log jobmanager-1.log

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: (was: test.jar) > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: test.jar > Fixed the wrong finalStatus of yarn application when application finished >

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849010#comment-16849010 ] lamber-ken commented on FLINK-12302: [~gjy], hi, can you show me your +flink-conf.yaml+ file? thanks

[jira] [Closed] (FLINK-12558) Yarn application can't stop when flink job finished in normal mode

[ https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken closed FLINK-12558. -- Resolution: Not A Problem Fix Version/s: 1.6.3 Release Note: it needs to add -ace option

[jira] [Commented] (FLINK-12558) Yarn application can't stop when flink job finished in normal mode

[ https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845457#comment-16845457 ] lamber-ken commented on FLINK-12558: hi, thanks for assign this issue [~frank wang], maybe the CLI

[jira] [Updated] (FLINK-12558) Yarn application can't stop when flink job finished in normal mode

[ https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12558: --- Summary: Yarn application can't stop when flink job finished in normal mode (was: Yarn application

[jira] [Comment Edited] (FLINK-12558) Yarn application can't stop when flink job finished

[ https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844434#comment-16844434 ] lamber-ken edited comment on FLINK-12558 at 5/21/19 1:37 AM: - [~frank wang],

[jira] [Commented] (FLINK-12558) Yarn application can't stop when flink job finished

[ https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844434#comment-16844434 ] lamber-ken commented on FLINK-12558: [~frank wang], I think the +FlinkJobNotFoundException+ is not

[jira] [Updated] (FLINK-12558) Yarn application can't stop when flink job finished

[ https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12558: --- Description: I run a flink +SocketWindowWordCount+ job on yarn cluste mode, when I kill the

[jira] [Updated] (FLINK-12558) Yarn application can't stop when flink job finished

[ https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12558: --- Attachment: jobmanager.txt > Yarn application can't stop when flink job finished >

[jira] [Created] (FLINK-12558) Yarn application can't stop when flink job finished

lamber-ken created FLINK-12558: -- Summary: Yarn application can't stop when flink job finished Key: FLINK-12558 URL: https://issues.apache.org/jira/browse/FLINK-12558 Project: Flink Issue Type:

[jira] [Closed] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime()

[ https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken closed FLINK-11010. -- Resolution: Won't Fix > Flink SQL timestamp is inconsistent with currentProcessingTime() >

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840354#comment-16840354 ] lamber-ken commented on FLINK-12302: [~gjy] this is an extreme example, but that reflects the

[jira] [Commented] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840352#comment-16840352 ] lamber-ken commented on FLINK-12302: thanks for your comment [~gjy], follow below steps, you'll get

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: screenshot-2.png > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12302: --- Attachment: screenshot-1.png > Fixed the wrong finalStatus of yarn application when application

[jira] [Updated] (FLINK-12400) NullpointerException using SimpleStringSchema with Kafka

[ https://issues.apache.org/jira/browse/FLINK-12400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-12400: --- Environment: * Flink 1.7.2 job on 1.8 cluster * Kafka 0.10 with a topic in log-compaction was:

[jira] [Reopened] (FLINK-12219) Yarn application can't stop when flink job failed in per-job yarn cluster mode

[ https://issues.apache.org/jira/browse/FLINK-12219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken reopened FLINK-12219: > Yarn application can't stop when flink job failed in per-job yarn cluster mode >

  1   2   >