Re: [PR] Update example with correct values [flink]

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

[PR] Update example with correct values [flink]

2024-04-05 Thread via GitHub
leestradac opened a new pull request, #24626: URL: https://github.com/apache/flink/pull/24626 Correct values: 'key.avro-confluent.subject' = 'user_events_example3-key', 'value.avro-confluent.subject' = 'user_events_example3-value' Old example was not generating the schema in

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

2024-04-05 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-34657. -- Resolution: Fixed [{{d3d8ae4}}|https://github.com/apache/flink/commit/d3d8ae428397794683e5ba05

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

2024-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-34988. -- Resolution: Fixed > Class loading issues in JDK17 and JDK21 > ---

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

2024-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-34988: -- Assignee: Weijie Guo > Class loading issues in JDK17 and JDK21 >

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

2024-04-05 Thread via GitHub
mbalassi commented on PR #24619: URL: https://github.com/apache/flink/pull/24619#issuecomment-2040138761 Merging this given no additional comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

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

2024-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34988: --- Fix Version/s: 1.20.0 > Class loading issues in JDK17 and JDK21 > --

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

2024-04-05 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834376#comment-17834376 ] Weijie Guo commented on FLINK-34988: I have just merged the fix: master(1.20) via 5

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

2024-04-05 Thread via GitHub
mbalassi merged PR #24619: URL: https://github.com/apache/flink/pull/24619 -- 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] [FLINK-34988][build] Fix the reflection issue of ExecutionEnvironmentImpl for JDK17 [flink]

2024-04-05 Thread via GitHub
reswqa merged PR #24610: URL: https://github.com/apache/flink/pull/24610 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

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

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

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

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

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

2024-04-05 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834346#comment-17834346 ] Ryan Skraba commented on FLINK-34450: - 1.20 Jdk8 https://github.com/apache/flink/ac

[jira] [Resolved] (FLINK-34025) Show data skew score on Flink Dashboard

2024-04-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-34025. - Resolution: Done > Show data skew score on Flink Dashboard > ---

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

2024-04-05 Thread via GitHub
hlteoh37 merged PR #24598: URL: https://github.com/apache/flink/pull/24598 -- 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-34025) Show data skew score on Flink Dashboard

2024-04-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834339#comment-17834339 ] Hong Liang Teoh commented on FLINK-34025: -  merged commit [{{080efb9}}|https://

[jira] [Assigned] (FLINK-34025) Show data skew score on Flink Dashboard

2024-04-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-34025: --- Assignee: Emre Kartoglu > Show data skew score on Flink Dashboard > ---

[jira] [Commented] (FLINK-34025) Show data skew score on Flink Dashboard

2024-04-05 Thread Emre Kartoglu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834316#comment-17834316 ] Emre Kartoglu commented on FLINK-34025: --- https://github.com/apache/flink/pull/2459

Re: [PR] [FLINK-34996][Connectors/Kafka] Use UserCodeCL to instantiate Deserializer [flink-connector-kafka]

2024-04-05 Thread via GitHub
hugogu commented on PR #89: URL: https://github.com/apache/flink-connector-kafka/pull/89#issuecomment-2039767446 @MartijnVisser I also fix a few style errors, please let me know if it is good now or any other change to make. Thanks for your review. -- This is an automated message from t

[jira] [Closed] (FLINK-35021) AggregateQueryOperations produces wrong asSerializableString representation

2024-04-05 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-35021. Resolution: Fixed Fixed in 77215aaf6ca7ccbff7bd3752e59068ac9956d549 > AggregateQueryOpera

Re: [PR] [FLINK-35021] AggregateQueryOperations produces wrong asSerializableString representation [flink]

2024-04-05 Thread via GitHub
dawidwys merged PR #24624: URL: https://github.com/apache/flink/pull/24624 -- 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] [hotfix] Log Job ID when task is failed externally [flink]

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

[PR] [hotfix] Log Job ID when task is failed externally [flink]

2024-04-05 Thread via GitHub
rkhachatryan opened a new pull request, #24625: URL: https://github.com/apache/flink/pull/24625 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring th

Re: [PR] [FLINK-34954][core] Kryo Input bug fix [flink]

2024-04-05 Thread via GitHub
qinghui-xu commented on PR #24586: URL: https://github.com/apache/flink/pull/24586#issuecomment-2039567737 Hello team, Could I get a review for this, 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 a

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

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

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

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

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

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

Re: [PR] [FLINK-35021] AggregateQueryOperations produces wrong asSerializableString representation [flink]

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

[jira] [Updated] (FLINK-35021) AggregateQueryOperations produces wrong asSerializableString representation

2024-04-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35021: --- Labels: pull-request-available (was: ) > AggregateQueryOperations produces wrong asSerializ

[PR] [FLINK-35021] AggregateQueryOperations produces wrong asSerializableString representation [flink]

2024-04-05 Thread via GitHub
dawidwys opened a new pull request, #24624: URL: https://github.com/apache/flink/pull/24624 ## What is the purpose of the change Fixes the bug that `AggregateQueryOperation` produces a wrong SQL if there were no explicit groupings provided ## Verifying this change

[jira] [Created] (FLINK-35021) AggregateQueryOperations produces wrong asSerializableString representation

2024-04-05 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-35021: Summary: AggregateQueryOperations produces wrong asSerializableString representation Key: FLINK-35021 URL: https://issues.apache.org/jira/browse/FLINK-35021 P

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

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

Re: [PR] [FLINK-24939][table] Support `SHOW CREATE CATALOG` syntax [flink]

2024-04-05 Thread via GitHub
liyubin117 commented on code in PR #24555: URL: https://github.com/apache/flink/pull/24555#discussion_r1549263092 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowCreateCatalog.java: ## @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-24939][table] Support `SHOW CREATE CATALOG` syntax [flink]

2024-04-05 Thread via GitHub
liyubin117 commented on code in PR #24555: URL: https://github.com/apache/flink/pull/24555#discussion_r1549263092 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowCreateCatalog.java: ## @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-24939][table] Support `SHOW CREATE CATALOG` syntax [flink]

2024-04-05 Thread via GitHub
liyubin117 commented on code in PR #24555: URL: https://github.com/apache/flink/pull/24555#discussion_r1549266972 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowCreateCatalog.java: ## @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache Software

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

2024-04-05 Thread via GitHub
HuangZhenQiu commented on code in PR #24623: URL: https://github.com/apache/flink/pull/24623#discussion_r1553216879 ## flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java: ## @@ -82,6 +83,7 @@ public Reader createReader(

Re: [PR] [FLINK-24939][table] Support `SHOW CREATE CATALOG` syntax [flink]

2024-04-05 Thread via GitHub
liyubin117 commented on PR #24555: URL: https://github.com/apache/flink/pull/24555#issuecomment-2039271867 @LadyForest Thanks for your suggestions, I have updated as you said and CI passed, PTAL :) -- This is an automated message from the Apache Git Service. To respond to the message, ple

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

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

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

2024-04-05 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834196#comment-17834196 ] Robert Metzger commented on FLINK-34450: I'm checking how easy this is to reprod

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

2024-04-05 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: Critical (was: Blocker) > TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusF

Re: [PR] [FLINK-34551][core] Refactor retry logic in `FutureUtils` [flink]

2024-04-05 Thread via GitHub
XComp commented on PR #24578: URL: https://github.com/apache/flink/pull/24578#issuecomment-2039189465 Closing the PR. See FLINK-34551 for more context -- 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

Re: [PR] [FLINK-34551][core] Refactor retry logic in `FutureUtils` [flink]

2024-04-05 Thread via GitHub
XComp closed pull request #24578: [FLINK-34551][core] Refactor retry logic in `FutureUtils` URL: https://github.com/apache/flink/pull/24578 -- 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

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

2024-04-05 Thread via GitHub
mbalassi commented on code in PR #24623: URL: https://github.com/apache/flink/pull/24623#discussion_r1553038255 ## flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java: ## @@ -82,6 +83,7 @@ public Reader createReader(

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

2024-04-05 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-35015: -- Assignee: Zhenqiu Huang > Flink Parquet Reader doesn't honor parquet configuration >