Ken created FLINK-19212:
---
Summary: Failed to serialize the result for RPC call :
requestTaskManagerInfo.
Key: FLINK-19212
URL: https://issues.apache.org/jira/browse/FLINK-19212
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17001312#comment-17001312
]
lamber-ken edited comment on FLINK-14816 at 12/21/19 12:33 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17001312#comment-17001312
]
lamber-ken commented on FLINK-14816:
Thanks, done.
> Add thread dump feature for ta
[
https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17000645#comment-17000645
]
lamber-ken commented on FLINK-14177:
It took me a long time to care about this pr(op
[
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
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-15087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989515#comment-16989515
]
lamber-ken commented on FLINK-15087:
(y)
> JobManager is forced to shutdown JVM due
[
https://issues.apache.org/jira/browse/FLINK-15087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989482#comment-16989482
]
lamber-ken commented on FLINK-15087:
hi, this may be is a duplicate of FLINK-10052.
[
https://issues.apache.org/jira/browse/FLINK-14984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16985263#comment-16985263
]
lamber-ken edited comment on FLINK-14984 at 11/30/19 5:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-14984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16985263#comment-16985263
]
lamber-ken commented on FLINK-14984:
hi, [~chesnay] I think I can do it. Could anyon
[
https://issues.apache.org/jira/browse/FLINK-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16979864#comment-16979864
]
lamber-ken commented on FLINK-3158:
---
[~rmetzger] (y)
> Shading does not remove google
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
[
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 t
[
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 t
[
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
> ---
[
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.
!
[
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
>
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
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
[
https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964969#comment-16964969
]
Ken commented on FLINK-11127:
-
[~hwanju] [~trohrmann], for context, the "fix" I mentioned is
[
https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962337#comment-16962337
]
Ken edited comment on FLINK-11127 at 10/29/19 10:19 PM:
[~hwanju
[
https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962337#comment-16962337
]
Ken edited comment on FLINK-11127 at 10/29/19 7:40 PM:
---
[~hwanju],
[
https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962337#comment-16962337
]
Ken commented on FLINK-11127:
-
[~hwanju], I upgraded from 1.7 to 1.8. Previously I use the w
[
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
CuratorFr
[
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
CuratorFr
[
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
CuratorFr
[
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
CuratorFr
[
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
> --
[
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 Curat
[
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
> -
>
>
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
Reporte
[
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
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-11420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928298#comment-16928298
]
lamber-ken commented on FLINK-11420:
(y)
> Serialization of case classes containing
[
https://issues.apache.org/jira/browse/FLINK-11218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919579#comment-16919579
]
lamber-ken commented on FLINK-11218:
ok
> fix the default restart stragegy delay va
[
https://issues.apache.org/jira/browse/FLINK-11218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919574#comment-16919574
]
lamber-ken commented on FLINK-11218:
Hi, [~till.rohrmann]. It's no problem.
> fix t
[
https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919417#comment-16919417
]
lamber-ken commented on FLINK-13787:
[~fly_in_gis] [~kaibo.zhou]
Hi，you can use thi
[
https://issues.apache.org/jira/browse/FLINK-11457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911889#comment-16911889
]
lamber-ken commented on FLINK-11457:
hi, [~opwvhk]
In our product env, we also met
[
https://issues.apache.org/jira/browse/FLINK-13787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911888#comment-16911888
]
lamber-ken commented on FLINK-13787:
hi, [~kaibo.zhou].
In our product env, we also
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16891015#comment-16891015
]
lamber-ken commented on FLINK-10052:
Hi [~quan]
This main point of this issue is ab
[
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 FLINK-1005
[
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 th
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16887276#comment-16887276
]
lamber-ken commented on FLINK-10052:
[~Tison],
btw, which way is better? update PR#
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16887268#comment-16887268
]
lamber-ken edited comment on FLINK-10052 at 7/17/19 5:28 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16887268#comment-16887268
]
lamber-ken commented on FLINK-10052:
[~Tison] yes, I checke the shaded class file by
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16886815#comment-16886815
]
lamber-ken commented on FLINK-10052:
[~Tison]，Ok, I see.
I had read the doc before
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16886699#comment-16886699
]
lamber-ken edited comment on FLINK-10052 at 7/17/19 6:01 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16886699#comment-16886699
]
lamber-ken commented on FLINK-10052:
[~Tison] (y), I have some points need to talk w
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1688#comment-1688
]
lamber-ken commented on FLINK-10052:
hi, [~Tison]
We can learn about the difference
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16886663#comment-16886663
]
lamber-ken edited comment on FLINK-10052 at 7/17/19 4:06 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16886663#comment-16886663
]
lamber-ken commented on FLINK-10052:
[~Tison], right, it's a better way to upgrate c
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16884567#comment-16884567
]
lamber-ken edited comment on FLINK-10052 at 7/14/19 5:30 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16884567#comment-16884567
]
lamber-ken edited comment on FLINK-10052 at 7/14/19 5:29 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16884567#comment-16884567
]
lamber-ken commented on FLINK-10052:
Hi, all.
BTW, if we upgrade curator dependenc
[
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 o
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882859#comment-16882859
]
lamber-ken commented on FLINK-10052:
Hi, all, I'm glad to fix this issue, when more
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882303#comment-16882303
]
lamber-ken edited comment on FLINK-10052 at 7/10/19 5:46 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882303#comment-16882303
]
lamber-ken commented on FLINK-10052:
Hi all, I'm very sorry that I created a duplica
[
https://issues.apache.org/jira/browse/FLINK-13189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882289#comment-16882289
]
lamber-ken commented on FLINK-13189:
Thanks for remind me that [~elevy]. We met this
[
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
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
Pro
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852775#comment-16852775
]
lamber-ken commented on FLINK-12302:
Thanks very match!
> Fixed the wrong finalStat
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849540#comment-16849540
]
lamber-ken edited comment on FLINK-12302 at 5/28/19 9:47 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849540#comment-16849540
]
lamber-ken commented on FLINK-12302:
By the way, can you help me to review my anothe
[
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 applic
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849537#comment-16849537
]
lamber-ken edited comment on FLINK-12302 at 5/28/19 9:43 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849537#comment-16849537
]
lamber-ken edited comment on FLINK-12302 at 5/28/19 9:42 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849537#comment-16849537
]
lamber-ken commented on FLINK-12302:
Hi [~gjy],
Thanks for your detail explain. I
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849071#comment-16849071
]
lamber-ken edited comment on FLINK-12302 at 5/27/19 4:53 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849080#comment-16849080
]
lamber-ken commented on FLINK-12302:
So, when the unexcepted scene happens, it displ
[
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 when
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849071#comment-16849071
]
lamber-ken edited comment on FLINK-12302 at 5/27/19 4:47 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849071#comment-16849071
]
lamber-ken edited comment on FLINK-12302 at 5/27/19 4:43 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849071#comment-16849071
]
lamber-ken edited comment on FLINK-12302 at 5/27/19 4:42 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849071#comment-16849071
]
lamber-ken edited comment on FLINK-12302 at 5/27/19 4:34 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849071#comment-16849071
]
lamber-ken commented on FLINK-12302:
[~gjy], from another side, we can analysis this
[
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)
> Fixed
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849038#comment-16849038
]
lamber-ken commented on FLINK-12302:
[~gjy], here my env files.
1,test jars --> [^t
[
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 fini
[
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 fini
[
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 finis
[
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 appli
[
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
> -
[
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 applic
[
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 appli
[
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 f
[
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
[
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 f
[
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
> -
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849010#comment-16849010
]
lamber-ken commented on FLINK-12302:
[~gjy], hi, can you show me your +flink-conf.ya
[
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 t
[
https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845457#comment-16845457
]
lamber-ken commented on FLINK-12558:
hi, thanks for assign this issue [~frank wang],
[
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
[
https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844434#comment-16844434
]
lamber-ken edited comment on FLINK-12558 at 5/21/19 1:37 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-12558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844434#comment-16844434
]
lamber-ken commented on FLINK-12558:
[~frank wang], I think the +FlinkJobNotFoundExc
[
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
socket,
[
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
> -
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: B
[
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()
> ---
[
https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840354#comment-16840354
]
lamber-ken commented on FLINK-12302:
[~gjy] this is an extreme example, but that ref
1 - 100 of 191 matches
Mail list logo
