[jira] [Commented] (FLINK-24999) flink-python doesn't work on Java 17

2022-12-26 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652091#comment-17652091 ] Luning Wang commented on FLINK-24999: - maven-shade-plugin 3.2.4 don't support java17, bump it to >=

[jira] [Commented] (FLINK-24999) flink-python doesn't work on Java 17

2022-12-15 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647943#comment-17647943 ] Luning Wang commented on FLINK-24999: - I want to bump Scala version to 2.12.16 in my local, but it

[jira] [Created] (FLINK-29354) Support TO_DATE and TO_TIMESTAMP built-in function in the Table API

2022-09-20 Thread Luning Wang (Jira)
Luning Wang created FLINK-29354: --- Summary: Support TO_DATE and TO_TIMESTAMP built-in function in the Table API Key: FLINK-29354 URL: https://issues.apache.org/jira/browse/FLINK-29354 Project: Flink

[jira] [Created] (FLINK-29353) Support UNIX_TIMESTAMP built-in function in Table API

2022-09-20 Thread Luning Wang (Jira)
Luning Wang created FLINK-29353: --- Summary: Support UNIX_TIMESTAMP built-in function in Table API Key: FLINK-29353 URL: https://issues.apache.org/jira/browse/FLINK-29353 Project: Flink Issue

[jira] [Created] (FLINK-29352) Support CONVERT_TZ built-in function in Table API

2022-09-20 Thread Luning Wang (Jira)
Luning Wang created FLINK-29352: --- Summary: Support CONVERT_TZ built-in function in Table API Key: FLINK-29352 URL: https://issues.apache.org/jira/browse/FLINK-29352 Project: Flink Issue Type:

[jira] [Commented] (FLINK-28920) Release Testing: Verify Python DataStream Window

2022-08-15 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17580053#comment-17580053 ] Luning Wang commented on FLINK-28920: - This test can successfully run on an M1 chip. [~hxbks2ks] >

[jira] [Commented] (FLINK-28918) Release Testing: Verify FLIP-206 in Python DataStream API

2022-08-15 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17580054#comment-17580054 ] Luning Wang commented on FLINK-28918: - This test can successfully run on an M1 chip. [~hxbks2ks] >

[jira] [Commented] (FLINK-28920) Release Testing: Verify Python DataStream Window

2022-08-15 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17580025#comment-17580025 ] Luning Wang commented on FLINK-28920: - I will test this on M1 Chip. > Release Testing: Verify

[jira] [Commented] (FLINK-28918) Release Testing: Verify FLIP-206 in Python DataStream API

2022-08-15 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17580024#comment-17580024 ] Luning Wang commented on FLINK-28918: - I will test this on M1 Chip. > Release Testing: Verify

[jira] [Updated] (FLINK-28972) Add methods of StartCursor and StopCursor to align the Java

2022-08-15 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luning Wang updated FLINK-28972: Fix Version/s: 1.15.2 1.14.6 > Add methods of StartCursor and StopCursor to

[jira] [Updated] (FLINK-28972) Add methods of StartCursor and StopCursor to align the Java

2022-08-15 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luning Wang updated FLINK-28972: Fix Version/s: 1.16.0 > Add methods of StartCursor and StopCursor to align the Java >

[jira] [Commented] (FLINK-28972) Add methods of StartCursor and StopCursor to align the Java

2022-08-15 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17579667#comment-17579667 ] Luning Wang commented on FLINK-28972: - I'll fix this soon > Add methods of StartCursor and

[jira] [Created] (FLINK-28972) Add methods of StartCursor and StopCursor to align the Java

2022-08-15 Thread Luning Wang (Jira)
Luning Wang created FLINK-28972: --- Summary: Add methods of StartCursor and StopCursor to align the Java Key: FLINK-28972 URL: https://issues.apache.org/jira/browse/FLINK-28972 Project: Flink

[jira] [Created] (FLINK-28882) ENCODE return error

2022-08-08 Thread Luning Wang (Jira)
Luning Wang created FLINK-28882: --- Summary: ENCODE return error Key: FLINK-28882 URL: https://issues.apache.org/jira/browse/FLINK-28882 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-27588) Update broadcast state related docs for PyFlink

2022-08-08 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576637#comment-17576637 ] Luning Wang edited comment on FLINK-27588 at 8/8/22 12:05 PM: -- [~dianfu]

[jira] [Commented] (FLINK-27588) Update broadcast state related docs for PyFlink

2022-08-08 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576637#comment-17576637 ] Luning Wang commented on FLINK-27588: - [~dianfu] [~hxbks2ks] Sorry I'm late. Since the code is

[jira] [Commented] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

2022-08-03 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17574553#comment-17574553 ] Luning Wang commented on FLINK-28786: - I can't reproduce this problem in macOS Monterey 12.4 &

[jira] [Closed] (FLINK-28508) Support SPLIT_INDEX and STR_TO_MAP built-in function in Table API

2022-07-14 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LuNing Wang closed FLINK-28508. --- Resolution: Fixed > Support SPLIT_INDEX and STR_TO_MAP built-in function in Table API >

