Re: [VOTE] FLIP-118: Improve Flink’s ID system

+1, thanks for this FLIP! On Fri, Apr 17, 2020 at 1:16 PM Zhu Zhu wrote: > Thanks for proposing this improvement, Yangze. > > +1 (binding) > > Thanks, > Zhu Zhu > > Zhijiang 于2020年4月17日周五 下午12:36写道： > > > Thanks for this FLIP, Yangze. > > > > Sorry for not involving in the previous discussion.

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

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

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

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] [Created] (FLINK-15992) Incorrect classloader when finding TableFactory

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

[DISCUSS] FLINK-15447: Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

Hi, Currently, the "java.io.tmpdir" property of Flink on Yarn is set to "/tmp", which may cause exceptions in case of a full "/tmp" directory, especially when the user depends on some third-party libraries using "java.io.tmpdir" to store files. I would like to suggest to use the working directory

Re: Watermark options for TwoInputStreamOperator

Hi Jocean, How about assigning the control data stream with Long.MAX_VALUE as watermark? Best, Victor Jocean shi 于2019年12月25日周三 上午9:53写道： > Hi Congxian, > > It is not the same with Idling Source > > Best > Ocean > > Congxian Qiu 于2019年12月24日周二 下午4:39写道： > > > > Hi > > > > Maybe the doc[1] abo

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

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

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

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

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

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

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

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] [Created] (FLINK-14817) "Streaming Aggregation" document contains misleading code examples

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 Proj

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

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] [Created] (FLINK-14626) User jar packaged with hadoop dependencies may cause class conflit with hadoop jars on yarn

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] [Created] (FLINK-12648) Load Hadoop file system via FileSystem.get()

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] [Created] (FLINK-12646) Fix broken tests of RestClientTest

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] [Created] (FLINK-12472) Support setting attemptFailuresValidityInterval of jobs on Yarn

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

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] [Created] (FLINK-12459) YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should affect the order of classpath between user jars and flink jar

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: https://issues.apache.org/jira

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

Victor Wong created FLINK-12130: --- Summary: Apply command line options to configuration before install security modules Key: FLINK-12130 URL: https://issues.apache.org/jira/browse/FLINK-12130 Project