[GitHub] [flink-connector-pulsar] tisonkun commented on pull request #44: [FLINK-32003] Upgrade pulsar-client version to work with OAuth2

2023-05-05 Thread via GitHub
tisonkun commented on PR #44: URL: https://github.com/apache/flink-connector-pulsar/pull/44#issuecomment-1537071531 Emm...It seems that plugin is default to skip. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[GitHub] [flink-connector-pulsar] tisonkun commented on pull request #44: [FLINK-32003] Upgrade pulsar-client version to work with OAuth2

2023-05-05 Thread via GitHub
tisonkun commented on PR #44: URL: https://github.com/apache/flink-connector-pulsar/pull/44#issuecomment-1537071088 Werid. I run already `mvn spotless:apply` and no diff report. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink-connector-pulsar] reswqa commented on pull request #44: [FLINK-32003] Upgrade pulsar-client version to work with OAuth2

2023-05-05 Thread via GitHub
reswqa commented on PR #44: URL: https://github.com/apache/flink-connector-pulsar/pull/44#issuecomment-1537070591 It seems that we have some format violations. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink] dmvk commented on a diff in pull request #22506: [FLINK-31890][runtime] Introduce JobMaster per-task failure enrichment/labeling

2023-05-05 Thread via GitHub
dmvk commented on code in PR #22506: URL: https://github.com/apache/flink/pull/22506#discussion_r1186649483 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -473,26 +500,50 @@ public CompletableFuture cancel(Time timeout) { @Override

[GitHub] [flink] dmvk commented on a diff in pull request #22506: [FLINK-31890][runtime] Introduce JobMaster per-task failure enrichment/labeling

2023-05-05 Thread via GitHub
dmvk commented on code in PR #22506: URL: https://github.com/apache/flink/pull/22506#discussion_r1186649257 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -473,26 +500,50 @@ public CompletableFuture cancel(Time timeout) { @Override

[GitHub] [flink] dmvk commented on a diff in pull request #22506: [FLINK-31890][runtime] Introduce JobMaster per-task failure enrichment/labeling

2023-05-05 Thread via GitHub
dmvk commented on code in PR #22506: URL: https://github.com/apache/flink/pull/22506#discussion_r1186649257 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -473,26 +500,50 @@ public CompletableFuture cancel(Time timeout) { @Override

[GitHub] [flink-connector-pulsar] tisonkun commented on pull request #44: [FLINK-32003] Upgrade pulsar-client version to work with OAuth2

2023-05-05 Thread via GitHub
tisonkun commented on PR #44: URL: https://github.com/apache/flink-connector-pulsar/pull/44#issuecomment-1537068806 Change to builder which is a compatible way - test compile from 2.10.1 to 2.10.4. -- This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink-connector-pulsar] tisonkun opened a new pull request, #45: [hotfix] Workaround new violations message

2023-05-05 Thread via GitHub
tisonkun opened a new pull request, #45: URL: https://github.com/apache/flink-connector-pulsar/pull/45 ## Purpose of the change AS TITLE ## Verifying this change This change is a trivial rework / code cleanup without any test coverage. ## Significant changes

[GitHub] [flink-connector-pulsar] tisonkun commented on pull request #44: [FLINK-32003] Upgrade pulsar-client version to work with OAuth2

2023-05-05 Thread via GitHub
tisonkun commented on PR #44: URL: https://github.com/apache/flink-connector-pulsar/pull/44#issuecomment-1537065990 @nlu90 No luck - Pulsar patch release breaks interface: ``` Error: COMPILATION ERROR : [INFO] - Er

[jira] [Resolved] (FLINK-32010) KubernetesLeaderRetrievalDriver always waits for lease update to resolve leadership

2023-05-05 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-32010. --- Fix Version/s: 1.16.2 1.18.0 1.17.1 Resolution:

[jira] [Comment Edited] (FLINK-32010) KubernetesLeaderRetrievalDriver always waits for lease update to resolve leadership

2023-05-05 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719968#comment-17719968 ] David Morávek edited comment on FLINK-32010 at 5/6/23 6:20 AM: ---

[GitHub] [flink] dmvk merged pull request #22530: [BP-1.17][FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the leader is a

2023-05-05 Thread via GitHub
dmvk merged PR #22530: URL: https://github.com/apache/flink/pull/22530 -- 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.o

[GitHub] [flink] dmvk merged pull request #22529: [BP-1.16][FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the leader is a

