[jira] [Updated] (FLINK-26013) Develop ArchUnit test (infra) for Flink core and runtime test code

2023-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26013: --- Labels: pull-request-available (was: ) > Develop ArchUnit test (infra) for Flink core and

Re: [PR] [FLINK-26013][flink-core][test] add archunit tests for the test code [flink]

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

[PR] add archunit tests for the test code of flink-core [flink]

2023-11-24 Thread via GitHub
JingGe opened a new pull request, #23799: URL: https://github.com/apache/flink/pull/23799 ## What is the purpose of the change add archunit tests for the test code of flink-core ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on

Re: [PR] Develop archunit test for filesystem test code [flink]

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

[PR] Develop archunit test for filesystem test code [flink]

2023-11-24 Thread via GitHub
JingGe opened a new pull request, #23798: URL: https://github.com/apache/flink/pull/23798 ## What is the purpose of the change Develop archunit test for filesystem test code ## Verifying this change This change are new archunit tests without any test coverage. ##

Re: [PR] [FLINK-33649][doc] Add the doc related to Exponential Delay [flink]

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

[jira] [Updated] (FLINK-33649) Exponential Delay doc is missed

2023-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33649: --- Labels: pull-request-available (was: ) > Exponential Delay doc is missed >

[PR] [FLINK-33649][doc] Add the doc related to Exponential Delay [flink]

2023-11-24 Thread via GitHub
1996fanrui opened a new pull request, #23797: URL: https://github.com/apache/flink/pull/23797 Exponential Delay doc is missed in 2 pages: - Configuration page missed Exponential Delay related options -

[jira] [Created] (FLINK-33649) Exponential Delay doc is missed

2023-11-24 Thread Rui Fan (Jira)
Rui Fan created FLINK-33649: --- Summary: Exponential Delay doc is missed Key: FLINK-33649 URL: https://issues.apache.org/jira/browse/FLINK-33649 Project: Flink Issue Type: Technical Debt

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

2023-11-24 Thread via GitHub
1996fanrui commented on code in PR #695: URL: https://github.com/apache/flink-web/pull/695#discussion_r1404746526 ## docs/data/release_archive.yml: ## @@ -522,6 +522,11 @@ release_archive: version: 3.0.1 release_date: 2023-10-30 filename: "kafka" +-

Re: [PR] [FLINK-33646][table] Cleanup the rest usage of deprecated TableEnvironment#registerFunction and in docs [flink]

2023-11-24 Thread via GitHub
JingGe commented on code in PR #23796: URL: https://github.com/apache/flink/pull/23796#discussion_r1404714357 ## docs/content.zh/docs/dev/table/functions/udfs.md: ## @@ -1282,7 +1282,7 @@ public static class WeightedAvg extends

[jira] [Created] (FLINK-33648) table usfs doc in Chinese is out-of-date

2023-11-24 Thread Jing Ge (Jira)
Jing Ge created FLINK-33648: --- Summary: table usfs doc in Chinese is out-of-date Key: FLINK-33648 URL: https://issues.apache.org/jira/browse/FLINK-33648 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-33647) Implement restore tests for LookupJoin node

2023-11-24 Thread Bonnie Varghese (Jira)
Bonnie Varghese created FLINK-33647: --- Summary: Implement restore tests for LookupJoin node Key: FLINK-33647 URL: https://issues.apache.org/jira/browse/FLINK-33647 Project: Flink Issue

Re: [PR] [FLINK-32993][table] Datagen connector handles length-constrained fields according to the schema definition by default [flink]

2023-11-24 Thread via GitHub
liyubin117 commented on code in PR #23678: URL: https://github.com/apache/flink/pull/23678#discussion_r1404708247 ## flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/connector/datagen/table/RandomGeneratorVisitor.java: ## @@ -135,7 +135,7 @@ public

[jira] [Commented] (FLINK-33626) Wrong style in flink ui

2023-11-24 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789592#comment-17789592 ] Sergey Nuyanzin commented on FLINK-33626: - That's a good question i played a bit with it to try

Re: [PR] [FLINK-33646][table] Cleanup the rest usage of deprecated TableEnvironment#registerFunction and in docs [flink]

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

[jira] [Updated] (FLINK-33646) Cleanup the rest usage of deprecated TableEnvironment#registerFunction and in docs

2023-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33646: --- Labels: pull-request-available (was: ) > Cleanup the rest usage of deprecated

[PR] [FLINK-33646][table] Cleanup the rest usage of deprecated TableEnvironment#registerFunction and in docs [flink]