[jira] [Created] (FLINK-28509) Support REVERSE built-in function in Table API

2022-07-12 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28509: --- Summary: Support REVERSE built-in function in Table API Key: FLINK-28509 URL: https://issues.apache.org/jira/browse/FLINK-28509 Project: Flink Issue Type:

[jira] [Created] (FLINK-28508) Support SPLIT_INDEX and STR_TO_MAP built-in function in Table API

2022-07-12 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28508: --- Summary: Support SPLIT_INDEX and STR_TO_MAP built-in function in Table API Key: FLINK-28508 URL: https://issues.apache.org/jira/browse/FLINK-28508 Project: Flink

[jira] [Updated] (FLINK-28444) Support SUBSTR without parameter in SQL and Table API

2022-07-07 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LuNing Wang updated FLINK-28444: Description: SUBSTR() has no parameter functionality in the doc, but the code only supports

[jira] [Commented] (FLINK-28444) Support SUBSTR without parameter in SQL and Table API

2022-07-07 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563662#comment-17563662 ] LuNing Wang commented on FLINK-28444: - I would like to take this. > Support SUBSTR without

[jira] [Created] (FLINK-28444) Support SUBSTR without parameter in SQL and Table API

2022-07-07 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28444: --- Summary: Support SUBSTR without parameter in SQL and Table API Key: FLINK-28444 URL: https://issues.apache.org/jira/browse/FLINK-28444 Project: Flink Issue

[jira] [Created] (FLINK-28439) Support SUBSTR and REGEXP built-in function in Table API

2022-07-07 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28439: --- Summary: Support SUBSTR and REGEXP built-in function in Table API Key: FLINK-28439 URL: https://issues.apache.org/jira/browse/FLINK-28439 Project: Flink

[jira] [Comment Edited] (FLINK-28428) Example in the Elasticsearch doc of fault tolerance section is missing

2022-07-06 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563273#comment-17563273 ] LuNing Wang edited comment on FLINK-28428 at 7/6/22 2:46 PM: - Whether this

[jira] [Commented] (FLINK-28428) Example in the Elasticsearch doc of fault tolerance section is missing

2022-07-06 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563273#comment-17563273 ] LuNing Wang commented on FLINK-28428: - Whether this

[jira] [Commented] (FLINK-28428) Example in the Elasticsearch doc of fault tolerance section is missing

2022-07-06 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563197#comment-17563197 ] LuNing Wang commented on FLINK-28428: - I will fix this. > Example in the Elasticsearch doc of fault

[jira] [Created] (FLINK-28428) Example in the Elasticsearch doc of fault tolerance section is missing

2022-07-06 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28428: --- Summary: Example in the Elasticsearch doc of fault tolerance section is missing Key: FLINK-28428 URL: https://issues.apache.org/jira/browse/FLINK-28428 Project: Flink

[jira] [Created] (FLINK-28369) Support PARSE_URL bulit-in function in Table API

2022-07-03 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28369: --- Summary: Support PARSE_URL bulit-in function in Table API Key: FLINK-28369 URL: https://issues.apache.org/jira/browse/FLINK-28369 Project: Flink Issue Type:

[jira] [Created] (FLINK-28354) Support instr and locate bulit-in function in Table API

2022-07-01 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28354: --- Summary: Support instr and locate bulit-in function in Table API Key: FLINK-28354 URL: https://issues.apache.org/jira/browse/FLINK-28354 Project: Flink Issue

[jira] [Created] (FLINK-28298) Support left and right built-in function in the Table API

2022-06-29 Thread LuNing Wang (Jira)
Title: Message Title LuNing Wang created

[jira] [Updated] (FLINK-28288) Support decode and encode built-in function in the Table API

2022-06-28 Thread LuNing Wang (Jira)
Title: Message Title LuNing Wang updated

[jira] [Updated] (FLINK-28288) Support decode and encode built-in function in the Table API

2022-06-28 Thread LuNing Wang (Jira)
Title: Message Title LuNing Wang updated

[jira] [Created] (FLINK-28288) Support decode and encode built-in function in the Table API

2022-06-28 Thread LuNing Wang (Jira)
Title: Message Title LuNing Wang created

[jira] [Commented] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

2022-06-22 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557293#comment-17557293 ] LuNing Wang commented on FLINK-26541: - big +1 for this feature > SQL Client should support

[jira] [Commented] (FLINK-28107) Support id of document is null

2022-06-19 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17556045#comment-17556045 ] LuNing Wang commented on FLINK-28107: - [~jingge] Thanks, currently I will create the same two PR for

[jira] [Updated] (FLINK-28109) Delete useful code in the row emitter.

2022-06-17 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LuNing Wang updated FLINK-28109: Description:   The `.id(key)` in the RowElasticsearchEmitter make users get confused. The

[jira] [Created] (FLINK-28109) Delete useful code in the row emitter.

2022-06-17 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28109: --- Summary: Delete useful code in the row emitter. Key: FLINK-28109 URL: https://issues.apache.org/jira/browse/FLINK-28109 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-28107) Support id of document is null

