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`
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
[
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
[
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
> ---
[
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
>
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
[
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
> --
[
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
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
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
[
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
[
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
[
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
[
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
> ---
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
[
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://
[
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
> ---
[
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
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
[
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
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
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`
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
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
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
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
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
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`
[
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
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
Dawid Wysakowicz created FLINK-35021:
Summary: AggregateQueryOperations produces wrong
asSerializableString representation
Key: FLINK-35021
URL: https://issues.apache.org/jira/browse/FLINK-35021
P
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
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
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
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
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(
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
[
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
[
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
[
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
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
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
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(
[
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
>
44 matches
Mail list logo