2023-11-24 Thread via GitHub
snuyanzin opened a new pull request, #23796: URL: https://github.com/apache/flink/pull/23796 This is the follow up task for https://github.com/apache/flink/pull/23751 to finish it in java/scala code and docs ## Verifying this change This change is a trivial rework

[jira] [Created] (FLINK-33646) Cleanup the rest usage of deprecated TableEnvironment#registerFunction and in docs

2023-11-24 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33646: --- Summary: Cleanup the rest usage of deprecated TableEnvironment#registerFunction and in docs Key: FLINK-33646 URL: https://issues.apache.org/jira/browse/FLINK-33646

[jira] [Commented] (FLINK-31197) Unable to write Parquet files containing Arrays with complex types.

2023-11-24 Thread Bjarke Tornager (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789569#comment-17789569 ] Bjarke Tornager commented on FLINK-31197: - [~martijnvisser] any update on this issue? I am

Re: [PR] [FLINK-33572] Add tests for ScalingTracking#removeOldRecords() [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
afedulov commented on PR #715: URL: https://github.com/apache/flink-kubernetes-operator/pull/715#issuecomment-1826058144 @mxm is this the right ticket? [FLINK-33572] Minimize ConfigMap API operations for autoscaler state -- This is an automated message from the Apache Git Service.

Re: [PR] [FLINK-33572] Add tests for ScalingTracking#removeOldRecords() [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
afedulov commented on code in PR #715: URL: https://github.com/apache/flink-kubernetes-operator/pull/715#discussion_r1404628070 ## flink-autoscaler/src/test/java/org/apache/flink/autoscaler/ScalingTrackingTest.java: ## @@ -52,6 +52,7 @@ void setUp() {

Re: [PR] [FLINK-33572] Add tests for ScalingTracking#removeOldRecords() [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
afedulov commented on code in PR #715: URL: https://github.com/apache/flink-kubernetes-operator/pull/715#discussion_r1404628070 ## flink-autoscaler/src/test/java/org/apache/flink/autoscaler/ScalingTrackingTest.java: ## @@ -52,6 +52,7 @@ void setUp() {

Re: [PR] [hotfix][doc] fix Retained Checkpoints link in checkpointing [flink]

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

[PR] [hotfix][doc] fix Retained Checkpoints link in checkpointing [flink]

2023-11-24 Thread via GitHub
JingGe opened a new pull request, #23795: URL: https://github.com/apache/flink/pull/23795 ## What is the purpose of the change fix link in the checkpointing doc ## Verifying this change This change is a trivial doc fix without any test coverage. ## Does this pull

Re: [PR] [FLINK-33637][table-planner][JUnit5 Migration] Introduce ArchTest to ban Junit 4 for module table-planner [flink]

2023-11-24 Thread via GitHub
Jiabao-Sun commented on code in PR #23791: URL: https://github.com/apache/flink/pull/23791#discussion_r1404574920 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java: ## @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache

Re: [PR] [hotfix][doc] fix outdated link of externalized checkpoints [flink]

2023-11-24 Thread via GitHub
JingGe merged PR #23792: URL: https://github.com/apache/flink/pull/23792 -- 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-33572] Add tests for ScalingTracking#removeOldRecords() [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
mxm commented on code in PR #715: URL: https://github.com/apache/flink-kubernetes-operator/pull/715#discussion_r1404552495 ## flink-autoscaler/src/test/java/org/apache/flink/autoscaler/ScalingTrackingTest.java: ## @@ -52,6 +52,7 @@ void setUp() {

Re: [PR] [FLINK-33637][table-planner][JUnit5 Migration] Introduce ArchTest to ban Junit 4 for module table-planner [flink]

2023-11-24 Thread via GitHub
JingGe commented on code in PR #23791: URL: https://github.com/apache/flink/pull/23791#discussion_r1404551610 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java: ## @@ -0,0 +1,46 @@ +/* + * Licensed to the Apache

[PR] Add Kafka connector v3.0.2 release [flink-web]

2023-11-24 Thread via GitHub
tzulitai opened a new pull request, #700: URL: https://github.com/apache/flink-web/pull/700 (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 unsubscribe,

[PR] [hotfix] Add tests for ScalingTracking#removeOldRecords() [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
afedulov opened a new pull request, #715: URL: https://github.com/apache/flink-kubernetes-operator/pull/715 This is a trivial addition of tests for removal of old records in `ScalingTracking` -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

2023-11-24 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-26409: Fix Version/s: kafka-3.0.3 (was: kafka-3.0.2) > Remove

Re: [PR] [FLINK-30593][autoscaler] Determine restart time on the fly fo Autoscaler [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
afedulov commented on PR #711: URL: https://github.com/apache/flink-kubernetes-operator/pull/711#issuecomment-1825920714 Thanks @mxm and @gyfora ! -- 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

[jira] [Resolved] (FLINK-30593) Determine restart time on the fly for Autoscaler

2023-11-24 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-30593. Fix Version/s: kubernetes-operator-1.8.0 Resolution: Fixed > Determine

Re: [PR] [FLINK-30593][autoscaler] Determine restart time on the fly fo Autoscaler [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
mxm merged PR #711: URL: https://github.com/apache/flink-kubernetes-operator/pull/711 -- 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-30593][autoscaler] Determine restart time on the fly fo Autoscaler [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
mxm commented on code in PR #711: URL: https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1404530659 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java: ## @@ -142,6 +142,27 @@ private static

Re: [PR] [FLINK-30593][autoscaler] Determine restart time on the fly fo Autoscaler [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
mxm commented on PR #711: URL: https://github.com/apache/flink-kubernetes-operator/pull/711#issuecomment-1825907949 Great work! Thanks @afedulov! -- 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

[jira] [Updated] (FLINK-30400) Stop bundling connector-base in externalized connectors

2023-11-24 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-30400: Fix Version/s: kafka-3.0.2 > Stop bundling connector-base in externalized

[jira] [Commented] (FLINK-30400) Stop bundling connector-base in externalized connectors

2023-11-24 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789514#comment-17789514 ] Tzu-Li (Gordon) Tai commented on FLINK-30400: - fixed for apache/flink-connector-kafka:v3.0

[jira] [Commented] (FLINK-30400) Stop bundling connector-base in externalized connectors

2023-11-24 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789511#comment-17789511 ] Leonard Xu commented on FLINK-30400: Hey [~ruanhang1993], recently we meet some issue when release

Re: [PR] [FLINK-30400][build] Stop bundling flink-connector-base [flink-connector-pulsar]

2023-11-24 Thread via GitHub
leonardBang commented on PR #61: URL: https://github.com/apache/flink-connector-pulsar/pull/61#issuecomment-1825863241 @ruanhang1993 Could you rebase the latest main branch and which will trigger the CI again? -- This is an automated message from the Apache Git Service. To respond to

Re: [PR] [FLINK-30400][build] Stop bundling flink-connector-base [flink-connector-pulsar]

2023-11-24 Thread via GitHub
leonardBang commented on PR #61: URL: https://github.com/apache/flink-connector-pulsar/pull/61#issuecomment-1825862059 > @zentol @ruanhang1993 does this mean that a connector JAR is always used with Flink's `lib` so that the

[jira] [Closed] (FLINK-33564) Implement restore tests for GroupWindowAggregate node

2023-11-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-33564. Fix Version/s: 1.19.0 Resolution: Fixed Implemented in

Re: [PR] [FLINK-33564] Implement restore tests for GroupWindowAggregate node [flink]

2023-11-24 Thread via GitHub
dawidwys merged PR #23728: URL: https://github.com/apache/flink/pull/23728 -- 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-30593][autoscaler] Determine restart time on the fly fo Autoscaler [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
mxm commented on PR #711: URL: https://github.com/apache/flink-kubernetes-operator/pull/711#issuecomment-1825846863 The docs need to be regenerated after the last config change. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [FLINK-33637][table-planner][JUnit5 Migration] Introduce ArchTest to ban Junit 4 for module table-planner [flink]

2023-11-24 Thread via GitHub
leonardBang commented on PR #23791: URL: https://github.com/apache/flink/pull/23791#issuecomment-1825836973 Could you rebase to latest master ? @Jiabao-Sun -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Resolved] (FLINK-33629) Introduce ArchTest rules to ban Junit 4 for modules already completed the migration

2023-11-24 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-33629. Resolution: Fixed master(1.19): 34436e70d58f61f2746e707647ad0135788e2b95 > Introduce ArchTest

[jira] [Assigned] (FLINK-33629) Introduce ArchTest rules to ban Junit 4 for modules already completed the migration

2023-11-24 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-33629: -- Assignee: Jiabao Sun > Introduce ArchTest rules to ban Junit 4 for modules already completed

[jira] [Updated] (FLINK-33629) Introduce ArchTest rules to ban Junit 4 for modules already completed the migration

2023-11-24 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-33629: --- Fix Version/s: 1.19.0 > Introduce ArchTest rules to ban Junit 4 for modules already completed the

Re: [PR] [FLINK-33629][test] Introduce ArchTest rules to ban Junit 4 for modules already completed the migration [flink]

2023-11-24 Thread via GitHub
leonardBang merged PR #23790: URL: https://github.com/apache/flink/pull/23790 -- 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-18356) flink-table-planner Exit code 137 returned from process

2023-11-24 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789497#comment-17789497 ] Leonard Xu commented on FLINK-18356: Thanks [~337361...@qq.com], [~lincoln.86xy] and [~mapohl] for

[jira] [Resolved] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-18356. --- Fix Version/s: 1.19.0 1.18.1 1.17.3 Resolution:

[jira] [Commented] (FLINK-33490) Validate the name conflicts when creating view

2023-11-24 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789494#comment-17789494 ] lincoln lee commented on FLINK-33490: - Here're my two cents: from my previous reference to the sql

Re: [PR] [BP-1.17][FLINK-18356] Update CI image [flink]

2023-11-24 Thread via GitHub
XComp merged PR #23757: URL: https://github.com/apache/flink/pull/23757 -- 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-26782] Remove PlannerExpression and related [flink]

2023-11-24 Thread via GitHub
dawidwys commented on code in PR #23761: URL: https://github.com/apache/flink/pull/23761#discussion_r1404465452 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/LegacyUserDefinedFunctionInference.java: ## @@ -0,0 +1,529 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-33645) Env vars in config not added to Taskmanagers in Standalone mode

2023-11-24 Thread Tony Garrard (Jira)
Tony Garrard created FLINK-33645: Summary: Env vars in config not added to Taskmanagers in Standalone mode Key: FLINK-33645 URL: https://issues.apache.org/jira/browse/FLINK-33645 Project: Flink

Re: [PR] [FLINK-30593][autoscaler] Determine restart time on the fly fo Autoscaler [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
mxm commented on code in PR #711: URL: https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r1404437571 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java: ## @@ -0,0 +1,171 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-30593][autoscaler] Determine restart time on the fly fo Autoscaler [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
mxm commented on code in PR #711: URL: https://github.com/apache/flink-kubernetes-operator/pull/711#discussion_r140447 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingTracking.java: ## @@ -0,0 +1,171 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-33634) Add Conditions to Flink CRD's Status field

2023-11-24 Thread Tony Garrard (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789478#comment-17789478 ] Tony Garrard commented on FLINK-33634: -- So we would use theĀ 

[jira] [Updated] (FLINK-33644) FLIP-393: Make QueryOperations SQL serializable

2023-11-24 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-33644: - Description: https://cwiki.apache.org/confluence/x/4guZE > FLIP-393: Make

[jira] [Commented] (FLINK-33638) Support variable-length data generation for variable-length data types

2023-11-24 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789457#comment-17789457 ] lincoln lee commented on FLINK-33638: - [~liyubin117] assigned to you, thank you for contributing

[jira] [Created] (FLINK-33644) FLIP-393: Make QueryOperations SQL serializable

2023-11-24 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-33644: Summary: FLIP-393: Make QueryOperations SQL serializable Key: FLINK-33644 URL: https://issues.apache.org/jira/browse/FLINK-33644 Project: Flink

[jira] [Assigned] (FLINK-33638) Support variable-length data generation for variable-length data types

2023-11-24 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-33638: --- Assignee: Yubin Li > Support variable-length data generation for variable-length data

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

2023-11-24 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789447#comment-17789447 ] Piotr Nowojski commented on FLINK-27681: Ahh got it. In that case I would argue always failing

[jira] [Updated] (FLINK-33639) Support zookeeper 3.9.0+

2023-11-24 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33639: -- Description: This is a follow up task for Flink once Curator's CURATOR-687 task to support

Re: [PR] [FLINK-33643][runtime] Allow StreamExecutionEnvironment's executeAsync API to use default JobName [flink]

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

Re: [PR] [Flink 31966] Flink Kubernetes operator lacks TLS support [flink-kubernetes-operator]

2023-11-24 Thread via GitHub
tagarr commented on PR #712: URL: https://github.com/apache/flink-kubernetes-operator/pull/712#issuecomment-1825603694 Hi @gaborgsomogyi made changes according to your review -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-33643) Allow StreamExecutionEnvironment's executeAsync API to use default JobName

2023-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33643: --- Labels: pull-request-available (was: ) > Allow StreamExecutionEnvironment's executeAsync

[PR] [FLINK-33643][runtime] Allow StreamExecutionEnvironment's executeAsync API to use default JobName [flink]

2023-11-24 Thread via GitHub
wangzzu opened a new pull request, #23794: URL: https://github.com/apache/flink/pull/23794 ## 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

Re: [PR] [FLINK-33642] Use docker image with jdk21 in CI [flink]

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

[jira] [Updated] (FLINK-33642) Use docker image with jdk21 in CI

2023-11-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33642: --- Labels: pull-request-available (was: ) > Use docker image with jdk21 in CI >

[PR] [FLINK-33642] Use docker image with jdk21 in CI [flink]

2023-11-24 Thread via GitHub
snuyanzin opened a new pull request, #23793: URL: https://github.com/apache/flink/pull/23793 ## What is the purpose of the change Use image with jdk21 from https://github.com/zentol/flink-ci-docker/pull/2#issuecomment-1825532069 ## Brief change log

[jira] [Created] (FLINK-33643) Allow StreamExecutionEnvironment's executeAsync API to use default JobName

2023-11-24 Thread Matt Wang (Jira)
Matt Wang created FLINK-33643: - Summary: Allow StreamExecutionEnvironment's executeAsync API to use default JobName Key: FLINK-33643 URL: https://issues.apache.org/jira/browse/FLINK-33643 Project: Flink

[jira] [Created] (FLINK-33642) Use docker image with jdk21 in CI

2023-11-24 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33642: --- Summary: Use docker image with jdk21 in CI Key: FLINK-33642 URL: https://issues.apache.org/jira/browse/FLINK-33642 Project: Flink Issue Type: Sub-task

[jira] [Resolved] (FLINK-33620) Add Java 21 to docker image

2023-11-24 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33620. - Resolution: Fixed Closing since the PR is merged and new image with jdk21 is available

[jira] [Closed] (FLINK-33620) Add Java 21 to docker image

2023-11-24 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-33620. --- > Add Java 21 to docker image > --- > > Key:

[jira] [Commented] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer

2023-11-24 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789436#comment-17789436 ] Hong Liang Teoh commented on FLINK-6349: This will be addressed by the new FLIP-27 based

Re: [PR] [BP-1.17][FLINK-18356] Update CI image [flink]

2023-11-24 Thread via GitHub
XComp commented on code in PR #23757: URL: https://github.com/apache/flink/pull/23757#discussion_r1404258309 ## tools/azure-pipelines/build-apache-repo.yml: ## @@ -37,9 +37,12 @@ trigger: resources: containers: # Container with Maven 3.2.5, SSL to have the same

[jira] [Updated] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer

2023-11-24 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-6349: --- Priority: Major (was: Not a Priority) > Enforce per-subtask record ordering on resharding

[jira] [Created] (FLINK-33641) RankITCase.testMultipleUnaryTopNAfterAgg fails on AZP

2023-11-24 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33641: --- Summary: RankITCase.testMultipleUnaryTopNAfterAgg fails on AZP Key: FLINK-33641 URL: https://issues.apache.org/jira/browse/FLINK-33641 Project: Flink

[jira] [Commented] (FLINK-33414) MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot fails due to unexpected TimeoutException

2023-11-24 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789434#comment-17789434 ] Sergey Nuyanzin commented on FLINK-33414: -

Re: [PR] [BP-1.17][FLINK-18356] Update CI image [flink]

2023-11-24 Thread via GitHub
snuyanzin commented on PR #23757: URL: https://github.com/apache/flink/pull/23757#issuecomment-1825509030 Thanks for the update it loks good from my side, I left a minor comment however it's up to you to ignore it or not -- This is an automated message from the Apache Git Service. To

Re: [PR] [BP-1.17][FLINK-18356] Update CI image [flink]

2023-11-24 Thread via GitHub
snuyanzin commented on code in PR #23757: URL: https://github.com/apache/flink/pull/23757#discussion_r1404229031 ## tools/azure-pipelines/build-apache-repo.yml: ## @@ -37,9 +37,12 @@ trigger: resources: containers: # Container with Maven 3.2.5, SSL to have the same

Re: [PR] [BP-1.17][FLINK-18356] Update CI image [flink]

2023-11-24 Thread via GitHub
snuyanzin commented on code in PR #23757: URL: https://github.com/apache/flink/pull/23757#discussion_r1404229031 ## tools/azure-pipelines/build-apache-repo.yml: ## @@ -37,9 +37,12 @@ trigger: resources: containers: # Container with Maven 3.2.5, SSL to have the same

Re: [PR] [FLINK-28048][connectors] Introduce Source API alternative to FiniteTestSource [flink]

2023-11-24 Thread via GitHub
mxm commented on code in PR #23777: URL: https://github.com/apache/flink/pull/23777#discussion_r1404209068 ## flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DataGenerators.java: ## @@ -0,0 +1,87 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

2023-11-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789427#comment-17789427 ] Rui Fan commented on FLINK-27681: - {quote}In what scenario file that we are verifying before the upload,

Re: [PR] [BP-1.17][FLINK-18356] Update CI image [flink]

2023-11-24 Thread via GitHub
XComp commented on PR #23757: URL: https://github.com/apache/flink/pull/23757#issuecomment-1825457076 > After looking at [FLINK-28203](https://issues.apache.org/jira/browse/FLINK-28203) i noticed that there are also files tools/ci/compile.sh tools/ci/maven-utils.sh

[jira] [Commented] (FLINK-33638) Support variable-length data generation for variable-length data types

2023-11-24 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789425#comment-17789425 ] Yubin Li commented on FLINK-33638: -- [~lincoln] Hi, could you please assign this to me? thanks! >

[jira] [Closed] (FLINK-33613) Python UDF Runner process leak in Process Mode

2023-11-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-33613. --- Fix Version/s: 1.19.0 1.18.1 1.17.3 Resolution: Fixed Fixed

Re: [PR] [FLINK-33613][python] Make sure gRPC server is shutdown gracefully if Python process startup failed [flink]

2023-11-24 Thread via GitHub
dianfu closed pull request #23789: [FLINK-33613][python] Make sure gRPC server is shutdown gracefully if Python process startup failed URL: https://github.com/apache/flink/pull/23789 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

2023-11-24 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789418#comment-17789418 ] Piotr Nowojski commented on FLINK-27681: Thanks [~fanrui] for pinging me, and double thanks to

[jira] [Created] (FLINK-33640) Support configuring FLINK_CONF_FILE through environment variables

2023-11-24 Thread Matt Wang (Jira)
Matt Wang created FLINK-33640: - Summary: Support configuring FLINK_CONF_FILE through environment variables Key: FLINK-33640 URL: https://issues.apache.org/jira/browse/FLINK-33640 Project: Flink

Re: [PR] [FLINK-27681] RocksdbStatebackend verify incremental sst file checksum during checkpoint [flink]

2023-11-24 Thread via GitHub
1996fanrui commented on code in PR #23765: URL: https://github.com/apache/flink/pull/23765#discussion_r1404180821 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java: ## @@

Re: [PR] [FLINK-27681] RocksdbStatebackend verify incremental sst file checksum during checkpoint [flink]

2023-11-24 Thread via GitHub
1996fanrui commented on code in PR #23765: URL: https://github.com/apache/flink/pull/23765#discussion_r1404180821 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java: ## @@

Re: [PR] [FLINK-27681] RocksdbStatebackend verify incremental sst file checksum during checkpoint [flink]

2023-11-24 Thread via GitHub
mayuehappy commented on code in PR #23765: URL: https://github.com/apache/flink/pull/23765#discussion_r1404175347 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java: ## @@

[jira] [Created] (FLINK-33639) Support zookeeper 3.9.0+

2023-11-24 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33639: --- Summary: Support zookeeper 3.9.0+ Key: FLINK-33639 URL: https://issues.apache.org/jira/browse/FLINK-33639 Project: Flink Issue Type: Technical Debt

Re: [PR] [FLINK-27681] RocksdbStatebackend verify incremental sst file checksum during checkpoint [flink]

2023-11-24 Thread via GitHub
1996fanrui commented on code in PR #23765: URL: https://github.com/apache/flink/pull/23765#discussion_r1404136470 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java: ## @@

Re: [PR] [hotfix][doc] fix outdated link of externalized checkpoints [flink]

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

Re: [PR] [FLINK-33541][table-planner] function RAND and RAND_INTEGER should return type nullable if the arguments are nullable [flink]

2023-11-24 Thread via GitHub
libenchao commented on code in PR #23779: URL: https://github.com/apache/flink/pull/23779#discussion_r1404151790 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/RandFunctionTest.java: ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

2023-11-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789409#comment-17789409 ] Rui Fan commented on FLINK-27681: - Thanks for the quick response. {quote}Strictly speaking, I think it

  1   2   >