2022-06-17 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555488#comment-17555488 ] LuNing Wang commented on FLINK-28107: - [~martijnvisser] When this PR merge the main repo, I will

[jira] [Updated] (FLINK-28107) Support id of document is null

2022-06-17 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LuNing Wang updated FLINK-28107: Description:   {code:java} es7_sink = Elasticsearch7SinkBuilder() \

[jira] [Created] (FLINK-28107) Support id of document is null

2022-06-17 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28107: --- Summary: Support id of document is null Key: FLINK-28107 URL: https://issues.apache.org/jira/browse/FLINK-28107 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-28071) Support missing built-in functions in Table API

2022-06-17 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555445#comment-17555445 ] LuNing Wang edited comment on FLINK-28071 at 6/17/22 7:33 AM: -- [~twalthr]

[jira] [Commented] (FLINK-28071) Support missing built-in functions in Table API

2022-06-17 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555445#comment-17555445 ] LuNing Wang commented on FLINK-28071: - [~twalthr] I only support existing built-in functions no more

[jira] [Commented] (FLINK-28071) Support missing built-in functions in Table API

2022-06-16 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555359#comment-17555359 ] LuNing Wang commented on FLINK-28071: - [~twalthr]  Thanks a lot, I will take a look at these issues.

[jira] [Commented] (FLINK-28092) Support ASCII and CHR built-in function in the Table API

2022-06-16 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554993#comment-17554993 ] LuNing Wang commented on FLINK-28092: - [~Sergey Nuyanzin] Thanks a lot. You are right. > Support

[jira] (FLINK-28071) Support missing built-in functions in Table API

2022-06-16 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28071 ] LuNing Wang deleted comment on FLINK-28071: - was (Author: ana4): Support ASCII and CHR built-in function in the Table API > Support missing built-in functions in Table API >

[jira] (FLINK-28071) Support missing built-in functions in Table API

2022-06-16 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28071 ] LuNing Wang deleted comment on FLINK-28071: - was (Author: ana4): Support ASCII and CHR built-in function in the Table API > Support missing built-in functions in Table API >

[jira] [Commented] (FLINK-28071) Support missing built-in functions in Table API

2022-06-16 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554986#comment-17554986 ] LuNing Wang commented on FLINK-28071: - Support ASCII and CHR built-in function in the Table API >

[jira] [Commented] (FLINK-28071) Support missing built-in functions in Table API

2022-06-16 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554985#comment-17554985 ] LuNing Wang commented on FLINK-28071: - Support ASCII and CHR built-in function in the Table API >

[jira] [Created] (FLINK-28092) Support ASCII and CHR built-in function in the Table API

2022-06-16 Thread LuNing Wang (Jira)
LuNing Wang created FLINK-28092: --- Summary: Support ASCII and CHR built-in function in the Table API Key: FLINK-28092 URL: https://issues.apache.org/jira/browse/FLINK-28092 Project: Flink Issue

[jira] [Commented] (FLINK-28071) Support missing built-in functions in Table API

2022-06-15 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17554402#comment-17554402 ] LuNing Wang commented on FLINK-28071: - I would like to take this. [~dianfu]  > Support missing

[jira] [Commented] (FLINK-27197) Port ArrowTableSource and PythonInputFormatTableSource to DynamicTableSource

2022-06-10 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552612#comment-17552612 ] LuNing Wang commented on FLINK-27197: - [~dianfu] I would like to take this. > Port ArrowTableSource

[jira] [Comment Edited] (FLINK-27197) Port ArrowTableSource and PythonInputFormatTableSource to DynamicTableSource

2022-06-10 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552522#comment-17552522 ] LuNing Wang edited comment on FLINK-27197 at 6/10/22 7:25 AM: -- We need to

[jira] [Comment Edited] (FLINK-27197) Port ArrowTableSource and PythonInputFormatTableSource to DynamicTableSource

2022-06-10 Thread LuNing Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552522#comment-17552522 ] LuNing Wang edited comment on FLINK-27197 at 6/10/22 7:25 AM: -- We need to

[jira] [Updated] (FLINK-27010) Support setting sql client args via flink conf

2022-04-02 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luning Wang updated FLINK-27010: Description: '-i' '-j' and '-l' only be set in startup options.  I want to add the following

[jira] [Commented] (FLINK-27010) Support setting sql client args via flink conf

2022-04-02 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516252#comment-17516252 ] Luning Wang commented on FLINK-27010: - I would like to take this, please assign it to me. > Support

[jira] [Updated] (FLINK-27010) Support setting sql client args via flink conf

2022-04-02 Thread Luning Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luning Wang updated FLINK-27010: Description: -i' '-j' and '-l' only be set in startup options.  I want to add the following

[jira] [Created] (FLINK-27010) Support setting sql client args via flink conf

2022-04-02 Thread Luning Wang (Jira)
Luning Wang created FLINK-27010: --- Summary: Support setting sql client args via flink conf Key: FLINK-27010 URL: https://issues.apache.org/jira/browse/FLINK-27010 Project: Flink Issue Type: