[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33555:
--
Labels: test-stability (was: github-actions test-stability)
> LocalRecoveryITCase.testRecover
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33555:
--
Parent: (was: FLINK-27075)
Issue Type: Bug (was: Sub-task)
> LocalRecoveryITCase.
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33555:
--
Priority: Critical (was: Major)
> LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithW
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33555:
--
Affects Version/s: 1.19.0
1.20.0
> LocalRecoveryITCase.testRecoverLocal
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817860#comment-17817860
]
Matthias Pohl commented on FLINK-33555:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817860#comment-17817860
]
Matthias Pohl edited comment on FLINK-33555 at 2/16/24 7:57 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817857#comment-17817857
]
Matthias Pohl commented on FLINK-22765:
---
JDK21:
https://dev.azure.com/apache-flin
[
https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817858#comment-17817858
]
Matthias Pohl commented on FLINK-29114:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34448:
--
Priority: Critical (was: Major)
> ChangelogLocalRecoveryITCase failed fatally with 127 exit c
Matthias Pohl created FLINK-34448:
-
Summary: ChangelogLocalRecoveryITCase failed fatally with 127 exit
code
Key: FLINK-34448
URL: https://issues.apache.org/jira/browse/FLINK-34448
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817856#comment-17817856
]
Matthias Pohl commented on FLINK-34202:
---
1.20 (master):
https://dev.azure.com/apa
mas-chen commented on PR #42:
URL:
https://github.com/apache/flink-connector-kafka/pull/42#issuecomment-1947817531
@sunxiaojian have you considered implementing this as a Flink format? You
could draw inspiration from pre-existing formats:
https://github.com/apache/flink/tree/master/flink-f
hanyuzheng7 commented on code in PR #23171:
URL: https://github.com/apache/flink/pull/23171#discussion_r1491954798
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed
hanyuzheng7 commented on code in PR #23171:
URL: https://github.com/apache/flink/pull/23171#discussion_r1491954798
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817845#comment-17817845
]
Sergey Nuyanzin commented on FLINK-34446:
-
[~jingge] , [~jeyhunkarimov]
I appli
flinkbot commented on PR #24317:
URL: https://github.com/apache/flink/pull/24317#issuecomment-1947771463
## CI report:
* 893202ea5400dae5021f31f538a59f7f772ac044 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34446:
---
Labels: pull-request-available (was: )
> SqlValidatorException with LATERAL TABLE and JOIN
snuyanzin opened a new pull request, #24317:
URL: https://github.com/apache/flink/pull/24317
## What is the purpose of the change
The PR applies WA to fix
[CALCITE-6266](https://issues.apache.org/jira/browse/CALCITE-6266)
It applieas similar fix as for
[CALCITE-6266](https://i
mas-chen commented on code in PR #70:
URL:
https://github.com/apache/flink-connector-kafka/pull/70#discussion_r1491960996
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/FlinkKafkaInternalProducer.java:
##
@@ -74,6 +76,10 @@ private static Propertie
hanyuzheng7 commented on code in PR #23171:
URL: https://github.com/apache/flink/pull/23171#discussion_r1491954798
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed
hanyuzheng7 commented on code in PR #23171:
URL: https://github.com/apache/flink/pull/23171#discussion_r1491941807
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed
hanyuzheng7 commented on code in PR #23171:
URL: https://github.com/apache/flink/pull/23171#discussion_r1491941807
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed
hanyuzheng7 commented on code in PR #23171:
URL: https://github.com/apache/flink/pull/23171#discussion_r1491941807
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed
hanyuzheng7 commented on code in PR #23171:
URL: https://github.com/apache/flink/pull/23171#discussion_r1491941807
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed
hanyuzheng7 commented on code in PR #23171:
URL: https://github.com/apache/flink/pull/23171#discussion_r1491941807
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491299515
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -391,6 +391,16 @@ ANY, and(logical(LogicalTy
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491937994
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -1370,4 +1371,145 @@ private Stream
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491299515
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -391,6 +391,16 @@ ANY, and(logical(LogicalTy
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491405037
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491933930
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491330263
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
flinkbot commented on PR #24316:
URL: https://github.com/apache/flink/pull/24316#issuecomment-1947357889
## CI report:
* 17c5b7b107584a3c084ace278d144917d9744ca3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hanyuzheng7 opened a new pull request, #24316:
URL: https://github.com/apache/flink/pull/24316
hashCode
## 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-
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491405037
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491405037
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817758#comment-17817758
]
Kevin Tseng commented on FLINK-33545:
-
Hi [~mason6345] , [~yang]
I have simplified
[
https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817750#comment-17817750
]
Hong Liang Teoh commented on FLINK-32964:
-
merged commit
[{{5e1d76d}}|https://
hlteoh37 merged PR #129:
URL: https://github.com/apache/flink-connector-aws/pull/129
--
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...@
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491405037
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
rkhachatryan commented on code in PR #24292:
URL: https://github.com/apache/flink/pull/24292#discussion_r1491395312
##
flink-core/src/main/java/org/apache/flink/util/JobIdLoggingExecutorService.java:
##
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
z3d1k opened a new pull request, #130:
URL: https://github.com/apache/flink-connector-aws/pull/130
## Purpose of the change
Add instructions for Intellij on how to interpret Jira ticket ids and FLIPs.
This change allows to easily navigate from git log view in IDE to these
locations
rkhachatryan commented on code in PR #24292:
URL: https://github.com/apache/flink/pull/24292#discussion_r1491387438
##
flink-core/src/main/java/org/apache/flink/util/JobIdLoggingExecutor.java:
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
rkhachatryan commented on code in PR #24292:
URL: https://github.com/apache/flink/pull/24292#discussion_r1491387018
##
flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java:
##
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491354424
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491337569
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491337569
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491337569
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491337569
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491337569
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
XComp commented on PR #24314:
URL: https://github.com/apache/flink/pull/24314#issuecomment-1946576926
@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.
To
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491330263
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,161 @@
+/*
+ * Licensed to
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491299515
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -391,6 +391,16 @@ ANY, and(logical(LogicalTy
hanyuzheng7 commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491299515
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -391,6 +391,16 @@ ANY, and(logical(LogicalTy
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817728#comment-17817728
]
Jing Ge commented on FLINK-31362:
-
Thanks for the clarification.
> Upgrade to Calcite v
flinkbot commented on PR #24315:
URL: https://github.com/apache/flink/pull/24315#issuecomment-1946420906
## CI report:
* 83368ca5bda5692ebc43f9024fa13d0f803369be UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp opened a new pull request, #24315:
URL: https://github.com/apache/flink/pull/24315
## What is the purpose of the change
The test failed mostly with JDK21. It can happen that the OutOfMemoryError
appeared during the compilation phase. In that case, it would print a different
err
hanyuzheng7 commented on code in PR #22951:
URL: https://github.com/apache/flink/pull/22951#discussion_r1491240847
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java:
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to th
hanyuzheng7 commented on code in PR #22951:
URL: https://github.com/apache/flink/pull/22951#discussion_r1491240847
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java:
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to th
nathantalewis commented on PR #24035:
URL: https://github.com/apache/flink/pull/24035#issuecomment-1946388197
I just tested this on one of my clients' datasets which uses a lot of
`oneof` fields and it fixed the same problem that wckdman mentioned.
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817717#comment-17817717
]
Sergey Nuyanzin edited comment on FLINK-31362 at 2/15/24 3:51 PM:
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817711#comment-17817711
]
Jing Ge edited comment on FLINK-31362 at 2/15/24 3:47 PM:
--
Hi f
hanyuzheng7 commented on code in PR #22951:
URL: https://github.com/apache/flink/pull/22951#discussion_r1491222383
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -231,6 +231,28 @@ ANY, and(logical(LogicalTy
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817717#comment-17817717
]
Sergey Nuyanzin edited comment on FLINK-31362 at 2/15/24 3:44 PM:
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817717#comment-17817717
]
Sergey Nuyanzin commented on FLINK-31362:
-
Calcite upgrade itself is pretty comp
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817711#comment-17817711
]
Jing Ge edited comment on FLINK-31362 at 2/15/24 3:35 PM:
--
Hi f
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817711#comment-17817711
]
Jing Ge commented on FLINK-31362:
-
Hi folks, would you like share the reason why we shou
[
https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated FLINK-34446:
---
Description:
found one regression issue. Query working Flink 1.17.2, but failing with Flink
mxm commented on code in PR #765:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/765#discussion_r1491077036
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/config/AutoscalerStandaloneOptions.java:
##
@@ -109,4 +110,51 @@ privat
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817683#comment-17817683
]
Matthias Pohl edited comment on FLINK-22765 at 2/15/24 2:06 PM:
--
dawidwys commented on code in PR #23171:
URL: https://github.com/apache/flink/pull/23171#discussion_r1491059814
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayIntersectFunction.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed to
dawidwys commented on code in PR #23173:
URL: https://github.com/apache/flink/pull/23173#discussion_r1491037396
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -391,6 +391,16 @@ ANY, and(logical(LogicalTypeR
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817683#comment-17817683
]
Matthias Pohl commented on FLINK-22765:
---
The following error is reported:
{code}
T
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817676#comment-17817676
]
Matthias Pohl edited comment on FLINK-22765 at 2/15/24 1:50 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817676#comment-17817676
]
Matthias Pohl edited comment on FLINK-22765 at 2/15/24 1:49 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817676#comment-17817676
]
Matthias Pohl edited comment on FLINK-22765 at 2/15/24 1:49 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817676#comment-17817676
]
Matthias Pohl commented on FLINK-22765:
---
The issue seems to be related with the JD
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817676#comment-17817676
]
Matthias Pohl edited comment on FLINK-22765 at 2/15/24 1:34 PM:
--
rkhachatryan commented on code in PR #24292:
URL: https://github.com/apache/flink/pull/24292#discussion_r1491016717
##
flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcGateway.java:
##
@@ -34,4 +34,16 @@ public interface RpcGateway {
* @return Fully q
rkhachatryan commented on code in PR #24292:
URL: https://github.com/apache/flink/pull/24292#discussion_r1491013640
##
docs/content.zh/docs/deployment/advanced/logging.md:
##
@@ -40,6 +40,21 @@ Flink 中的日志记录是使用 [SLF4J](http://www.slf4j.org/) 日志接口实
+### Structured logging
+
rmoff commented on PR #24310:
URL: https://github.com/apache/flink/pull/24310#issuecomment-1946084609
squashed, thanks @JingGe !
--
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
[
https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817665#comment-17817665
]
Sergey Nuyanzin edited comment on FLINK-34446 at 2/15/24 12:50 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817665#comment-17817665
]
Sergey Nuyanzin commented on FLINK-34446:
-
most probably comes with 1.31.0 as pa
[
https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Emre Kartoglu updated FLINK-34025:
--
Affects Version/s: 1.20.0
(was: 1.19.0)
> Show data skew score on F
dawidwys commented on code in PR #22951:
URL: https://github.com/apache/flink/pull/22951#discussion_r1490935727
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -231,6 +232,21 @@ ANY, and(logical(LogicalTypeR
dawidwys commented on code in PR #22951:
URL: https://github.com/apache/flink/pull/22951#discussion_r1490931709
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArraySortFunction.java:
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Emre Kartoglu reopened FLINK-34025:
---
reopening based on the votes I've received for
[https://cwiki.apache.org/confluence/display/FLI
1996fanrui commented on PR #24288:
URL: https://github.com/apache/flink/pull/24288#issuecomment-1945972912
@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
1996fanrui commented on code in PR #765:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/765#discussion_r1490909393
##
flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/config/AutoscalerStandaloneOptions.java:
##
@@ -109,4 +110,51 @@
mxm merged PR #762:
URL: https://github.com/apache/flink-kubernetes-operator/pull/762
--
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...
[
https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817644#comment-17817644
]
Matthias Pohl commented on FLINK-22765:
---
https://dev.azure.com/apache-flink/apache
XComp commented on PR #24309:
URL: https://github.com/apache/flink/pull/24309#issuecomment-1945921834
I looked into the missing synchronization for the
`FineGrainedSlotManager#started` field: AFAIU, we're relying on all the methods
which touch `#started` to run in the same thread (which is
flinkbot commented on PR #24314:
URL: https://github.com/apache/flink/pull/24314#issuecomment-1945913323
## CI report:
* 40f4f24be9f6a9d45bf0dd1078b1ce75b876f36d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1996fanrui commented on code in PR #762:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/762#discussion_r1490866557
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/utils/MemoryTuningUtils.java:
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-34447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-34447:
-
Assignee: Matthias Pohl
> ActiveResourceManagerTest#testWorkerRegistrationTimeoutNotCou
[
https://issues.apache.org/jira/browse/FLINK-34447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34447:
---
Labels: pull-request-available (was: )
> ActiveResourceManagerTest#testWorkerRegistrationTi
XComp opened a new pull request, #24314:
URL: https://github.com/apache/flink/pull/24314
## What is the purpose of the change
We're still seeing test instabilities here if the machine is slow because
the release could be trigger resulting in the completion of the
`releaseResourceFutu
[
https://issues.apache.org/jira/browse/FLINK-34038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-34038.
--
Fix Version/s: 1.20.0
Resolution: Fixed
> IncrementalGroupAggregateRestoreTest.
[
https://issues.apache.org/jira/browse/FLINK-34248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17817640#comment-17817640
]
Dawid Wysakowicz commented on FLINK-34248:
--
Implemented in
e76ccdc1fd8b15a5aac
[
https://issues.apache.org/jira/browse/FLINK-34248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-34248.
Fix Version/s: 1.20.0
Resolution: Implemented
> Implement restore tests for Changel
dawidwys merged PR #24203:
URL: https://github.com/apache/flink/pull/24203
--
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
1 - 100 of 126 matches
Mail list logo
