Re: [PR] [hotfix] Fix spelling of RowTimeMiniBatchAssignerOperator class [flink]

2024-01-27 Thread via GitHub
flinkbot commented on PR #24210: URL: https://github.com/apache/flink/pull/24210#issuecomment-1913491004 ## CI report: * 6d0993d870ff48c28409170332baaf7678981022 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [hotfix] Fix spelling of RowTimeMiniBatchAssignerOperator class [flink]

2024-01-27 Thread via GitHub
dchristle opened a new pull request, #24210: URL: https://github.com/apache/flink/pull/24210 ## What is the purpose of the change Fixes the spelling of the table runtime class `RowTimeMiniBatchAssginerOperator` -> `RowTimeMiniBatchAssignerOperator`, and updates associated

[jira] [Commented] (FLINK-34239) Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl

2024-01-27 Thread Kumar Mallikarjuna (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811634#comment-17811634 ] Kumar Mallikarjuna commented on FLINK-34239: Hi, I'm new to the community. This seems like a

Re: [PR] [FLINK-34058][table] Support optional parameters for named parameters [flink]

2024-01-27 Thread via GitHub
hackergin commented on code in PR #24183: URL: https://github.com/apache/flink/pull/24183#discussion_r1468766280 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference/TypeInferenceOperandChecker.java: ## @@ -116,7 +127,17 @@ public

Re: [PR] [FLINK-34058][table] Support optional parameters for named parameters [flink]

2024-01-27 Thread via GitHub
hackergin commented on code in PR #24183: URL: https://github.com/apache/flink/pull/24183#discussion_r1468765647 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference/TypeInferenceOperandChecker.java: ## @@ -116,7 +127,17 @@ public

[jira] [Commented] (FLINK-34200) AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

2024-01-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811633#comment-17811633 ] Zhu Zhu commented on FLINK-34200: -

Re: [PR] [FLINK-34245][python] Fix config retrieval logic from nested YAML in pyflink_gateway_server with flattened keys. [flink]

2024-01-27 Thread via GitHub
zhuzhurk commented on PR #24209: URL: https://github.com/apache/flink/pull/24209#issuecomment-1913475259 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

Re: [PR] [FLINK-34058][table] Support optional parameters for named parameters [flink]

2024-01-27 Thread via GitHub
hackergin commented on code in PR #24183: URL: https://github.com/apache/flink/pull/24183#discussion_r1468765647 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference/TypeInferenceOperandChecker.java: ## @@ -116,7 +127,17 @@ public

Re: [PR] [FLINK-34058][table] Support optional parameters for named parameters [flink]

2024-01-27 Thread via GitHub
hackergin commented on code in PR #24183: URL: https://github.com/apache/flink/pull/24183#discussion_r1468763844 ## flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/extraction/TypeInferenceExtractorTest.java: ## @@ -1810,4 +1844,30 @@ public String

Re: [PR] [FLINK-34237][connectors/mongodb] Update MongoWriterITCase to be compatible with updated SinkV2 interfaces [flink-connector-mongodb]

2024-01-27 Thread via GitHub
Jiabao-Sun commented on PR #22: URL: https://github.com/apache/flink-connector-mongodb/pull/22#issuecomment-1913457035 Thanks @leonardBang for the review. PR title was updated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-33996) Support disabling project rewrite when multiple exprs in the project reference the same sub project field.

2024-01-27 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811594#comment-17811594 ] Jeyhun Karimov commented on FLINK-33996: Hi [~libenchao] Thanks for your comment. I agree that

Re: [PR] [FLINK-34245][python] Fix config retrieval logic from nested YAML in pyflink_gateway_server with flattened keys. [flink]

2024-01-27 Thread via GitHub
flinkbot commented on PR #24209: URL: https://github.com/apache/flink/pull/24209#issuecomment-1913271805 ## CI report: * 2a84b534a38f3b94225f987286f57ff39dc61e56 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34245) CassandraSinkTest.test_cassandra_sink fails under JDK17 and JDK21 due to InaccessibleObjectException

2024-01-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34245: --- Labels: pull-request-available test-stability (was: test-stability) >

[PR] [FLINK-34245][python] Fix config retrieval logic from nested YAML in pyflink_gateway_server with flattened keys. [flink]

2024-01-27 Thread via GitHub
JunRuiLee opened a new pull request, #24209: URL: https://github.com/apache/flink/pull/24209 ## What is the purpose of the change Fix wrong logic in pyflink_gateway_server that using flattened key to get value from a nested standard yaml. ## Verifying this

[jira] [Commented] (FLINK-34245) CassandraSinkTest.test_cassandra_sink fails under JDK17 and JDK21 due to InaccessibleObjectException

2024-01-27 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811562#comment-17811562 ] Junrui Li commented on FLINK-34245: --- [~Sergey Nuyanzin] Thanks for kindly reminder, it's a bug that

Re: [PR] [FLINK-21573][table-planner] Support expression reuse in codegen [flink]

2024-01-27 Thread via GitHub
flinkbot commented on PR #24208: URL: https://github.com/apache/flink/pull/24208#issuecomment-1913261797 ## CI report: * 6b1bd2ced37baed874d8570a043f0bcab9780afb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-21573) Support expression reuse in codegen

2024-01-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21573: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[PR] [FLINK-21573][table-planner] Support expression reuse in codegen [flink]

2024-01-27 Thread via GitHub
jeyhunkarimov opened a new pull request, #24208: URL: https://github.com/apache/flink/pull/24208 ## What is the purpose of the change Support expression reuse in codegen ## Brief change log - Support RexLocalRef - Optimize expression list and eliminate the

Re: [PR] [FLINK-34103][examples] Include flink-connector-datagen for AsyncIO example and bundle it into the dist by default [flink]

2024-01-27 Thread via GitHub
flinkbot commented on PR #24207: URL: https://github.com/apache/flink/pull/24207#issuecomment-1913257936 ## CI report: * 36cdc303a1e9686245bc9e28394f60b078fa6d96 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34103) AsyncIO example failed to run as DataGen Connector is not bundled

2024-01-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34103: --- Labels: pull-request-available (was: ) > AsyncIO example failed to run as DataGen

[PR] [FLINK-34103][examples] Include flink-connector-datagen for AsyncIO example and bundle it into the dist by default [flink]

2024-01-27 Thread via GitHub
X-czh opened a new pull request, #24207: URL: https://github.com/apache/flink/pull/24207 ## What is the purpose of the change Include flink-connector-datagen for AsyncIO example to fix dep missing problem and bundle it into the dist by default. ```xml

Re: [PR] [FLINK-34052][examples] Install the shaded streaming example jars in the maven repo [flink]

2024-01-27 Thread via GitHub
flinkbot commented on PR #24206: URL: https://github.com/apache/flink/pull/24206#issuecomment-1913252250 ## CI report: * e6cb657f8c0c2a59e73d2353b594684aa7a76c51 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

2024-01-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34052: --- Labels: pull-request-available (was: ) > Missing TopSpeedWindowing and SessionWindowing

[PR] [FLINK-34052][examples] Install the shaded streaming example jars in the maven repo [flink]

2024-01-27 Thread via GitHub
X-czh opened a new pull request, #24206: URL: https://github.com/apache/flink/pull/24206 ## What is the purpose of the change As a result of the changes implemented in [FLINK-32821](https://issues.apache.org/jira/browse/FLINK-32821), the build process no longer produces

[jira] [Comment Edited] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

2024-01-27 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811556#comment-17811556 ] Zhanghao Chen edited comment on FLINK-34052 at 1/27/24 4:26 PM: After

[jira] [Commented] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

2024-01-27 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811556#comment-17811556 ] Zhanghao Chen commented on FLINK-34052: --- After invertigation, it turned out that the issue was

[jira] [Comment Edited] (FLINK-34052) Missing TopSpeedWindowing and SessionWindowing JARs in Flink Maven Repository

2024-01-27 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811556#comment-17811556 ] Zhanghao Chen edited comment on FLINK-34052 at 1/27/24 4:25 PM: After

Re: [PR] [FLINK-34222][table] End-to-end implementation of minibatch join [flink]

2024-01-27 Thread via GitHub
lincoln-lil commented on PR #24161: URL: https://github.com/apache/flink/pull/24161#issuecomment-1913183889 @xishuaidelin The failure case is an known issue (https://issues.apache.org/jira/browse/FLINK-34206), you can rebase the latest master and rerun the tests. -- This is an

[jira] [Commented] (FLINK-34245) CassandraSinkTest.test_cassandra_sink fails under JDK17 and JDK21 due to InaccessibleObjectException

2024-01-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811522#comment-17811522 ] Sergey Nuyanzin commented on FLINK-34245: - Bisect shows that the error is related to

[jira] [Comment Edited] (FLINK-34245) CassandraSinkTest.test_cassandra_sink fails under JDK17 and JDK21 due to InaccessibleObjectException

2024-01-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811522#comment-17811522 ] Sergey Nuyanzin edited comment on FLINK-34245 at 1/27/24 1:44 PM: --

[jira] [Closed] (FLINK-34122) Deprecate old serialization config methods and options

2024-01-27 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-34122. -- Resolution: Done master via 2e56caf11c0ebe4461e6389b7d5c1a9ea2ff621f > Deprecate old serialization

Re: [PR] [FLINK-34122][core] Deprecate old serialization config methods and options [flink]

2024-01-27 Thread via GitHub
reswqa commented on PR #24193: URL: https://github.com/apache/flink/pull/24193#issuecomment-1913143127 Thanks, merged. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

Re: [PR] [FLINK-34122][core] Deprecate old serialization config methods and options [flink]

2024-01-27 Thread via GitHub
reswqa merged PR #24193: URL: https://github.com/apache/flink/pull/24193 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-34246) Allow only archive failed job to history server

2024-01-27 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811480#comment-17811480 ] Lim Qing Wei commented on FLINK-34246: -- Hi [~Wencong Liu] , thanks for replying. Sorry I wasnt