[jira] [Commented] (FLINK-25188) Cannot install PyFlink on MacOS with M1 chip

2021-12-06 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453987#comment-17453987 ] Nicholas Jiang commented on FLINK-25188: [~ana4], IMO, this version could be upgraded but this

[jira] [Commented] (FLINK-24785) Relocate RocksDB's log under flink log directory by default

2021-11-22 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447264#comment-17447264 ] Nicholas Jiang commented on FLINK-24785: [~yunta], sorry for mistake to discuss on the issue. I

[jira] [Comment Edited] (FLINK-22793) HybridSource Table Implementation

2021-11-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442578#comment-17442578 ] Nicholas Jiang edited comment on FLINK-22793 at 11/15/21, 12:39 PM:

[jira] [Commented] (FLINK-22793) HybridSource Table Implementation

2021-11-11 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442578#comment-17442578 ] Nicholas Jiang commented on FLINK-22793: [~nicholasjiang], yes of course. > HybridSource Table

[jira] [Commented] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000)

2021-11-10 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442071#comment-17442071 ] Nicholas Jiang commented on FLINK-24586: [~airblader], could you please assign this ticket to

[jira] [Commented] (FLINK-24606) AvroDeserializationSchema buffer is not clean

2021-10-21 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432219#comment-17432219 ] Nicholas Jiang commented on FLINK-24606: [~douheyu], IMO, the decoder in

[jira] [Commented] (FLINK-24355) Expose the flag for enabling checkpoints after tasks finish in the Web UI

2021-10-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429967#comment-17429967 ] Nicholas Jiang commented on FLINK-24355: [~dwysakowicz], could you please assign this ticket to

[jira] [Commented] (FLINK-24564) Change the default compression to snappy for parquet, orc, avro in table

2021-10-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429908#comment-17429908 ] Nicholas Jiang commented on FLINK-24564: [~lzljs3620320], could you please assign this ticket to

[jira] [Closed] (FLINK-24335) Get java.net.MalformedURLException when submit job from python by pyflink table api.

2021-09-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang closed FLINK-24335. -- Resolution: Duplicate > Get java.net.MalformedURLException when submit job from python by

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

2021-09-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24336: --- Description: When I run flink client to submit a python based workflow, I got the

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

2021-09-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24336: --- Summary: PyFlink TableEnvironment executes the SQL randomly MalformedURLException with the

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment execute SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

2021-09-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24336: --- Affects Version/s: 1.14.1 1.14.0 1.13.2 >

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment execute SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

2021-09-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24336: --- Component/s: API / Python > PyFlink TableEnvironment execute SQL randomly

[jira] [Updated] (FLINK-24336) PyFlink TableEnvironment execute SQL randomly MalformedURLException with the configuration for 'pipeline.classpaths'

2021-09-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24336: --- Summary: PyFlink TableEnvironment execute SQL randomly MalformedURLException with the

[jira] [Created] (FLINK-24336) PyFlink

2021-09-18 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-24336: -- Summary: PyFlink Key: FLINK-24336 URL: https://issues.apache.org/jira/browse/FLINK-24336 Project: Flink Issue Type: Bug Reporter: Nicholas

[jira] [Commented] (FLINK-19883) Support "IF EXISTS" in DDL for ALTER TABLE

2021-09-06 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410414#comment-17410414 ] Nicholas Jiang commented on FLINK-19883: [~airblader], could you please assign this to me? >

[jira] [Commented] (FLINK-24061) RMQSourceITCase.testAckFailure fails on azure

2021-09-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17409360#comment-17409360 ] Nicholas Jiang commented on FLINK-24061: [~cmick], [~arvid], could increasing the timeout time

[jira] [Commented] (FLINK-23704) FLIP-27 sources are not generating LatencyMarkers

2021-09-01 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408257#comment-17408257 ] Nicholas Jiang commented on FLINK-23704: [~pnowojski], I have pushed the PR for the

[jira] [Commented] (FLINK-23755) Modify the default value of table.dynamic-table-options.enabled to true

2021-08-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403659#comment-17403659 ] Nicholas Jiang commented on FLINK-23755: [~lzljs3620320], I have push a PR for this. Please

[jira] [Commented] (FLINK-20726) Introduce Pulsar connector

2021-08-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401476#comment-17401476 ] Nicholas Jiang commented on FLINK-20726: [~Jianyun Zhao], Is this lack of the document of Pulsar

[jira] [Commented] (FLINK-22793) HybridSource Table Implementation

2021-08-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400991#comment-17400991 ] Nicholas Jiang commented on FLINK-22793: [~t...@apache.org], could you please assign this ticket

[jira] [Commented] (FLINK-23192) Move connector/format option classes into a common package

2021-06-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371959#comment-17371959 ] Nicholas Jiang commented on FLINK-23192: [~airblader], would you refactor these options in

[jira] [Comment Edited] (FLINK-23192) Move connector/format option classes into a common package

2021-06-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371959#comment-17371959 ] Nicholas Jiang edited comment on FLINK-23192 at 6/30/21, 11:50 AM: ---

[jira] [Comment Edited] (FLINK-23165) Add StreamExecutionEnvironment#registerSlotSharingGroup to PyFlink

2021-06-29 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371793#comment-17371793 ] Nicholas Jiang edited comment on FLINK-23165 at 6/30/21, 4:11 AM: --

[jira] [Comment Edited] (FLINK-23165) Add StreamExecutionEnvironment#registerSlotSharingGroup to PyFlink

2021-06-29 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371793#comment-17371793 ] Nicholas Jiang edited comment on FLINK-23165 at 6/30/21, 4:09 AM: --

[jira] [Commented] (FLINK-23165) Add StreamExecutionEnvironment#registerSlotSharingGroup to PyFlink

2021-06-29 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17371793#comment-17371793 ] Nicholas Jiang commented on FLINK-23165: [~karmagyz], I have already completed to work for this

[jira] [Commented] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality

2021-06-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369798#comment-17369798 ] Nicholas Jiang commented on FLINK-23017: [~jark], I would like to take this ticket and could you

[jira] [Comment Edited] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer

2021-06-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369294#comment-17369294 ] Nicholas Jiang edited comment on FLINK-22956 at 6/25/21, 10:39 AM: ---

[jira] [Commented] (FLINK-22956) Stream Over TTL should use enableTimeToLive of state instead of timer

2021-06-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369294#comment-17369294 ] Nicholas Jiang commented on FLINK-22956: [~lzljs3620320], what's the problem in your

[jira] [Comment Edited] (FLINK-23154) Fix Python PackagedProgramRetrieverImplTest implementations

2021-06-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369291#comment-17369291 ] Nicholas Jiang edited comment on FLINK-23154 at 6/25/21, 7:12 AM: --

[jira] [Comment Edited] (FLINK-23154) Fix Python PackagedProgramRetrieverImplTest implementations

2021-06-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369291#comment-17369291 ] Nicholas Jiang edited comment on FLINK-23154 at 6/25/21, 7:09 AM: --

[jira] [Comment Edited] (FLINK-23154) Fix Python PackagedProgramRetrieverImplTest implementations

2021-06-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369291#comment-17369291 ] Nicholas Jiang edited comment on FLINK-23154 at 6/25/21, 7:09 AM: --

[jira] [Commented] (FLINK-23154) Fix Python PackagedProgramRetrieverImplTest implementations

2021-06-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17369291#comment-17369291 ] Nicholas Jiang commented on FLINK-23154: [~mapohl], According to previous experience for adding

[jira] [Comment Edited] (FLINK-22968) Improve exception message when using toAppendStream[String]

2021-06-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363608#comment-17363608 ] Nicholas Jiang edited comment on FLINK-22968 at 6/16/21, 11:59 AM: ---

[jira] [Comment Edited] (FLINK-22968) Improve exception message when using toAppendStream[String]

2021-06-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363608#comment-17363608 ] Nicholas Jiang edited comment on FLINK-22968 at 6/16/21, 11:55 AM: ---

[jira] [Comment Edited] (FLINK-22968) Improve exception message when using toAppendStream[String]

2021-06-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363608#comment-17363608 ] Nicholas Jiang edited comment on FLINK-22968 at 6/16/21, 11:51 AM: ---

[jira] [Issue Comment Deleted] (FLINK-22998) Flink SQL does not support block comment before SET command

2021-06-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-22998: --- Comment: was deleted (was: [~airblader], [~pensz], IMO, if the 'EXTENDED_PARSER' couldn't

[jira] [Commented] (FLINK-22968) Improve exception message when using toAppendStream[String]

2021-06-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363608#comment-17363608 ] Nicholas Jiang commented on FLINK-22968: [~twalthr], as you mentioned, does this need to improve

[jira] [Comment Edited] (FLINK-22998) Flink SQL does not support block comment before SET command

2021-06-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363587#comment-17363587 ] Nicholas Jiang edited comment on FLINK-22998 at 6/15/21, 11:35 AM: ---

[jira] [Comment Edited] (FLINK-22998) Flink SQL does not support block comment before SET command

2021-06-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363587#comment-17363587 ] Nicholas Jiang edited comment on FLINK-22998 at 6/15/21, 11:30 AM: ---

[jira] [Commented] (FLINK-22998) Flink SQL does not support block comment before SET command

2021-06-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17363587#comment-17363587 ] Nicholas Jiang commented on FLINK-22998: [~airblader], [~pensz], IMO, if the 'EXTENDED_PARSER'

[jira] [Commented] (FLINK-22878) Allow placeholder options in format factories

2021-06-11 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361508#comment-17361508 ] Nicholas Jiang commented on FLINK-22878: [~twalthr], `ReadableConfig` has no `set` API and

[jira] [Commented] (FLINK-22968) Improve exception message when using toAppendStream[String]

2021-06-10 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361378#comment-17361378 ] Nicholas Jiang commented on FLINK-22968: [~jark], I would like to take this issue. Could you

[jira] [Comment Edited] (FLINK-22748) Allow dynamic target topic selection in SQL Kafka sinks

2021-06-01 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17355098#comment-17355098 ] Nicholas Jiang edited comment on FLINK-22748 at 6/1/21, 1:34 PM: - IMO,

[jira] [Comment Edited] (FLINK-22748) Allow dynamic target topic selection in SQL Kafka sinks

2021-06-01 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17355098#comment-17355098 ] Nicholas Jiang edited comment on FLINK-22748 at 6/1/21, 1:33 PM: - IMO,

[jira] [Commented] (FLINK-22748) Allow dynamic target topic selection in SQL Kafka sinks

2021-06-01 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17355098#comment-17355098 ] Nicholas Jiang commented on FLINK-22748: IMO, as [~twalthr] mentioned, the solution that use

[jira] [Created] (FLINK-22793) HybridSource Table Implementation

2021-05-27 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-22793: -- Summary: HybridSource Table Implementation Key: FLINK-22793 URL: https://issues.apache.org/jira/browse/FLINK-22793 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351424#comment-17351424 ] Nicholas Jiang edited comment on FLINK-22698 at 5/26/21, 1:52 AM: --

[jira] [Comment Edited] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351424#comment-17351424 ] Nicholas Jiang edited comment on FLINK-22698 at 5/26/21, 1:52 AM: --

[jira] [Comment Edited] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351424#comment-17351424 ] Nicholas Jiang edited comment on FLINK-22698 at 5/26/21, 1:51 AM: --

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351424#comment-17351424 ] Nicholas Jiang commented on FLINK-22698: Thanks for [~cmick]'s investigation. The solution which

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-19 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348011#comment-17348011 ] Nicholas Jiang commented on FLINK-22698: [~austince], thanks for tracking this issue. From this

[jira] [Comment Edited] (FLINK-22234) Read savepoint before creating ExecutionGraph

2021-05-19 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337149#comment-17337149 ] Nicholas Jiang edited comment on FLINK-22234 at 5/19/21, 8:59 AM: --

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-19 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347340#comment-17347340 ] Nicholas Jiang commented on FLINK-22698: [~austince], thank you for your research. From your

[jira] [Commented] (FLINK-22699) Make ConstantArgumentCount public API

2021-05-19 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347327#comment-17347327 ] Nicholas Jiang commented on FLINK-22699: Making the ConstantArgumentCount as public API makes

[jira] [Commented] (FLINK-22678) Fix Loading Changelog Statebackend with configs set in job-level and cluster-level separately

2021-05-19 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347319#comment-17347319 ] Nicholas Jiang commented on FLINK-22678: [~ym], does this issue aim to deal with the situation

[jira] [Commented] (FLINK-22413) Hide Checkpointing page in the UI for batch jobs

2021-05-10 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341689#comment-17341689 ] Nicholas Jiang commented on FLINK-22413: [~rmetzger], I have added the JobGraph.jobType to the

[jira] [Comment Edited] (FLINK-22234) Read savepoint before creating ExecutionGraph

2021-05-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337149#comment-17337149 ] Nicholas Jiang edited comment on FLINK-22234 at 5/9/21, 11:24 PM: --

[jira] [Commented] (FLINK-22413) Hide Checkpointing page in the UI for batch jobs

2021-05-06 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340164#comment-17340164 ] Nicholas Jiang commented on FLINK-22413: [~rmetzger], I'm working for hiding the checkpointing

[jira] [Comment Edited] (FLINK-22234) Read savepoint before creating ExecutionGraph

2021-04-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337149#comment-17337149 ] Nicholas Jiang edited comment on FLINK-22234 at 4/30/21, 7:41 AM: --

[jira] [Commented] (FLINK-22234) Read savepoint before creating ExecutionGraph

2021-04-30 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337149#comment-17337149 ] Nicholas Jiang commented on FLINK-22234: [~trohrmann], [~chesnay], the behavior that read

[jira] [Commented] (FLINK-22490) YarnApplicationClusterEntryPoint does not pass configuration parameters

2021-04-29 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335277#comment-17335277 ] Nicholas Jiang commented on FLINK-22490: [~trohrmann], yes. I'm following the mirror comments

[jira] [Comment Edited] (FLINK-22490) YarnApplicationClusterEntryPoint does not pass configuration parameters

2021-04-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334385#comment-17334385 ] Nicholas Jiang edited comment on FLINK-22490 at 4/28/21, 11:56 AM: ---

[jira] [Commented] (FLINK-22490) YarnApplicationClusterEntryPoint does not pass configuration parameters

2021-04-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334385#comment-17334385 ] Nicholas Jiang commented on FLINK-22490: [~Z_RCoder], [~karmagyz],  this is duplicated with the

[jira] [Commented] (FLINK-22277) Refactor sql client's DynamicResult

2021-04-18 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324698#comment-17324698 ] Nicholas Jiang commented on FLINK-22277: [~jark], could you please assign this to me? I'm

[jira] [Comment Edited] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

2021-04-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17323765#comment-17323765 ] Nicholas Jiang edited comment on FLINK-21844 at 4/16/21, 12:42 PM: ---

[jira] [Comment Edited] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

2021-04-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17323765#comment-17323765 ] Nicholas Jiang edited comment on FLINK-21844 at 4/16/21, 12:28 PM: ---

[jira] [Commented] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

2021-04-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17323765#comment-17323765 ] Nicholas Jiang commented on FLINK-21844: [~trohrmann], do you mean that the restore from

[jira] [Comment Edited] (FLINK-22296) Introduce Preconditions-util into Python API

2021-04-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322557#comment-17322557 ] Nicholas Jiang edited comment on FLINK-22296 at 4/16/21, 1:58 AM: --

[jira] [Commented] (FLINK-22296) Introduce Preconditions-util into Python API

2021-04-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322557#comment-17322557 ] Nicholas Jiang commented on FLINK-22296: [~RocMarshal], IMO, the

[jira] [Commented] (FLINK-17683) Pojo with no-args constructor will be treated as ROW when returned by ScalarFunction, but not when it is a field of case class.

2021-04-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317062#comment-17317062 ] Nicholas Jiang commented on FLINK-17683: After [~twalthr] took a look, I would like to work for

[jira] [Commented] (FLINK-22065) Beautify the parse error exception when input invalid command in the sql client

2021-03-31 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312299#comment-17312299 ] Nicholas Jiang commented on FLINK-22065: [~fsk119], [~jark], please assign to me for fix. >

[jira] [Issue Comment Deleted] (FLINK-22065) Beautify the parse error exception when input invalid command in the sql client

2021-03-31 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-22065: --- Comment: was deleted (was: [~fsk119], [~jark], please assign to me for fix.) > Beautify

[jira] [Updated] (FLINK-20557) Support STATEMENT SET in SQL CLI

2021-03-28 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-20557: --- Summary: Support STATEMENT SET in SQL CLI (was: Support "STATEMENT SET" in SQL CLI) >

[jira] [Created] (FLINK-21849) 'SHOW MODULES' tests for CliClientITCase lack the default module test case

2021-03-17 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-21849: -- Summary: 'SHOW MODULES' tests for CliClientITCase lack the default module test case Key: FLINK-21849 URL: https://issues.apache.org/jira/browse/FLINK-21849

[jira] [Commented] (FLINK-21829) create HiveCatalog with custom hadoopconfdir first

2021-03-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303045#comment-17303045 ] Nicholas Jiang commented on FLINK-21829: [~hehuiyuan], you could update your pull request for

[jira] [Commented] (FLINK-21829) create HiveCatalog with custom hadoopconfdir first

2021-03-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303012#comment-17303012 ] Nicholas Jiang commented on FLINK-21829: [~hehuiyuan], I left the comment for the custom hadoop

[jira] [Comment Edited] (FLINK-21820) JDBC connector shouldn't read all rows in per statement by default

2021-03-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302498#comment-17302498 ] Nicholas Jiang edited comment on FLINK-21820 at 3/17/21, 1:42 AM: --

[jira] [Commented] (FLINK-21728) DegreesWithExceptionITCase crash

2021-03-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17303008#comment-17303008 ] Nicholas Jiang commented on FLINK-21728: [~dwysakowicz], according to the changes of your pull

[jira] [Commented] (FLINK-21820) JDBC connector shouldn't read all rows in per statement by default

2021-03-16 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302498#comment-17302498 ] Nicholas Jiang commented on FLINK-21820: [~Leonard Xu], by default, [most JDBC drivers use a

[jira] [Commented] (FLINK-21753) Cycle references between memory manager and gc cleaner action

2021-03-15 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301448#comment-17301448 ] Nicholas Jiang commented on FLINK-21753: [~kezhuw], will you copy the 

[jira] [Updated] (FLINK-21774) Do not display column names when return set is emtpy in SQL Client

2021-03-14 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-21774: --- Summary: Do not display column names when return set is emtpy in SQL Client (was: Do not

[jira] [Commented] (FLINK-21774) Do not display column names when retrun set is emtpy in SQL Client

2021-03-14 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301328#comment-17301328 ] Nicholas Jiang commented on FLINK-21774: [~jark], I'm working for this issue, could you please

[jira] [Commented] (FLINK-21419) Remove GC cleaner mechanism for unsafe memory segments

2021-03-11 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300013#comment-17300013 ] Nicholas Jiang commented on FLINK-21419: Thanks for [~kezhuw] reporting.  It's my mistake for no

[jira] [Commented] (FLINK-20557) Support statement set in SQL CLI

2021-03-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17298547#comment-17298547 ] Nicholas Jiang commented on FLINK-20557: [~fsk119], [~jark], IMO, I could work for this issue

[jira] [Commented] (FLINK-21667) Standby RM might remove resources from Kubernetes

2021-03-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297317#comment-17297317 ] Nicholas Jiang commented on FLINK-21667: [~xintongsong], do you mean that this could postpone

[jira] [Commented] (FLINK-21664) Support STATEMENT SET syntax in TableEnvironment

2021-03-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297239#comment-17297239 ] Nicholas Jiang commented on FLINK-21664: [~jark], I have followed the proposal above mentioned

[jira] [Commented] (FLINK-21602) Creation of ExecutionGraph happens in main thread

2021-03-07 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17296852#comment-17296852 ] Nicholas Jiang commented on FLINK-21602: [~trohrmann], is the point you mentioned above is that 

[jira] [Comment Edited] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295033#comment-17295033 ] Nicholas Jiang edited comment on FLINK-21564 at 3/4/21, 6:46 AM: -

[jira] [Comment Edited] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295033#comment-17295033 ] Nicholas Jiang edited comment on FLINK-21564 at 3/4/21, 6:43 AM: -

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17295033#comment-17295033 ] Nicholas Jiang commented on FLINK-21564: [~kezhuw], according to the logic of the codes you

[jira] [Comment Edited] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294433#comment-17294433 ] Nicholas Jiang edited comment on FLINK-21564 at 3/3/21, 9:57 AM: -

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294433#comment-17294433 ] Nicholas Jiang commented on FLINK-21564: [~kezhuw], is your point like as follows? while

[jira] [Issue Comment Deleted] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-21564: --- Comment: was deleted (was: [~kezhuw], is your point that  {code:java} while

[jira] [Commented] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

2021-03-03 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294428#comment-17294428 ] Nicholas Jiang commented on FLINK-21564: [~kezhuw], is your point that  {code:java} while

[jira] [Commented] (FLINK-21419) Remove GC cleaner mechanism for unsafe memory segments

2021-02-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291350#comment-17291350 ] Nicholas Jiang commented on FLINK-21419: [~xintongsong], because of no performace effect, I

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

2021-02-23 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289675#comment-17289675 ] Nicholas Jiang commented on FLINK-21236: [~xintongsong], [~trohrmann], [~ykt836], to summarize,

[jira] [Commented] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

2021-02-23 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289674#comment-17289674 ] Nicholas Jiang commented on FLINK-21445: [~fly_in_gis], [~mapohl], I would like to do a bit

[jira] [Commented] (FLINK-21303) Maybe remove LogicalSlot#getPhysicalSlotNumber

2021-02-05 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17279678#comment-17279678 ] Nicholas Jiang commented on FLINK-21303: [~chesnay], could you please assign this to me? >

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

2021-02-04 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-21045: --- Description: This improvement aims to # Simplify the module discovery mapping by module

<    1   2   3   4   5   6   7   >