[jira] [Commented] (FLINK-32988) HiveITCase failed due to TestContainer not coming up

[ https://issues.apache.org/jira/browse/FLINK-32988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762292#comment-17762292 ] Sergey Nuyanzin commented on FLINK-32988: - https://dev.azure.com/apache-flink/ap

[GitHub] [flink-kubernetes-operator] HuangZhenQiu commented on pull request #663: [FLINK-32777] add config for opt out okhttp hostname verification

HuangZhenQiu commented on PR #663: URL: https://github.com/apache/flink-kubernetes-operator/pull/663#issuecomment-1707763535 @gyfora The user reported a work around by using environment variable before the new Okhttp version upgrade. If so, the config is not needed. I will create anothe

[GitHub] [flink-kubernetes-operator] HuangZhenQiu closed pull request #663: [FLINK-32777] add config for opt out okhttp hostname verification

HuangZhenQiu closed pull request #663: [FLINK-32777] add config for opt out okhttp hostname verification URL: https://github.com/apache/flink-kubernetes-operator/pull/663 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #657: [FLINK-31406] Do not delete jobgraph on scale only last-state upgrades

gyfora commented on code in PR #657: URL: https://github.com/apache/flink-kubernetes-operator/pull/657#discussion_r1316788711 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerTest.java: ## @@ -873,6 +891,

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #657: [FLINK-31406] Do not delete jobgraph on scale only last-state upgrades

gyfora commented on code in PR #657: URL: https://github.com/apache/flink-kubernetes-operator/pull/657#discussion_r1316788012 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerTest.java: ## @@ -873,6 +891,

[GitHub] [flink] ldadima commented on pull request #23357: [FLINK-33034][Backport][runtime] Correct ValueState creating for StateBackendTestBase#testGetKeysAndNamespaces

ldadima commented on PR #23357: URL: https://github.com/apache/flink/pull/23357#issuecomment-1707734798 > ## CI report: > * [a9237c9](https://github.com/apache/flink/commit/a9237c916b63aa90ac8f84d42b76881936045948) Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8

[jira] [Assigned] (FLINK-32974) RestClusterClient always leaks flink-rest-client-jobgraphs* directories

[ https://issues.apache.org/jira/browse/FLINK-32974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-32974: -- Assignee: Lijie Wang > RestClusterClient always leaks flink-rest-client-jobgraphs* directorie

[GitHub] [flink-web] JingsongLi commented on a diff in pull request #665: [FLINK-32611] Redirect to Apache Paimon's link instead of legacy flink table store

JingsongLi commented on code in PR #665: URL: https://github.com/apache/flink-web/pull/665#discussion_r1316749601 ## docs/content.zh/documentation/flink-table-store-0.3.md: ## @@ -1,7 +1,7 @@ --- -weight: 10 -title: Table Store Master (snapshot) Review Comment: Maybe we can

[GitHub] [flink-web] JingsongLi commented on pull request #665: [FLINK-32611] Redirect to Apache Paimon's link instead of legacy flink table store

JingsongLi commented on PR #665: URL: https://github.com/apache/flink-web/pull/665#issuecomment-1707684233 Can you solve the conflicts? -- 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 specifi

[jira] [Assigned] (FLINK-32813) Split autoscaler ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-32813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-32813: -- Assignee: Gyula Fora > Split autoscaler ConfigMap > -- > >

[GitHub] [flink] flinkbot commented on pull request #23364: [FLINK-15922] Only remember expired checkpoints and log received late messages of those in CheckpointCoordinator

flinkbot commented on PR #23364: URL: https://github.com/apache/flink/pull/23364#issuecomment-1707646214 ## CI report: * d8550dd33aaf0c8760f7f070c63446236d43d3ac UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #23363: [FLINK-32974][client] Clean up the temp dir on RestClusterClient#close if the temp dir is created by the client

flinkbot commented on PR #23363: URL: https://github.com/apache/flink/pull/23363#issuecomment-1707646137 ## CI report: * 925630d03cb6eee9bcda6731f88701da94004294 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Zakelly opened a new pull request, #23364: [FLINK-15922] Only remember expired checkpoints and log received late messages of those in CheckpointCoordinator

Zakelly opened a new pull request, #23364: URL: https://github.com/apache/flink/pull/23364 ## What is the purpose of the change The message "Warn - received late message for checkpoint" is shown frequently in the logs, also when a checkpoint was purposefully canceled. In those case,

[GitHub] [flink] wanglijie95 opened a new pull request, #23363: [FLINK-32974][client] Clean up the temp dir on RestClusterClient#close if the temp dir is created by the client

wanglijie95 opened a new pull request, #23363: URL: https://github.com/apache/flink/pull/23363 ## What is the purpose of the change Fix FLINK-32974 ## Verifying this change Add test `RestClusterClientTest#testTempDirCleanedUpOnClose` ## Does this pull request potentially a

[GitHub] [flink] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

JunRuiLee commented on PR #23181: URL: https://github.com/apache/flink/pull/23181#issuecomment-1707627480 @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.

[GitHub] [flink-kubernetes-operator] SteNicholas commented on a diff in pull request #657: [FLINK-31406] Do not delete jobgraph on scale only last-state upgrades

SteNicholas commented on code in PR #657: URL: https://github.com/apache/flink-kubernetes-operator/pull/657#discussion_r1316695338 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerTest.java: ## @@ -847,6

[jira] [Comment Edited] (FLINK-32787) Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

[ https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762253#comment-17762253 ] luoyuxia edited comment on FLINK-32787 at 9/6/23 3:13 AM: -- [~ha

[jira] [Comment Edited] (FLINK-32787) Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

[ https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762253#comment-17762253 ] luoyuxia edited comment on FLINK-32787 at 9/6/23 3:02 AM: -- [~ha

[jira] [Comment Edited] (FLINK-32787) Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

[ https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762253#comment-17762253 ] luoyuxia edited comment on FLINK-32787 at 9/6/23 3:02 AM: -- [~ha

[GitHub] [flink-ml] zhaozijun109 commented on pull request #253: [FLINK-33003] Support isolation forest algorithm in Flink ML

zhaozijun109 commented on PR #253: URL: https://github.com/apache/flink-ml/pull/253#issuecomment-1707585256 @lindong28 Please review again teacher，thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Comment Edited] (FLINK-32787) Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

[ https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762253#comment-17762253 ] luoyuxia edited comment on FLINK-32787 at 9/6/23 3:01 AM: -- [~ha

[GitHub] [flink] flinkbot commented on pull request #23362: [FLINK-33041][docs] Add an article to guide users to migrate their DataSet jobs to DataStream

flinkbot commented on PR #23362: URL: https://github.com/apache/flink/pull/23362#issuecomment-1707583009 ## CI report: * 4de1347037bc376bd3587ee4f3265b75ffe058fd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-32787) Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

[ https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762253#comment-17762253 ] luoyuxia commented on FLINK-32787: -- I think it may be that after drop the table, the fi

[GitHub] [flink] WencongLiu opened a new pull request, #23362: [FLINK-33041][docs] Add an article to guide users to migrate their DataSet jobs to DataStream

WencongLiu opened a new pull request, #23362: URL: https://github.com/apache/flink/pull/23362 ## What is the purpose of the change Add an article to guide users to migrate their DataSet jobs to DataStream. ## Brief change log - Add an article to guide users to mig

[jira] [Created] (FLINK-33041) Add an introduction about how to migrate DataSet API to DataStream

Wencong Liu created FLINK-33041: --- Summary: Add an introduction about how to migrate DataSet API to DataStream Key: FLINK-33041 URL: https://issues.apache.org/jira/browse/FLINK-33041 Project: Flink

[jira] [Assigned] (FLINK-5279) Improve error message when trying to access keyed state in non-keyed operator

[ https://issues.apache.org/jira/browse/FLINK-5279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-5279: -- Assignee: Zakelly Lan > Improve error message when trying to access keyed state in non-keyed o

[jira] [Closed] (FLINK-24965) Improper usage of Map.Entry after Entry Iterator.remove in TaskLocaStateStoreImpl#pruneCheckpoints

[ https://issues.apache.org/jira/browse/FLINK-24965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan closed FLINK-24965. --- Resolution: Fixed > Improper usage of Map.Entry after Entry Iterator.remove in > TaskLocaStateStore

[jira] [Commented] (FLINK-24965) Improper usage of Map.Entry after Entry Iterator.remove in TaskLocaStateStoreImpl#pruneCheckpoints

[ https://issues.apache.org/jira/browse/FLINK-24965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762250#comment-17762250 ] Zakelly Lan commented on FLINK-24965: - I think this has been fixed by FLINK-27692, s

[jira] [Comment Edited] (FLINK-33038) remove getMinRetentionTime in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-33038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762248#comment-17762248 ] xiaogang zhou edited comment on FLINK-33038 at 9/6/23 2:26 AM: ---

[jira] [Commented] (FLINK-33038) remove getMinRetentionTime in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-33038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762248#comment-17762248 ] xiaogang zhou commented on FLINK-33038: --- [~Sergey Nuyanzin] [https://github.com/ap

[GitHub] [flink] YasuoStudyJava commented on a diff in pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

YasuoStudyJava commented on code in PR #17676: URL: https://github.com/apache/flink/pull/17676#discussion_r1316599115 ## flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/OracleRowConverter.java: ## @@ -123,21 +121,33 @@ publi

[GitHub] [flink] YasuoStudyJava commented on a diff in pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

YasuoStudyJava commented on code in PR #17676: URL: https://github.com/apache/flink/pull/17676#discussion_r1316599115 ## flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/OracleRowConverter.java: ## @@ -123,21 +121,33 @@ publi

[GitHub] [flink] lincoln-lil merged pull request #23350: [FLINK-33026][doc] Fix the title of sql 'Performance Tuning' in the chinese index page

lincoln-lil merged PR #23350: URL: https://github.com/apache/flink/pull/23350 -- 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.a

[jira] [Resolved] (FLINK-32475) Add doc for time travel

[ https://issues.apache.org/jira/browse/FLINK-32475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-32475. -- Fix Version/s: 1.18.0 1.19.0 Resolution: Fixed > Add doc for time travel > -

[jira] [Resolved] (FLINK-32472) FLIP-308: Support Time Travel

[ https://issues.apache.org/jira/browse/FLINK-32472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-32472. -- Resolution: Fixed > FLIP-308: Support Time Travel > - > >

[jira] [Comment Edited] (FLINK-32475) Add doc for time travel

[ https://issues.apache.org/jira/browse/FLINK-32475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761192#comment-17761192 ] luoyuxia edited comment on FLINK-32475 at 9/6/23 1:34 AM: -- mast

[GitHub] [flink] luoyuxia merged pull request #23346: [BP-1.18][FLINK-32475][docs] Add doc for time travel

luoyuxia merged PR #23346: URL: https://github.com/apache/flink/pull/23346 -- 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.apac

[GitHub] [flink-connector-kafka] Gerrrr commented on a diff in pull request #46: [FLINK-33017] Remove dependency on shaded guava

Ge commented on code in PR #46: URL: https://github.com/apache/flink-connector-kafka/pull/46#discussion_r1316549706 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java: ## @@ -279,7 +279,8 @@ FlinkKafkaInternalProducer getCurrentPr

[GitHub] [flink-connector-kafka] Gerrrr commented on a diff in pull request #46: [FLINK-33017] Remove dependency on shaded guava

Ge commented on code in PR #46: URL: https://github.com/apache/flink-connector-kafka/pull/46#discussion_r1316546581 ## flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/shuffle/KafkaShuffleITCase.java: ## @@ -374,17 +371,16 @@ private void test

[GitHub] [flink-connector-kafka] Gerrrr commented on a diff in pull request #46: [FLINK-33017] Remove dependency on shaded guava

Ge commented on code in PR #46: URL: https://github.com/apache/flink-connector-kafka/pull/46#discussion_r1316546436 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java: ## @@ -245,12 +245,12 @@ public void close() throws Exception {

[GitHub] [flink-connector-kafka] Gerrrr commented on a diff in pull request #46: [FLINK-33017] Remove dependency on shaded guava

Ge commented on code in PR #46: URL: https://github.com/apache/flink-connector-kafka/pull/46#discussion_r1316546163 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java: ## @@ -452,12 +453,9 @@ public void onCompletion(RecordMetadata

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #46: [FLINK-33017] Remove dependency on shaded guava

tzulitai commented on code in PR #46: URL: https://github.com/apache/flink-connector-kafka/pull/46#discussion_r1316526004 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java: ## @@ -452,12 +453,9 @@ public void onCompletion(RecordMetada

[jira] [Commented] (FLINK-31121) KafkaSink should be able to catch and ignore exp via config on/off

[ https://issues.apache.org/jira/browse/FLINK-31121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762235#comment-17762235 ] Mason Chen commented on FLINK-31121: [~martijnvisser] [~zjureel] Hi! I'm going to ta

[GitHub] [flink-connector-kafka] Gerrrr opened a new pull request, #46: [FLINK-33017] Remove dependency on shaded guava

Ge opened a new pull request, #46: URL: https://github.com/apache/flink-connector-kafka/pull/46 The bump in shaded guava in Flink 1.18 changed import paths and caused the class loader fail when loading ManagedMemoryUtils. Looking at the root cause of the issue, shading was used as

[jira] [Commented] (FLINK-32671) Document Externalized Declarative Resource Management

[ https://issues.apache.org/jira/browse/FLINK-32671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762227#comment-17762227 ] Shahid Chohan commented on FLINK-32671: --- Will there also be guidance on the produc

[jira] [Updated] (FLINK-32476) Support configuring object-reuse for internal operators

[ https://issues.apache.org/jira/browse/FLINK-32476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32476: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available stal

[jira] [Updated] (FLINK-32701) Potential Memory Leak in Flink CEP due to Persistent Starting States in NFAState

[ https://issues.apache.org/jira/browse/FLINK-32701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32701: --- Labels: CEP cep stale-critical (was: CEP cep) I am the [Flink Jira Bot|https://github.com/a

[jira] [Commented] (FLINK-31871) Interpret Flink MemoryUnits according to the actual user input

[ https://issues.apache.org/jira/browse/FLINK-31871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1776#comment-1776 ] Mason Chen commented on FLINK-31871: It would be nice and intuitive to support what

[GitHub] [flink-connector-elasticsearch] mtfelisb commented on a diff in pull request #53: [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support

mtfelisb commented on code in PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1316470031 ## flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Operation.java: ## @@ -0,0 +1,70 @@ +/* + * + * Licens

[GitHub] [flink] flinkbot commented on pull request #23361: Bump org.apache.kafka:kafka-clients from 2.2.2 to 2.6.3 in /flink-end-to-end-tests/flink-sql-client-test

flinkbot commented on PR #23361: URL: https://github.com/apache/flink/pull/23361#issuecomment-1707368077 ## CI report: * 62c67c387d6c6f77581977f93ba230057d765803 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-connector-elasticsearch] mtfelisb commented on a diff in pull request #53: [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support

mtfelisb commented on code in PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1316465669 ## flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Operation.java: ## @@ -0,0 +1,70 @@ +/* + * + * Licens

[GitHub] [flink-statefun] dependabot[bot] opened a new pull request, #338: Bump org.apache.kafka:kafka-clients from 2.4.1 to 2.6.3 in /statefun-e2e-tests/statefun-e2e-tests-common

dependabot[bot] opened a new pull request, #338: URL: https://github.com/apache/flink-statefun/pull/338 Bumps org.apache.kafka:kafka-clients from 2.4.1 to 2.6.3. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=o

[GitHub] [flink] dependabot[bot] opened a new pull request, #23361: Bump org.apache.kafka:kafka-clients from 2.2.2 to 2.6.3 in /flink-end-to-end-tests/flink-sql-client-test

dependabot[bot] opened a new pull request, #23361: URL: https://github.com/apache/flink/pull/23361 Bumps org.apache.kafka:kafka-clients from 2.2.2 to 2.6.3. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=org.ap

[GitHub] [flink] gaborgsomogyi commented on pull request #23359: [WIP][FLINK-33029][python] Drop python 3.7 support

gaborgsomogyi commented on PR #23359: URL: https://github.com/apache/flink/pull/23359#issuecomment-1706959682 @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 comm

[jira] [Updated] (FLINK-33040) flink-connector-hive builds might be blocked (but not fail) because Maven tries to access conjars.org repository (which times out)

[ https://issues.apache.org/jira/browse/FLINK-33040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33040: -- Description: We (thanks to [~mdedetrich]) experienced timeouts when building {{flink-connecto

[jira] [Commented] (FLINK-33040) flink-connector-hive builds might be blocked (but not fail) because Maven tries to access conjars.org repository (which times out)

[ https://issues.apache.org/jira/browse/FLINK-33040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762155#comment-17762155 ] Matthias Pohl commented on FLINK-33040: --- I guess, the right way to handle it to up

[jira] [Updated] (FLINK-33040) flink-connector-hive builds might be blocked (but not fail) because Maven tries to access conjars.org repository (which times out)

[ https://issues.apache.org/jira/browse/FLINK-33040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33040: -- Description: We (thanks to [~mdedetrich]) experienced timeouts when building {{flink-connecto

[jira] [Created] (FLINK-33040) flink-connector-hive builds might be blocked (but not fail) because Maven tries to access conjars.org repository (which times out)

Matthias Pohl created FLINK-33040: - Summary: flink-connector-hive builds might be blocked (but not fail) because Maven tries to access conjars.org repository (which times out) Key: FLINK-33040 URL: https://issues.

[jira] [Commented] (FLINK-32777) Upgrade Okhttp version to support IPV6

[ https://issues.apache.org/jira/browse/FLINK-32777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762137#comment-17762137 ] Zhenqiu Huang commented on FLINK-32777: --- [~heywxl] Thanks for the confirmation.

[jira] [Closed] (FLINK-33027) Users should be able to change parallelism of excluded vertices

[ https://issues.apache.org/jira/browse/FLINK-33027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-33027. -- Resolution: Fixed merged to main 305cccf6d4cb9d4261a3f55ef71779aeaef26e14 > Users should be able to c

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #664: [FLINK-33027] Allow users to override parallelism of excluded vertices

gyfora merged PR #664: URL: https://github.com/apache/flink-kubernetes-operator/pull/664 -- 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

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #664: [FLINK-33027] Allow users to override parallelism of excluded vertices

gyfora commented on PR #664: URL: https://github.com/apache/flink-kubernetes-operator/pull/664#issuecomment-1706730826 > Thanks for the cleanup! Ideally, autoscaling would manage the overrides end-to-end but this is already cleaner than before. I agree, but for that as you said we ne

[jira] [Created] (FLINK-33039) Avro Specific Record Logical timestamp is not serialized in Parquet

Ahmed Elhassany created FLINK-33039: --- Summary: Avro Specific Record Logical timestamp is not serialized in Parquet Key: FLINK-33039 URL: https://issues.apache.org/jira/browse/FLINK-33039 Project: Fl

[GitHub] [flink] ldadima commented on pull request #23357: [FLINK-33034][Backport][runtime] Correct ValueState creating for StateBackendTestBase#testGetKeysAndNamespaces

ldadima commented on PR #23357: URL: https://github.com/apache/flink/pull/23357#issuecomment-1706625083 > ## CI report: > * [a9237c9](https://github.com/apache/flink/commit/a9237c916b63aa90ac8f84d42b76881936045948) Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #664: [FLINK-33027] Allow users to override parallelism of excluded vertices

mxm commented on code in PR #664: URL: https://github.com/apache/flink-kubernetes-operator/pull/664#discussion_r1315892963 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/JobAutoScaler.java: ## @@ -30,6 +28,6 @@ public inter

[GitHub] [flink] flinkbot commented on pull request #23360: [FLINK-33038][table-planner] remove getMinRetentionTime in StreamExec…

flinkbot commented on PR #23360: URL: https://github.com/apache/flink/pull/23360#issuecomment-1706612522 ## CI report: * c0dfad2fb5cd29d508fb610e64acbc1d8a3509cb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zhougit86 opened a new pull request, #23360: [FLINK-33038][table-planner] remove getMinRetentionTime in StreamExec…

zhougit86 opened a new pull request, #23360: URL: https://github.com/apache/flink/pull/23360 ## What is the purpose of the change remove code no longer needed ## Brief change log - *remove the getMinRetentionTime* ## Verifying this change

[jira] [Commented] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

[ https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762077#comment-17762077 ] Jane Chan commented on FLINK-32718: --- Can you provide the physical plans (by the "EXPLA

[GitHub] [flink] flinkbot commented on pull request #23359: [FLINK-33029][python] Drop python 3.7 support

flinkbot commented on PR #23359: URL: https://github.com/apache/flink/pull/23359#issuecomment-1706520017 ## CI report: * 03d9cb05239f6b88a84c174e3547ad0aa773c33d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] gaborgsomogyi opened a new pull request, #23359: [FLINK-][python] Drop python 3.7 support

gaborgsomogyi opened a new pull request, #23359: URL: https://github.com/apache/flink/pull/23359 ## What is the purpose of the change * Python 3.7.17 is the latest security patch of the 3.7 line. This version is end-of-life and is no longer supported: https://www.python.org/downloads

[jira] [Comment Edited] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API

[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762056#comment-17762056 ] Etienne Chauchot edited comment on FLINK-30314 at 9/5/23 11:58 AM: ---

[jira] [Comment Edited] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API

[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762056#comment-17762056 ] Etienne Chauchot edited comment on FLINK-30314 at 9/5/23 11:50 AM: ---

[jira] [Commented] (FLINK-30314) Unable to read all records from compressed line-delimited JSON files using Table API

[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762056#comment-17762056 ] Etienne Chauchot commented on FLINK-30314: -- [~dyaraev] Sorry for resuming this

[jira] [Assigned] (FLINK-33038) remove getMinRetentionTime in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-33038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-33038: --- Assignee: xiaogang zhou > remove getMinRetentionTime in StreamExecDeduplicate > ---

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #665: [FLINK-33005] Upgrade JOSDK to 4.4.2 and Fabric8 to 6.8.1

gyfora opened a new pull request, #665: URL: https://github.com/apache/flink-kubernetes-operator/pull/665 ## What is the purpose of the change Upgrade the core fabric8 and josdk dependencies and eliminate some deprecated calls. ## Brief change log - *Update dependencie

[GitHub] [flink] X-czh commented on a diff in pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

X-czh commented on code in PR #20232: URL: https://github.com/apache/flink/pull/20232#discussion_r1315777208 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java: ## @@ -203,7 +203,8 @@ public static SubtaskExecutionAt

[GitHub] [flink] huwh commented on a diff in pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

huwh commented on code in PR #20232: URL: https://github.com/apache/flink/pull/20232#discussion_r1315762231 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java: ## @@ -203,7 +203,8 @@ public static SubtaskExecutionAtt

[jira] [Commented] (FLINK-32872) Add option to control the default partitioner when the parallelism of upstream and downstream operator does not match

[ https://issues.apache.org/jira/browse/FLINK-32872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762051#comment-17762051 ] Weihua Hu commented on FLINK-32872: --- [~Zhanghao Chen] Thanks for bring this. We need a

[GitHub] [flink] flinkbot commented on pull request #23358: [FLINK-33032][table-planner][JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

flinkbot commented on PR #23358: URL: https://github.com/apache/flink/pull/23358#issuecomment-1706421683 ## CI report: * 789cf16c03d471953f81e54cfb26d74c087ece1e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Jiabao-Sun opened a new pull request, #23358: [FLINK-33032][table-planner][JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase)

Jiabao-Sun opened a new pull request, #23358: URL: https://github.com/apache/flink/pull/23358 ## What is the purpose of the change [FLINK-33032][table-planner][JUnit5 Migration] Module: flink-table-planner (ExpressionTestBase) ## Brief change log JUnit5 Migration

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762042#comment-17762042 ] Hong Liang Teoh commented on FLINK-33021: - merged commit  [{{8b0ae0f}}|https://g

[jira] [Resolved] (FLINK-33021) AWS nightly builds fails on architecture tests

[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33021. - Resolution: Fixed > AWS nightly builds fails on architecture tests > ---

[jira] [Assigned] (FLINK-33021) AWS nightly builds fails on architecture tests

[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33021: --- Assignee: Hong Liang Teoh > AWS nightly builds fails on architecture tests > --

[jira] (FLINK-33021) AWS nightly builds fails on architecture tests

[ https://issues.apache.org/jira/browse/FLINK-33021 ] Hong Liang Teoh deleted comment on FLINK-33021: - was (Author: hong): Triggering the nightly build now.  https://github.com/apache/flink-connector-aws/actions/runs/6067488560 > AWS nightl

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762040#comment-17762040 ] Hong Liang Teoh commented on FLINK-33021: - Latest nightly build has passed. Will

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762039#comment-17762039 ] Hong Liang Teoh commented on FLINK-28513: - merged commit  [{{2437cf5}}|https://g

[GitHub] [flink] hlteoh37 merged pull request #23352: [FLINK-28513][Backport][release-1.18] Fix Flink Table API CSV streaming sink throws

hlteoh37 merged PR #23352: URL: https://github.com/apache/flink/pull/23352 -- 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.apac

[GitHub] [flink-ml] weibozhao opened a new pull request, #254: [Flink 33036] Add transformer and estimator of Als.

weibozhao opened a new pull request, #254: URL: https://github.com/apache/flink-ml/pull/254 ## What is the purpose of the change This pull request adds transformer and estimator of Als. ## Brief change log - *Adds Transformer and Estimator implementation of Als in Java and

[GitHub] [flink] X-czh commented on a diff in pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

X-czh commented on code in PR #20232: URL: https://github.com/apache/flink/pull/20232#discussion_r1315734864 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java: ## @@ -203,7 +203,8 @@ public static SubtaskExecutionAt

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

1996fanrui commented on code in PR #20232: URL: https://github.com/apache/flink/pull/20232#discussion_r1315731682 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java: ## @@ -203,7 +203,8 @@ public static SubtaskExecut

[GitHub] [flink] X-czh commented on a diff in pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

X-czh commented on code in PR #20232: URL: https://github.com/apache/flink/pull/20232#discussion_r1315725139 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskManagerLocation.java: ## @@ -275,6 +275,15 @@ public static String getHostName(InetAddress inetAdd

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

1996fanrui commented on code in PR #20232: URL: https://github.com/apache/flink/pull/20232#discussion_r1315713611 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java: ## @@ -203,7 +203,8 @@ public static SubtaskExecut

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

1996fanrui commented on code in PR #20232: URL: https://github.com/apache/flink/pull/20232#discussion_r1315711282 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskManagerLocation.java: ## @@ -275,6 +275,15 @@ public static String getHostName(InetAddress in

[jira] [Commented] (FLINK-33038) remove getMinRetentionTime in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-33038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762032#comment-17762032 ] xiaogang zhou commented on FLINK-33038: --- [~snuyanzin] would you please help assign

[jira] [Updated] (FLINK-33038) remove getMinRetentionTime in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-33038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-33038: -- Description: I suggest to remove the getMinRetentionTime method in StreamExecDeduplicate as i

[jira] [Created] (FLINK-33038) remove getMinRetentionTime in StreamExecDeduplicate

xiaogang zhou created FLINK-33038: - Summary: remove getMinRetentionTime in StreamExecDeduplicate Key: FLINK-33038 URL: https://issues.apache.org/jira/browse/FLINK-33038 Project: Flink Issue T

[jira] [Assigned] (FLINK-33005) Upgrade JOSDK to 4.4.2 and Fabric8 to 6.8.1

[ https://issues.apache.org/jira/browse/FLINK-33005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-33005: -- Assignee: Gyula Fora > Upgrade JOSDK to 4.4.2 and Fabric8 to 6.8.1 >

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #664: [FLINK-33027] Allow users to override parallelism of excluded vertices

gyfora commented on code in PR #664: URL: https://github.com/apache/flink-kubernetes-operator/pull/664#discussion_r1315671205 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/JobAutoScaler.java: ## @@ -30,6 +28,6 @@ public in

[GitHub] [flink] huwh commented on a diff in pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

huwh commented on code in PR #20232: URL: https://github.com/apache/flink/pull/20232#discussion_r1315660721 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/SubtaskCurrentAttemptDetailsHandlerTest.java: ## @@ -186,7 +186,9 @@ public void testHandleRequest

[GitHub] [flink] ldadima commented on pull request #23355: [FLINK-33034][runtime] Correct ValueState creating for StateBackendTestBase#testGetKeysAndNamespaces

ldadima commented on PR #23355: URL: https://github.com/apache/flink/pull/23355#issuecomment-1706295010 > ## CI report: > * Unknown: [CANCELED](TBD) > * [bcf37a5](https://github.com/apache/flink/commit/bcf37a5af73e2c71fbafbccbaae84b7ec686f066) UNKNOWN > > Bot commands

  1   2   >