adiaixin commented on pull request #16584:
URL: https://github.com/apache/flink/pull/16584#issuecomment-1034793957
@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
adiaixin removed a comment on pull request #16584:
URL: https://github.com/apache/flink/pull/16584#issuecomment-1034791954
@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
flinkbot edited a comment on pull request #18649:
URL: https://github.com/apache/flink/pull/18649#issuecomment-1031570072
## CI report:
* 7abbdf54df75a8e9e0041e908ab61d785d800410 Azure:
flinkbot edited a comment on pull request #16584:
URL: https://github.com/apache/flink/pull/16584#issuecomment-885710999
## CI report:
* 3556331fec7ec8ca1139085a136035a45b2d0977 Azure:
dannycranmer commented on a change in pull request #18669:
URL: https://github.com/apache/flink/pull/18669#discussion_r803555992
##
File path:
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterStateSerializer.java
adiaixin commented on pull request #16584:
URL: https://github.com/apache/flink/pull/16584#issuecomment-1034791954
@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
zentol commented on a change in pull request #18678:
URL: https://github.com/apache/flink/pull/18678#discussion_r803558181
##
File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh
##
@@ -225,4 +225,9 @@ function get_host_machine_address {
fi
}
+function
flinkbot edited a comment on pull request #18701:
URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277
## CI report:
* 1dd05d2b0f15ae91f251248c9eb6a48cd87fe0ba Azure:
zentol commented on a change in pull request #18678:
URL: https://github.com/apache/flink/pull/18678#discussion_r803558181
##
File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh
##
@@ -225,4 +225,9 @@ function get_host_machine_address {
fi
}
+function
pnowojski commented on a change in pull request #18651:
URL: https://github.com/apache/flink/pull/18651#discussion_r803467988
##
File path:
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java
##
@@ -267,18
CrynetLogistics commented on a change in pull request #18553:
URL: https://github.com/apache/flink/pull/18553#discussion_r803545078
##
File path:
flinkbot edited a comment on pull request #18701:
URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277
## CI report:
* 1dd05d2b0f15ae91f251248c9eb6a48cd87fe0ba Azure:
flinkbot edited a comment on pull request #18673:
URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561
## CI report:
* 33d97563bf625b702679c32c67a739f880228a42 Azure:
flinkbot edited a comment on pull request #18656:
URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760
## CI report:
* 9720c3e92ef12305e72d1b0de4f70d8be5a3d9af Azure:
flinkbot edited a comment on pull request #18624:
URL: https://github.com/apache/flink/pull/18624#issuecomment-1029176049
## CI report:
* 861fa3fa04ca63de1ce8cfc9b057699ebc0e2002 Azure:
flinkbot commented on pull request #18701:
URL: https://github.com/apache/flink/pull/18701#issuecomment-1034767545
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-12189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-12189:
---
Labels: auto-deprioritized-critical auto-deprioritized-major
auto-unassigned
slinkydeveloper commented on pull request #18657:
URL: https://github.com/apache/flink/pull/18657#issuecomment-1034766454
Thanks for the explanation!
As I said before, a comment which explains this would be nice to have there,
for the rest it looks good and it sounds like a nice
flinkbot commented on pull request #18701:
URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277
## CI report:
* 1dd05d2b0f15ae91f251248c9eb6a48cd87fe0ba UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #18693:
URL: https://github.com/apache/flink/pull/18693#issuecomment-1034140883
## CI report:
* 71fd9a5a7917a6bc423a45ca3deec8b84007c9e3 Azure:
flinkbot edited a comment on pull request #18686:
URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484
## CI report:
* fbdf72f62409be6aa9d7ff9663029a90bc38585b Azure:
flinkbot edited a comment on pull request #18656:
URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760
## CI report:
* 9720c3e92ef12305e72d1b0de4f70d8be5a3d9af Azure:
flinkbot edited a comment on pull request #18624:
URL: https://github.com/apache/flink/pull/18624#issuecomment-1029176049
## CI report:
* 861fa3fa04ca63de1ce8cfc9b057699ebc0e2002 Azure:
[
https://issues.apache.org/jira/browse/FLINK-26071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26071:
---
Labels: pull-request-available (was: )
> TableEnvironment#compilePlan should fail
>
slinkydeveloper opened a new pull request #18701:
URL: https://github.com/apache/flink/pull/18701
## What is the purpose of the change
This PR is a followup of FLINK-25841 and has a couple of quality of life
improvements for the new API:
* Now `Planner#compilePlan` fails if
matriv commented on pull request #18624:
URL: https://github.com/apache/flink/pull/18624#issuecomment-1034760863
I've kept only basic `consumedOptions` for the python nodes.
@twalthr Can you check again?
--
This is an automated message from the Apache Git Service.
To respond to the
flinkbot edited a comment on pull request #18678:
URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685
## CI report:
* 146d81ca276cd3189fbf26b073d513b588b571fa Azure:
[
https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25813:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-24626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24626:
---
Labels: correctness stale-major (was: correctness)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-20951:
---
Labels: auto-deprioritized-critical auto-deprioritized-major
auto-unassigned stale-minor
[
https://issues.apache.org/jira/browse/FLINK-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-8970:
--
Labels: auto-deprioritized-major auto-unassigned stale-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-8478:
--
Labels: auto-deprioritized-major auto-unassigned stale-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-2147:
--
Labels: approximate auto-deprioritized-major auto-deprioritized-minor
statistics (was:
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-2055:
--
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
[
https://issues.apache.org/jira/browse/FLINK-2151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-2151:
--
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-2023:
--
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-2220:
--
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-2186:
--
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
[
https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-2313:
--
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-2350:
--
Labels: auto-deprioritized-major auto-deprioritized-minor
pull-request-available (was:
[
https://issues.apache.org/jira/browse/FLINK-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-2284:
--
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-2396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-2396:
--
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
(was:
flinkbot edited a comment on pull request #18641:
URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534
## CI report:
* 995943ebd415f3b43e55d8fe2c491e3e16cdc82c Azure:
RyanSkraba commented on a change in pull request #18697:
URL: https://github.com/apache/flink/pull/18697#discussion_r803517717
##
File path: mvnw
##
@@ -0,0 +1,310 @@
+#!/bin/sh
+#
+# Licensed to the
rkhachatryan commented on a change in pull request #18391:
URL: https://github.com/apache/flink/pull/18391#discussion_r803516082
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java
##
@@ -322,19 +335,20 @@
dannycranmer commented on a change in pull request #18669:
URL: https://github.com/apache/flink/pull/18669#discussion_r803521963
##
File path:
zentol commented on a change in pull request #18692:
URL: https://github.com/apache/flink/pull/18692#discussion_r803521572
##
File path:
flink-filesystems/flink-s3-fs-presto/src/test/java/org/apache/flink/fs/s3presto/MinioTestContainer.java
##
@@ -0,0 +1,146 @@
+/*
+ *
flinkbot edited a comment on pull request #18651:
URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806
## CI report:
* 83d261d7dfaa98ed991d32f2600ce9d9acc181e2 Azure:
flinkbot edited a comment on pull request #18656:
URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760
## CI report:
* 9720c3e92ef12305e72d1b0de4f70d8be5a3d9af Azure:
flinkbot edited a comment on pull request #18605:
URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418
## CI report:
* 56d378844fb46ed0957fb6a96f800a949eb31f11 Azure:
dannycranmer commented on a change in pull request #18651:
URL: https://github.com/apache/flink/pull/18651#discussion_r803519894
##
File path:
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java
##
@@ -267,18
flinkbot edited a comment on pull request #18669:
URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800
## CI report:
* 17b33c5cff12c7a0523e4644a7fec0be0bf608f3 Azure:
tillrohrmann commented on pull request #18697:
URL: https://github.com/apache/flink/pull/18697#issuecomment-1034741301
Thanks for opening this PR @GOODBOY008. Could you add a short description of
what the script does? Is it copied from somewhere or did you develop it from
scratch? If yes,
zentol commented on a change in pull request #18692:
URL: https://github.com/apache/flink/pull/18692#discussion_r803513590
##
File path: flink-filesystems/flink-s3-fs-presto/pom.xml
##
@@ -46,6 +46,36 @@ under the License.
provided
+
zentol commented on a change in pull request #18692:
URL: https://github.com/apache/flink/pull/18692#discussion_r803513214
##
File path: flink-filesystems/flink-s3-fs-presto/pom.xml
##
@@ -46,6 +46,36 @@ under the License.
provided
+
zentol commented on a change in pull request #18692:
URL: https://github.com/apache/flink/pull/18692#discussion_r803512948
##
File path: flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java
##
@@ -588,8 +588,10 @@ public static URI getDefaultFsUri() {
*
flinkbot edited a comment on pull request #18669:
URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800
## CI report:
* 17b33c5cff12c7a0523e4644a7fec0be0bf608f3 Azure:
zentol commented on a change in pull request #18692:
URL: https://github.com/apache/flink/pull/18692#discussion_r803512647
##
File path: flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java
##
@@ -684,7 +686,9 @@ public boolean exists(final Path f) throws
flinkbot edited a comment on pull request #18649:
URL: https://github.com/apache/flink/pull/18649#issuecomment-1031570072
## CI report:
* 7abbdf54df75a8e9e0041e908ab61d785d800410 Azure:
[
https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490071#comment-17490071
]
Roman Khachatryan commented on FLINK-25872:
---
The issue also affects non-incremental
[
https://issues.apache.org/jira/browse/FLINK-25975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-25975.
-
Resolution: Fixed
Fixed via 222b72f2de43bb60b2f4741fde023493967d20f7
> add doc for how to use
tillrohrmann closed pull request #18660:
URL: https://github.com/apache/flink/pull/18660
--
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:
[
https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-25872:
--
Environment: (was: The issue also affects non-incremental checkpoints,
updating
[
https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-25872:
--
Description: If we restore from checkpoint with changelog state-backend
enabled in
flinkbot edited a comment on pull request #18699:
URL: https://github.com/apache/flink/pull/18699#issuecomment-1034581144
## CI report:
* 4a9ad6db0e1a01e9c33529b47053643721622eb7 Azure:
Francesco Guardiani created FLINK-26071:
---
Summary: TableEnvironment#compilePlan should fail
Key: FLINK-26071
URL: https://issues.apache.org/jira/browse/FLINK-26071
Project: Flink
Issue
flinkbot edited a comment on pull request #18691:
URL: https://github.com/apache/flink/pull/18691#issuecomment-1034110616
## CI report:
* Unknown: [CANCELED](TBD)
* 84f974662b25cb8ecd1f2c644fa50a9b4625cd2d Azure:
flinkbot edited a comment on pull request #18673:
URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561
## CI report:
* 33d97563bf625b702679c32c67a739f880228a42 Azure:
flinkbot edited a comment on pull request #16584:
URL: https://github.com/apache/flink/pull/16584#issuecomment-885710999
## CI report:
* beeecc75734e1ffe1033d4ffbda7ee43e7d57e5f Azure:
autophagy commented on a change in pull request #18678:
URL: https://github.com/apache/flink/pull/18678#discussion_r803490313
##
File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh
##
@@ -225,4 +225,9 @@ function get_host_machine_address {
fi
}
adiaixin commented on pull request #16584:
URL: https://github.com/apache/flink/pull/16584#issuecomment-1034712719
@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
flinkbot edited a comment on pull request #18691:
URL: https://github.com/apache/flink/pull/18691#issuecomment-1034110616
## CI report:
* Unknown: [CANCELED](TBD)
* 84f974662b25cb8ecd1f2c644fa50a9b4625cd2d UNKNOWN
Bot commands
The @flinkbot bot supports the
flinkbot edited a comment on pull request #18673:
URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561
## CI report:
* 33d97563bf625b702679c32c67a739f880228a42 Azure:
flinkbot edited a comment on pull request #18670:
URL: https://github.com/apache/flink/pull/18670#issuecomment-1033075650
## CI report:
* 360c74aff2caa70284a90375a17519dc4843d4b2 Azure:
wanglijie95 commented on pull request #18673:
URL: https://github.com/apache/flink/pull/18673#issuecomment-1034709902
@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
flinkbot edited a comment on pull request #16584:
URL: https://github.com/apache/flink/pull/16584#issuecomment-885710999
## CI report:
* beeecc75734e1ffe1033d4ffbda7ee43e7d57e5f Azure:
CrynetLogistics commented on pull request #18691:
URL: https://github.com/apache/flink/pull/18691#issuecomment-1034708422
--
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.
XComp commented on a change in pull request #18692:
URL: https://github.com/apache/flink/pull/18692#discussion_r803484034
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/AbstractHaJobRunITCase.java
##
@@ -0,0 +1,133 @@
+/*
+ * Licensed to
XComp commented on a change in pull request #18692:
URL: https://github.com/apache/flink/pull/18692#discussion_r803481934
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/AbstractHaJobRunITCase.java
##
@@ -0,0 +1,133 @@
+/*
+ * Licensed to
flinkbot edited a comment on pull request #18672:
URL: https://github.com/apache/flink/pull/18672#issuecomment-1033272608
## CI report:
* e88e25f069efe98417e027028d3fdf202379dd92 Azure:
flinkbot edited a comment on pull request #18670:
URL: https://github.com/apache/flink/pull/18670#issuecomment-1033075650
## CI report:
* 360c74aff2caa70284a90375a17519dc4843d4b2 Azure:
pltbkd commented on a change in pull request #18680:
URL: https://github.com/apache/flink/pull/18680#discussion_r803478421
##
File path:
flink-connectors/flink-file-sink-common/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketWriter.java
##
@@
[
https://issues.apache.org/jira/browse/FLINK-25742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo closed FLINK-25742.
--
Resolution: Done
> Remove the redundant serialization of RPC invocation at Flink side.
>
[
https://issues.apache.org/jira/browse/FLINK-25742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490061#comment-17490061
]
Yangze Guo commented on FLINK-25742:
master: 155657e60607913b679827123cc3a0c0281d5c76
> Remove the
zentol commented on a change in pull request #18670:
URL: https://github.com/apache/flink/pull/18670#discussion_r803475693
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
##
@@ -54,6 +54,7 @@
* (LAST), or be positioned
[
https://issues.apache.org/jira/browse/FLINK-26067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490060#comment-17490060
]
David Morávek commented on FLINK-26067:
---
could be related to the Zookeeper upgrade. I won't have a
KarmaGYZ closed pull request #18434:
URL: https://github.com/apache/flink/pull/18434
--
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:
flinkbot edited a comment on pull request #18698:
URL: https://github.com/apache/flink/pull/18698#issuecomment-1034521527
## CI report:
* 3e380541d698a93d71dbfc0f88723b22c50bccf5 Azure:
flinkbot edited a comment on pull request #18672:
URL: https://github.com/apache/flink/pull/18672#issuecomment-1033272608
## CI report:
* e88e25f069efe98417e027028d3fdf202379dd92 Azure:
tsreaper commented on pull request #18657:
URL: https://github.com/apache/flink/pull/18657#issuecomment-1034694706
Hi @slinkydeveloper .
Your observation is correct. Avro is a format that stores the schema in the
file itself. When calling `DataFileReader.openReader` it will call
[
https://issues.apache.org/jira/browse/FLINK-26067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490058#comment-17490058
]
Yun Gao commented on FLINK-26067:
-
Hi [~dmvk]~ could you have a look at this issue and
wanglijie95 commented on pull request #18672:
URL: https://github.com/apache/flink/pull/18672#issuecomment-1034692239
@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
zentol commented on a change in pull request #18678:
URL: https://github.com/apache/flink/pull/18678#discussion_r803470735
##
File path:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
##
@@ -273,6 +274,8 @@ public void setupYarnClient() {
}
zentol commented on a change in pull request #18678:
URL: https://github.com/apache/flink/pull/18678#discussion_r803468860
##
File path:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
##
@@ -273,6 +274,8 @@ public void setupYarnClient() {
}
zentol commented on a change in pull request #18678:
URL: https://github.com/apache/flink/pull/18678#discussion_r803465610
##
File path:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
##
@@ -273,6 +274,8 @@ public void setupYarnClient() {
}
flinkbot edited a comment on pull request #18698:
URL: https://github.com/apache/flink/pull/18698#issuecomment-1034521527
## CI report:
* 3e380541d698a93d71dbfc0f88723b22c50bccf5 Azure:
pnowojski commented on a change in pull request #18651:
URL: https://github.com/apache/flink/pull/18651#discussion_r803467988
##
File path:
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java
##
@@ -267,18
zentol commented on a change in pull request #18678:
URL: https://github.com/apache/flink/pull/18678#discussion_r803467068
##
File path:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
##
@@ -273,6 +274,8 @@ public void setupYarnClient() {
}
flinkbot edited a comment on pull request #18673:
URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561
## CI report:
* 33d97563bf625b702679c32c67a739f880228a42 Azure:
zentol commented on a change in pull request #18678:
URL: https://github.com/apache/flink/pull/18678#discussion_r803467068
##
File path:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
##
@@ -273,6 +274,8 @@ public void setupYarnClient() {
}
901 - 1000 of 1089 matches
Mail list logo