[jira] [Commented] (FLINK-25234) Flink should parse ISO timestamp in UTC format

2024-05-09 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845049#comment-17845049 ] Eric Xiao commented on FLINK-25234: --- We just hit similar errors when trying to consume JSON data with

[jira] [Created] (FLINK-31941) Not backwards compatible naming for some kubernetes resources

2023-04-25 Thread Eric Xiao (Jira)
Eric Xiao created FLINK-31941: - Summary: Not backwards compatible naming for some kubernetes resources Key: FLINK-31941 URL: https://issues.apache.org/jira/browse/FLINK-31941 Project: Flink

[jira] [Updated] (FLINK-31873) Add setMaxParallelism to the DataStreamSink Class

2023-04-21 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Xiao updated FLINK-31873: -- Description: When turning on Flink reactive mode, it is suggested to convert all {{setParallelism}}

[jira] [Updated] (FLINK-31873) Add setMaxParallelism to the DataStreamSink Class

2023-04-21 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Xiao updated FLINK-31873: -- Description: When turning on Flink reactive mode, it is suggested to convert all {{setParallelism}}

[jira] [Commented] (FLINK-31873) Add setMaxParallelism to the DataStreamSink Class

2023-04-21 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715028#comment-17715028 ] Eric Xiao commented on FLINK-31873: --- Thanks [~martijnvisser] and [~luoyuxia], I will start with

[jira] [Commented] (FLINK-31873) Add setMaxParallelism to the DataStreamSink Class

2023-04-20 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714745#comment-17714745 ] Eric Xiao commented on FLINK-31873: --- I have an open PR to address this issue:

[jira] [Updated] (FLINK-31873) Add setMaxParallelism to the DataStreamSink Class

2023-04-20 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Xiao updated FLINK-31873: -- Attachment: Screenshot 2023-04-20 at 4.33.14 PM.png > Add setMaxParallelism to the DataStreamSink

[jira] [Updated] (FLINK-31873) Add setMaxParallelism to the DataStreamSink Class

2023-04-20 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Xiao updated FLINK-31873: -- Description: When turning on Flink reactive mode, it is suggested to convert all {{setParallelism}}

[jira] [Created] (FLINK-31873) Add setMaxParallelism to the DataStreamSink Class

2023-04-20 Thread Eric Xiao (Jira)
Eric Xiao created FLINK-31873: - Summary: Add setMaxParallelism to the DataStreamSink Class Key: FLINK-31873 URL: https://issues.apache.org/jira/browse/FLINK-31873 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-29073) [FLIP-91] Support SQL Gateway(Part 2)

2022-11-23 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637941#comment-17637941 ] Eric Xiao commented on FLINK-29073: --- Thanks [~yzl]! Yes let's connect after the FLIP is accepted as

[jira] [Comment Edited] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

2022-11-21 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636864#comment-17636864 ] Eric Xiao edited comment on FLINK-21301 at 11/21/22 8:16 PM: - Hi there, I

[jira] [Commented] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

2022-11-21 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636864#comment-17636864 ] Eric Xiao commented on FLINK-21301: --- Hi there, I had a read of

[jira] [Commented] (FLINK-29073) [FLIP-91] Support SQL Gateway(Part 2)

2022-11-21 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636842#comment-17636842 ] Eric Xiao commented on FLINK-29073: --- Hi there, are any of the tasks above good for someone new to the

[jira] [Commented] (FLINK-29837) SQL API does not expose the RowKind of the Row for processing Changelogs

2022-11-03 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628369#comment-17628369 ] Eric Xiao commented on FLINK-29837: --- Hi [~luoyuxia] thanks for responding! We are exploring the Flink

[jira] [Updated] (FLINK-29837) SQL API does not expose the RowKind of the Row for processing Changelogs

2022-11-03 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Xiao updated FLINK-29837: -- Description: When working with `{{{}ChangeLog{}}}` data in the SQL API it was a bit misleading to

[jira] [Created] (FLINK-29837) SQL API does not expose the RowKind of the Row for processing Changelogs

2022-11-01 Thread Eric Xiao (Jira)
Eric Xiao created FLINK-29837: - Summary: SQL API does not expose the RowKind of the Row for processing Changelogs Key: FLINK-29837 URL: https://issues.apache.org/jira/browse/FLINK-29837 Project: Flink

