[jira] [Updated] (FLINK-21045) Improve Usability of Pluggable Modules

[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-21045: --- Summary: Improve Usability of Pluggable Modules (was: Support 'load module' and 'unload

[jira] [Commented] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278794#comment-17278794 ] Nicholas Jiang commented on FLINK-21045: [~qingyue], I think that the title of this issue could

[jira] [Commented] (FLINK-21027) Add isStateKeyValueSerialized() method to KeyedStateBackend interface

[ https://issues.apache.org/jira/browse/FLINK-21027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278590#comment-17278590 ] Nicholas Jiang commented on FLINK-21027: [~jark], is the `isStateKeyValueSerialized()` API only

[jira] [Commented] (FLINK-21272) Resuming Savepoint (rocks, scale down, rocks timers) end-to-end test' Fail

[ https://issues.apache.org/jira/browse/FLINK-21272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278577#comment-17278577 ] Nicholas Jiang commented on FLINK-21272: [~maguowei], is this issue duplicated with 

[jira] [Commented] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278500#comment-17278500 ] Nicholas Jiang commented on FLINK-21236: [~ykt836], [~jark], I could replace `HeapMemorySegment`

[jira] [Commented] (FLINK-21210) ApplicationClusterEntryPoints should explicitly close PackagedProgram

[ https://issues.apache.org/jira/browse/FLINK-21210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275812#comment-17275812 ] Nicholas Jiang commented on FLINK-21210: [~chesnay], I have pushed a pull request for this

[jira] [Comment Edited] (FLINK-21172) canal-json format include es field

[ https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273411#comment-17273411 ] Nicholas Jiang edited comment on FLINK-21172 at 1/28/21, 8:32 AM: --

[jira] [Commented] (FLINK-21172) canal-json format include es field

[ https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273411#comment-17273411 ] Nicholas Jiang commented on FLINK-21172: [~jark], I would like to add the metadata key as

[jira] [Comment Edited] (FLINK-21172) canal-json format include es field

[ https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273411#comment-17273411 ] Nicholas Jiang edited comment on FLINK-21172 at 1/28/21, 8:31 AM: --

[jira] [Commented] (FLINK-21172) canal-json format include es field

[ https://issues.apache.org/jira/browse/FLINK-21172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273347#comment-17273347 ] Nicholas Jiang commented on FLINK-21172: I agree with the point of [~jiabao.sun][~jark].

[jira] [Comment Edited] (FLINK-21005) Introduce new provider for unified Sink API and implement in planner

[ https://issues.apache.org/jira/browse/FLINK-21005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272539#comment-17272539 ] Nicholas Jiang edited comment on FLINK-21005 at 1/28/21, 2:37 AM: --

[jira] [Commented] (FLINK-21005) Introduce new provider for unified Sink API and implement in planner

[ https://issues.apache.org/jira/browse/FLINK-21005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272539#comment-17272539 ] Nicholas Jiang commented on FLINK-21005: [~benjobs], if you aren't available for this issue, I

[jira] [Comment Edited] (FLINK-17572) Remove checkpoint alignment buffered metric from webui

[ https://issues.apache.org/jira/browse/FLINK-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272531#comment-17272531 ] Nicholas Jiang edited comment on FLINK-17572 at 1/27/21, 3:16 AM: --

[jira] [Commented] (FLINK-17572) Remove checkpoint alignment buffered metric from webui

[ https://issues.apache.org/jira/browse/FLINK-17572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272531#comment-17272531 ] Nicholas Jiang commented on FLINK-17572: [~chesnay], IMO, alignmentBuffered could be removed in

[jira] [Comment Edited] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271910#comment-17271910 ] Nicholas Jiang edited comment on FLINK-21045 at 1/26/21, 7:13 AM: --

[jira] [Commented] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271910#comment-17271910 ] Nicholas Jiang commented on FLINK-21045: [~qingyue][~jark], IMO, the WITH is more suitable to

[jira] [Commented] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17269304#comment-17269304 ] Nicholas Jiang commented on FLINK-21045: [~jark], I think [~qingyue] could work for this issue

[jira] [Commented] (FLINK-21069) Configuration "parallelism.default" doesn't take effect for TableEnvironment#explainSql

[ https://issues.apache.org/jira/browse/FLINK-21069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17269292#comment-17269292 ] Nicholas Jiang commented on FLINK-21069: [~jark], I could fix the bug to make configuration

[jira] [Commented] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17269273#comment-17269273 ] Nicholas Jiang commented on FLINK-21058: [~sunzheng], IMO, you could refer to SHOW PARTITIONS in

[jira] [Created] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

Nicholas Jiang created FLINK-21045: -- Summary: Support 'load module' and 'unload module' SQL syntax Key: FLINK-21045 URL: https://issues.apache.org/jira/browse/FLINK-21045 Project: Flink

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267759#comment-17267759 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong], I would follow your suggestion. Please

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267672#comment-17267672 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong], [~ZhenqiuHuang], thanks for the summary

[jira] [Updated] (FLINK-20953) Option 'canal-json.database.include' and 'canal-json.table.include' support regular expression

[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20953: --- Summary: Option 'canal-json.database.include' and 'canal-json.table.include' support

[jira] [Updated] (FLINK-20953) Option 'canal-json.database.include' and 'canal-json.table.include' supports regular expression

[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20953: --- Description: |h5. canal-json.database.include|optional|(none)|String|Only read changelog

[jira] [Updated] (FLINK-20953) Option 'canal-json.database.include' and 'canal-json.table.include' supports regular expression

[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20953: --- Summary: Option 'canal-json.database.include' and 'canal-json.table.include' supports

[jira] [Commented] (FLINK-19446) canal-json has a situation that -U and +U are equal, when updating the null field to be non-null

[ https://issues.apache.org/jira/browse/FLINK-19446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264602#comment-17264602 ] Nicholas Jiang commented on FLINK-19446: [~jark], if no one is available to work for this issue,

[jira] [Commented] (FLINK-20953) Option canal-json.table.include supports regular expression

[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264134#comment-17264134 ] Nicholas Jiang commented on FLINK-20953: [~jark], I could support the regular expression for

[jira] [Comment Edited] (FLINK-20953) Option canal-json.table.include supports regular expression

[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264134#comment-17264134 ] Nicholas Jiang edited comment on FLINK-20953 at 1/13/21, 1:10 PM: --

[jira] [Updated] (FLINK-20885) Deserialization exception when using 'canal-json.table.include' to filter out the binlog of the specified table

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20885: --- Summary: Deserialization exception when using 'canal-json.table.include' to filter out the

[jira] [Updated] (FLINK-20885) Parse exception when using 'canal-json.table.include' to filter out the binlog of the specified table

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20885: --- Summary: Parse exception when using 'canal-json.table.include' to filter out the binlog of

[jira] [Updated] (FLINK-20885) Parse exception when using 'canal-json.table.include' to filter Canal binlog

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20885: --- Summary: Parse exception when using 'canal-json.table.include' to filter Canal binlog

[jira] [Updated] (FLINK-20885) Exception when using 'canal-json.table.include' to filter Canal binlog

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20885: --- Summary: Exception when using 'canal-json.table.include' to filter Canal binlog (was:

[jira] [Updated] (FLINK-20953) Option canal-json.table.include supports regular expression

[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20953: --- Summary: Option canal-json.table.include supports regular expression (was: Option

[jira] [Updated] (FLINK-20953) Option canal-json.table.include supports regular or wildcard characters

[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20953: --- Summary: Option canal-json.table.include supports regular or wildcard characters (was:

[jira] [Commented] (FLINK-20953) canal-json.table.include Supports regular or wildcard characters

[ https://issues.apache.org/jira/browse/FLINK-20953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263966#comment-17263966 ] Nicholas Jiang commented on FLINK-20953: [~jark], IMO, the regular expression match for the

[jira] [Issue Comment Deleted] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20885: --- Comment: was deleted (was: [~wangfeiair2324], I operates the steps above you mentioned, but

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263929#comment-17263929 ] Nicholas Jiang commented on FLINK-20885: [~wangfeiair2324], I operates the steps above you

[jira] [Comment Edited] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263921#comment-17263921 ] Nicholas Jiang edited comment on FLINK-20885 at 1/13/21, 6:59 AM: --

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263921#comment-17263921 ] Nicholas Jiang commented on FLINK-20885: [~wangfeiair2324], do you confirm that the JSON above

[jira] [Comment Edited] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263913#comment-17263913 ] Nicholas Jiang edited comment on FLINK-20885 at 1/13/21, 6:43 AM: --

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263913#comment-17263913 ] Nicholas Jiang commented on FLINK-20885: [~wangfeiair2324], the "data" field in binlog record

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263851#comment-17263851 ] Nicholas Jiang commented on FLINK-20885: [~wangfeiair2324], could you please provide me with the

[jira] [Commented] (FLINK-20885) Exception when use 'canal-json.table.include' to filter Canal binlog but table contains 'source' column

[ https://issues.apache.org/jira/browse/FLINK-20885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17263315#comment-17263315 ] Nicholas Jiang commented on FLINK-20885: [~jark], I would like to work for this issue. Please

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260957#comment-17260957 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong], could the

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17259473#comment-17259473 ] Nicholas Jiang commented on FLINK-20811: [~fly_in_gis][~xintongsong], IMO, the second solution

[jira] [Comment Edited] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258036#comment-17258036 ] Nicholas Jiang edited comment on FLINK-20811 at 1/4/21, 7:48 AM: -

[jira] [Comment Edited] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258036#comment-17258036 ] Nicholas Jiang edited comment on FLINK-20811 at 1/4/21, 7:45 AM: -

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258036#comment-17258036 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong], is this issue duplicated with

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256800#comment-17256800 ] Nicholas Jiang commented on FLINK-20385: [~wangfeiair2324], this has already been merge into

[jira] [Comment Edited] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256472#comment-17256472 ] Nicholas Jiang edited comment on FLINK-20811 at 12/30/20, 11:39 AM:

[jira] [Comment Edited] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256472#comment-17256472 ] Nicholas Jiang edited comment on FLINK-20811 at 12/30/20, 11:32 AM:

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256472#comment-17256472 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong][~fly_in_gis][~zoucao], IMO, the changes

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256371#comment-17256371 ] Nicholas Jiang commented on FLINK-20811: [~xintongsong], if nobody work for this issue, I would

[jira] [Commented] (FLINK-17855) UDF with parameter Array(Row) can not work

[ https://issues.apache.org/jira/browse/FLINK-17855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255898#comment-17255898 ] Nicholas Jiang commented on FLINK-17855: [~jark], if no anybody work for this issue, I would

[jira] [Commented] (FLINK-20748) Remap excess slots to outstanding requirements

[ https://issues.apache.org/jira/browse/FLINK-20748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255864#comment-17255864 ] Nicholas Jiang commented on FLINK-20748: [~chesnay], IMO, DeclarativeSlotPool could add

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250158#comment-17250158 ] Nicholas Jiang commented on FLINK-20385: [~wangfeiair2324], I would push the pull request this

[jira] [Commented] (FLINK-20385) Allow to read metadata for Canal-json format

[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242228#comment-17242228 ] Nicholas Jiang commented on FLINK-20385: [~Leonard Xu], I could work for this issue which

[jira] [Commented] (FLINK-20425) Change exit code in FatalExitExceptionHandler to be different from JvmShutdownSafeguard

[ https://issues.apache.org/jira/browse/FLINK-20425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241478#comment-17241478 ] Nicholas Jiang commented on FLINK-20425: [~rmetzger], IMO, I agree with your point that

[jira] [Comment Edited] (FLINK-20289) Computed columns can be calculated after ChangelogNormalize to reduce shuffle

[ https://issues.apache.org/jira/browse/FLINK-20289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238118#comment-17238118 ] Nicholas Jiang edited comment on FLINK-20289 at 11/26/20, 3:20 AM: ---

[jira] [Commented] (FLINK-20250) NPE when invoking AsyncLookupJoinRunner#close method

[ https://issues.apache.org/jira/browse/FLINK-20250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238120#comment-17238120 ] Nicholas Jiang commented on FLINK-20250: [~hailong wang], are you working for this issue? If you

[jira] [Commented] (FLINK-20289) Computed columns can be calculated after ChangelogNormalize to reduce shuffle

[ https://issues.apache.org/jira/browse/FLINK-20289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238118#comment-17238118 ] Nicholas Jiang commented on FLINK-20289: [~jark], is this improvement that all computed column

[jira] [Comment Edited] (FLINK-20242) Support to set job name in StatementSet.execute() method

[ https://issues.apache.org/jira/browse/FLINK-20242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238007#comment-17238007 ] Nicholas Jiang edited comment on FLINK-20242 at 11/24/20, 10:06 AM:

[jira] [Commented] (FLINK-20242) Support to set job name in StatementSet.execute() method

[ https://issues.apache.org/jira/browse/FLINK-20242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238007#comment-17238007 ] Nicholas Jiang commented on FLINK-20242: [~zouyunhe], what is your business case to set a job

[jira] [Commented] (FLINK-20314) Empty Calc is not removed by CalcRemoveRule

[ https://issues.apache.org/jira/browse/FLINK-20314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237958#comment-17237958 ] Nicholas Jiang commented on FLINK-20314: [~bugboy], please translate your description of issue

[jira] [Commented] (FLINK-20260) YAML for SQL client only supports legacy interfaces

[ https://issues.apache.org/jira/browse/FLINK-20260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237846#comment-17237846 ] Nicholas Jiang commented on FLINK-20260: [~airblader], IMO, currently in

[jira] [Comment Edited] (FLINK-20280) Support batch mode for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237844#comment-17237844 ] Nicholas Jiang edited comment on FLINK-20280 at 11/24/20, 4:08 AM: ---

[jira] [Commented] (FLINK-20280) Support batch mode for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237844#comment-17237844 ] Nicholas Jiang commented on FLINK-20280: [~dian.fu], I previously worked for the support of

[jira] [Commented] (FLINK-20109) java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-20109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230609#comment-17230609 ] Nicholas Jiang commented on FLINK-20109: Recommend take this issue to user...@flink.apache.org.

[jira] [Issue Comment Deleted] (FLINK-20004) UpperLimitExceptionParameter description is misleading

[ https://issues.apache.org/jira/browse/FLINK-20004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20004: --- Comment: was deleted (was: [~f.pompermaier], you could refer to MessageQueryParameter. In

[jira] [Commented] (FLINK-20004) UpperLimitExceptionParameter description is misleading

[ https://issues.apache.org/jira/browse/FLINK-20004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229784#comment-17229784 ] Nicholas Jiang commented on FLINK-20004: [~f.pompermaier], you could refer to

[jira] [Commented] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229652#comment-17229652 ] Nicholas Jiang commented on FLINK-20013: [~AHeise], IMO, I think it should be backported to 1.11

[jira] [Issue Comment Deleted] (FLINK-19682) Actively timeout checkpoint barriers on the inputs

[ https://issues.apache.org/jira/browse/FLINK-19682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19682: --- Comment: was deleted (was: [~pnowojski], yeah, I'm very willing to work on that tight

[jira] [Commented] (FLINK-20020) Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract.

[ https://issues.apache.org/jira/browse/FLINK-20020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17229021#comment-17229021 ] Nicholas Jiang commented on FLINK-20020: [~kkl0u], I agree with your point above mentioned that

[jira] [Commented] (FLINK-19989) Add collect operation in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227351#comment-17227351 ] Nicholas Jiang commented on FLINK-19989: [~dian.fu], could you please assign this issue to me?

[jira] [Comment Edited] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227227#comment-17227227 ] Nicholas Jiang edited comment on FLINK-20013 at 11/6/20, 11:34 AM: ---

[jira] [Comment Edited] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227265#comment-17227265 ] Nicholas Jiang edited comment on FLINK-20013 at 11/6/20, 11:12 AM: ---

[jira] [Comment Edited] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227265#comment-17227265 ] Nicholas Jiang edited comment on FLINK-20013 at 11/6/20, 11:11 AM: ---

[jira] [Commented] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227265#comment-17227265 ] Nicholas Jiang commented on FLINK-20013: [~zhuzh], when task is failed or canceled, the current

[jira] [Commented] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227227#comment-17227227 ] Nicholas Jiang commented on FLINK-20013: [~zhuzh], I have already offline discussed with

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19984: --- Description: Currently we have TypeInfoTestCoverageTest which checks that we have a test

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19984: --- Description: Currently we have TypeInfoTestCoverageTest which checks that we have a test

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19984: --- Affects Version/s: 1.12.0 > Add TypeSerializerTestCoverageTest to check whether tests based

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19984: --- Fix Version/s: (was: 1.12.0) > Add TypeSerializerTestCoverageTest to check whether

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19984: --- Description: Currently we have TypeInfoTestCoverageTest which checks that we have a test

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19984: --- Fix Version/s: 1.12.0 > Add TypeSerializerTestCoverageTest to check whether tests based on

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19984: --- Component/s: API / Core > Add TypeSerializerTestCoverageTest to check whether tests based

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19984: --- Description: Currently we have TypeInfoTestCoverageTest which checks that we have a test

[jira] [Created] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

Nicholas Jiang created FLINK-19984: -- Summary: Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase Key: FLINK-19984 URL:

[jira] [Commented] (FLINK-19949) Unescape CSV format line delimiter character

[ https://issues.apache.org/jira/browse/FLINK-19949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225246#comment-17225246 ] Nicholas Jiang commented on FLINK-19949: [~jark], I thought this issue wouldn't be fixed after

[jira] [Issue Comment Deleted] (FLINK-19868) Csv Serialization schema contains line delimiter

[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19868: --- Comment: was deleted (was: I agree with [~jark] the point that remove csv.line-delimiter

[jira] [Commented] (FLINK-19868) Csv Serialization schema contains line delimiter

[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223462#comment-17223462 ] Nicholas Jiang commented on FLINK-19868: I agree with [~jark] the point that remove

[jira] [Commented] (FLINK-19892) Replace __metaclass__ field with metaclass keyword

[ https://issues.apache.org/jira/browse/FLINK-19892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223443#comment-17223443 ] Nicholas Jiang commented on FLINK-19892: [~hxbks2ks], have you already completed for this issue?

[jira] [Commented] (FLINK-19837) Don't emit intermediate watermarks from watermark operators in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-19837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222060#comment-17222060 ] Nicholas Jiang commented on FLINK-19837: [~aljoscha], okay, wait for your PR ready. Thanks. >

[jira] [Commented] (FLINK-19842) PyFlinkStreamUserDefinedTableFunctionTests.test_table_function_with_sql_query is unstable

[ https://issues.apache.org/jira/browse/FLINK-19842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221879#comment-17221879 ] Nicholas Jiang commented on FLINK-19842: cc [~dianfu], [~hxbks2ks] >

[jira] [Commented] (FLINK-19837) Don't emit intermediate watermarks from watermark operators in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-19837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221875#comment-17221875 ] Nicholas Jiang commented on FLINK-19837: [~aljoscha], I could work for this issue. Could you

[jira] [Comment Edited] (FLINK-19833) Rename Sink API Writer interface to SinkWriter

[ https://issues.apache.org/jira/browse/FLINK-19833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221404#comment-17221404 ] Nicholas Jiang edited comment on FLINK-19833 at 10/28/20, 12:51 AM:

[jira] [Commented] (FLINK-19833) Rename Sink API Writer interface to SinkWriter

[ https://issues.apache.org/jira/browse/FLINK-19833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221404#comment-17221404 ] Nicholas Jiang commented on FLINK-19833: [~aljoscha], does this issue simply rename the Writer

[jira] [Comment Edited] (FLINK-19682) Actively timeout checkpoint barriers on the inputs

[ https://issues.apache.org/jira/browse/FLINK-19682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221371#comment-17221371 ] Nicholas Jiang edited comment on FLINK-19682 at 10/27/20, 12:29 PM:

[jira] [Commented] (FLINK-19682) Actively timeout checkpoint barriers on the inputs

[ https://issues.apache.org/jira/browse/FLINK-19682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221371#comment-17221371 ] Nicholas Jiang commented on FLINK-19682: [~pnowojski], yeah, I'm very willing to do this. I come

[jira] [Comment Edited] (FLINK-19682) Actively timeout checkpoint barriers on the inputs

[ https://issues.apache.org/jira/browse/FLINK-19682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221230#comment-17221230 ] Nicholas Jiang edited comment on FLINK-19682 at 10/27/20, 12:00 PM:

<    1   2   3   4   5   6   7   >