[jira] [Commented] (FLINK-14317) make hadoop history server logs accessible through flink ui

[ https://issues.apache.org/jira/browse/FLINK-14317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416277#comment-17416277 ] Ethan Li commented on FLINK-14317: -- Hello! May I ask what's the current plan for this? We have

[jira] [Comment Edited] (FLINK-17641) How to secure flink applications on yarn on multi-tenant environment

[ https://issues.apache.org/jira/browse/FLINK-17641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17236289#comment-17236289 ] Ethan Li edited comment on FLINK-17641 at 11/20/20, 5:06 PM: - Thanks very

[jira] [Commented] (FLINK-17641) How to secure flink applications on yarn on multi-tenant environment

[ https://issues.apache.org/jira/browse/FLINK-17641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17236289#comment-17236289 ] Ethan Li commented on FLINK-17641: -- Thanks very much for your reply [~rmetzger]. The suggestions are

[jira] [Created] (FLINK-17641) How to secure flink applications on yarn on multi-tenant environment

Ethan Li created FLINK-17641: Summary: How to secure flink applications on yarn on multi-tenant environment Key: FLINK-17641 URL: https://issues.apache.org/jira/browse/FLINK-17641 Project: Flink

[jira] [Comment Edited] (FLINK-16517) Add a long running WordCount example

[ https://issues.apache.org/jira/browse/FLINK-16517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061327#comment-17061327 ] Ethan Li edited comment on FLINK-16517 at 3/18/20, 2:26 AM: Thanks

[jira] [Comment Edited] (FLINK-16517) Add a long running WordCount example

[ https://issues.apache.org/jira/browse/FLINK-16517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061327#comment-17061327 ] Ethan Li edited comment on FLINK-16517 at 3/18/20, 2:26 AM: Thanks

[jira] [Comment Edited] (FLINK-16517) Add a long running WordCount example

[ https://issues.apache.org/jira/browse/FLINK-16517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061327#comment-17061327 ] Ethan Li edited comment on FLINK-16517 at 3/18/20, 2:25 AM: Thanks

[jira] [Commented] (FLINK-16517) Add a long running WordCount example

[ https://issues.apache.org/jira/browse/FLINK-16517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061327#comment-17061327 ] Ethan Li commented on FLINK-16517: -- Thanks [~aljoscha] I put up a pull request to add the new unbounded

[jira] [Comment Edited] (FLINK-16517) Add a long running WordCount example

[ https://issues.apache.org/jira/browse/FLINK-16517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056571#comment-17056571 ] Ethan Li edited comment on FLINK-16517 at 3/11/20, 1:31 AM: [~aljoscha] 

[jira] [Comment Edited] (FLINK-16517) Add a long running WordCount example

[ https://issues.apache.org/jira/browse/FLINK-16517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056571#comment-17056571 ] Ethan Li edited comment on FLINK-16517 at 3/11/20, 1:30 AM: [~aljoscha] 

[jira] [Commented] (FLINK-16517) Add a long running WordCount example

[ https://issues.apache.org/jira/browse/FLINK-16517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056571#comment-17056571 ] Ethan Li commented on FLINK-16517: -- [~aljoscha] Thanks for the link. I feel like it's still not simple

[jira] [Commented] (FLINK-16517) Add a long running WordCount example

[ https://issues.apache.org/jira/browse/FLINK-16517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055515#comment-17055515 ] Ethan Li commented on FLINK-16517: -- I will put up a pull request if you think this makes sense. > Add

[jira] [Updated] (FLINK-16517) Add a long running WordCount example

[ https://issues.apache.org/jira/browse/FLINK-16517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ethan Li updated FLINK-16517: - Description: As far as I know, flink doesn't have a long running WordCount example for users to start

[jira] [Created] (FLINK-16517) Add a long running WordCount example

Ethan Li created FLINK-16517: Summary: Add a long running WordCount example Key: FLINK-16517 URL: https://issues.apache.org/jira/browse/FLINK-16517 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17026777#comment-17026777 ] Ethan Li commented on FLINK-12122: -- bq. there are no plan to backport this feature to 1.8. Thanks

[jira] [Commented] (FLINK-15386) SingleJobSubmittedJobGraphStore.putJobGraph has a logic error

[ https://issues.apache.org/jira/browse/FLINK-15386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002910#comment-17002910 ] Ethan Li commented on FLINK-15386: -- I'd like to work on this if anyone can assign it to me. Thanks >

[jira] [Created] (FLINK-15386) SingleJobSubmittedJobGraphStore.putJobGraph has a logic error

Ethan Li created FLINK-15386: Summary: SingleJobSubmittedJobGraphStore.putJobGraph has a logic error Key: FLINK-15386 URL: https://issues.apache.org/jira/browse/FLINK-15386 Project: Flink Issue

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002369#comment-17002369 ] Ethan Li commented on FLINK-12122: -- Is there any plan to backport this to 1.8? > Spread out tasks

[jira] [Commented] (FLINK-13807) Flink-avro unit tests fails if the character encoding in the environment is not default to UTF-8

[ https://issues.apache.org/jira/browse/FLINK-13807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16912431#comment-16912431 ] Ethan Li commented on FLINK-13807: -- Thanks for fixing it. Sorry I am not able to test it in a short

[jira] [Updated] (FLINK-13807) Flink-avro unit tests fails if the character encoding in the environment is not default to UTF-8

[ https://issues.apache.org/jira/browse/FLINK-13807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ethan Li updated FLINK-13807: - Description: On Flink release-1.8 branch: {code:java} [ERROR] Tests run: 12, Failures: 4, Errors: 0,

[jira] [Created] (FLINK-13807) Flink-avro unit tests fails if the character encoding in the environment is not default to UTF-8

Ethan Li created FLINK-13807: Summary: Flink-avro unit tests fails if the character encoding in the environment is not default to UTF-8 Key: FLINK-13807 URL: https://issues.apache.org/jira/browse/FLINK-13807

[jira] [Commented] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster

[ https://issues.apache.org/jira/browse/FLINK-9684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16526449#comment-16526449 ] Ethan Li commented on FLINK-9684: - PR: https://github.com/apache/flink/pull/6225 >

[jira] [Created] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal

Ethan Li created FLINK-9685: --- Summary: Flink should support hostname-substitution for security.kerberos.login.principal Key: FLINK-9685 URL: https://issues.apache.org/jira/browse/FLINK-9685 Project: Flink

[jira] [Created] (FLINK-9684) HistoryServerArchiveFetcher not working properly with secure hdfs cluster

Ethan Li created FLINK-9684: --- Summary: HistoryServerArchiveFetcher not working properly with secure hdfs cluster Key: FLINK-9684 URL: https://issues.apache.org/jira/browse/FLINK-9684 Project: Flink

[jira] [Created] (FLINK-9683) inconsistent behaviors when setting historyserver.archive.fs.dir

Ethan Li created FLINK-9683: --- Summary: inconsistent behaviors when setting historyserver.archive.fs.dir Key: FLINK-9683 URL: https://issues.apache.org/jira/browse/FLINK-9683 Project: Flink Issue