[jira] [Comment Edited] (FLINK-20578) Cannot create empty array using ARRAY[]

2022-10-26 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154 ] Eric Xiao edited comment on FLINK-20578 at 10/26/22 7:24 PM: - Hi I wanted to

[jira] [Comment Edited] (FLINK-20578) Cannot create empty array using ARRAY[]

2022-10-26 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154 ] Eric Xiao edited comment on FLINK-20578 at 10/26/22 7:20 PM: - Hi I wanted to

[jira] [Comment Edited] (FLINK-20578) Cannot create empty array using ARRAY[]

2022-10-26 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154 ] Eric Xiao edited comment on FLINK-20578 at 10/26/22 6:43 PM: - Hi I wanted to

[jira] [Comment Edited] (FLINK-20578) Cannot create empty array using ARRAY[]

2022-10-26 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154 ] Eric Xiao edited comment on FLINK-20578 at 10/26/22 6:29 PM: - Hi I wanted to

[jira] [Comment Edited] (FLINK-20578) Cannot create empty array using ARRAY[]

2022-10-26 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154 ] Eric Xiao edited comment on FLINK-20578 at 10/26/22 6:27 PM: - Hi I wanted to

[jira] [Comment Edited] (FLINK-20578) Cannot create empty array using ARRAY[]

2022-10-25 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154 ] Eric Xiao edited comment on FLINK-20578 at 10/26/22 4:19 AM: - Hi I wanted to

[jira] [Comment Edited] (FLINK-20578) Cannot create empty array using ARRAY[]

2022-10-25 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154 ] Eric Xiao edited comment on FLINK-20578 at 10/26/22 3:53 AM: - Hi I wanted to

[jira] [Comment Edited] (FLINK-20578) Cannot create empty array using ARRAY[]

2022-10-25 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154 ] Eric Xiao edited comment on FLINK-20578 at 10/26/22 3:04 AM: - Hi I wanted to

[jira] [Commented] (FLINK-20578) Cannot create empty array using ARRAY[]

2022-10-25 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154 ] Eric Xiao commented on FLINK-20578: --- Hi I wanted to get more involved in contributing to the Flink

[jira] [Updated] (FLINK-20578) Cannot create empty array using ARRAY[]

2022-10-25 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Xiao updated FLINK-20578: -- Attachment: Screen Shot 2022-10-25 at 10.50.42 PM.png Screen Shot 2022-10-25 at

[jira] [Commented] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-20 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621332#comment-17621332 ] Eric Xiao commented on FLINK-29498: --- [~gaoyunhaii], I believe I have a

[jira] [Comment Edited] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-20 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621332#comment-17621332 ] Eric Xiao edited comment on FLINK-29498 at 10/20/22 7:30 PM: - Hi

[jira] [Commented] (FLINK-25595) Specify hash/sort aggregate strategy in SQL hint

2022-10-20 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621193#comment-17621193 ] Eric Xiao commented on FLINK-25595: --- Hi [~godfreyhe] and [~jingzhang], I would like to get more

[jira] [Commented] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-16 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618378#comment-17618378 ] Eric Xiao commented on FLINK-29498: --- As discussed in the [slack

[jira] [Comment Edited] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-04 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612625#comment-17612625 ] Eric Xiao edited comment on FLINK-29498 at 10/4/22 2:03 PM: > For your case,

[jira] [Commented] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-04 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612625#comment-17612625 ] Eric Xiao commented on FLINK-29498: --- [~lincoln.86xy], is there a reason why the `AsyncRetryStrategies`

[jira] [Updated] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-03 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Xiao updated FLINK-29498: -- Description: We are using the async I/O to make HTTP calls and one of the features we wanted to

[jira] [Updated] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-03 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Xiao updated FLINK-29498: -- Description: When I try calling the function \{{AsyncDataStream.unorderedWaitWithRetry}} from the

[jira] [Created] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-03 Thread Eric Xiao (Jira)
Eric Xiao created FLINK-29498: - Summary: Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API Key: FLINK-29498 URL: https://issues.apache.org/jira/browse/FLINK-29498 Project: Flink