[jira] [Closed] (FLINK-23825) Test SQL Client manually

2022-03-07 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-23825. - Resolution: Fixed > Test SQL Client manually > > >

[jira] [Commented] (FLINK-23825) Test SQL Client manually

2022-03-07 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502128#comment-17502128 ] Shengkai Fang commented on FLINK-23825: --- Hi, all. I think it has been tested and we can close it

[jira] [Commented] (FLINK-24942) Could not find any factory for identifier 'hive' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath

2021-11-18 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445721#comment-17445721 ] Shengkai Fang commented on FLINK-24942: --- In the doc, it suggests to use catalog to manage tables

[jira] [Commented] (FLINK-24942) Could not find any factory for identifier 'hive' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath

2021-11-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445624#comment-17445624 ] Shengkai Fang commented on FLINK-24942: --- It seems the sql-client doesn't find the hive jar. You

[jira] [Closed] (FLINK-24930) Print Sink should also print the table identifier when output data

2021-11-16 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-24930. - Resolution: Fixed > Print Sink should also print the table identifier when output data >

[jira] [Created] (FLINK-24930) Print Sink should also print the table identifier when output data

2021-11-16 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-24930: - Summary: Print Sink should also print the table identifier when output data Key: FLINK-24930 URL: https://issues.apache.org/jira/browse/FLINK-24930 Project: Flink

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-23 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402994#comment-17402994 ] Shengkai Fang commented on FLINK-22198: --- Sounds great. I think it's much better than turn off the

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

2021-08-20 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402076#comment-17402076 ] Shengkai Fang commented on FLINK-22198: --- Thanks for the investigation:). In the

[jira] [Updated] (FLINK-23825) Test SQL Client manually

2021-08-16 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-23825: -- Description: In the 1.14.0, we have added JAR-related commands for the SQL CLIENT, including

[jira] [Updated] (FLINK-23825) Test SQL Client manually

2021-08-16 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-23825: -- Description: In the 1.14.0, we have added JAR-related commands for the SQL CLIENT, including

[jira] [Updated] (FLINK-23825) Test SQL Client manually

2021-08-16 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-23825: -- Labels: release-testing (was: ) > Test SQL Client manually > > >

[jira] [Created] (FLINK-23825) Test SQL Client manually

2021-08-16 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-23825: - Summary: Test SQL Client manually Key: FLINK-23825 URL: https://issues.apache.org/jira/browse/FLINK-23825 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-23671) Failed to inference type in correlate

2021-08-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-23671: -- Description: Please also turn off the assert by running the query *without* jvm parameter

[jira] [Updated] (FLINK-23671) Failed to inference type in correlate

2021-08-08 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-23671: -- Description: Please also turn off the assert by running the query *without* jvm parameter

[jira] [Updated] (FLINK-23671) Failed to inference type in correlate

2021-08-08 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-23671: -- Attachment: screenshot-1.png > Failed to inference type in correlate >

[jira] [Commented] (FLINK-23671) Failed to inference type in correlate

2021-08-08 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17395717#comment-17395717 ] Shengkai Fang commented on FLINK-23671: --- [~twalthr] I have updated the description. > Failed to

[jira] [Updated] (FLINK-23671) Failed to inference type in correlate

2021-08-08 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-23671: -- Description: {code:java} CREATE FUNCTION func111 AS

[jira] [Created] (FLINK-23671) Failed to inference type in correlate

2021-08-06 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-23671: - Summary: Failed to inference type in correlate Key: FLINK-23671 URL: https://issues.apache.org/jira/browse/FLINK-23671 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23623) Over expression should allow to order by any fields in batch mode

2021-08-04 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-23623: - Summary: Over expression should allow to order by any fields in batch mode Key: FLINK-23623 URL: https://issues.apache.org/jira/browse/FLINK-23623 Project: Flink

[jira] [Updated] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode

2021-08-03 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22334: -- Description: Please run in the streaming mode. The failed statement  {code:java} // Some

[jira] [Commented] (FLINK-23554) SqlCli throws an exception and hang

2021-07-30 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17390324#comment-17390324 ] Shengkai Fang commented on FLINK-23554: --- Thanks for [~qingru zhang]'s report. I will fix it soon.

[jira] [Created] (FLINK-23467) Remove the usage of the yaml file in pyflink e2e test

2021-07-22 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-23467: - Summary: Remove the usage of the yaml file in pyflink e2e test Key: FLINK-23467 URL: https://issues.apache.org/jira/browse/FLINK-23467 Project: Flink

[jira] [Created] (FLINK-23455) Remove the usage of the yaml file in SQLJobSubmission

2021-07-21 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-23455: - Summary: Remove the usage of the yaml file in SQLJobSubmission Key: FLINK-23455 URL: https://issues.apache.org/jira/browse/FLINK-23455 Project: Flink

[jira] [Created] (FLINK-23446) Refactor SQL Client end to end tests

2021-07-20 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-23446: - Summary: Refactor SQL Client end to end tests Key: FLINK-23446 URL: https://issues.apache.org/jira/browse/FLINK-23446 Project: Flink Issue Type:

[jira] [Closed] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-22969. - Resolution: Not A Problem > Validate the topic is not null or empty string when create kafka

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379660#comment-17379660 ] Shengkai Fang commented on FLINK-22969: ---  [~longwang0616] I don't think user should use the

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-07-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17379624#comment-17379624 ] Shengkai Fang commented on FLINK-22969: --- Hi, all. Sorry for the late response. I try to reproduce

[jira] [Created] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-06-10 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22969: - Summary: Validate the topic is not null or empty string when create kafka source/sink function Key: FLINK-22969 URL: https://issues.apache.org/jira/browse/FLINK-22969

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-06-10 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22969: -- Issue Type: Improvement (was: Bug) > Validate the topic is not null or empty string when

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

2021-06-10 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22969: -- Affects Version/s: 1.14.0 > Validate the topic is not null or empty string when create kafka

[jira] [Commented] (FLINK-22673) Add document about add jar related commands

2021-06-06 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358313#comment-17358313 ] Shengkai Fang commented on FLINK-22673: --- Please assign it to me.[~jark] > Add document about add

[jira] [Commented] (FLINK-22795) Throw better exception when executing remote SQL file in SQL Client

2021-05-30 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17354179#comment-17354179 ] Shengkai Fang commented on FLINK-22795: --- [~JasonLee] You can just submit a code patch and we can

[jira] [Commented] (FLINK-22786) sql-client can not create .flink-sql-history file

2021-05-30 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17354178#comment-17354178 ] Shengkai Fang commented on FLINK-22786: --- [~pensz] Are you still willing to contribute? I think it

[jira] [Comment Edited] (FLINK-22786) sql-client can not create .flink-sql-history file

2021-05-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352982#comment-17352982 ] Shengkai Fang edited comment on FLINK-22786 at 5/28/21, 6:17 AM: - Thanks

[jira] [Commented] (FLINK-22786) sql-client can not create .flink-sql-history file

2021-05-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352982#comment-17352982 ] Shengkai Fang commented on FLINK-22786: --- Thanks for your report! You are right. Please go ahead.

[jira] [Commented] (FLINK-22794) flink-sql-parser and flink-sql-hive-parser

2021-05-27 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352972#comment-17352972 ] Shengkai Fang commented on FLINK-22794: --- Thanks for your investigation. +1 to upgrade the

[jira] [Updated] (FLINK-22787) Fix parse error when input statement has inline comments

