Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1936908761 @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-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1936858432 @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-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on PR #22951: URL: https://github.com/apache/flink/pull/22951#issuecomment-1936835154 @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 commen

Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink]

2024-02-09 Thread via GitHub
AlanConfluent commented on PR #24224: URL: https://github.com/apache/flink/pull/24224#issuecomment-1936807100 @MartijnVisser I updated the documentation. Please tell me if anything else is required to make the deadline. -- This is an automated message from the Apache Git Service. To resp

Re: [PR] [FLINK-34094] Adds documentation for AsyncScalarFunction [flink]

2024-02-09 Thread via GitHub
AlanConfluent commented on code in PR #24224: URL: https://github.com/apache/flink/pull/24224#discussion_r1484927246 ## docs/content/docs/dev/table/functions/udfs.md: ## @@ -846,6 +847,119 @@ If you intend to implement or call functions in Python, please refer to the [Pyt {{

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1936765976 @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

[jira] [Commented] (FLINK-34378) Minibatch join disrupted the original order of input records

2024-02-09 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816252#comment-17816252 ] Jeyhun Karimov commented on FLINK-34378: Hi [~xuyangzhong] the ordering is diffe

[jira] [Commented] (FLINK-34129) MiniBatchGlobalGroupAggFunction will make -D as +I then make +I as -U when state expired

2024-02-09 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816250#comment-17816250 ] Jeyhun Karimov commented on FLINK-34129: Hi [~loserwang1024], [~xuyangzhong] I

[jira] [Updated] (FLINK-34407) Flaky tests causing workflow timeout

2024-02-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34407: --- Labels: pull-request-available (was: ) > Flaky tests causing workflow timeout > ---

[PR] [FLINK-34407][Connectors/Kinesis] Fix unstable test [flink-connector-aws]

2024-02-09 Thread via GitHub
z3d1k opened a new pull request, #128: URL: https://github.com/apache/flink-connector-aws/pull/128 ## Purpose of the change Tests that use `FakeKinesisFanOutBehavioursFactory` occasionally run into issue while creating mock for Kinesis shard subscription: ``` java.lang.ClassCast

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2024-02-09 Thread via GitHub
mtfelisb commented on code in PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1484848274 ## flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriterITCase.java: ## @@ -0,0 +1,27

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-02-09 Thread via GitHub
rkhachatryan commented on PR #24292: URL: https://github.com/apache/flink/pull/24292#issuecomment-1936575490 @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 comme

Re: [PR] [FLINK-33402] 2 CONTINUED [flink]

2024-02-09 Thread via GitHub
varun1729DD commented on PR #24055: URL: https://github.com/apache/flink/pull/24055#issuecomment-1936474945 @tweise requesting your review on this. I added additional details above ^ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

Re: [PR] [FLINK-28693][table] Fix janino compile failed because the code generated refers the class in table-planner [flink]

2024-02-09 Thread via GitHub
seb-pereira commented on PR #24280: URL: https://github.com/apache/flink/pull/24280#issuecomment-1936306609 I have tested this change on 1.18.0 in same conditions as reported in [FLINK-28693](https://issues.apache.org/jira/browse/FLINK-28693?focusedCommentId=17815957&page=com.atlassian.jira.

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-02-09 Thread via GitHub
rkhachatryan commented on PR #24292: URL: https://github.com/apache/flink/pull/24292#issuecomment-1936234814 @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 comme

Re: [PR] [FLINK-33936][table] Outputting Identical Results in Mini-Batch Aggregation with Set TTL [flink]