2023-05-05 Thread via GitHub
dmvk merged PR #22529: URL: https://github.com/apache/flink/pull/22529 -- 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.o

[jira] [Commented] (FLINK-32003) Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2

2023-05-05 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720101#comment-17720101 ] Zili Chen commented on FLINK-32003: --- Thanks for reporting this issue [~nlu90]! It's re

[jira] [Assigned] (FLINK-32003) Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2

2023-05-05 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-32003: - Assignee: Zili Chen > Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2 >

[jira] [Updated] (FLINK-32003) Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2

2023-05-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32003: --- Labels: pull-request-available (was: ) > Release 3.0.0-1.16 and 1.16.1 doesn't work with OA

[GitHub] [flink-connector-pulsar] tisonkun opened a new pull request, #44: [FLINK-32003] Upgrade pulsar-client version to work with OAuth2

2023-05-05 Thread via GitHub
tisonkun opened a new pull request, #44: URL: https://github.com/apache/flink-connector-pulsar/pull/44 ## Purpose of the change Upgrade pulsar-client version to work with OAuth2 ## Verifying this change Existing tests should pass. ## Significant changes *(Pl

[jira] [Commented] (FLINK-32011) flink1.15.2 loaded all the data in the table in mysql5.7

2023-05-05 Thread xueyongyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720091#comment-17720091 ] xueyongyang commented on FLINK-32011: - _Alright, thanks a lot_ > flink1.15.2 loaded

[jira] [Commented] (FLINK-32018) Many builds of benchmark have been interrupted since 20230428

2023-05-05 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720090#comment-17720090 ] Yanfei Lei commented on FLINK-32018: I suspect it has something to do with the versi

[GitHub] [flink] flinkbot commented on pull request #22536: [FLINK-31546][jdbc-driver] Close all statements when connection is closed

2023-05-05 Thread via GitHub
flinkbot commented on PR #22536: URL: https://github.com/apache/flink/pull/22536#issuecomment-1537050661 ## CI report: * 9e073ad4e758b4b5ff95f84469f5cb9edab5b114 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31546) Close all statements when connection is closed

2023-05-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31546: --- Labels: pull-request-available (was: ) > Close all statements when connection is closed > -

[GitHub] [flink] FangYongs opened a new pull request, #22536: [FLINK-31546][jdbc-driver] Close all statements when connection is closed

2023-05-05 Thread via GitHub
FangYongs opened a new pull request, #22536: URL: https://github.com/apache/flink/pull/22536 ## What is the purpose of the change This PR aims to close all statements when a specified connection is closed in jdbc driver. ## Brief change log - Add statement list in flink co

[jira] [Commented] (FLINK-32011) flink1.15.2 loaded all the data in the table in mysql5.7

2023-05-05 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720083#comment-17720083 ] Benchao Li commented on FLINK-32011: JDBC connector was split to separate repo and r

[jira] [Closed] (FLINK-32011) flink1.15.2 loaded all the data in the table in mysql5.7

2023-05-05 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li closed FLINK-32011. -- Resolution: Not A Problem > flink1.15.2 loaded all the data in the table in mysql5.7 > ---

[jira] [Updated] (FLINK-31546) Close all statements when connection is closed

