Re: [PR] [FLINK-33453][build] Add java21-target profile [flink]

2023-11-03 Thread via GitHub
snuyanzin commented on PR #23657: URL: https://github.com/apache/flink/pull/23657#issuecomment-1793115293 @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

[jira] [Commented] (FLINK-32902) Docs creation and checks in multiple locations

2023-11-03 Thread ZY tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782804#comment-17782804 ] ZY tang commented on FLINK-32902: - I can merge the scrips to reduce redundancy. Could you assign it to

[jira] (FLINK-33445) Translate DataSet migration guideline to Chinese

2023-11-03 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33445 ] Yuxin Tan deleted comment on FLINK-33445: --- was (Author: tanyuxin): [~liyubin117] Thanks for helping, assigned to you. > Translate DataSet migration guideline to Chinese >

[jira] [Commented] (FLINK-33285) e2e 1 stage: Wordcount on Docker test (custom fs plugin)

2023-11-03 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782436#comment-17782436 ] Matthias Pohl commented on FLINK-33285: --- without docker-compose installation: *

[jira] [Assigned] (FLINK-33397) FLIP-373: Support Configuring Different State TTLs using SQL Hint

2023-11-03 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan reassigned FLINK-33397: - Assignee: xuyang > FLIP-373: Support Configuring Different State TTLs using SQL Hint >

[jira] [Commented] (FLINK-33397) FLIP-373: Support Configuring Different State TTLs using SQL Hint

2023-11-03 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782458#comment-17782458 ] Jane Chan commented on FLINK-33397: --- Thanks [~xuyangzhong] for the volunteer! > FLIP-373: Support

[jira] [Updated] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-03 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-33417: -- Attachment: run.log > Update netty version to 4.1.83 for flink-shaded >

Re: [PR] [FLINK-33407] Remove old expression stack leftovers for time functions [flink]

2023-11-03 Thread via GitHub
dawidwys merged PR #23630: URL: https://github.com/apache/flink/pull/23630 -- 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-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-03 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782463#comment-17782463 ] Yuxin Tan commented on FLINK-33417: --- [~mapohl] ok. Thanks for the tracking. The error is on our test

[jira] [Closed] (FLINK-33407) Remove old expression stack leftovers for time functions

2023-11-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-33407. Resolution: Fixed Fixed in 5da6b3eff29c14931c86b2018331c40ed256420f > Remove old

[jira] [Resolved] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-03 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-33417. --- Fix Version/s: shaded-16.2 Resolution: Fixed > Update netty version to 4.1.83 for

Re: [PR] [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core [flink]

2023-11-03 Thread via GitHub
GOODBOY008 closed pull request #19563: [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core URL: https://github.com/apache/flink/pull/19563 -- 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

Re: [PR] [FLINK-33171][table planner] Consistent implicit type coercion support for equal and non-equal comparisons for codegen [flink]

2023-11-03 Thread via GitHub
fengjiajie commented on PR #23478: URL: https://github.com/apache/flink/pull/23478#issuecomment-1792143248 @lincoln-lil @LadyForest When you have time, please take a look if any further modifications are needed, thanks. -- This is an automated message from the Apache Git Service. To

[jira] [Assigned] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

2023-11-03 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33448: --- Assignee: RocMarshal > Introduce a new configuration item 'taskmanager.load-balance.mode' >

Re: [PR] [FLINK-33099][autoscaler] Introduce the Standalone Autoscaler and support flink cluster [flink-kubernetes-operator]

2023-11-03 Thread via GitHub
1996fanrui commented on code in PR #698: URL: https://github.com/apache/flink-kubernetes-operator/pull/698#discussion_r1381453368 ## flink-autoscaler-standalone/src/test/java/org/apache/flink/autoscaler/standalone/StandaloneAutoscalerExecutorTest.java: ## @@ -0,0 +1,122 @@ +/*

Re: [PR] [FLINK-33304] Introduce the DeduplicatedMutator to resolve the mutation write conflict problem [flink-connector-hbase]

2023-11-03 Thread via GitHub
ferenc-csaky commented on code in PR #30: URL: https://github.com/apache/flink-connector-hbase/pull/30#discussion_r1381523010 ## flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java: ## @@ -256,4 +263,39 @@ public void

Re: [PR] [FLINK-33304] Introduce the DeduplicatedMutator to resolve the mutation write conflict problem [flink-connector-hbase]

2023-11-03 Thread via GitHub
ferenc-csaky commented on PR #30: URL: https://github.com/apache/flink-connector-hbase/pull/30#issuecomment-1792265703 @MartijnVisser this is ready for merge IMO. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-03 Thread Maciej Obuchowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782529#comment-17782529 ] Maciej Obuchowski commented on FLINK-31275: --- [~zjureel]  Generally the idea is that the

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-11-03 Thread via GitHub
1996fanrui commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1381212518 ## flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java: ## @@ -708,6 +708,20 @@ public class TaskManagerOptions {

[jira] [Assigned] (FLINK-30960) OutOfMemory error using jdbc sink

2023-11-03 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30960: -- Assignee: Bo Shen > OutOfMemory error using jdbc sink >

Re: [PR] [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core [flink]

2023-11-03 Thread via GitHub
Jiabao-Sun commented on code in PR #19563: URL: https://github.com/apache/flink/pull/19563#discussion_r1381328430 ## flink-core/src/test/java/org/apache/flink/api/common/accumulators/AverageAccumulatorTest.java: ## @@ -94,21 +92,21 @@ public void testMergeSuccess() { }

[jira] [Commented] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

2023-11-03 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782487#comment-17782487 ] RocMarshal commented on FLINK-33448: The Jira ticket resulted from

[jira] [Updated] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

2023-11-03 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33448: --- Description: Introduce a new configuration item 'taskmanager.load-balance.mode' and make it 

Re: [PR] [FLINK-33304] Introduce the DeduplicatedMutator to resolve the mutation write conflict problem [flink-connector-hbase]

2023-11-03 Thread via GitHub
Tan-JiaLiang commented on code in PR #30: URL: https://github.com/apache/flink-connector-hbase/pull/30#discussion_r1381499570 ## flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java: ## @@ -256,4 +263,39 @@ public void

[jira] [Commented] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-03 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782434#comment-17782434 ] Matthias Pohl commented on FLINK-33417: --- I see. But can you elaborate a bit more on how to

Re: [PR] [FLINK-33417][netty] Upgrade 4.1.82 -> 4.1.83 [flink-shaded]

2023-11-03 Thread via GitHub
XComp commented on PR #127: URL: https://github.com/apache/flink-shaded/pull/127#issuecomment-1791964077 Thanks @reswqa for verifying the PR as well. There's a discussion ongoing in FLINK-33417. I'm gonna wait with merging this change until the last questions are answered. -- This is an

Re: [PR] [FLINK-33417][netty] Upgrade 4.1.82 -> 4.1.83 [flink-shaded]

2023-11-03 Thread via GitHub
XComp commented on PR #127: URL: https://github.com/apache/flink-shaded/pull/127#issuecomment-1792100017 I merged the PR after a final investigation. The results of the investigation are collected in

Re: [PR] [FLINK-33417][netty] Upgrade 4.1.82 -> 4.1.83 [flink-shaded]

2023-11-03 Thread via GitHub
XComp merged PR #127: URL: https://github.com/apache/flink-shaded/pull/127 -- 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] [Created] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

2023-11-03 Thread RocMarshal (Jira)
RocMarshal created FLINK-33448: -- Summary: Introduce a new configuration item 'taskmanager.load-balance.mode' Key: FLINK-33448 URL: https://issues.apache.org/jira/browse/FLINK-33448 Project: Flink

[PR] Add Opensearch connector v1.1.0 [flink-web]

2023-11-03 Thread via GitHub
dannycranmer opened a new pull request, #694: URL: https://github.com/apache/flink-web/pull/694 (no comment) -- 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

[jira] [Updated] (FLINK-33447) Avoid CompiledPlan recompilation during loading

2023-11-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33447: --- Labels: pull-request-available (was: ) > Avoid CompiledPlan recompilation during loading >

Re: [PR] [FLINK-33099][autoscaler] Introduce the Standalone Autoscaler and support flink cluster [flink-kubernetes-operator]

2023-11-03 Thread via GitHub
1996fanrui commented on code in PR #698: URL: https://github.com/apache/flink-kubernetes-operator/pull/698#discussion_r1381448261 ## flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/StandaloneAutoscalerEntrypoint.java: ## @@ -0,0 +1,121 @@ +/* +

Re: [PR] [FLINK-33304] Introduce the DeduplicatedMutator to resolve the mutation write conflict problem [flink-connector-hbase]

2023-11-03 Thread via GitHub
ferenc-csaky commented on code in PR #30: URL: https://github.com/apache/flink-connector-hbase/pull/30#discussion_r1381475790 ## flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java: ## @@ -256,4 +263,39 @@ public void

[jira] [Resolved] (FLINK-33442) UnsupportedOperationException thrown from RocksDBIncrementalRestoreOperation

2023-11-03 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-33442. --- Resolution: Fixed > UnsupportedOperationException thrown from

[jira] [Updated] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33018: -- Fix Version/s: gcp-pubsub-3.1.0 > GCP Pubsub >

[jira] [Updated] (FLINK-32031) Flink GCP Connector having issues with Conscrypt library

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32031: -- Fix Version/s: gcp-pubsub-3.1.0 > Flink GCP Connector having issues with Conscrypt library >

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-11-03 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1381224693 ## flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java: ## @@ -708,6 +708,20 @@ public class TaskManagerOptions {

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-11-03 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1381224693 ## flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java: ## @@ -708,6 +708,20 @@ public class TaskManagerOptions {

[jira] [Commented] (FLINK-33397) FLIP-373: Support Configuring Different State TTLs using SQL Hint

2023-11-03 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782453#comment-17782453 ] xuyang commented on FLINK-33397: Hi, [~qingyue] .I'd like to take this jira.  > FLIP-373: Support

[jira] [Commented] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-03 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782478#comment-17782478 ] Matthias Pohl commented on FLINK-33417: --- release-16.0: 2e81185ea46261e7f6aca88fdd0a982193b4c86c >

[jira] [Commented] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

2023-11-03 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782493#comment-17782493 ] Rui Fan commented on FLINK-33448: - {quote}1. Introduce a new configuration item

[PR] [FLINK-33447][table-planner] Avoid CompiledPlan recompilation during loading [flink]

2023-11-03 Thread via GitHub
twalthr opened a new pull request, #23655: URL: https://github.com/apache/flink/pull/23655 ## What is the purpose of the change Avoids re-serializing of JSON during the load operation. The re-serialization makes still sense to retrieve a normalized JSON but this is a rather uncommon

Re: [PR] [FLINK-33447][table-planner] Avoid CompiledPlan recompilation during loading [flink]

2023-11-03 Thread via GitHub
flinkbot commented on PR #23655: URL: https://github.com/apache/flink/pull/23655#issuecomment-1792174571 ## CI report: * f094ed164fcc4f156797afe33cd651a57feea247 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

2023-11-03 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782503#comment-17782503 ] RocMarshal commented on FLINK-33448: Thanks for the reply~ :) > Introduce a new configuration item

Re: [PR] [FLINK-33442] Copy local state collection preventively [flink]

2023-11-03 Thread via GitHub
rkhachatryan merged PR #23654: URL: https://github.com/apache/flink/pull/23654 -- 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] [Updated] (FLINK-30850) Update GCP E2E tests to updated setup so they no longer publish their JARs

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30850: -- Fix Version/s: gcp-pubsub-3.1.0 > Update GCP E2E tests to updated setup so they no longer

[jira] [Updated] (FLINK-31923) Connector weekly runs are only testing main branches instead of all supported branches

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31923: -- Fix Version/s: gcp-pubsub-3.1.0 > Connector weekly runs are only testing main branches

[PR] Add GCP PubSub connector v3.0.2 [flink-web]

2023-11-03 Thread via GitHub
dannycranmer opened a new pull request, #695: URL: https://github.com/apache/flink-web/pull/695 (no comment) -- 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

[jira] [Commented] (FLINK-33438) HiveITCase.testHiveDialect and HiveITCase.testReadWriteHive are failing

2023-11-03 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782435#comment-17782435 ] Matthias Pohl commented on FLINK-33438: --- *

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-11-03 Thread via GitHub
1996fanrui commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1381232496 ## flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java: ## @@ -708,6 +708,20 @@ public class TaskManagerOptions {

Re: [PR] [FLINK-33395][table-planner] fix the join hint doesn't work when appears in subquery [flink]

2023-11-03 Thread via GitHub
LadyForest commented on code in PR #23620: URL: https://github.com/apache/flink/pull/23620#discussion_r1379750950 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/FlinkHints.java: ## @@ -234,4 +232,112 @@ private RelNode visitBiRel(BiRel

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-03 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782461#comment-17782461 ] Fang Yong commented on FLINK-31275: --- [~ZhenqiuHuang] Sounds nice to me, I think we can consider this

[jira] [Updated] (FLINK-32425) Fix Opensearch Connector wrong empty doc link

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32425: -- Fix Version/s: opensearch-1.1.0 > Fix Opensearch Connector wrong empty doc link >

[jira] [Updated] (FLINK-32228) Bump testcontainers to 1.18.2

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32228: -- Fix Version/s: opensearch-1.1.0 > Bump testcontainers to 1.18.2 >

Re: [PR] [FLINK-33417][netty] Upgrade 4.1.82 -> 4.1.83 [flink-shaded]

2023-11-03 Thread via GitHub
TanYuxin-tyx commented on PR #127: URL: https://github.com/apache/flink-shaded/pull/127#issuecomment-1792105273 @XComp Thanks a lot for your investigation and the careful review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-11-03 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782488#comment-17782488 ] david radley commented on FLINK-33365: -- I did not create using the back level jdbc driver. Though I

Re: [PR] [FLINK-33099][autoscaler] Introduce the Standalone Autoscaler and support flink cluster [flink-kubernetes-operator]

2023-11-03 Thread via GitHub
mateczagany commented on code in PR #698: URL: https://github.com/apache/flink-kubernetes-operator/pull/698#discussion_r1381317015 ## flink-autoscaler-standalone/src/test/java/org/apache/flink/autoscaler/standalone/StandaloneAutoscalerExecutorTest.java: ## @@ -0,0 +1,122 @@

Re: [PR] [FLINK-33417][netty] Upgrade 4.1.82 -> 4.1.83 [flink-shaded]

2023-11-03 Thread via GitHub
reswqa commented on PR #127: URL: https://github.com/apache/flink-shaded/pull/127#issuecomment-1791968810 > I'm gonna wait with merging this change until the last questions are answered. Yes, make sense. -- This is an automated message from the Apache Git Service. To respond to

[jira] [Created] (FLINK-33447) Avoid CompiledPlan recompilation during loading

2023-11-03 Thread Timo Walther (Jira)
Timo Walther created FLINK-33447: Summary: Avoid CompiledPlan recompilation during loading Key: FLINK-33447 URL: https://issues.apache.org/jira/browse/FLINK-33447 Project: Flink Issue Type:

Re: [PR] [FLINK-30219] Fetch results api in sql gateway return error result [flink]

2023-11-03 Thread via GitHub
GOODBOY008 closed pull request #21400: [FLINK-30219] Fetch results api in sql gateway return error result URL: https://github.com/apache/flink/pull/21400 -- 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

Re: [PR] [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core [flink]

2023-11-03 Thread via GitHub
GOODBOY008 commented on PR #19563: URL: https://github.com/apache/flink/pull/19563#issuecomment-1792071026 @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

[jira] [Updated] (FLINK-32024) Short code related to externalized connector retrieve version from its own data yaml

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32024: -- Fix Version/s: opensearch-1.1.0 opensearch-1.0.2 > Short code related to

[jira] [Updated] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30998: -- Fix Version/s: opensearch-1.1.0 (was: opensearch-1.0.2) > Add optional

[jira] [Commented] (FLINK-33417) Update netty version to 4.1.83 for flink-shaded

2023-11-03 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782476#comment-17782476 ] Matthias Pohl commented on FLINK-33417: --- Thanks for sharing. AFAIU, it's being caused by intel

Re: [PR] [FLINK-32073][checkpoint] Implement file merging in snapshot [flink]

2023-11-03 Thread via GitHub
Zakelly commented on code in PR #23514: URL: https://github.com/apache/flink/pull/23514#discussion_r1381343756 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FileMergingCheckpointStateOutputStream.java: ## @@ -0,0 +1,255 @@ +/* + * Licensed to the

[PR] [WIP][FLINK-25537] [JUnit5 Migration] Module: flink-core [flink]

2023-11-03 Thread via GitHub
GOODBOY008 opened a new pull request, #19563: URL: https://github.com/apache/flink/pull/19563 ## What is the purpose of the change *Update the flink-core module to AssertJ and JUnit 5 following the [JUnit

[jira] [Closed] (FLINK-33309) java.security.manager is desallow by default starting in java18

2023-11-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-33309. Resolution: Fixed master: 7295c3bcf92c0e106d3e91c57b6492030c760a25 >

Re: [PR] [FLINK-33309] Add `-Djava.security.manager=allow` [flink]

2023-11-03 Thread via GitHub
zentol merged PR #23547: URL: https://github.com/apache/flink/pull/23547 -- 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:

Re: [PR] [FLINK-33447][table-planner] Avoid CompiledPlan recompilation during loading [flink]

2023-11-03 Thread via GitHub
dawidwys commented on code in PR #23655: URL: https://github.com/apache/flink/pull/23655#discussion_r1381570218 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/ExecNodeGraphInternalPlan.java: ## @@ -34,16 +34,17 @@ import

Re: [PR] [FLINK-32563] Allow to execute archunit tests only with Flink version that connectors were built against [flink-connector-shared-utils]

2023-11-03 Thread via GitHub
zentol commented on code in PR #23: URL: https://github.com/apache/flink-connector-shared-utils/pull/23#discussion_r1381576332 ## .github/workflows/ci.yml: ## @@ -88,6 +93,10 @@ jobs: if: ${{ inputs.run_dependency_convergence }} run: echo

[jira] [Updated] (FLINK-33449) Support array_contains_seq function

2023-11-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33449: --- Labels: pull-request-available (was: ) > Support array_contains_seq function >

Re: [PR] [FLINK-33449][table]Support array_contains_seq function [flink]

2023-11-03 Thread via GitHub
flinkbot commented on PR #23656: URL: https://github.com/apache/flink/pull/23656#issuecomment-1792360510 ## CI report: * 31d5c1e7a3896f8b5958dc56486f510c9bfdd263 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-18286] Implement type inference for functions on composite types [flink]

2023-11-03 Thread via GitHub
dawidwys commented on code in PR #23622: URL: https://github.com/apache/flink/pull/23622#discussion_r1381627176 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/utils/ArrayTypeTestBase.scala: ## @@ -19,7 +19,9 @@ package

[jira] [Created] (FLINK-33450) Implement JdbcAutoScalerStateStore

2023-11-03 Thread Rui Fan (Jira)
Rui Fan created FLINK-33450: --- Summary: Implement JdbcAutoScalerStateStore Key: FLINK-33450 URL: https://issues.apache.org/jira/browse/FLINK-33450 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-33451) Implement FileSytemAutoScalerStateStore

2023-11-03 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782578#comment-17782578 ] Samrat Deb edited comment on FLINK-33451 at 11/3/23 1:54 PM: - i would like

[jira] [Comment Edited] (FLINK-33451) Implement FileSytemAutoScalerStateStore

2023-11-03 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782590#comment-17782590 ] Samrat Deb edited comment on FLINK-33451 at 11/3/23 2:46 PM: - Thank you

Re: [PR] [FLINK-32563] Allow to execute archunit tests only with Flink version that connectors were built against [flink-connector-shared-utils]

2023-11-03 Thread via GitHub
zentol commented on code in PR #23: URL: https://github.com/apache/flink-connector-shared-utils/pull/23#discussion_r1381576332 ## .github/workflows/ci.yml: ## @@ -88,6 +93,10 @@ jobs: if: ${{ inputs.run_dependency_convergence }} run: echo

Re: [PR] [FLINK-33099][autoscaler] Introduce the Standalone Autoscaler and support flink cluster [flink-kubernetes-operator]

2023-11-03 Thread via GitHub
mxm commented on code in PR #698: URL: https://github.com/apache/flink-kubernetes-operator/pull/698#discussion_r1381602097 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/standalone/JobListFetcher.java: ## @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software

[PR] [FLINK-33449][table]Support array_contains_seq function [flink]

2023-11-03 Thread via GitHub
leoyy0316 opened a new pull request, #23656: URL: https://github.com/apache/flink/pull/23656 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

Re: [PR] [FLINK-33099][autoscaler] Introduce the Standalone Autoscaler and support flink cluster [flink-kubernetes-operator]

2023-11-03 Thread via GitHub
gyfora commented on code in PR #698: URL: https://github.com/apache/flink-kubernetes-operator/pull/698#discussion_r1381618479 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoScalerEventHandler.java: ## @@ -32,32 +35,45 @@ import static

[jira] [Updated] (FLINK-30960) OutOfMemory error using jdbc sink

2023-11-03 Thread Bo Shen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Shen updated FLINK-30960: Description: Here in production I have an environment consisting of a kafka source, to which third-party

[jira] [Created] (FLINK-33451) Implement FileSytemAutoScalerStateStore

2023-11-03 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-33451: -- Summary: Implement FileSytemAutoScalerStateStore Key: FLINK-33451 URL: https://issues.apache.org/jira/browse/FLINK-33451 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-33100) Implement YarnJobFetcher for Standalone Autoscaler

2023-11-03 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33100: Parent: FLINK-33452 Issue Type: Sub-task (was: New Feature) > Implement YarnJobFetcher for

[jira] [Commented] (FLINK-33451) Implement FileSytemAutoScalerStateStore

2023-11-03 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782585#comment-17782585 ] Rui Fan commented on FLINK-33451: - Hi [~samrat007] , thanks for creating this JIRA. I have assigned it

[jira] [Created] (FLINK-33453) Add java21-target profile

2023-11-03 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33453: --- Summary: Add java21-target profile Key: FLINK-33453 URL: https://issues.apache.org/jira/browse/FLINK-33453 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-33453) Add java21-target profile

2023-11-03 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-33453: --- Assignee: Sergey Nuyanzin > Add java21-target profile > -

[jira] [Closed] (FLINK-33304) Atomicity of RowMutations would broken when Delete and Put on same columnFamily/column/row

2023-11-03 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33304. -- Resolution: Fixed > Atomicity of RowMutations would broken when Delete and Put on same >

[jira] [Commented] (FLINK-33304) Atomicity of RowMutations would broken when Delete and Put on same columnFamily/column/row

2023-11-03 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782611#comment-17782611 ] Martijn Visser commented on FLINK-33304: Fixed in apache/flink-connector-hbase main:

Re: [PR] [FLINK-32563] Allow to execute archunit tests only with Flink version that connectors were built against [flink-connector-shared-utils]

2023-11-03 Thread via GitHub
zentol commented on code in PR #23: URL: https://github.com/apache/flink-connector-shared-utils/pull/23#discussion_r1381576332 ## .github/workflows/ci.yml: ## @@ -88,6 +93,10 @@ jobs: if: ${{ inputs.run_dependency_convergence }} run: echo

Re: [PR] [FLINK-33447][table-planner] Avoid CompiledPlan recompilation during loading [flink]

2023-11-03 Thread via GitHub
twalthr commented on code in PR #23655: URL: https://github.com/apache/flink/pull/23655#discussion_r1381585785 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/StreamPlanner.scala: ## @@ -190,10 +190,12 @@ class StreamPlanner( }

Re: [PR] [FLINK-18286] Implement type inference for functions on composite types [flink]

2023-11-03 Thread via GitHub
dawidwys commented on code in PR #23622: URL: https://github.com/apache/flink/pull/23622#discussion_r1381630850 ## flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/ArrayElementTypeStrategyTest.java: ## @@ -0,0 +1,43 @@ +/* + *

Re: [PR] [FLINK-33099][autoscaler] Introduce the Standalone Autoscaler and support flink cluster [flink-kubernetes-operator]

2023-11-03 Thread via GitHub
1996fanrui commented on code in PR #698: URL: https://github.com/apache/flink-kubernetes-operator/pull/698#discussion_r1381682586 ## flink-autoscaler-standalone/README.md: ## @@ -0,0 +1,83 @@ +# Flink Autoscaler Standalone + +## What's the autoscaler standalone? + +`Flink

Re: [PR] [FLINK-33099][autoscaler] Introduce the Standalone Autoscaler and support flink cluster [flink-kubernetes-operator]

2023-11-03 Thread via GitHub
1996fanrui commented on code in PR #698: URL: https://github.com/apache/flink-kubernetes-operator/pull/698#discussion_r1381684156 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoScalerEventHandler.java: ## @@ -32,32 +35,45 @@ import static

[jira] [Updated] (FLINK-30960) OutOfMemory error using jdbc sink

2023-11-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30960: --- Labels: pull-request-available (was: ) > OutOfMemory error using jdbc sink >

[PR] [FLINK-30960] Fix a corner case oom error [flink-connector-jdbc]

2023-11-03 Thread via GitHub
bs352 opened a new pull request, #77: URL: https://github.com/apache/flink-connector-jdbc/pull/77 (no comment) -- 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-30960] Fix a corner case oom error [flink-connector-jdbc]

2023-11-03 Thread via GitHub
boring-cyborg[bot] commented on PR #77: URL: https://github.com/apache/flink-connector-jdbc/pull/77#issuecomment-1792455939 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[jira] [Created] (FLINK-33452) A series of improvements of Autoscaler Standalone

2023-11-03 Thread Rui Fan (Jira)
Rui Fan created FLINK-33452: --- Summary: A series of improvements of Autoscaler Standalone Key: FLINK-33452 URL: https://issues.apache.org/jira/browse/FLINK-33452 Project: Flink Issue Type:

[jira] [Updated] (FLINK-32947) Standalone autoscaler supports the metric reporter

2023-11-03 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32947: Parent: (was: FLINK-32723) Issue Type: Improvement (was: Sub-task) > Standalone autoscaler

[jira] [Updated] (FLINK-32947) Standalone autoscaler supports the metric reporter

2023-11-03 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32947: Parent: FLINK-33452 Issue Type: Sub-task (was: Improvement) > Standalone autoscaler supports the

[jira] [Updated] (FLINK-33287) Using the flink shaded jackson for flink-autoscaler

2023-11-03 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33287: Parent: (was: FLINK-32723) Issue Type: Improvement (was: Sub-task) > Using the flink shaded

  1   2   >