[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

2020-12-06 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244953#comment-17244953 ] Victor Wong commented on FLINK-12130: - [~lingyaKK], thanks for your time! [~aljoscha], could you

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

2020-12-01 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241404#comment-17241404 ] Victor Wong commented on FLINK-12130: - [~lingyaKK],[~zhouqi], hi, I come up with a new PR,

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

2020-11-12 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231204#comment-17231204 ] Victor Wong commented on FLINK-12130: - [~lingyaKK][~zhouqi] Very sorry, I haven't worked on this

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

2020-08-24 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183280#comment-17183280 ] Victor Wong commented on FLINK-12130: - [~aljoscha] I'd like to help, what about a new PR based on

[jira] [Created] (FLINK-16884) The "rest.port" configuration is always "0" with flink-yarn jobs

2020-03-31 Thread Victor Wong (Jira)
Victor Wong created FLINK-16884: --- Summary: The "rest.port" configuration is always "0" with flink-yarn jobs Key: FLINK-16884 URL: https://issues.apache.org/jira/browse/FLINK-16884 Project: Flink

[jira] [Commented] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

2020-03-19 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063064#comment-17063064 ] Victor Wong commented on FLINK-15447: - Currently, we can solve this issue through "env.java.opts:

[jira] [Closed] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

2020-03-19 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong closed FLINK-15447. --- Resolution: Not A Problem > To improve utilization of the `java.io.tmpdir` for YARN module >

[jira] [Commented] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

2020-03-06 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053156#comment-17053156 ] Victor Wong commented on FLINK-15447: - Hi, [~trohrmann], since this issue is still valid against the

[jira] [Commented] (FLINK-16376) Using consistent method to get Yarn application directory

2020-03-05 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052688#comment-17052688 ] Victor Wong commented on FLINK-16376: - Hi, [~trohrmann], the PR is attached. > Using consistent

[jira] [Updated] (FLINK-16376) Using consistent method to get Yarn application directory

2020-03-02 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-16376: Description: The Yarn application directory of Flink is "/user/{user.name}/.flink", but this

[jira] [Created] (FLINK-16376) Using consistent method to get Yarn application directory

2020-03-02 Thread Victor Wong (Jira)
Victor Wong created FLINK-16376: --- Summary: Using consistent method to get Yarn application directory Key: FLINK-16376 URL: https://issues.apache.org/jira/browse/FLINK-16376 Project: Flink

[jira] [Commented] (FLINK-15992) Incorrect classloader when finding TableFactory

2020-02-21 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041731#comment-17041731 ] Victor Wong commented on FLINK-15992: - [~jark] ok, sorry for the inconvenience caused by this PR:(

[jira] [Commented] (FLINK-15992) Incorrect classloader when finding TableFactory

2020-02-11 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034961#comment-17034961 ] Victor Wong commented on FLINK-15992: - [~jark], thanks Jark, I will open a PR for this and ping you

[jira] [Commented] (FLINK-15992) Incorrect classloader when finding TableFactory

2020-02-11 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034349#comment-17034349 ] Victor Wong commented on FLINK-15992: - That's right, we can just remove the

[jira] [Updated] (FLINK-15992) Incorrect classloader when finding TableFactory

2020-02-11 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-15992: Description: *Background* As a streaming service maintainer in our company, to ensure our users

[jira] [Created] (FLINK-15992) Incorrect classloader when finding TableFactory

2020-02-11 Thread Victor Wong (Jira)
Victor Wong created FLINK-15992: --- Summary: Incorrect classloader when finding TableFactory Key: FLINK-15992 URL: https://issues.apache.org/jira/browse/FLINK-15992 Project: Flink Issue Type:

[jira] [Commented] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

2020-02-02 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028644#comment-17028644 ] Victor Wong commented on FLINK-15447: - [~trohrmann], thanks for your attention.  _I am wondering

[jira] [Commented] (FLINK-15449) Retain lost task managers on Flink UI

2020-02-02 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028639#comment-17028639 ] Victor Wong commented on FLINK-15449: - [~chesnay], as suggested by [~fly_in_gis], we could _use the

[jira] [Commented] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

2020-01-23 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021862#comment-17021862 ] Victor Wong commented on FLINK-15447: - [~fly_in_gis], it makes sense to make "java.io.tmpdir"

[jira] [Commented] (FLINK-14642) Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values

2020-01-23 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021859#comment-17021859 ] Victor Wong commented on FLINK-14642: - [~liuyufei] if I understand correctly, the Tuple and

[jira] [Commented] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

2020-01-23 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021858#comment-17021858 ] Victor Wong commented on FLINK-15447: - [~rongr] updated this issue based on your suggestion. Could

[jira] [Updated] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

2020-01-23 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-15447: Description: *#Background* Currently, when running Flink on Yarn, the "java.io.tmpdir" property

[jira] [Updated] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

2020-01-23 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-15447: Description: # *Background* Currently, when running Flink on Yarn, the "java.io.tmpdir" property

[jira] [Updated] (FLINK-15447) To improve utilization of the `java.io.tmpdir` for YARN module

2020-01-23 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-15447: Summary: To improve utilization of the `java.io.tmpdir` for YARN module (was: Change

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2020-01-18 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018792#comment-17018792 ] Victor Wong commented on FLINK-15447: - [~fly_in_gis] the owner of the working directory of Yarn

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2020-01-18 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018790#comment-17018790 ] Victor Wong edited comment on FLINK-15447 at 1/19/20 4:24 AM: -- [~rongr] for

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2020-01-18 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018790#comment-17018790 ] Victor Wong edited comment on FLINK-15447 at 1/19/20 4:23 AM: -- [~rongr] for

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2020-01-18 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018790#comment-17018790 ] Victor Wong commented on FLINK-15447: - [~rongr] for me #2 is most close to the main concern, but we

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2020-01-17 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018462#comment-17018462 ] Victor Wong edited comment on FLINK-15447 at 1/18/20 1:41 AM: -- [~rongr]

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2020-01-17 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018462#comment-17018462 ] Victor Wong edited comment on FLINK-15447 at 1/18/20 1:40 AM: -- [~rongr]

[jira] [Comment Edited] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2020-01-17 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018462#comment-17018462 ] Victor Wong edited comment on FLINK-15447 at 1/18/20 1:40 AM: -- [~rongr]

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2020-01-17 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018462#comment-17018462 ] Victor Wong commented on FLINK-15447: - [~rongr] Thanks for your reply! _Could you elaborate what

[jira] [Commented] (FLINK-15448) Log host informations for TaskManager failures.

2020-01-08 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011475#comment-17011475 ] Victor Wong commented on FLINK-15448: - [~trohrmann] I haven't done this before, but if you guys are

[jira] [Commented] (FLINK-15448) Log host informations for TaskManager failures.

2020-01-08 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010590#comment-17010590 ] Victor Wong commented on FLINK-15448: - [~zhuzh] different ResourceID could have constructors with

[jira] [Commented] (FLINK-15448) Log host informations for TaskManager failures.

2020-01-08 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010485#comment-17010485 ] Victor Wong commented on FLINK-15448: - I agreed that using extended ResourceID would be a great

[jira] [Updated] (FLINK-15448) Log host informations for TaskManager failures.

2020-01-07 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-15448: Labels: (was: pull-request-available) > Log host informations for TaskManager failures. >

[jira] [Updated] (FLINK-15448) Log host informations for TaskManager failures.

2020-01-07 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-15448: Labels: (was: pull-request-available) > Log host informations for TaskManager failures. >

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2020-01-02 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007267#comment-17007267 ] Victor Wong commented on FLINK-15447: - [~yunta], [~lzljs3620320], sorry to ping you guys, I'd like

[jira] [Commented] (FLINK-15450) Add kafka topic information to Kafka source name on Flink UI

2020-01-02 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007265#comment-17007265 ] Victor Wong commented on FLINK-15450: - Any suggestion on this:) > Add kafka topic information to

[jira] [Commented] (FLINK-15448) Log host informations for TaskManager failures.

2020-01-02 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007263#comment-17007263 ] Victor Wong commented on FLINK-15448: - [~zhuzh], sorry for my late response, my personal initial

[jira] [Commented] (FLINK-15448) Log host informations for TaskManager failures.

2020-01-02 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006726#comment-17006726 ] Victor Wong commented on FLINK-15448: - [~zhuzh], with a long-running job it's actually quite not

[jira] [Commented] (FLINK-15448) Make "ResourceID#toString" more descriptive

2020-01-02 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006663#comment-17006663 ] Victor Wong commented on FLINK-15448: - [~xintongsong], thanks for your patient explanation,

[jira] [Updated] (FLINK-15450) Add kafka topic information to Kafka source name on Flink UI

2020-01-01 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-15450: Component/s: API / Core > Add kafka topic information to Kafka source name on Flink UI >

[jira] [Commented] (FLINK-15448) Make "ResourceID#toString" more descriptive

2020-01-01 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006609#comment-17006609 ] Victor Wong commented on FLINK-15448: - [~xintongsong], thanks for your reply, I think your concern

[jira] [Commented] (FLINK-15449) Retain lost task managers on Flink UI

2020-01-01 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006573#comment-17006573 ] Victor Wong commented on FLINK-15449: - Nice suggestion! We could add the constructed log URL (the

[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2020-01-01 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006558#comment-17006558 ] Victor Wong commented on FLINK-15447: - [~yunta] [~klion26] Thanks for your reply :) _What caused

[jira] [Updated] (FLINK-15450) Add kafka topic information to Kafka source name on Flink UI

2019-12-31 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-15450: Description: If the user did not specify a custom name to the source, e.g. Kafka source, Flink

[jira] [Updated] (FLINK-15450) Add kafka topic information to Kafka source name on Flink UI

2019-12-31 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-15450: Summary: Add kafka topic information to Kafka source name on Flink UI (was: Add kafka topic

[jira] [Created] (FLINK-15450) Add kafka topic information to Kafka source

2019-12-31 Thread Victor Wong (Jira)
Victor Wong created FLINK-15450: --- Summary: Add kafka topic information to Kafka source Key: FLINK-15450 URL: https://issues.apache.org/jira/browse/FLINK-15450 Project: Flink Issue Type:

[jira] [Created] (FLINK-15449) Retain lost task managers on Flink UI

2019-12-31 Thread Victor Wong (Jira)
Victor Wong created FLINK-15449: --- Summary: Retain lost task managers on Flink UI Key: FLINK-15449 URL: https://issues.apache.org/jira/browse/FLINK-15449 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15448) Make "ResourceID#toString" more descriptive

2019-12-31 Thread Victor Wong (Jira)
Victor Wong created FLINK-15448: --- Summary: Make "ResourceID#toString" more descriptive Key: FLINK-15448 URL: https://issues.apache.org/jira/browse/FLINK-15448 Project: Flink Issue Type:

[jira] [Updated] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2019-12-31 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-15447: Description: Currently, when running Flink on Yarn, the "java.io.tmpdir" property is set to the

[jira] [Created] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

2019-12-31 Thread Victor Wong (Jira)
Victor Wong created FLINK-15447: --- Summary: Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp" Key: FLINK-15447 URL: https://issues.apache.org/jira/browse/FLINK-15447 Project: Flink

[jira] [Closed] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

2019-11-29 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong closed FLINK-14835. --- Resolution: Abandoned > Make `org.apache.flink.configuration.Configuration` support method chaining

[jira] [Commented] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

2019-11-29 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984971#comment-16984971 ] Victor Wong commented on FLINK-14835: - That's great:) > Make

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

2019-11-26 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983089#comment-16983089 ] Victor Wong commented on FLINK-14653: - _"introduce a new exception which users can throw to indicate

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

2019-11-26 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982434#comment-16982434 ] Victor Wong commented on FLINK-14653: - [~mxm], any progress on this? I have some solutions, do you

[jira] [Commented] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

2019-11-26 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982317#comment-16982317 ] Victor Wong commented on FLINK-14835: - [~jark], after changing the return type of `Configuration`,

[jira] [Commented] (FLINK-14817) "Streaming Aggregation" document contains misleading code examples

2019-11-26 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982285#comment-16982285 ] Victor Wong commented on FLINK-14817: - [~jark], the PR is ready, could you take a look when

[jira] [Commented] (FLINK-14817) "Streaming Aggregation" document contains misleading code examples

2019-11-17 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976257#comment-16976257 ] Victor Wong commented on FLINK-14817: - [~jark], thanks for your quick reply. Please assign this

[jira] [Updated] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

2019-11-17 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14835: Description: *Goal:* To make the following code examples work in production, which is very handy

[jira] [Updated] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

2019-11-17 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14835: Description: To make the following code examples work in production, which is very handy for

[jira] [Updated] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

2019-11-17 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14835: External issue URL: (was: https://issues.apache.org/jira/browse/FLINK-14817) > Make

[jira] [Created] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

2019-11-17 Thread Victor Wong (Jira)
Victor Wong created FLINK-14835: --- Summary: Make `org.apache.flink.configuration.Configuration` support method chaining Key: FLINK-14835 URL: https://issues.apache.org/jira/browse/FLINK-14835 Project:

[jira] [Updated] (FLINK-14817) "Streaming Aggregation" document contains misleading code examples

2019-11-15 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14817: Description: In the document of [Streaming Aggregation

[jira] [Updated] (FLINK-14817) "Streaming Aggregation" document contains misleading code examples

2019-11-15 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14817: Description: In the document of [Streaming

[jira] [Updated] (FLINK-14817) "Streaming Aggregation" document contains misleading code examples

2019-11-15 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14817: Description: In the document of [Streaming Aggregation |

[jira] [Created] (FLINK-14817) "Streaming Aggregation" document contains misleading code examples

2019-11-15 Thread Victor Wong (Jira)
Victor Wong created FLINK-14817: --- Summary: "Streaming Aggregation" document contains misleading code examples Key: FLINK-14817 URL: https://issues.apache.org/jira/browse/FLINK-14817 Project: Flink

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

2019-11-08 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16970104#comment-16970104 ] Victor Wong commented on FLINK-14653: - Thanks for your explanation, now I think it makes sense. >

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

2019-11-08 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969976#comment-16969976 ] Victor Wong commented on FLINK-14653: - _"I'm ok with tolerating checkpointing failures, but not ok

[jira] [Commented] (FLINK-14642) Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values

2019-11-08 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969921#comment-16969921 ] Victor Wong commented on FLINK-14642: - [~sewen], here is the PR, 

[jira] [Commented] (FLINK-14653) Job-related errors in snapshotState do not result in job failure

2019-11-07 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969910#comment-16969910 ] Victor Wong commented on FLINK-14653: - [~mxm], if

[jira] [Closed] (FLINK-14626) User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn

2019-11-07 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong closed FLINK-14626. --- Resolution: Invalid > User jar packaged with hadoop dependencies may cause class conflit with >

[jira] [Comment Edited] (FLINK-14626) User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn

2019-11-07 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969388#comment-16969388 ] Victor Wong edited comment on FLINK-14626 at 11/7/19 4:20 PM: -- [~chesnay],

[jira] [Commented] (FLINK-14626) User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn

2019-11-07 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969388#comment-16969388 ] Victor Wong commented on FLINK-14626: - [~chesnay], thanks for your quick response. As an engineer

[jira] [Commented] (FLINK-14642) Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values

2019-11-07 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16969369#comment-16969369 ] Victor Wong commented on FLINK-14642: - [~sewen], sure I will ping you once PR is ready:) > Flink

[jira] [Updated] (FLINK-14642) Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values

2019-11-06 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14642: Description: Currently, TupleSerializer and CaseCassSerializer do not support serialize NULL

[jira] [Created] (FLINK-14642) Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values

2019-11-06 Thread Victor Wong (Jira)
Victor Wong created FLINK-14642: --- Summary: Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values Key: FLINK-14642 URL: https://issues.apache.org/jira/browse/FLINK-14642 Project:

[jira] [Closed] (FLINK-12130) Apply command line options to configuration before installing security modules

2019-11-06 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong closed FLINK-12130. --- Resolution: Won't Fix > Apply command line options to configuration before installing security

[jira] [Closed] (FLINK-12648) Load Hadoop file system via org.apache.hadoop.fs.FileSystem.get()

2019-11-06 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong closed FLINK-12648. --- Resolution: Won't Fix > Load Hadoop file system via org.apache.hadoop.fs.FileSystem.get() >

[jira] [Created] (FLINK-14626) User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn

2019-11-05 Thread Victor Wong (Jira)
Victor Wong created FLINK-14626: --- Summary: User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn Key: FLINK-14626 URL: https://issues.apache.org/jira/browse/FLINK-14626

[jira] [Commented] (FLINK-13749) Make Flink client respect classloading policy

2019-11-05 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967429#comment-16967429 ] Victor Wong commented on FLINK-13749: - Any progress on this? If the Assignee is busy, I'd love to

[jira] [Commented] (FLINK-13586) Method ClosureCleaner.clean broke backward compatibility between 1.8.0 and 1.8.1

2019-08-06 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16901096#comment-16901096 ] Victor Wong commented on FLINK-13586: - I think it would be helpful to attach [mail

[jira] [Commented] (FLINK-13586) Method ClosureCleaner.clean broke backward compatibility between 1.8.0 and 1.8.1

2019-08-05 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900142#comment-16900142 ] Victor Wong commented on FLINK-13586: - Hi Gaël, could you assign this ticket to me, so I can come up

[jira] [Commented] (FLINK-12646) Fix broken tests of RestClientTest

2019-06-07 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16859022#comment-16859022 ] Victor Wong commented on FLINK-12646: - I'd love to, [https://github.com/apache/flink/pull/8663] >

[jira] [Updated] (FLINK-12648) Load Hadoop file system via org.apache.hadoop.fs.FileSystem.get()

2019-05-28 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12648: Summary: Load Hadoop file system via org.apache.hadoop.fs.FileSystem.get() (was: Load Hadoop

[jira] [Created] (FLINK-12648) Load Hadoop file system via FileSystem.get()

2019-05-28 Thread Victor Wong (JIRA)
Victor Wong created FLINK-12648: --- Summary: Load Hadoop file system via FileSystem.get() Key: FLINK-12648 URL: https://issues.apache.org/jira/browse/FLINK-12648 Project: Flink Issue Type:

[jira] [Updated] (FLINK-12646) Fix broken tests of RestClientTest

2019-05-28 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12646: Description: In {code:java} org.apache.flink.runtime.rest.RestClientTest#testConnectionTimeout

[jira] [Updated] (FLINK-12646) Fix broken tests of RestClientTest

2019-05-28 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12646: Description: In {code:java} org.apache.flink.runtime.rest.RestClientTest#testConnectionTimeout

[jira] [Updated] (FLINK-12646) Fix broken tests of RestClientTest

2019-05-28 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12646: Description: In {code:java} org.apache.flink.runtime.rest.RestClientTest#testConnectionTimeout

[jira] [Updated] (FLINK-12646) Fix broken tests of RestClientTest

2019-05-28 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12646: Description: In {code:java} // code placeholder {code}

[jira] [Created] (FLINK-12646) Fix broken tests of RestClientTest

2019-05-28 Thread Victor Wong (JIRA)
Victor Wong created FLINK-12646: --- Summary: Fix broken tests of RestClientTest Key: FLINK-12646 URL: https://issues.apache.org/jira/browse/FLINK-12646 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-12459) YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should affect the order of classpath between user jars and flink jars

2019-05-09 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12459: Description: When setting YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR to "LAST", I think the

[jira] [Updated] (FLINK-12459) YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should affect the order of classpath between user jars and flink jars

2019-05-09 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12459: Description: When setting YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR to "LAST", I think the

[jira] [Created] (FLINK-12472) Support setting attemptFailuresValidityInterval of jobs on Yarn

2019-05-09 Thread Victor Wong (JIRA)
Victor Wong created FLINK-12472: --- Summary: Support setting attemptFailuresValidityInterval of jobs on Yarn Key: FLINK-12472 URL: https://issues.apache.org/jira/browse/FLINK-12472 Project: Flink

[jira] [Created] (FLINK-12468) Unregister application from the YARN Resource Manager with a valid appTrackingUrl

2019-05-09 Thread Victor Wong (JIRA)
Victor Wong created FLINK-12468: --- Summary: Unregister application from the YARN Resource Manager with a valid appTrackingUrl Key: FLINK-12468 URL: https://issues.apache.org/jira/browse/FLINK-12468

[jira] [Updated] (FLINK-12459) YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should affect the order of classpath between user jars and flink jars

2019-05-09 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12459: Summary: YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should affect the order of classpath

[jira] [Updated] (FLINK-12459) YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should affect the order of classpath between user jars and flink jar

2019-05-09 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-12459: Description: When setting YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR to "LAST", I think the

[jira] [Created] (FLINK-12459) YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should affect the order of classpath between user jars and flink jar

2019-05-09 Thread Victor Wong (JIRA)
Victor Wong created FLINK-12459: --- Summary: YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should affect the order of classpath between user jars and flink jar Key: FLINK-12459 URL:

[jira] [Comment Edited] (FLINK-12130) Apply command line options to configuration before installing security modules

2019-04-18 Thread Victor Wong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16817050#comment-16817050 ] Victor Wong edited comment on FLINK-12130 at 4/19/19 1:20 AM: -- Hi 

  1   2   >