2023-05-05 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-31546: -- Description: Close all statements when connection is closed (was: Create column and related classes f

[jira] [Updated] (FLINK-31546) Close all statements when connection is closed

2023-05-05 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-31546: -- Summary: Close all statements when connection is closed (was: Add column info and management for sql

[GitHub] [flink] cy2008 commented on pull request #22500: [FLINK-31928][build] Upgrade okhttp3 to 4.11.0

2023-05-05 Thread via GitHub
cy2008 commented on PR #22500: URL: https://github.com/apache/flink/pull/22500#issuecomment-1537044242 @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. T

[jira] [Commented] (FLINK-32009) Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout

2023-05-05 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720078#comment-17720078 ] Weihua Hu commented on FLINK-32009: --- [~baibaiwuchang] This log only shows that Job not

[jira] [Created] (FLINK-32022) Source level scaling is not applied to operators with chaining applied

2023-05-05 Thread Tan Kim (Jira)
Tan Kim created FLINK-32022: --- Summary: Source level scaling is not applied to operators with chaining applied Key: FLINK-32022 URL: https://issues.apache.org/jira/browse/FLINK-32022 Project: Flink

[jira] [Updated] (FLINK-31953) FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

2023-05-05 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-31953: -- Description: This improvement implements [FLIP-288|https://cwiki.apache.org/confluence/displa

[jira] [Created] (FLINK-32021) Improvement the Javadoc for SpecifiedOffsetsInitializer and TimestampOffsetsInitializer.

2023-05-05 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-32021: - Summary: Improvement the Javadoc for SpecifiedOffsetsInitializer and TimestampOffsetsInitializer. Key: FLINK-32021 URL: https://issues.apache.org/jira/browse/FLINK-32021

[GitHub] [flink] flinkbot commented on pull request #22535: [BP-1.16][FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool.

2023-05-05 Thread via GitHub
flinkbot commented on PR #22535: URL: https://github.com/apache/flink/pull/22535#issuecomment-1537020404 ## CI report: * 344c3b0896f64f86f8ec5eaadfa80caaea89a132 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32020) Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288

2023-05-05 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-32020: -- Affects Version/s: kafka-3.0.0 > Enable Dynamic Partition Discovery by Default in Kafka Source

[jira] [Updated] (FLINK-32020) Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288

2023-05-05 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-32020: -- Component/s: Connectors / Kafka > Enable Dynamic Partition Discovery by Default in Kafka Sourc

[jira] [Updated] (FLINK-32020) Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288

2023-05-05 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-32020: -- Fix Version/s: kafka-4.0.0 > Enable Dynamic Partition Discovery by Default in Kafka Source bas

[jira] [Created] (FLINK-32020) Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288

2023-05-05 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-32020: - Summary: Enable Dynamic Partition Discovery by Default in Kafka Source based on FLIP-288 Key: FLINK-32020 URL: https://issues.apache.org/jira/browse/FLINK-32020 Pro

[jira] [Created] (FLINK-32019) EARLIEST offset strategy for partitions discoveried later based on FLIP-288

2023-05-05 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-32019: - Summary: EARLIEST offset strategy for partitions discoveried later based on FLIP-288 Key: FLINK-32019 URL: https://issues.apache.org/jira/browse/FLINK-32019 Project

[GitHub] [flink] flinkbot commented on pull request #22534: [hotfix][docs] The tab name scala is changed to the uniformly used Scala in the table api document.

2023-05-05 Thread via GitHub
flinkbot commented on PR #22534: URL: https://github.com/apache/flink/pull/22534#issuecomment-1537011416 ## CI report: * 4ee0c320e21e4e4648aaa77ef1c3ff4381837915 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] reswqa opened a new pull request, #22535: [BP-1.16][FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool.

2023-05-05 Thread via GitHub
reswqa opened a new pull request, #22535: URL: https://github.com/apache/flink/pull/22535 Backport FLINK-31764 to release-1.16. -- 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

[GitHub] [flink-connector-kafka] loserwang1024 closed pull request #27: [FLINK-31953][Connector/Kafka] EARLIEST offset strategy for partitions discoveried later based on FLIP-288

2023-05-05 Thread via GitHub
loserwang1024 closed pull request #27: [FLINK-31953][Connector/Kafka] EARLIEST offset strategy for partitions discoveried later based on FLIP-288 URL: https://github.com/apache/flink-connector-kafka/pull/27 -- This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink-connector-kafka] loserwang1024 commented on pull request #27: [FLINK-31953][Connector/Kafka] EARLIEST offset strategy for partitions discoveried later based on FLIP-288

2023-05-05 Thread via GitHub
loserwang1024 commented on PR #27: URL: https://github.com/apache/flink-connector-kafka/pull/27#issuecomment-1537009837 Split FLIP-288 into more subtasks to see details more clearly. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[GitHub] [flink] zhuangchong opened a new pull request, #22534: [hotfix][docs] The tab name scala is changed to the uniformly used Scala in the table api document.

2023-05-05 Thread via GitHub
zhuangchong opened a new pull request, #22534: URL: https://github.com/apache/flink/pull/22534 … the table api document. ## 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

[GitHub] [flink] Myasuka commented on a diff in pull request #22458: [FLINK-31743][statebackend/rocksdb] disable rocksdb log relocating wh…

2023-05-05 Thread via GitHub
Myasuka commented on code in PR #22458: URL: https://github.com/apache/flink/pull/22458#discussion_r1186599166 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java: ## @@ -82,30 +89,36 @@ public f

[jira] [Closed] (FLINK-31764) Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool

2023-05-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31764. -- Fix Version/s: 1.18.0 1.17.1 Resolution: Fixed master(1.18) via 3379c2c085da

[GitHub] [flink] reswqa merged pull request #22447: [FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool

2023-05-05 Thread via GitHub
reswqa merged PR #22447: URL: https://github.com/apache/flink/pull/22447 -- 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

[GitHub] [flink] reswqa commented on pull request #22447: [FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool

2023-05-05 Thread via GitHub
reswqa commented on PR #22447: URL: https://github.com/apache/flink/pull/22447#issuecomment-1536997003 CI passed, merging... -- 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.

[GitHub] [flink] reswqa merged pull request #22528: [BP-1.17][FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool.

2023-05-05 Thread via GitHub
reswqa merged PR #22528: URL: https://github.com/apache/flink/pull/22528 -- 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

[GitHub] [flink] reswqa commented on pull request #22528: [BP-1.17][FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool.

2023-05-05 Thread via GitHub
reswqa commented on PR #22528: URL: https://github.com/apache/flink/pull/22528#issuecomment-1536996082 Reviewed in #22447, merging... -- 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

[GitHub] [flink-connector-kafka] loserwang1024 commented on pull request #26: [FLINK-31208][Connectors/Kafka] KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits)

2023-05-05 Thread via GitHub
loserwang1024 commented on PR #26: URL: https://github.com/apache/flink-connector-kafka/pull/26#issuecomment-1536990876 add more subtask to see details more easily -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [flink-connector-kafka] loserwang1024 closed pull request #26: [FLINK-31208][Connectors/Kafka] KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits)

2023-05-05 Thread via GitHub
loserwang1024 closed pull request #26: [FLINK-31208][Connectors/Kafka] KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits) URL: https://github.com/apache/flink-connector-kafka/pull/26 -- This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Comment Edited] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scaling down with unaligned checkpoints

2023-05-05 Thread Tan Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720049#comment-17720049 ] Tan Kim edited comment on FLINK-31963 at 5/6/23 2:24 AM: - Q1 If

[jira] [Updated] (FLINK-32018) Many builds of benchmark have been interrupted since 20230428

2023-05-05 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-32018: --- Description: Since 2023.04.28, flink-statebackend-benchmarks-java8, flink-statebackend-benchmarks-j

[jira] [Created] (FLINK-32018) Many builds of benchmark have been interrupted since 20230428

2023-05-05 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-32018: -- Summary: Many builds of benchmark have been interrupted since 20230428 Key: FLINK-32018 URL: https://issues.apache.org/jira/browse/FLINK-32018 Project: Flink Is

[jira] [Comment Edited] (FLINK-31976) Once marked as an inefficient scale-up, further scaling may not happen forever

2023-05-05 Thread Tan Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720055#comment-17720055 ] Tan Kim edited comment on FLINK-31976 at 5/6/23 2:04 AM: - [~gyfo

[GitHub] [flink] flinkbot commented on pull request #22533: [FLINK-31687][jdbc-driver] Get rid of flink-core for jdbc driver

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

[jira] [Commented] (FLINK-31976) Once marked as an inefficient scale-up, further scaling may not happen forever

2023-05-05 Thread Tan Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720055#comment-17720055 ] Tan Kim commented on FLINK-31976: - [~gyfora]  I understand the principle of inefficient

[jira] [Updated] (FLINK-31687) Flink jdbc driver get rid of flink core

2023-05-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31687: --- Labels: pull-request-available (was: ) > Flink jdbc driver get rid of flink core >

[GitHub] [flink] FangYongs opened a new pull request, #22533: [FLINK-31687][jdbc-driver] Get rid of flink-core for jdbc driver

2023-05-05 Thread via GitHub
FangYongs opened a new pull request, #22533: URL: https://github.com/apache/flink/pull/22533 ## What is the purpose of the change This PR aims to get rid of flink-core for flink jdbc driver ## Brief change log - Get Map instead of Configuratioin in Executor.getSessionConfig

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scaling down with unaligned checkpoints

2023-05-05 Thread Tan Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720049#comment-17720049 ] Tan Kim commented on FLINK-31963: - Q1 If it happens once during recovery from an unalig

[jira] [Created] (FLINK-32017) DISTINCT COUNT result is incorrect with ttl

2023-05-05 Thread Bo Cui (Jira)
Bo Cui created FLINK-32017: -- Summary: DISTINCT COUNT result is incorrect with ttl Key: FLINK-32017 URL: https://issues.apache.org/jira/browse/FLINK-32017 Project: Flink Issue Type: Bug Affects V

[GitHub] [flink] mas-chen commented on pull request #22531: [FLINK-28853] Document the split level watermark alignment feature an…

2023-05-05 Thread via GitHub
mas-chen commented on PR #22531: URL: https://github.com/apache/flink/pull/22531#issuecomment-1536964851 @mxm @tweise -- 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 un

[jira] [Created] (FLINK-32016) Logs are printed as disabled even if the autoscaler option is true

2023-05-05 Thread Tan Kim (Jira)
Tan Kim created FLINK-32016: --- Summary: Logs are printed as disabled even if the autoscaler option is true Key: FLINK-32016 URL: https://issues.apache.org/jira/browse/FLINK-32016 Project: Flink Iss

[GitHub] [flink] cy2008 commented on pull request #22499: [FLINK-31928][build] Upgrade okhttp3 to 4.11.0

2023-05-05 Thread via GitHub
cy2008 commented on PR #22499: URL: https://github.com/apache/flink/pull/22499#issuecomment-1536959119 @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. T

[GitHub] [flink] clownxc commented on pull request #22353: [FLINK-31320][table]Modify DATE_FORMAT system (built-in) function to accepts DATEs

2023-05-05 Thread via GitHub
clownxc commented on PR #22353: URL: https://github.com/apache/flink/pull/22353#issuecomment-1536956546 Could you please take a look when you have time? thanks a lot ! @liuyongvs @snuyanzin -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] flinkbot commented on pull request #22532: [FLINK-31548][jdbc-driver] Introduce FlinkDataSource

2023-05-05 Thread via GitHub
flinkbot commented on PR #22532: URL: https://github.com/apache/flink/pull/22532#issuecomment-1536954759 ## CI report: * 96eafdc3e4bacc80c544311f3c28634a6c58f536 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] cy2008 commented on pull request #22500: [FLINK-31928][build] Upgrade okhttp3 to 4.11.0

2023-05-05 Thread via GitHub
cy2008 commented on PR #22500: URL: https://github.com/apache/flink/pull/22500#issuecomment-1536953432 @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. T

[jira] [Updated] (FLINK-31548) Introduce FlinkDataSource for jdbc driver

2023-05-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31548: --- Labels: pull-request-available (was: ) > Introduce FlinkDataSource for jdbc driver > --

[GitHub] [flink] FangYongs opened a new pull request, #22532: [FLINK-31548][jdbc-driver] Introduce FlinkDataSource

2023-05-05 Thread via GitHub
FangYongs opened a new pull request, #22532: URL: https://github.com/apache/flink/pull/22532 ## What is the purpose of the change Introduce data source for flink jdbc driver ## Brief change log - Add FlinkDataSource ## Verifying this change This change add

[jira] [Updated] (FLINK-32011) flink1.15.2 loaded all the data in the table in mysql5.7

2023-05-05 Thread xueyongyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyongyang updated FLINK-32011: Fix Version/s: (was: 1.15.2) > flink1.15.2 loaded all the data in the table in mysql5.7 >

[jira] [Commented] (FLINK-32011) flink1.15.2 loaded all the data in the table in mysql5.7

2023-05-05 Thread xueyongyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720034#comment-17720034 ] xueyongyang commented on FLINK-32011: - [~libenchao] Ok, thank you, but I still have

[GitHub] [flink] venkata91 commented on pull request #22509: [FLINK-31983] Add yarn Acls capability to Flink containers

2023-05-05 Thread via GitHub
venkata91 commented on PR #22509: URL: https://github.com/apache/flink/pull/22509#issuecomment-1536901384 @gaborgsomogyi Could you help to review this PR? -- 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

[jira] [Updated] (FLINK-32015) Flink does not fail SSL Handshake when expired cert is used

2023-05-05 Thread Dhruv Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruv Patel updated FLINK-32015: Description: We recently observed that Flink is able to perform SSL communication without any iss

[jira] [Created] (FLINK-32015) Flink does not fail SSL Handshake when expired cert is used

2023-05-05 Thread Dhruv Patel (Jira)
Dhruv Patel created FLINK-32015: --- Summary: Flink does not fail SSL Handshake when expired cert is used Key: FLINK-32015 URL: https://issues.apache.org/jira/browse/FLINK-32015 Project: Flink Is

[GitHub] [flink] pgaref commented on pull request #22481: [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8

2023-05-05 Thread via GitHub
pgaref commented on PR #22481: URL: https://github.com/apache/flink/pull/22481#issuecomment-1536782582 @tzulitai / @dmvk can you please take another look? -- 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

[GitHub] [flink] pgaref commented on a diff in pull request #22481: [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8

2023-05-05 Thread via GitHub
pgaref commented on code in PR #22481: URL: https://github.com/apache/flink/pull/22481#discussion_r1186501105 ## flink-formats/flink-orc-nohive/src/test/java/org/apache/flink/orc/nohive/OrcColumnarRowSplitReaderNoHiveTest.java: ## @@ -105,7 +105,9 @@ protected OrcColumnarRowSpli

[GitHub] [flink] flinkbot commented on pull request #22531: [FLINK-28853] Document the split level watermark alignment feature an…

2023-05-05 Thread via GitHub
flinkbot commented on PR #22531: URL: https://github.com/apache/flink/pull/22531#issuecomment-1536773688 ## CI report: * 72110d93613439cb4f265e07af792d114086b0db UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dongjoon-hyun commented on pull request #22481: [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8

2023-05-05 Thread via GitHub
dongjoon-hyun commented on PR #22481: URL: https://github.com/apache/flink/pull/22481#issuecomment-1536768582 Also, cc @williamhyun once more too.. -- 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

[GitHub] [flink] dongjoon-hyun commented on pull request #22481: [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8

2023-05-05 Thread via GitHub
dongjoon-hyun commented on PR #22481: URL: https://github.com/apache/flink/pull/22481#issuecomment-1536767114 It's great! Thank you so much, @pgaref . -- 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

[GitHub] [flink] pgaref commented on pull request #22481: [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8

2023-05-05 Thread via GitHub
pgaref commented on PR #22481: URL: https://github.com/apache/flink/pull/22481#issuecomment-1536767873 > BTW, could you cast your +1 with that information on Apache ORC 1.7.9 vote thread? Sure, will do -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] dongjoon-hyun commented on pull request #22481: [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8

2023-05-05 Thread via GitHub
dongjoon-hyun commented on PR #22481: URL: https://github.com/apache/flink/pull/22481#issuecomment-1536767645 BTW, could you cast your +1 with that information on Apache ORC 1.7.9 vote thread? -- This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink] mas-chen opened a new pull request, #22531: [FLINK-28853] Document the split level watermark alignment feature an…

2023-05-05 Thread via GitHub
mas-chen opened a new pull request, #22531: URL: https://github.com/apache/flink/pull/22531 …d fixup grammar from the configuration table ## What is the purpose of the change Update docs for watermark alignment. ## Brief change log - Update docs for watermark a

[GitHub] [flink] pgaref commented on pull request #22481: [FLINK-27805][Connectors/ORC] bump orc version to 1.7.8

2023-05-05 Thread via GitHub
pgaref commented on PR #22481: URL: https://github.com/apache/flink/pull/22481#issuecomment-1536766494 FYI @dongjoon-hyun @wgtmac we had a [green run for 1.7.9](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=48695&view=results). Switching back to 1.7.8 to get

[GitHub] [flink] rmetzger commented on pull request #22509: [FLINK-31983] Add yarn Acls capability to Flink containers

2023-05-05 Thread via GitHub
rmetzger commented on PR #22509: URL: https://github.com/apache/flink/pull/22509#issuecomment-1536706789 I'm going to be out of office for the next 2 weeks, and I haven't worked on the YARN code much recently. Maybe it would be easiest to look for folks who have recently worked on Flink on

[GitHub] [flink] GJL commented on pull request #22509: [FLINK-31983] Add yarn Acls capability to Flink containers

2023-05-05 Thread via GitHub
GJL commented on PR #22509: URL: https://github.com/apache/flink/pull/22509#issuecomment-1536699484 Sorry, I don't have bandwidth at the moment and I don't remember the initial PR from 4 years ago. @rmetzger could you take a look? -- This is an automated message from the Apache Git Servic

[GitHub] [flink] flinkbot commented on pull request #22530: [BP-1.17][FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the l

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

[GitHub] [flink] flinkbot commented on pull request #22529: [BP-1.16][FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the l

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

[GitHub] [flink] dmvk opened a new pull request, #22530: [BP-1.17][FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the lead

2023-05-05 Thread via GitHub
dmvk opened a new pull request, #22530: URL: https://github.com/apache/flink/pull/22530 Backport of https://github.com/apache/flink/pull/22524 -- 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

[GitHub] [flink] dmvk opened a new pull request, #22529: [BP-1.16][FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the lead

2023-05-05 Thread via GitHub
dmvk opened a new pull request, #22529: URL: https://github.com/apache/flink/pull/22529 Backport of https://github.com/apache/flink/pull/22524 -- 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

[jira] [Commented] (FLINK-32010) KubernetesLeaderRetrievalDriver always waits for lease update to resolve leadership

2023-05-05 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719968#comment-17719968 ] David Morávek commented on FLINK-32010: --- master: 026d7ccfe1d6f4cfa26c9038dd05403c8

[GitHub] [flink] dmvk merged pull request #22524: [FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the leader is already kn

2023-05-05 Thread via GitHub
dmvk merged PR #22524: URL: https://github.com/apache/flink/pull/22524 -- 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.o

[GitHub] [flink] kurnoolsaketh commented on a diff in pull request #10594: [FLINK-15266] Fix NPE for case operator code gen in blink planner

2023-05-05 Thread via GitHub
kurnoolsaketh commented on code in PR #10594: URL: https://github.com/apache/flink/pull/10594#discussion_r1186404125 ## flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala: ## @@ -1287,12 +1287,16 @@ object S

[GitHub] [flink] mohsenrezaeithe commented on pull request #21849: [FLINK-30596][Runtime/REST] Fix duplicate jobs when submitting with the same jobId

2023-05-05 Thread via GitHub
mohsenrezaeithe commented on PR #21849: URL: https://github.com/apache/flink/pull/21849#issuecomment-1536603073 @zentol can you please take a look and approve? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [flink] venkata91 commented on pull request #22509: [FLINK-31983] Add yarn Acls capability to Flink containers

2023-05-05 Thread via GitHub
venkata91 commented on PR #22509: URL: https://github.com/apache/flink/pull/22509#issuecomment-1536584767 Gentle ping @GJL and @becketqin for review. -- 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

[GitHub] [flink] flinkbot commented on pull request #22528: [BP-1.17][FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool.

2023-05-05 Thread via GitHub
flinkbot commented on PR #22528: URL: https://github.com/apache/flink/pull/22528#issuecomment-1536538670 ## CI report: * 2698dafe36b6e5a2c160d3b0de319dd1704f43a1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] reswqa opened a new pull request, #22528: [BP-1.17][FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool.

2023-05-05 Thread via GitHub
reswqa opened a new pull request, #22528: URL: https://github.com/apache/flink/pull/22528 Backport FLINK-31764 to release-1.17. -- 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

[GitHub] [flink] XComp commented on a diff in pull request #21349: [FLINK-28203] Support Maven 3.3+

2023-05-05 Thread via GitHub
XComp commented on code in PR #21349: URL: https://github.com/apache/flink/pull/21349#discussion_r1186303817 ## tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/optional/ShadeOptionalChecker.java: ## @@ -0,0 +1,206 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink] XComp commented on a diff in pull request #21349: [FLINK-28203] Support Maven 3.3+

2023-05-05 Thread via GitHub
XComp commented on code in PR #21349: URL: https://github.com/apache/flink/pull/21349#discussion_r1186303817 ## tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/optional/ShadeOptionalChecker.java: ## @@ -0,0 +1,206 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink] WencongLiu commented on pull request #22342: [FLINK-31636][network] Upstream supports reading buffers from tiered store

2023-05-05 Thread via GitHub
WencongLiu commented on PR #22342: URL: https://github.com/apache/flink/pull/22342#issuecomment-1536438795 @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-29852) Adaptive Scheduler duplicates operators for each parallel instance in the Web UI

2023-05-05 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719915#comment-17719915 ] David Morávek commented on FLINK-29852: --- This is just a problem with the REST API

[jira] [Commented] (FLINK-29852) Adaptive Scheduler duplicates operators for each parallel instance in the Web UI

2023-05-05 Thread Leonissimo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719902#comment-17719902 ] Leonissimo commented on FLINK-29852: We are facing this issue in 1.16.1 and need to

  1   2   3   >