[jira] [Comment Edited] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185585#comment-17185585 ] Nicholas Jiang edited comment on FLINK-19038 at 8/29/20, 8:50 AM: --

[jira] [Issue Comment Deleted] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-19064: --- Comment: was deleted (was: [~ZhuShang] Please pay attention to the defintion of method 

[jira] [Comment Edited] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186232#comment-17186232 ] Nicholas Jiang edited comment on FLINK-19064 at 8/28/20, 3:22 AM: --

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186232#comment-17186232 ] Nicholas Jiang commented on FLINK-19064: [~ZhuShang] Please pay attention to the defintion of

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186224#comment-17186224 ] Nicholas Jiang commented on FLINK-19064: [~jark] I guess the meaning of [~ZhuShang] is that the

[jira] [Comment Edited] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

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

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186197#comment-17186197 ] Nicholas Jiang commented on FLINK-19064: [~jark] Yes of course. Could you assign this to me? >

[jira] [Comment Edited] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185856#comment-17185856 ] Nicholas Jiang edited comment on FLINK-19064 at 8/27/20, 1:56 PM: --

[jira] [Commented] (FLINK-19064) HBaseRowDataInputFormat is leaking resources

[ https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185856#comment-17185856 ] Nicholas Jiang commented on FLINK-19064: [~rmetzger] HBaseRowDataInputFormat should create

[jira] [Comment Edited] (FLINK-19038) It doesn't support to call Table.limit() continuously

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

[jira] [Comment Edited] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185585#comment-17185585 ] Nicholas Jiang edited comment on FLINK-19038 at 8/27/20, 5:40 AM: --

[jira] [Comment Edited] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185585#comment-17185585 ] Nicholas Jiang edited comment on FLINK-19038 at 8/27/20, 3:37 AM: --

[jira] [Comment Edited] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185585#comment-17185585 ] Nicholas Jiang edited comment on FLINK-19038 at 8/27/20, 3:37 AM: --

[jira] [Commented] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185585#comment-17185585 ] Nicholas Jiang commented on FLINK-19038: [~twalthr],[~dwysakowicz],   {code:java} private

[jira] [Commented] (FLINK-19049) TableEnvironmentImpl.executeInternal() does not wait for the final job status

[ https://issues.apache.org/jira/browse/FLINK-19049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185024#comment-17185024 ] Nicholas Jiang commented on FLINK-19049: [~rmetzger] The entire definition of executeSql is

[jira] [Comment Edited] (FLINK-19049) TableEnvironmentImpl.executeInternal() does not wait for the final job status

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

[jira] [Commented] (FLINK-19049) TableEnvironmentImpl.executeInternal() does not wait for the final job status

[ https://issues.apache.org/jira/browse/FLINK-19049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185008#comment-17185008 ] Nicholas Jiang commented on FLINK-19049: [~rmetzger] I thought that the user could get table

[jira] [Commented] (FLINK-19049) TableEnvironmentImpl.executeInternal() does not wait for the final job status

[ https://issues.apache.org/jira/browse/FLINK-19049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17184989#comment-17184989 ] Nicholas Jiang commented on FLINK-19049: [~rmetzger] Do you mean that it should check the job

[jira] [Updated] (FLINK-18258) Implement SHOW PARTITIONS for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-18258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-18258: --- Fix Version/s: 1.12.0 > Implement SHOW PARTITIONS for Hive dialect >

[jira] [Commented] (FLINK-18900) HiveCatalog should error out when listing partitions with an invalid spec

[ https://issues.apache.org/jira/browse/FLINK-18900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176173#comment-17176173 ] Nicholas Jiang commented on FLINK-18900: [~lzljs3620320] Could you please assign this to me? I

[jira] [Commented] (FLINK-18823) Support serialization for debezium-json format

[ https://issues.apache.org/jira/browse/FLINK-18823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171333#comment-17171333 ] Nicholas Jiang commented on FLINK-18823: Hi, [~jark], could you please assign this to me? I

[jira] [Issue Comment Deleted] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-18816: --- Comment: was deleted (was: [~sunjincheng121]Could you please assign this to me?) > Correct

[jira] [Commented] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171231#comment-17171231 ] Nicholas Jiang commented on FLINK-18816: [~sunjincheng121]Could you please assign this to me? >

[jira] [Issue Comment Deleted] (FLINK-18407) NPE in SlotPoolImpl.maybeRemapOrphanedAllocation if no pending request is registered

[ https://issues.apache.org/jira/browse/FLINK-18407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-18407: --- Comment: was deleted (was: [~zhuzh], I just want to add the null check for the pending

[jira] [Commented] (FLINK-18407) NPE in SlotPoolImpl.maybeRemapOrphanedAllocation if no pending request is registered

[ https://issues.apache.org/jira/browse/FLINK-18407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141955#comment-17141955 ] Nicholas Jiang commented on FLINK-18407: [~zhuzh], I just want to add the null check for the

[jira] [Commented] (FLINK-18378) CatalogManager checks for CatalogTableImpl instead of CatalogTable

[ https://issues.apache.org/jira/browse/FLINK-18378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141933#comment-17141933 ] Nicholas Jiang commented on FLINK-18378: [~dwysakowicz] Thanks for the explanation! >

[jira] [Commented] (FLINK-18407) NPE in SlotPoolImpl.maybeRemapOrphanedAllocation if no pending request is registered

[ https://issues.apache.org/jira/browse/FLINK-18407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141932#comment-17141932 ] Nicholas Jiang commented on FLINK-18407: [~trohrmann], do you mean that get pending request

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

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

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

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

[jira] [Commented] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

[ https://issues.apache.org/jira/browse/FLINK-18347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140916#comment-17140916 ] Nicholas Jiang commented on FLINK-18347: [~chesnay], user's project doesn't contain fragments

[jira] [Commented] (FLINK-18258) Implement SHOW PARTITIONS for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-18258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140534#comment-17140534 ] Nicholas Jiang commented on FLINK-18258: [~lzljs3620320], [~lirui] could you please assign this

[jira] [Issue Comment Deleted] (FLINK-18378) CatalogManager checks for CatalogTableImpl instead of CatalogTable

[ https://issues.apache.org/jira/browse/FLINK-18378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-18378: --- Comment: was deleted (was: I have interest to fix the instance check of CatalogTable as

[jira] [Comment Edited] (FLINK-18378) CatalogManager checks for CatalogTableImpl instead of CatalogTable

[ https://issues.apache.org/jira/browse/FLINK-18378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140501#comment-17140501 ] Nicholas Jiang edited comment on FLINK-18378 at 6/19/20, 12:34 PM: --- I

[jira] [Commented] (FLINK-18378) CatalogManager checks for CatalogTableImpl instead of CatalogTable

[ https://issues.apache.org/jira/browse/FLINK-18378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140501#comment-17140501 ] Nicholas Jiang commented on FLINK-18378: I have interest to fix the instance check of

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

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

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

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

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

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

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

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

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

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

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

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

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

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

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

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

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

[ https://issues.apache.org/jira/browse/FLINK-18347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140081#comment-17140081 ] Nicholas Jiang edited comment on FLINK-18347 at 6/19/20, 1:53 AM: -- This

[jira] [Comment Edited] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

[ https://issues.apache.org/jira/browse/FLINK-18347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140081#comment-17140081 ] Nicholas Jiang edited comment on FLINK-18347 at 6/19/20, 1:49 AM: -- This

[jira] [Commented] (FLINK-18347) kinesis connector throw Error java.lang.NoSuchFieldError: NO_INTS

[ https://issues.apache.org/jira/browse/FLINK-18347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140081#comment-17140081 ] Nicholas Jiang commented on FLINK-18347: This exception is caused by conflicting versions of the

[jira] [Commented] (FLINK-18201) Support create_function in Python Table API

[ https://issues.apache.org/jira/browse/FLINK-18201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134005#comment-17134005 ] Nicholas Jiang commented on FLINK-18201: [~twalthr], are you working on API: void

[jira] [Commented] (FLINK-18247) Unstable test: TableITCase.testCollectWithClose:122 expected: but was:

[ https://issues.apache.org/jira/browse/FLINK-18247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132993#comment-17132993 ] Nicholas Jiang commented on FLINK-18247: [~rmetzger], because job status may not be CANCELED

[jira] [Issue Comment Deleted] (FLINK-18189) Incorrect size check for sum of heap/non-heap memory

[ https://issues.apache.org/jira/browse/FLINK-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-18189: --- Comment: was deleted (was: [~azagrebin], I. thought that this message is correct, but the

[jira] [Commented] (FLINK-18214) Incorrect warning if jobstore.cache-size exceeds heap size

[ https://issues.apache.org/jira/browse/FLINK-18214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129196#comment-17129196 ] Nicholas Jiang commented on FLINK-18214: [~chesnay], therefore, if this pull request is merged,

[jira] [Comment Edited] (FLINK-18214) Incorrect warning if jobstore.cache-size exceeds heap size

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

[jira] [Comment Edited] (FLINK-18214) Incorrect warning if jobstore.cache-size exceeds heap size

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

[jira] [Comment Edited] (FLINK-18214) Incorrect warning if jobstore.cache-size exceeds heap size

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

[jira] [Commented] (FLINK-18214) Incorrect warning if jobstore.cache-size exceeds heap size

[ https://issues.apache.org/jira/browse/FLINK-18214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129175#comment-17129175 ] Nicholas Jiang commented on FLINK-18214: [~chesnay] This bug has already fixed in [Jobstore size

[jira] [Commented] (FLINK-18189) Incorrect size check for sum of heap/non-heap memory

[ https://issues.apache.org/jira/browse/FLINK-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129174#comment-17129174 ] Nicholas Jiang commented on FLINK-18189: [~azagrebin], I. thought that this message is correct,

[jira] [Issue Comment Deleted] (FLINK-18189) Incorrect size check for sum of heap/non-heap memory

[ https://issues.apache.org/jira/browse/FLINK-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-18189: --- Comment: was deleted (was: [~azagrebin]Yes, sorry for previously not pushing 'start

[jira] [Commented] (FLINK-18189) Incorrect size check for sum of heap/non-heap memory

[ https://issues.apache.org/jira/browse/FLINK-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129159#comment-17129159 ] Nicholas Jiang commented on FLINK-18189: [~azagrebin]Yes, sorry for previously not pushing

[jira] [Comment Edited] (FLINK-18189) Incorrect size check for sum of heap/non-heap memory

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

[jira] [Comment Edited] (FLINK-18189) Incorrect size check for sum of heap/non-heap memory

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

[jira] [Commented] (FLINK-18202) Introduce ProtoBuffer format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128943#comment-17128943 ] Nicholas Jiang commented on FLINK-18202: [~libenchao]What do you think about compatibility of

[jira] [Commented] (FLINK-18201) Support create_function in Python Table API

[ https://issues.apache.org/jira/browse/FLINK-18201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128940#comment-17128940 ] Nicholas Jiang commented on FLINK-18201: [~dian.fu]Could you please assign this to me？ >

[jira] [Commented] (FLINK-18191) Rename new Master memory options to start with "master" prefix

[ https://issues.apache.org/jira/browse/FLINK-18191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128936#comment-17128936 ] Nicholas Jiang commented on FLINK-18191: [~chesnay]Therefore, I would like to work on this.

[jira] [Commented] (FLINK-18191) Rename new Master memory options to start with "master" prefix

[ https://issues.apache.org/jira/browse/FLINK-18191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128776#comment-17128776 ] Nicholas Jiang commented on FLINK-18191: [~chesnay]Do you mean that replace "jobmanager" prefix

[jira] [Commented] (FLINK-18189) Incorrect size check for sum of heap/non-heap memory

[ https://issues.apache.org/jira/browse/FLINK-18189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128754#comment-17128754 ] Nicholas Jiang commented on FLINK-18189: [~azagrebin][~chesnay] Could you please assign this to

[jira] [Comment Edited] (FLINK-18157) Jobstore size check compares against offHeapMemory

[ https://issues.apache.org/jira/browse/FLINK-18157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126756#comment-17126756 ] Nicholas Jiang edited comment on FLINK-18157 at 6/5/20, 1:08 PM: -

[jira] [Comment Edited] (FLINK-18157) Jobstore size check compares against offHeapMemory

[ https://issues.apache.org/jira/browse/FLINK-18157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126756#comment-17126756 ] Nicholas Jiang edited comment on FLINK-18157 at 6/5/20, 1:07 PM: -

[jira] [Commented] (FLINK-18157) Jobstore size check compares against offHeapMemory

[ https://issues.apache.org/jira/browse/FLINK-18157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126756#comment-17126756 ] Nicholas Jiang commented on FLINK-18157: [~chesnay] Just the log of method

[jira] [Issue Comment Deleted] (FLINK-18157) Jobstore size check compares against offHeapMemory

[ https://issues.apache.org/jira/browse/FLINK-18157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-18157: --- Comment: was deleted (was: [~chesnay]Could you please assign this to me? I would like to

[jira] [Commented] (FLINK-18157) Jobstore size check compares against offHeapMemory

[ https://issues.apache.org/jira/browse/FLINK-18157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126735#comment-17126735 ] Nicholas Jiang commented on FLINK-18157: [~chesnay]Could you please assign this to me? I would

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125632#comment-17125632 ] Nicholas Jiang commented on FLINK-17726: I have already discuss with [~trohrmann] offline. And

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125565#comment-17125565 ] Nicholas Jiang commented on FLINK-17726: In general，[~zhuzh][~trohrmann]The solution could be to

[jira] [Commented] (FLINK-18009) Select an invalid column crashes the SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-18009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123687#comment-17123687 ] Nicholas Jiang commented on FLINK-18009: [~godfreyhe]This issue is related to [SQL-CLI no

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123422#comment-17123422 ] Nicholas Jiang commented on FLINK-17726: [~zhuzh]Thanks for your explanation, therefore this

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121477#comment-17121477 ] Nicholas Jiang commented on FLINK-17726: [~zhuzh]I agree with that directly CANCELED tasks

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120883#comment-17120883 ] Nicholas Jiang commented on FLINK-17726: [~zhuzh]I have double checked the methods that trigger

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119166#comment-17119166 ] Nicholas Jiang commented on FLINK-17726: Hi [~trohrmann], I previously double checked whether a

[jira] [Updated] (FLINK-17996) NPE in CatalogTableStatisticsConverter.convertToColumnStats method

[ https://issues.apache.org/jira/browse/FLINK-17996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-17996: --- Description: Currently, hive catalog only supports a few kinds of statistics, otherwise

[jira] [Updated] (FLINK-17996) NPE in CatalogTableStatisticsConverter.convertToColumnStats method

[ https://issues.apache.org/jira/browse/FLINK-17996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-17996: --- Summary: NPE in CatalogTableStatisticsConverter.convertToColumnStats method (was: NEP in

[jira] [Commented] (FLINK-18009) Select an invalid column crashes the SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-18009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118673#comment-17118673 ] Nicholas Jiang commented on FLINK-18009: [~lirui]Could you please assign to me? > Select an

[jira] [Commented] (FLINK-17996) NEP in CatalogTableStatisticsConverter.convertToColumnStats method

[ https://issues.apache.org/jira/browse/FLINK-17996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118600#comment-17118600 ] Nicholas Jiang commented on FLINK-17996: [~lzljs3620320]Could you please assign this bug to me

[jira] [Commented] (FLINK-17960) Improve commands in the "Common Questions" document for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117581#comment-17117581 ] Nicholas Jiang commented on FLINK-17960: [~hequn8128], I would like to modify script of "Common

[jira] [Comment Edited] (FLINK-17902) Support the new interfaces about temporary functions in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117562#comment-17117562 ] Nicholas Jiang edited comment on FLINK-17902 at 5/27/20, 9:20 AM: --

[jira] [Comment Edited] (FLINK-17901) Add module interface in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117567#comment-17117567 ] Nicholas Jiang edited comment on FLINK-17901 at 5/27/20, 9:20 AM: --

[jira] [Comment Edited] (FLINK-17901) Add module interface in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117567#comment-17117567 ] Nicholas Jiang edited comment on FLINK-17901 at 5/27/20, 9:20 AM: --

[jira] [Commented] (FLINK-17901) Add module interface in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117567#comment-17117567 ] Nicholas Jiang commented on FLINK-17901: Hequn ChengDian Fu, could you please assign this issue

[jira] [Comment Edited] (FLINK-17901) Add module interface in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117567#comment-17117567 ] Nicholas Jiang edited comment on FLINK-17901 at 5/27/20, 9:19 AM: --

[jira] [Comment Edited] (FLINK-17901) Add module interface in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117567#comment-17117567 ] Nicholas Jiang edited comment on FLINK-17901 at 5/27/20, 9:19 AM: --

[jira] [Commented] (FLINK-17902) Support the new interfaces about temporary functions in PyFlink

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

[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=17107123#comment-17107123 ] Nicholas Jiang edited comment on FLINK-17572 at 5/26/20, 1:58 AM: --

[jira] [Commented] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116347#comment-17116347 ] Nicholas Jiang commented on FLINK-17883: [~dian.fu], as you mentioned, this issue has already

[jira] [Commented] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17114549#comment-17114549 ] Nicholas Jiang commented on FLINK-17883: [~dian.fu][~lzljs3620320][~jark]As you discuss, do you

[jira] [Comment Edited] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113880#comment-17113880 ] Nicholas Jiang edited comment on FLINK-17883 at 5/22/20, 9:22 AM: --

[jira] [Commented] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113880#comment-17113880 ] Nicholas Jiang commented on FLINK-17883: [~rmetzger], I don't agree with you any more. I

[jira] [Commented] (FLINK-17879) Update Python row serializer

[ https://issues.apache.org/jira/browse/FLINK-17879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113859#comment-17113859 ] Nicholas Jiang commented on FLINK-17879: [~twalthr], [~hequn8128] could decide this point, who

[jira] [Commented] (FLINK-17879) Update Python row serializer

[ https://issues.apache.org/jira/browse/FLINK-17879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113847#comment-17113847 ] Nicholas Jiang commented on FLINK-17879: [~twalthr]In my opinion, I prefer use the new format

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113809#comment-17113809 ] Nicholas Jiang commented on FLINK-17726: [~zhuzh]Could you please assign this to me? I would

[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=17107123#comment-17107123 ] Nicholas Jiang commented on FLINK-17572: [~kevin.cyj]I think this just removes alignmentBuffered

[jira] [Commented] (FLINK-17562) Monitoring REST API page has duplicate items

[ https://issues.apache.org/jira/browse/FLINK-17562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105270#comment-17105270 ] Nicholas Jiang commented on FLINK-17562: [~chesnay]I have already fixed the bug in

[jira] [Commented] (FLINK-17562) Monitoring REST API page has duplicate items

[ https://issues.apache.org/jira/browse/FLINK-17562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105173#comment-17105173 ] Nicholas Jiang commented on FLINK-17562: [~hequn8128]Please assign this to me for fixing. >

[jira] [Issue Comment Deleted] (FLINK-17562) Monitoring REST API page has duplicate items

[ https://issues.apache.org/jira/browse/FLINK-17562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-17562: --- Comment: was deleted (was: [~godfreyhe]Please assign this to me for fixing.) > Monitoring

[jira] [Commented] (FLINK-17562) Monitoring REST API page has duplicate items

[ https://issues.apache.org/jira/browse/FLINK-17562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105172#comment-17105172 ] Nicholas Jiang commented on FLINK-17562: [~godfreyhe]Please assign this to me for fixing. >

<    1   2   3   4   5   6   7   >