2021-05-27 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22787: -- Description: You can reproduce this problem by using {code:java} CREATE TABLE test( a

[jira] [Updated] (FLINK-22787) Fix parse error when input statement has inline comments

2021-05-27 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22787: -- Description: You can reproduce this problem by using {code:java} CREATE TABLE test( a

[jira] [Created] (FLINK-22787) Fix parse error when input statement has inline comments

2021-05-27 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22787: - Summary: Fix parse error when input statement has inline comments Key: FLINK-22787 URL: https://issues.apache.org/jira/browse/FLINK-22787 Project: Flink

[jira] [Commented] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

2021-05-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17352234#comment-17352234 ] Shengkai Fang commented on FLINK-19973: --- [~twalthr] Sure. I will take a look recently. >

[jira] [Commented] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

2021-05-23 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350220#comment-17350220 ] Shengkai Fang commented on FLINK-22758: --- I think this bug has been fixed during the  

[jira] [Commented] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader

2021-05-23 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350202#comment-17350202 ] Shengkai Fang commented on FLINK-22758: --- Could you tell us the step to reproduce this bug? >

[jira] [Comment Edited] (FLINK-22693) EXPLAIN cannot be used on Hbase table when useing ROW type

2021-05-21 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349027#comment-17349027 ] Shengkai Fang edited comment on FLINK-22693 at 5/21/21, 6:59 AM: - I

[jira] [Commented] (FLINK-22693) EXPLAIN cannot be used on Hbase table when useing ROW type

2021-05-21 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349027#comment-17349027 ] Shengkai Fang commented on FLINK-22693: --- I rerun the program in FLINK-1.13. It seems the problem

[jira] [Created] (FLINK-22694) Refactor TPCH end to end tests

2021-05-18 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22694: - Summary: Refactor TPCH end to end tests Key: FLINK-22694 URL: https://issues.apache.org/jira/browse/FLINK-22694 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-16 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17345866#comment-17345866 ] Shengkai Fang commented on FLINK-22655: --- Thanks for your help. Just call me when you finish. >

[jira] [Created] (FLINK-22673) Add document about add jar related commands

2021-05-16 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22673: - Summary: Add document about add jar related commands Key: FLINK-22673 URL: https://issues.apache.org/jira/browse/FLINK-22673 Project: Flink Issue Type:

[jira] [Commented] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-16 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17345834#comment-17345834 ] Shengkai Fang commented on FLINK-22655: --- Thanks for your hint. The solution doesn' t fix the

[jira] [Commented] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344348#comment-17344348 ] Shengkai Fang commented on FLINK-22655: --- OK... It seems we can't use comment around the sql client

[jira] [Commented] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344287#comment-17344287 ] Shengkai Fang commented on FLINK-22655: --- I think the main reason is the {{ExtendedParser}} has no

[jira] [Comment Edited] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344287#comment-17344287 ] Shengkai Fang edited comment on FLINK-22655 at 5/14/21, 3:42 AM: - I

[jira] [Commented] (FLINK-22639) ClassLoaderUtil cannot print classpath of FlinkUserCodeClassLoader

2021-05-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344263#comment-17344263 ] Shengkai Fang commented on FLINK-22639: --- +1 to support it > ClassLoaderUtil cannot print

[jira] [Comment Edited] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344261#comment-17344261 ] Shengkai Fang edited comment on FLINK-22655 at 5/14/21, 2:44 AM: - Hi,

[jira] [Commented] (FLINK-22655) When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-13 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344261#comment-17344261 ] Shengkai Fang commented on FLINK-22655: --- Hi, [~JasonLee]. Could you offer the LOG for more

[jira] [Closed] (FLINK-22486) Wrong results of the IN operator

2021-05-11 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-22486. - Resolution: Cannot Reproduce > Wrong results of the IN operator >

[jira] [Commented] (FLINK-22503) getting error on select query in flink sql

2021-05-06 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17340513#comment-17340513 ] Shengkai Fang commented on FLINK-22503: --- [~bhagi__R]. Could you offer more details about the

[jira] [Commented] (FLINK-22499) JDBC sink table-api support "sink.parallelism" ?

2021-04-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335142#comment-17335142 ] Shengkai Fang commented on FLINK-22499: --- This is the feature supported in FLINK-19942. You may cp

[jira] [Commented] (FLINK-22503) getting error on select query in flink sql

2021-04-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17335137#comment-17335137 ] Shengkai Fang commented on FLINK-22503: --- Hi. This is the expected error. Please call `{{SET

[jira] [Closed] (FLINK-22503) getting error on select query in flink sql

2021-04-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-22503. - Resolution: Not A Bug > getting error on select query in flink sql >

[jira] [Updated] (FLINK-22503) getting error on select query in flink sql

2021-04-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22503: -- Component/s: (was: Table SQL / API) Table SQL / Client > getting error

[jira] [Closed] (FLINK-22499) JDBC sink table-api support "sink.parallelism" ?

2021-04-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-22499. - Resolution: Implemented > JDBC sink table-api support "sink.parallelism" ? >

[jira] [Commented] (FLINK-22499) JDBC sink table-api support "sink.parallelism" ?

2021-04-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334473#comment-17334473 ] Shengkai Fang commented on FLINK-22499: --- Please refer to the doc[1]  

[jira] [Commented] (FLINK-22460) Conversion to relational algebra failed due to NOT NULL modifier

2021-04-26 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17332902#comment-17332902 ] Shengkai Fang commented on FLINK-22460: --- It seems the input schema is not as same as the sink

[jira] [Created] (FLINK-22486) Wrong results of the IN operator

2021-04-26 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22486: - Summary: Wrong results of the IN operator Key: FLINK-22486 URL: https://issues.apache.org/jira/browse/FLINK-22486 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-22460) Conversion to relational algebra failed due to NOT NULL modifier

2021-04-25 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331727#comment-17331727 ] Shengkai Fang commented on FLINK-22460: --- Could you provide the ddl of the `result_1` ? >

[jira] [Updated] (FLINK-22454) Ignore CAST condition in lookup join

2021-04-25 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22454: -- Component/s: (was: Table SQL / API) Table SQL / Planner > Ignore CAST

[jira] [Created] (FLINK-22454) Ignore CAST condition in temporal join

2021-04-25 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22454: - Summary: Ignore CAST condition in temporal join Key: FLINK-22454 URL: https://issues.apache.org/jira/browse/FLINK-22454 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-22454) Ignore CAST condition in lookup join

2021-04-25 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22454: -- Summary: Ignore CAST condition in lookup join (was: Ignore CAST condition in temporal join )

[jira] [Closed] (FLINK-22170) Manual test for hive dialect

2021-04-19 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-22170. - Resolution: Fixed > Manual test for hive dialect > > >

[jira] [Updated] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

2021-04-19 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22338: -- Fix Version/s: 1.14.0 > Clear watermark output when test finished for >

[jira] [Comment Edited] (FLINK-22170) Manual test for hive dialect

2021-04-19 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324665#comment-17324665 ] Shengkai Fang edited comment on FLINK-22170 at 4/19/21, 6:07 AM: - Thanks

[jira] [Updated] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

2021-04-18 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22338: -- Fix Version/s: 1.13.0 > Clear watermark output when test finished for >

[jira] [Created] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

2021-04-18 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22338: - Summary: Clear watermark output when test finished for FromElementSourceFunctionWithWatermark Key: FLINK-22338 URL: https://issues.apache.org/jira/browse/FLINK-22338

[jira] [Commented] (FLINK-22170) Manual test for hive dialect

2021-04-18 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324665#comment-17324665 ] Shengkai Fang commented on FLINK-22170: --- Thanks for [~lirui] detailed guidance. I have verified

[jira] [Created] (FLINK-22334) Fail to translate the hive-sql in STREAMING mode

2021-04-18 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22334: - Summary: Fail to translate the hive-sql in STREAMING mode Key: FLINK-22334 URL: https://issues.apache.org/jira/browse/FLINK-22334 Project: Flink Issue

[jira] [Created] (FLINK-22309) Reduce response time when using SQL Client submit query(SELECT)

2021-04-16 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22309: - Summary: Reduce response time when using SQL Client submit query(SELECT) Key: FLINK-22309 URL: https://issues.apache.org/jira/browse/FLINK-22309 Project: Flink

[jira] [Created] (FLINK-22308) Fix CliTableauResultView print results after cancel in STREAMING mode

2021-04-16 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22308: - Summary: Fix CliTableauResultView print results after cancel in STREAMING mode Key: FLINK-22308 URL: https://issues.apache.org/jira/browse/FLINK-22308 Project:

[jira] [Closed] (FLINK-20813) SQL Client should create modules with user class loader

2021-04-15 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-20813. - Resolution: Fixed Fixed. > SQL Client should create modules with user class loader >

[jira] [Closed] (FLINK-20549) New ExecutionContext doesn't inherit classloader from previous context

2021-04-15 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-20549. - Resolution: Fixed !image-2021-04-15-16-52-38-799.png! Verified in my local env. > New

[jira] [Updated] (FLINK-20549) New ExecutionContext doesn't inherit classloader from previous context

2021-04-15 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-20549: -- Attachment: image-2021-04-15-16-51-16-765.png > New ExecutionContext doesn't inherit

[jira] [Closed] (FLINK-21746) flink sql fields in row access error about scalarfunction

2021-04-15 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-21746. - Resolution: Fixed Fix in FLINK-22082. Verify the case in local environment. > flink sql fields

[jira] [Updated] (FLINK-22176) Test SQL Client manually

2021-04-14 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22176: -- Description: Test SQL Client including - SET/RESET runtime parameter, e.g job name - Use

[jira] [Updated] (FLINK-22245) Reuse PrintUtils.MAX_COLUMN_WIDTH in CliChangelogResultView and CliTableResultView

2021-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22245: -- Description: The max column width in CliChangelogResultView and CliTableResultView is 25. In

[jira] [Updated] (FLINK-22245) Reuse PrintUtils.MAX_COLUMN_WIDTH in CliChangelogResultView and CliTableResultView

2021-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22245: -- Attachment: sql-client.png > Reuse PrintUtils.MAX_COLUMN_WIDTH in CliChangelogResultView and

[jira] [Updated] (FLINK-22245) Reuse PrintUtils.MAX_COLUMN_WIDTH in CliChangelogResultView and CliTableResultView

2021-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22245: -- Description: The max column width in CliChangelogResultView and CliTableResultView is 25. In

[jira] [Created] (FLINK-22245) Reuse PrintUtils.MAX_COLUMN_WIDTH in CliChangelogResultView and CliTableResultView

2021-04-12 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22245: - Summary: Reuse PrintUtils.MAX_COLUMN_WIDTH in CliChangelogResultView and CliTableResultView Key: FLINK-22245 URL: https://issues.apache.org/jira/browse/FLINK-22245

[jira] [Commented] (FLINK-21464) Support ADD JAR command in sql client

2021-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319831#comment-17319831 ] Shengkai Fang commented on FLINK-21464: --- [~xiangtao] Thanks for your contribution. Will take a

[jira] [Closed] (FLINK-17948) Use new type system for SQL Client collect sink

2021-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-17948. - Resolution: Fixed > Use new type system for SQL Client collect sink >

[jira] [Commented] (FLINK-17948) Use new type system for SQL Client collect sink

2021-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319821#comment-17319821 ] Shengkai Fang commented on FLINK-17948: --- !image-2021-04-13-10-26-34-721.png! solved > Use new

[jira] [Updated] (FLINK-17948) Use new type system for SQL Client collect sink

2021-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-17948: -- Attachment: image-2021-04-13-10-26-34-721.png > Use new type system for SQL Client collect

[jira] [Closed] (FLINK-15509) Use sql cilents create view occur Unexpected exception

2021-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-15509. - Resolution: Not A Problem > Use sql cilents create view occur Unexpected exception >

[jira] [Commented] (FLINK-21748) LocalExecutorITCase.testBatchQueryExecutionMultipleTimes[Planner: old] fails

2021-04-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319458#comment-17319458 ] Shengkai Fang commented on FLINK-21748: --- Thanks for Kurt's tips. The problem is because of

[jira] [Updated] (FLINK-22176) Test SQL Client manually

2021-04-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22176: -- Labels: release-testing (was: ) > Test SQL Client manually > > >

[jira] [Updated] (FLINK-22176) Test SQL Client manually

2021-04-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22176: -- Issue Type: Test (was: Bug) > Test SQL Client manually > > >

[jira] [Updated] (FLINK-22176) Test SQL Client manually

2021-04-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22176: -- Priority: Critical (was: Major) > Test SQL Client manually > > >

[jira] [Created] (FLINK-22176) Test SQL Client manually

2021-04-09 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22176: - Summary: Test SQL Client manually Key: FLINK-22176 URL: https://issues.apache.org/jira/browse/FLINK-22176 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-22171) Update the doc about SQL Client

2021-04-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22171: -- Fix Version/s: 1.13.0 > Update the doc about SQL Client > --- > >

[jira] [Updated] (FLINK-22171) Update the doc about SQL Client

2021-04-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22171: -- Affects Version/s: 1.13.0 > Update the doc about SQL Client > ---

[jira] [Created] (FLINK-22171) Update the doc about SQL Client

2021-04-09 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22171: - Summary: Update the doc about SQL Client Key: FLINK-22171 URL: https://issues.apache.org/jira/browse/FLINK-22171 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-22171) Update the doc about SQL Client

2021-04-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22171: -- Component/s: Documentation > Update the doc about SQL Client >

<    3   4   5   6   7   8   9   10   11   >