[jira] [Updated] (FLINK-35006) Use try with-resource for StandaloneAutoscalerExecutor

2024-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35006: --- Labels: pull-request-available (was: ) > Use try with-resource for StandaloneAutoscalerExec

Re: [PR] [FLINK-35006] Use try with-resource for StandaloneAutoscalerExecutor [flink-kubernetes-operator]

2024-04-04 Thread via GitHub
plugatarev commented on PR #811: URL: https://github.com/apache/flink-kubernetes-operator/pull/811#issuecomment-2038585218 Hi @1996fanrui , please help take a look in your free time, thanks~ -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [FLINK-35015][formats] allow passing hadoop config into parquet reader [flink]

2024-04-04 Thread via GitHub
flinkbot commented on PR #24623: URL: https://github.com/apache/flink/pull/24623#issuecomment-2038554781 ## CI report: * 77838762519adab2d2f971c19331c9f3ea7fca2f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

2024-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35015: --- Labels: pull-request-available (was: ) > Flink Parquet Reader doesn't honor parquet configu

[PR] [FLINK-35015][formats] allow passing hadoop config into parquet reader [flink]

2024-04-04 Thread via GitHub
HuangZhenQiu opened a new pull request, #24623: URL: https://github.com/apache/flink/pull/24623 ## What is the purpose of the change Allow passing hadoop config into parquet reader ## Brief change log - Change AvroParquetRecordFormat to take hadoop config in AvroParquetRea

[jira] [Created] (FLINK-35020) Model Catalog implementation in Hive etc

2024-04-04 Thread Hao Li (Jira)
Hao Li created FLINK-35020: -- Summary: Model Catalog implementation in Hive etc Key: FLINK-35020 URL: https://issues.apache.org/jira/browse/FLINK-35020 Project: Flink Issue Type: Sub-task