2024-02-09 Thread via GitHub
hackergin commented on PR #24290: URL: https://github.com/apache/flink/pull/24290#issuecomment-1936224206 @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-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484533063 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484532480 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484532093 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484526273 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484526273 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484524404 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementArgumentTypeStrategy.java: ## @@ -0,0 +1,125

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484523821 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -231,6 +232,21 @@ ANY, and(logical(LogicalTy

[jira] [Commented] (FLINK-28747) "target_id can not be missing" in HTTP statefun request

2024-02-09 Thread Nathan Taylor Armstrong Lewis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816124#comment-17816124 ] Nathan Taylor Armstrong Lewis commented on FLINK-28747: --- In Protob

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
dawidwys commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484478770 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -231,6 +232,21 @@ ANY, and(logical(LogicalTypeR

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
dawidwys commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484479808 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -231,6 +232,21 @@ ANY, and(logical(LogicalTypeR

[jira] [Commented] (FLINK-21227) Upgrade Protobof 3.7.0 for (power)ppc64le support

2024-02-09 Thread Nathan Taylor Armstrong Lewis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816116#comment-17816116 ] Nathan Taylor Armstrong Lewis commented on FLINK-21227: --- Is there

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
dawidwys commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484473796 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to the A

Re: [PR] [FLINK-33958] Fix IntervalJoin restore test flakiness [flink]

2024-02-09 Thread via GitHub
bvarghese1 commented on PR #24196: URL: https://github.com/apache/flink/pull/24196#issuecomment-1936127479 > @bvarghese1 Could you please explain how does this improve the test reliability? Previously the input was: ``` Row.of(7, 3, "2020-04-15 08:00:16"), Row.of(

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
dawidwys commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484467843 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementArgumentTypeStrategy.java: ## @@ -0,0 +1,125 @@

Re: [PR] [FLINK-34282][docker] Updates snapshot workflow configuration [flink-docker]

2024-02-09 Thread via GitHub
XComp commented on code in PR #180: URL: https://github.com/apache/flink-docker/pull/180#discussion_r1484449607 ## .github/workflows/snapshot.yml: ## @@ -38,14 +38,14 @@ jobs: matrix: java_version: [8, 11] build: - - flink_version: 1.19-SNAPSHOT

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484427940 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementArgumentTypeStrategy.java: ## @@ -0,0 +1,125

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484440158 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -231,6 +232,21 @@ ANY, and(logical(LogicalTy

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484427940 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementArgumentTypeStrategy.java: ## @@ -0,0 +1,125

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484430188 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to th

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484427940 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayComparableElementArgumentTypeStrategy.java: ## @@ -0,0 +1,125

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484422529 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -231,6 +232,21 @@ ANY, and(logical(LogicalTy

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484422529 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -231,6 +232,21 @@ ANY, and(logical(LogicalTy

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484422529 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -231,6 +232,21 @@ ANY, and(logical(LogicalTy

Re: [PR] [FLINK-34282][docker] Updates snapshot workflow configuration [flink-docker]

2024-02-09 Thread via GitHub
XComp commented on code in PR #180: URL: https://github.com/apache/flink-docker/pull/180#discussion_r1484401070 ## .github/workflows/snapshot.yml: ## @@ -38,14 +38,14 @@ jobs: matrix: java_version: [8, 11] build: - - flink_version: 1.19-SNAPSHOT

Re: [PR] Fix typo on schema_evolution.md [flink]

2024-02-09 Thread via GitHub
rafaelzimmermann closed pull request #22943: Fix typo on schema_evolution.md URL: https://github.com/apache/flink/pull/22943 -- 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-34239) Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl

2024-02-09 Thread Kumar Mallikarjuna (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816077#comment-17816077 ] Kumar Mallikarjuna commented on FLINK-34239: Thank you, [~zjureel] ! > Intr

Re: [PR] [hotfix] Bumps Flink snapshot version and related flink-shaded version [flink-benchmarks]

2024-02-09 Thread via GitHub
XComp closed pull request #86: [hotfix] Bumps Flink snapshot version and related flink-shaded version URL: https://github.com/apache/flink-benchmarks/pull/86 -- 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 t

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1935962036 Hi @JingGe , thank you for your advice, it is my first time participating in the Flink project. i have added 2 commits with your suggestion, Please review it when you have free time, t

Re: [PR] [FLINK-34417] Log Job ID via MDC [flink]

2024-02-09 Thread via GitHub
rkhachatryan commented on PR #24292: URL: https://github.com/apache/flink/pull/24292#issuecomment-1935958746 @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 comme

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1935949613 > Thanks @lxliyou001 for your contribution. I just left some comments. Hi @JingGe , thank you for your advice, it is my first time participating in the Flink project. i have added 2

Re: [PR] [FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese [flink]

2024-02-09 Thread via GitHub
lxliyou001 commented on PR #24279: URL: https://github.com/apache/flink/pull/24279#issuecomment-1935945569 Hi @JingGe , thank you for your advice, it is my first time participating in the Flink project. i have added 2 commits with your suggestion, Please review it when you have free time,

Re: [PR] [hotfix] Bumps Flink snapshot version and related flink-shaded version [flink-benchmarks]

2024-02-09 Thread via GitHub
snuyanzin commented on code in PR #86: URL: https://github.com/apache/flink-benchmarks/pull/86#discussion_r1484312133 ## pom.xml: ## @@ -45,8 +45,8 @@ under the License. UTF-8 - 1.19-SNAPSHOT - 16.1 + 1.20-SNA

Re: [PR] [hotfix] Bumps Flink snapshot version and related flink-shaded version [flink-benchmarks]

2024-02-09 Thread via GitHub
snuyanzin commented on code in PR #86: URL: https://github.com/apache/flink-benchmarks/pull/86#discussion_r1484312133 ## pom.xml: ## @@ -45,8 +45,8 @@ under the License. UTF-8 - 1.19-SNAPSHOT - 16.1 + 1.20-SNA

Re: [PR] [FLINK-34386][state] Add RocksDB bloom filter metrics [flink]

2024-02-09 Thread via GitHub
JingGe commented on PR #24274: URL: https://github.com/apache/flink/pull/24274#issuecomment-1935899938 There some issue while building the hadoop image: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=57409&view=logs&j=ef799394-2d67-5ff4-b2e5-410b80c9c0af&t=9e5768bc-da

Re: [PR] [HOTFIX][Doc] update readme to clarify that generate-stackbrew-library-docker.sh should be run on local machine directly. [flink-docker]

2024-02-09 Thread via GitHub
JingGe merged PR #163: URL: https://github.com/apache/flink-docker/pull/163 -- 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: issues-unsubscr...@flink.apa

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-09 Thread via GitHub
dawidwys commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1484177231 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java: ## @@ -0,0 +1,141 @@ +/* + * Licensed to the A

Re: [PR] [FLINK-34282][docker] Updates snapshot workflow configuration [flink-docker]

2024-02-09 Thread via GitHub
JingGe commented on code in PR #180: URL: https://github.com/apache/flink-docker/pull/180#discussion_r1484202025 ## .github/workflows/snapshot.yml: ## @@ -38,14 +38,14 @@ jobs: matrix: java_version: [8, 11] build: - - flink_version: 1.19-SNAPSHO

Re: [PR] [FLINK-34282][docker] Merge commit 44f05828 (pre-FLINK-34282 dev-master) into dev-1.19 [flink-docker]

2024-02-09 Thread via GitHub
XComp closed pull request #179: [FLINK-34282][docker] Merge commit 44f05828 (pre-FLINK-34282 dev-master) into dev-1.19 URL: https://github.com/apache/flink-docker/pull/179 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

Re: [PR] [FLINK-34282][docker] Merge commit 44f05828 (pre-FLINK-34282 dev-master) into dev-1.19 [flink-docker]

2024-02-09 Thread via GitHub
XComp commented on PR #179: URL: https://github.com/apache/flink-docker/pull/179#issuecomment-1935753499 This merge commit PR can be closed. I force-pushed a rebase to {{dev-master~1}} ([44f05828](https://github.com/apache/flink-docker/commit/44f058287cc956a620b12b6f8ed214e44dc3db77)) afte

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816022#comment-17816022 ] Matthias Pohl commented on FLINK-34282: --- I rebased {{dev-1.19}} to {{dev-master~1}

[jira] [Updated] (FLINK-33163) Support Java 21 (LTS)

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33163: -- Fix Version/s: (was: 1.19.0) > Support Java 21 (LTS) > - > >

[PR] [FLINK-34282][docker] Updates snapshot workflow configuration [flink-docker]

2024-02-09 Thread via GitHub
XComp opened a new pull request, #180: URL: https://github.com/apache/flink-docker/pull/180 This way we are aligned with what's described in the [README.md](https://github.com/apache/flink-docker/blob/master/README.md#development-workflow) again. -- This is an automated message from the

[jira] [Updated] (FLINK-34419) flink-docker's .github/workflows/snapshot.yml doesn't support JDK 17 and 21

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34419: -- Labels: starter (was: ) > flink-docker's .github/workflows/snapshot.yml doesn't support JDK 1

[jira] [Updated] (FLINK-33163) Support Java 21 (LTS)

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33163: -- Fix Version/s: 1.19.0 > Support Java 21 (LTS) > - > > Key:

[jira] [Created] (FLINK-34419) flink-docker's .github/workflows/snapshot.yml doesn't support JDK 17 and 21

2024-02-09 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34419: - Summary: flink-docker's .github/workflows/snapshot.yml doesn't support JDK 17 and 21 Key: FLINK-34419 URL: https://issues.apache.org/jira/browse/FLINK-34419 Project

Re: [PR] [FLINK-34152] Tune heap memory of autoscaled jobs [flink-kubernetes-operator]

2024-02-09 Thread via GitHub
mateczagany commented on code in PR #762: URL: https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1484178999 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -106,7 +107,13 @@ public void scale(Context ctx) throws

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-09 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816018#comment-17816018 ] Jing Ge commented on FLINK-34282: - [~mapohl] please go ahead, thanks! > Create a releas

Re: [PR] feat: remove scala dependency [flink-connector-cassandra]

2024-02-09 Thread via GitHub
boring-cyborg[bot] commented on PR #27: URL: https://github.com/apache/flink-connector-cassandra/pull/27#issuecomment-1935719123 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816016#comment-17816016 ] Matthias Pohl commented on FLINK-34282: --- correct, I will go ahead and do that then

Re: [PR] feat: remove scala dependency [flink-connector-cassandra]

2024-02-09 Thread via GitHub
yuranye closed pull request #27: feat: remove scala dependency URL: https://github.com/apache/flink-connector-cassandra/pull/27 -- 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.

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816015#comment-17816015 ] Martijn Visser commented on FLINK-34282: [~mapohl] You mean force-pushing `dev-1

[jira] [Commented] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816011#comment-17816011 ] Matthias Pohl commented on FLINK-34403: --- [~dsaisharath] what's a heap size that wo

Re: [PR] [FLINK-34282][docker] Merge commit 44f05828 (pre-FLINK-34282 dev-master) into dev-1.19 [flink-docker]

2024-02-09 Thread via GitHub
XComp commented on PR #179: URL: https://github.com/apache/flink-docker/pull/179#issuecomment-1935691236 hm, handling the merge commit through GitHub seems to be not working as expected. I'm gonna close this PR and move the discussion into [FLINK-34282|https://issues.apache.org/jira/browse/

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816007#comment-17816007 ] Matthias Pohl commented on FLINK-34282: --- The {{dev-1.19}} branch in [apache/flink

[jira] [Closed] (FLINK-34267) Python connector test fails when running on MacBook with m1 processor

2024-02-09 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-34267. - > Python connector test fails when running on MacBook with m1 processor > --

[jira] [Assigned] (FLINK-34267) Python connector test fails when running on MacBook with m1 processor

2024-02-09 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-34267: - Assignee: Aleksandr Pilipenko > Python connector test fails when running on MacBook wit

Re: [PR] [FLINK-34267][CI] Update miniconda install script to fix build on MacOS [flink-connector-shared-utils]

2024-02-09 Thread via GitHub
gaborgsomogyi commented on PR #34: URL: https://github.com/apache/flink-connector-shared-utils/pull/34#issuecomment-1935638003 Thanks for the fix! -- 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] [Resolved] (FLINK-34267) Python connector test fails when running on MacBook with m1 processor

2024-02-09 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-34267. --- Resolution: Fixed [{{e6e1426}}|https://github.com/apache/flink-connector-shared-utils/commit

Re: [PR] [FLINK-34267][CI] Update miniconda install script to fix build on MacOS [flink-connector-shared-utils]

2024-02-09 Thread via GitHub
gaborgsomogyi merged PR #34: URL: https://github.com/apache/flink-connector-shared-utils/pull/34 -- 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: issues-

Re: [PR] [FLINK-34267][CI] Update miniconda install script to fix build on MacOS [flink-connector-shared-utils]

2024-02-09 Thread via GitHub
gaborgsomogyi commented on PR #34: URL: https://github.com/apache/flink-connector-shared-utils/pull/34#issuecomment-1935633037 @pvary Thanks! Now I remember that the newest conda version would work when the connector would bump Flink version. Merging... -- This is an automated message fr

[jira] [Updated] (FLINK-34411) "Wordcount on Docker test (custom fs plugin)" timed out with some strange issue while setting the test up

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34411: -- Affects Version/s: (was: 1.20.0) > "Wordcount on Docker test (custom fs plugin)" timed out

[jira] [Commented] (FLINK-34273) git fetch fails

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815976#comment-17815976 ] Matthias Pohl commented on FLINK-34273: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815975#comment-17815975 ] Matthias Pohl commented on FLINK-22040: --- https://dev.azure.com/apache-flink/apache

[jira] [Comment Edited] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815969#comment-17815969 ] Matthias Pohl edited comment on FLINK-34403 at 2/9/24 8:55 AM: ---

[jira] [Commented] (FLINK-34411) "Wordcount on Docker test (custom fs plugin)" timed out with some strange issue while setting the test up

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815973#comment-17815973 ] Matthias Pohl commented on FLINK-34411: --- Thanks for looking into it, [~ferenc-csak

[jira] [Comment Edited] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815969#comment-17815969 ] Matthias Pohl edited comment on FLINK-34403 at 2/9/24 8:52 AM: ---

[jira] [Commented] (FLINK-34411) "Wordcount on Docker test (custom fs plugin)" timed out with some strange issue while setting the test up

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815971#comment-17815971 ] Matthias Pohl commented on FLINK-34411: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815969#comment-17815969 ] Matthias Pohl commented on FLINK-34403: --- https://dev.azure.com/apache-flink/apache

[jira] [Created] (FLINK-34418) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots fail

2024-02-09 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34418: - Summary: YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots failed due to disk space

[jira] [Commented] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815965#comment-17815965 ] Matthias Pohl commented on FLINK-26515: --- https://github.com/apache/flink/actions/r

[jira] [Comment Edited] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815965#comment-17815965 ] Matthias Pohl edited comment on FLINK-26515 at 2/9/24 8:41 AM: ---

[jira] [Commented] (FLINK-30275) TaskExecutorTest.testSharedResourcesLifecycle fails

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815964#comment-17815964 ] Matthias Pohl commented on FLINK-30275: --- https://github.com/apache/flink/actions/r

[jira] [Comment Edited] (FLINK-34394) Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of virtual metadata columns configurable

2024-02-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815962#comment-17815962 ] Timo Walther edited comment on FLINK-34394 at 2/9/24 8:36 AM:

[jira] [Commented] (FLINK-34394) Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of virtual metadata columns configurable

2024-02-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815962#comment-17815962 ] Timo Walther commented on FLINK-34394: -- Hi [~lincoln.86xy], this feature is rather

[jira] [Resolved] (FLINK-34410) Disable nightly trigger in forks

2024-02-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-34410. --- Fix Version/s: 1.20.0 Resolution: Fixed master: [d2abd744621c6f0f65e7154a2c1b53bcaf7

[jira] [Closed] (FLINK-34394) Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of virtual metadata columns configurable

2024-02-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34394. Resolution: Fixed > Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of >

Re: [PR] [FLINK-34386][state] Add RocksDB bloom filter metrics [flink]

2024-02-09 Thread via GitHub
hejufang commented on PR #24274: URL: https://github.com/apache/flink/pull/24274#issuecomment-1935521846 @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-34410][ci] Disables the nightly trigger workflow for forks [flink]

2024-02-09 Thread via GitHub
XComp merged PR #24291: URL: https://github.com/apache/flink/pull/24291 -- 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: issues-unsubscr...@flink.apache.

[jira] [Commented] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression

2024-02-09 Thread Sebastien Pereira (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815957#comment-17815957 ] Sebastien Pereira commented on FLINK-28693: --- We are facing similar issue in 1.