Re: [PR] [FLINK-34025][runtime / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
z3d1k commented on code in PR #24598: URL: https://github.com/apache/flink/pull/24598#discussion_r1552278136 ## flink-runtime-web/web-dashboard/src/app/pages/job/dataskew/data-skew.component.html: ## @@ -0,0 +1,72 @@ + + + + +Your Flink job has data skew when a subset of s

[jira] [Created] (FLINK-35019) Support show create model syntax

2024-04-04 Thread Hao Li (Jira)
Hao Li created FLINK-35019: -- Summary: Support show create model syntax Key: FLINK-35019 URL: https://issues.apache.org/jira/browse/FLINK-35019 Project: Flink Issue Type: Sub-task Reporte

[jira] [Updated] (FLINK-34450) TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed

2024-04-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-34450: --- Fix Version/s: 1.20.0 > TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding fai

[jira] [Commented] (FLINK-34450) TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed

2024-04-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834061#comment-17834061 ] Robert Metzger commented on FLINK-34450: Builds on master are failing with this

[jira] [Updated] (FLINK-34450) TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed

2024-04-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-34450: --- Priority: Blocker (was: Major) > TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForw

Re: [PR] [backport][hotfix][table] Fix typo in maven shade configuration [flink]

2024-04-04 Thread via GitHub
rmetzger merged PR #24620: URL: https://github.com/apache/flink/pull/24620 -- 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

Re: [PR] [backport][hotfix][table] Fix typo in maven shade configuration [flink]

2024-04-04 Thread via GitHub
rmetzger merged PR #24621: URL: https://github.com/apache/flink/pull/24621 -- 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

[jira] [Commented] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

2024-04-04 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834045#comment-17834045 ] Zhenqiu Huang commented on FLINK-35015: --- After taking deeper look on the code, Avr

[jira] [Updated] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

2024-04-04 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-35015: -- Priority: Minor (was: Critical) > Flink Parquet Reader doesn't honor parquet configuration >

[jira] [Created] (FLINK-35018) ML_EVALUATE function

2024-04-04 Thread Hao Li (Jira)
Hao Li created FLINK-35018: -- Summary: ML_EVALUATE function Key: FLINK-35018 URL: https://issues.apache.org/jira/browse/FLINK-35018 Project: Flink Issue Type: Sub-task Reporter: Hao Li

[jira] [Created] (FLINK-35017) ML_PREDICT function

2024-04-04 Thread Hao Li (Jira)
Hao Li created FLINK-35017: -- Summary: ML_PREDICT function Key: FLINK-35017 URL: https://issues.apache.org/jira/browse/FLINK-35017 Project: Flink Issue Type: Sub-task Reporter: Hao Li

[jira] [Created] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

2024-04-04 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-35015: - Summary: Flink Parquet Reader doesn't honor parquet configuration Key: FLINK-35015 URL: https://issues.apache.org/jira/browse/FLINK-35015 Project: Flink Is

[jira] [Created] (FLINK-35014) SqlNode to operation conversion for models

2024-04-04 Thread Hao Li (Jira)
Hao Li created FLINK-35014: -- Summary: SqlNode to operation conversion for models Key: FLINK-35014 URL: https://issues.apache.org/jira/browse/FLINK-35014 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35013) Support temporary model

2024-04-04 Thread Hao Li (Jira)
Hao Li created FLINK-35013: -- Summary: Support temporary model Key: FLINK-35013 URL: https://issues.apache.org/jira/browse/FLINK-35013 Project: Flink Issue Type: Sub-task Reporter: Hao Li

[jira] [Created] (FLINK-35016) Catalog changes for model CRUD

2024-04-04 Thread Hao Li (Jira)
Hao Li created FLINK-35016: -- Summary: Catalog changes for model CRUD Key: FLINK-35016 URL: https://issues.apache.org/jira/browse/FLINK-35016 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Updated] (FLINK-34657) Implement Lineage Graph for streaming API use cases

2024-04-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-34657: --- Fix Version/s: 1.20.0 > Implement Lineage Graph for streaming API use cases > --

[jira] [Assigned] (FLINK-34657) Implement Lineage Graph for streaming API use cases

2024-04-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-34657: -- Assignee: Zhenqiu Huang > Implement Lineage Graph for streaming API use cases > -

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: api [flink]

2024-04-04 Thread via GitHub
Jiabao-Sun commented on code in PR #24603: URL: https://github.com/apache/flink/pull/24603#discussion_r1552030213 ## flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/AbstractGenericTypeComparatorTest.java: ## @@ -22,11 +22,12 @@ import org.apache.flink.api.c

[jira] [Updated] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 for Flink Mongodb connector

2024-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35010: --- Labels: pull-request-available (was: ) > Bump org.apache.commons:commons-compress from 1.24

Re: [PR] [FLINK-35010][connectors/mongodb] Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 for Flink Mongodb connector [flink-connector-mongodb]

2024-04-04 Thread via GitHub
GOODBOY008 commented on PR #32: URL: https://github.com/apache/flink-connector-mongodb/pull/32#issuecomment-2037677059 @Jiabao-Sun PTAL -- 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 specif

[PR] [FLINK-35010][connectors/mongodb] Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 for Flink Mongodb connector [flink-connector-mongodb]

2024-04-04 Thread via GitHub
GOODBOY008 opened a new pull request, #32: URL: https://github.com/apache/flink-connector-mongodb/pull/32 Changes: - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 for Flink Mongodb connector -- This is an automated message from the Apache Git Service. To respond t

Re: [PR] [FLINK-34969][cdc-cli]Add support for both new and old Flink config files in Flink… [flink-cdc]

2024-04-04 Thread via GitHub
skymilong commented on code in PR #3194: URL: https://github.com/apache/flink-cdc/pull/3194#discussion_r1552023129 ## flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/FlinkEnvironmentUtils.java: ## @@ -20,17 +20,24 @@ import org.apache.flink.cdc.common.configuration.C

[jira] [Commented] (FLINK-34998) Wordcount on Docker test failed on azure

2024-04-04 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834010#comment-17834010 ] Ryan Skraba commented on FLINK-34998: - * https://dev.azure.com/apache-flink/apache-

[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails

2024-04-04 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834007#comment-17834007 ] Ryan Skraba commented on FLINK-18476: - 1.19 jdk17 https://dev.azure.com/apache-flin

[jira] [Commented] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails

2024-04-04 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834006#comment-17834006 ] Ryan Skraba commented on FLINK-34513: - I just created FLINK-35012 which might be re

[jira] [Commented] (FLINK-34988) Class loading issues in JDK17 and JDK21

2024-04-04 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834009#comment-17834009 ] Ryan Skraba commented on FLINK-34988: - * 1.20 jdk17 https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2024-04-04 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834008#comment-17834008 ] Ryan Skraba commented on FLINK-28440: - 1.20 hadoop313 https://dev.azure.com/apache-

[jira] [Created] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure

2024-04-04 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35012: --- Summary: ChangelogNormalizeRestoreTest.testRestore failure Key: FLINK-35012 URL: https://issues.apache.org/jira/browse/FLINK-35012 Project: Flink Issue Type: B

Re: [PR] [FLINK-35011][tests] Change MockDeserializationSchema's visibility to public to prevent compilation failure in kafka connector [flink]

2024-04-04 Thread via GitHub
Jiabao-Sun commented on PR #24622: URL: https://github.com/apache/flink/pull/24622#issuecomment-2037623369 Hi @MartijnVisser. Sorry for the issues introduced in #24432. Please help review this PR when you have time. -- This is an automated message from the Apache Git Service. To resp

Re: [PR] [FLINK-35011][tests] Change MockDeserializationSchema's visibility to public to prevent compilation failure in kafka connector [flink]

2024-04-04 Thread via GitHub
flinkbot commented on PR #24622: URL: https://github.com/apache/flink/pull/24622#issuecomment-2037617363 ## CI report: * 14bc90df58418f9dbf6b61ee6ac689f11c4ab1e2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35011) The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector

2024-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35011: --- Labels: pull-request-available (was: ) > The change in visibility of MockDeserializationSch

[PR] [FLINK-35011][tests] Change MockDeserializationSchema's visibility to public to prevent compilation failure in kafka connector [flink]

2024-04-04 Thread via GitHub
Jiabao-Sun opened a new pull request, #24622: URL: https://github.com/apache/flink/pull/24622 ## What is the purpose of the change [FLINK-35011][tests] Change MockDeserializationSchema's visibility to public to prevent compilation failure in kafka connector ## Brief

[jira] [Updated] (FLINK-30793) PyFlink YARN per-job on Docker test fails on Azure due to permission issues

2024-04-04 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Skraba updated FLINK-30793: Attachment: log.txt > PyFlink YARN per-job on Docker test fails on Azure due to permission issues

[jira] [Commented] (FLINK-30793) PyFlink YARN per-job on Docker test fails on Azure due to permission issues

2024-04-04 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833998#comment-17833998 ] Ryan Skraba commented on FLINK-30793: - 1.20 https://dev.azure.com/apache-flink/apac

Re: [PR] [FLINK-33211][table] support flink table lineage [flink]

2024-04-04 Thread via GitHub
HuangZhenQiu commented on PR #24618: URL: https://github.com/apache/flink/pull/24618#issuecomment-2037597505 @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

[jira] [Created] (FLINK-35011) The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector

2024-04-04 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-35011: -- Summary: The change in visibility of MockDeserializationSchema cause compilation failure in kafka connector Key: FLINK-35011 URL: https://issues.apache.org/jira/browse/FLINK-35011

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-04-04 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833989#comment-17833989 ] Jiabao Sun commented on FLINK-25544: Thanks [~martijnvisser] for reporting this prob

Re: [PR] [FLINK-34988][build] Fix the reflection issue of ExecutionEnvironmentImpl for JDK17 [flink]

2024-04-04 Thread via GitHub
reswqa commented on PR #24610: URL: https://github.com/apache/flink/pull/24610#issuecomment-2037443704 @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

Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]

2024-04-04 Thread via GitHub
klam-shop commented on code in PR #24482: URL: https://github.com/apache/flink/pull/24482#discussion_r1551822003 ## flink-formats/flink-protobuf-confluent-registry/src/test/java/org/apache/flink/formats/protobuf/registry/confluent/utils/FlinkToProtoSchemaConverterTest.java: ## @

Re: [PR] [backport][hotfix][table] Fix typo in maven shade configuration [flink]

2024-04-04 Thread via GitHub
flinkbot commented on PR #24621: URL: https://github.com/apache/flink/pull/24621#issuecomment-2037410223 ## CI report: * 7150f150b5b432ceac0020dc077bb96a79c76152 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [backport][hotfix][table] Fix typo in maven shade configuration [flink]

2024-04-04 Thread via GitHub
flinkbot commented on PR #24620: URL: https://github.com/apache/flink/pull/24620#issuecomment-2037409715 ## CI report: * 105a885fa997766d751f083a65592d1dd5b46070 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-34999) PR CI stopped operating

2024-04-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-34999: -- Assignee: Lorenzo Affetti > PR CI stopped operating > --- > >

[PR] [backport][hotfix][table] Fix typo in maven shade configuration [flink]

2024-04-04 Thread via GitHub
rmetzger opened a new pull request, #24621: URL: https://github.com/apache/flink/pull/24621 (no comment) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-m

[PR] [backport][hotfix][table] Fix typo in maven shade configuration [flink]

2024-04-04 Thread via GitHub
rmetzger opened a new pull request, #24620: URL: https://github.com/apache/flink/pull/24620 Backport to 1.18 -- 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,

[jira] [Updated] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 for Flink Mongodb connector

2024-04-04 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-35010: Summary: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 for Flink Mongodb

[jira] [Commented] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Mongodb connector

2024-04-04 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833935#comment-17833935 ] Zhongqiang Gong commented on FLINK-35010: - [~Leonard] I'm willing to take this i

[jira] [Created] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Mongodb connector

2024-04-04 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-35010: --- Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Mongodb connector Key: FLINK-35010 URL: https://issues.apache.org/jira/browse/FLINK-35010

Re: [PR] [FLINK-34025][runtime / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
hlteoh37 commented on code in PR #24598: URL: https://github.com/apache/flink/pull/24598#discussion_r1551711141 ## flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts: ## @@ -71,45 +77,73 @@ export class MetricsService { ); } - /** Get aggregated met

[jira] [Commented] (FLINK-32513) Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()

2024-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833931#comment-17833931 ] Martijn Visser commented on FLINK-32513: I've filed FLINK-35009 for this issue,

[jira] [Created] (FLINK-35009) Change on getTransitivePredecessors breaks connectors

2024-04-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35009: -- Summary: Change on getTransitivePredecessors breaks connectors Key: FLINK-35009 URL: https://issues.apache.org/jira/browse/FLINK-35009 Project: Flink Iss

[jira] [Commented] (FLINK-32513) Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()

2024-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833929#comment-17833929 ] Martijn Visser commented on FLINK-32513: [~jeyhunkarimov] That shouldn't be our

[jira] [Commented] (FLINK-32513) Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()

2024-04-04 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833919#comment-17833919 ] Jeyhun Karimov commented on FLINK-32513: Hi [~martijnvisser]  Thanks for reporti

[jira] [Commented] (FLINK-32513) Job in BATCH mode with a significant number of transformations freezes on method StreamGraphGenerator.existsUnboundedSource()

2024-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833912#comment-17833912 ] Martijn Visser commented on FLINK-32513: [~zhuzh] [~jeyhunkarimov] I'm seeing te

Re: [PR] [FLINK-33466][Connectors/Kafka]: Bounded Kafka source never finishes after restore from savepoint [flink-connector-kafka]

2024-04-04 Thread via GitHub
MartijnVisser commented on PR #71: URL: https://github.com/apache/flink-connector-kafka/pull/71#issuecomment-2037005293 @mas-chen Do you also want to take a look at this one? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

Re: [PR] [FLINK-30935][connector/kafka] Add kafka serializers version check when using SimpleVersionedSerializer [flink-connector-kafka]

2024-04-04 Thread via GitHub
MartijnVisser commented on PR #10: URL: https://github.com/apache/flink-connector-kafka/pull/10#issuecomment-2037001916 @mas-chen Do you want to do a 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 abo

[jira] [Closed] (FLINK-33692) FlinkKafkaProducer could miss super.close

2024-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33692. -- Resolution: Invalid See PR; we believe the current code is fine, and we haven't had a response

Re: [PR] [FLINK-33692][Connectors/Kafka] FlinkKafkaProducer could miss super.close [flink-connector-kafka]

2024-04-04 Thread via GitHub
MartijnVisser commented on PR #74: URL: https://github.com/apache/flink-connector-kafka/pull/74#issuecomment-2037000510 Closing this PR as there's no response from @ustctozm -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

Re: [PR] [FLINK-33692][Connectors/Kafka] FlinkKafkaProducer could miss super.close [flink-connector-kafka]

2024-04-04 Thread via GitHub
MartijnVisser closed pull request #74: [FLINK-33692][Connectors/Kafka] FlinkKafkaProducer could miss super.close URL: https://github.com/apache/flink-connector-kafka/pull/74 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] [FLINK-25509][connector/kafka] Add RecordEvaluator to dynamically stop source based on de-serialized records [flink-connector-kafka]

2024-04-04 Thread via GitHub
MartijnVisser commented on PR #76: URL: https://github.com/apache/flink-connector-kafka/pull/76#issuecomment-2036996931 @ruanhang1993 Do you want to update your PR, and drop support for testing against 1.17 and 1.18 as a separate commit? That should unblock this PR. -- This is an automa

[jira] [Commented] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833910#comment-17833910 ] Matthias Pohl commented on FLINK-34989: --- [~martijnvisser] pointed out that we migh

[jira] [Created] (FLINK-35008) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector

2024-04-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35008: -- Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Kafka connector Key: FLINK-35008 URL: https://issues.apache.org/jira/browse/FLINK-35008

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833909#comment-17833909 ] Martijn Visser commented on FLINK-25544: [~jiabaosun] I'm looking at this change

[PR] [FLINK-35007] Add support for Flink 1.19 and test 1.20-SNAPSHOT [flink-connector-kafka]

2024-04-04 Thread via GitHub
MartijnVisser opened a new pull request, #90: URL: https://github.com/apache/flink-connector-kafka/pull/90 This also includes dropping the weekly tests for the `v3.0` branch, since `v3.1` has been released and that's our main version going forward. -- This is an automated message from the

[jira] [Updated] (FLINK-35007) Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT

2024-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35007: --- Labels: pull-request-available (was: ) > Update Flink Kafka connector to support 1.19 and t

[jira] [Created] (FLINK-35007) Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT

2024-04-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-35007: -- Summary: Update Flink Kafka connector to support 1.19 and test 1.20-SNAPSHOT Key: FLINK-35007 URL: https://issues.apache.org/jira/browse/FLINK-35007 Project: Flin

Re: [PR] [hotfix] Fix YARN ContainerId.getId Deprecated Used. [flink]

2024-04-04 Thread via GitHub
slfan1989 commented on PR #24601: URL: https://github.com/apache/flink/pull/24601#issuecomment-2036923515 @XComp Can you help review this pr? Thank you very much! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Created] (FLINK-35006) Use try with-resource for StandaloneAutoscalerExecutor

2024-04-04 Thread Kirill Plugatarev (Jira)
Kirill Plugatarev created FLINK-35006: - Summary: Use try with-resource for StandaloneAutoscalerExecutor Key: FLINK-35006 URL: https://issues.apache.org/jira/browse/FLINK-35006 Project: Flink

[jira] [Resolved] (FLINK-34999) PR CI stopped operating

2024-04-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-34999. --- Resolution: Fixed Thanks for working on it. I verified that [PR CI|https://dev.azure.com/ap

Re: [PR] [FLINK-34025][metrics / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
iemre commented on PR #24598: URL: https://github.com/apache/flink/pull/24598#issuecomment-2036748081 > Thanks for this contribution @iemre. Added some comments. > > Have we sanity checked that the mechanism works on all job statuses? > > 1. SUSPENDED > 2. FAILED > 3. FINI

[jira] [Commented] (FLINK-34999) PR CI stopped operating

2024-04-04 Thread Lorenzo Affetti (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833887#comment-17833887 ] Lorenzo Affetti commented on FLINK-34999: - Flink CI Bot had invalid credentials.

Re: [PR] [FLINK-34657] add lineage provider API [flink]

2024-04-04 Thread via GitHub
flinkbot commented on PR #24619: URL: https://github.com/apache/flink/pull/24619#issuecomment-2036689690 ## CI report: * efe1d3858110e263a7cdd2d148642f575dfbbaa9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-25537][JUnit5 Migration] Module: flink-core with,Package: types [flink]

2024-04-04 Thread via GitHub
flinkbot commented on PR #24613: URL: https://github.com/apache/flink/pull/24613#issuecomment-2036689119 ## CI report: * 96e5f69f178e5d2eaf3d4fb185efd9852ef46e90 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34988][build] Fix the reflection issue of ExecutionEnvironmentImpl for JDK17 [flink]

2024-04-04 Thread via GitHub
flinkbot commented on PR #24610: URL: https://github.com/apache/flink/pull/24610#issuecomment-2036688686 ## CI report: * df7e0d98ea76744856bbf665567c4191f8f85b9c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34986) Basic framework of async execution for state

2024-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34986: --- Labels: pull-request-available (was: ) > Basic framework of async execution for state > ---

Re: [PR] [FLINK-33211][table] support flink table lineage [flink]

2024-04-04 Thread via GitHub
flinkbot commented on PR #24618: URL: https://github.com/apache/flink/pull/24618#issuecomment-2036689498 ## CI report: * 3a01cfd18673178c04d9dad319236c8bac6bddf7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34986][Runtime/State] Basic framework of async execution for state [flink]

2024-04-04 Thread via GitHub
flinkbot commented on PR #24614: URL: https://github.com/apache/flink/pull/24614#issuecomment-2036689302 ## CI report: * fee30d9e3d135c9a4c32e544b8165e8c93d5c1e6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-25537][JUnit5 Migration] Module: flink-core with,Package: Configuration [flink]

2024-04-04 Thread via GitHub
flinkbot commented on PR #24612: URL: https://github.com/apache/flink/pull/24612#issuecomment-2036688897 ## CI report: * 94ff81023ed7f0fe9e9a2afd45ba73bd0006c134 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34025][metrics / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
iemre commented on PR #24598: URL: https://github.com/apache/flink/pull/24598#issuecomment-2036612868 > Could we also squash the commits into 1 please! I believe we can do this when merging. You can still have many commits in the branch for reviewability. Let me know -- Thi

Re: [PR] [FLINK-34025][metrics / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
iemre commented on code in PR #24598: URL: https://github.com/apache/flink/pull/24598#discussion_r1551271953 ## flink-runtime-web/web-dashboard/src/app/pages/job/dataskew/data-skew.component.html: ## @@ -0,0 +1,72 @@ + + + + +Your Flink job has data skew when a subset of s

Re: [PR] [FLINK-34025][metrics / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
iemre commented on code in PR #24598: URL: https://github.com/apache/flink/pull/24598#discussion_r1551265934 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/metrics/DoubleAccumulatorTest.java: ## @@ -0,0 +1,54 @@ +/* + * Licensed to the Apache Software F

Re: [PR] [FLINK-34025][metrics / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
iemre commented on code in PR #24598: URL: https://github.com/apache/flink/pull/24598#discussion_r1551256100 ## flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts: ## @@ -71,45 +77,73 @@ export class MetricsService { ); } - /** Get aggregated metric

Re: [PR] [FLINK-34025][metrics / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
iemre commented on code in PR #24598: URL: https://github.com/apache/flink/pull/24598#discussion_r1551256100 ## flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts: ## @@ -71,45 +77,73 @@ export class MetricsService { ); } - /** Get aggregated metric

Re: [PR] [FLINK-34025][metrics / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
iemre commented on code in PR #24598: URL: https://github.com/apache/flink/pull/24598#discussion_r1551256100 ## flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts: ## @@ -71,45 +77,73 @@ export class MetricsService { ); } - /** Get aggregated metric

Re: [PR] [FLINK-34025][metrics / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
hlteoh37 commented on PR #24598: URL: https://github.com/apache/flink/pull/24598#issuecomment-2036476532 Could we also squash the commits into 1 please! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

Re: [PR] [FLINK-34025][metrics / web frontend] Add data skew metric endpoint and UI [flink]

2024-04-04 Thread via GitHub
hlteoh37 commented on code in PR #24598: URL: https://github.com/apache/flink/pull/24598#discussion_r1551105900 ## flink-runtime-web/web-dashboard/src/app/services/metrics.service.ts: ## @@ -71,45 +77,73 @@ export class MetricsService { ); } - /** Get aggregated met

[PR] Flk 1380 [flink-training]

2024-04-04 Thread via GitHub
LaviniaMaria opened a new pull request, #76: URL: https://github.com/apache/flink-training/pull/76 implement lab1&lab2 -- 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] [Commented] (FLINK-34988) Class loading issues in JDK17 and JDK21

2024-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833851#comment-17833851 ] Martijn Visser commented on FLINK-34988: Since we have experimental support for

[jira] [Updated] (FLINK-34988) Class loading issues in JDK17 and JDK21

2024-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-34988: --- Priority: Blocker (was: Major) > Class loading issues in JDK17 and JDK21 >

[jira] [Commented] (FLINK-34995) flink kafka connector source stuck when partition leader invalid

2024-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833850#comment-17833850 ] Martijn Visser commented on FLINK-34995: Why do you think this is a Flink bug, a

[jira] [Updated] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL

2024-04-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34992: - Component/s: Table SQL / API Table SQL / Planner Table SQL / Ru

[jira] [Updated] (FLINK-35005) SqlClientITCase Failed to build JobManager image

2024-04-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35005: -- Component/s: Test Infrastructure > SqlClientITCase Failed to build JobManager image >

[jira] [Updated] (FLINK-35004) SqlGatewayE2ECase could not start container

2024-04-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35004: -- Component/s: Test Infrastructure > SqlGatewayE2ECase could not start container > -