[
https://issues.apache.org/jira/browse/FLINK-24331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-24331:
---
Priority: Critical (was: Major)
> PartiallyFinishedSourcesITCase fails with "No downstream
jianyun8023 commented on pull request #17452:
URL: https://github.com/apache/flink/pull/17452#issuecomment-940143459
@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 speci
flinkbot edited a comment on pull request #17452:
URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217
## CI report:
* 43ffad7e2cbbb990ea6c1008a804986b844aa639 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
jianyun8023 commented on pull request #17452:
URL: https://github.com/apache/flink/pull/17452#issuecomment-940140071
@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 speci
jianyun8023 commented on pull request #17452:
URL: https://github.com/apache/flink/pull/17452#issuecomment-940139594
@syhily @nlu90 This is the pr of Pulsar's new Sink, if you have time to help
review.
--
This is an automated message from the Apache Git Service.
To respond to the message
flinkbot edited a comment on pull request #17452:
URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217
## CI report:
* 43ffad7e2cbbb990ea6c1008a804986b844aa639 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
jianyun8023 commented on pull request #17452:
URL: https://github.com/apache/flink/pull/17452#issuecomment-940137342
There is still a lot of room for improvement in this part of PulsarSink's
state saving and recovery, so please help!
--
This is an automated message from the Apache Git Se
flinkbot commented on pull request #17452:
URL: https://github.com/apache/flink/pull/17452#issuecomment-940136862
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 pro
[
https://issues.apache.org/jira/browse/FLINK-24448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427204#comment-17427204
]
Mehul Batra commented on FLINK-24448:
-
Hi, [~twalthr] can you please help me underst
flinkbot commented on pull request #17452:
URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217
## CI report:
* 43ffad7e2cbbb990ea6c1008a804986b844aa639 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-20732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20732:
---
Labels: pull-request-available (was: )
> Pulsar Sink
> ---
>
> Key:
jianyun8023 opened a new pull request #17452:
URL: https://github.com/apache/flink/pull/17452
## What is the purpose of the change
This pull request completes the development of Pulsar based on the new
Sink, which will enable smoother data interaction between Flink and Pulsar.
[
https://issues.apache.org/jira/browse/FLINK-20732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427197#comment-17427197
]
Jianyun Zhao commented on FLINK-20732:
--
[~MartijnVisser] Thank you~
> Pulsar Sink
flinkbot edited a comment on pull request #17451:
URL: https://github.com/apache/flink/pull/17451#issuecomment-940126969
## CI report:
* 55bbb7e7f747599b91a2926e47af4ea299a728e4 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #17451:
URL: https://github.com/apache/flink/pull/17451#issuecomment-940127779
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 pro
flinkbot commented on pull request #17451:
URL: https://github.com/apache/flink/pull/17451#issuecomment-940126969
## CI report:
* 55bbb7e7f747599b91a2926e47af4ea299a728e4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-24476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-24476:
---
Labels: pull-request-available (was: )
> Rename all ElasticSearch to Elasticsearch (without
RyanSkraba opened a new pull request #17451:
URL: https://github.com/apache/flink/pull/17451
## What is the purpose of the change
FLINK-24476 This pull request renames all documentation and code instances
of ElasticSearch to Elasticsearch to align with their brand guidelines.
[
https://issues.apache.org/jira/browse/FLINK-24509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias reassigned FLINK-24509:
Assignee: Ali Bahadir Zeybek
> FlinkKafkaProducer example is not compiling due to incorrect const
Ali Bahadir Zeybek created FLINK-24509:
--
Summary: FlinkKafkaProducer example is not compiling due to
incorrect constructer signature used
Key: FLINK-24509
URL: https://issues.apache.org/jira/browse/FLINK-2450
flinkbot edited a comment on pull request #17441:
URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036
## CI report:
* f3d5c648bf84c4709dfc8baa512e5ba37b601873 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427194#comment-17427194
]
Nicolas Ferrario commented on FLINK-22533:
--
[~igal] just tested and it works gr
[
https://issues.apache.org/jira/browse/FLINK-20732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427190#comment-17427190
]
Martijn Visser commented on FLINK-20732:
[~Jianyun Zhao] I've assigned you!
> P
[
https://issues.apache.org/jira/browse/FLINK-20732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-20732:
--
Assignee: Jianyun Zhao
> Pulsar Sink
> ---
>
> Key: FLINK-207
[
https://issues.apache.org/jira/browse/FLINK-20732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427187#comment-17427187
]
Jianyun Zhao commented on FLINK-20732:
--
[~arvid] Hello, how are you doing? I have p
flinkbot edited a comment on pull request #17345:
URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717
## CI report:
* 70e18ce30aa0dbb1df85d84e35c9dbaeca6ff71f Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17449:
URL: https://github.com/apache/flink/pull/17449#issuecomment-939885083
## CI report:
* 4c8bdc9001bd15ad2bb1e63ec49b63faf1808bff Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-24496:
Comment: was deleted
(was: Probably the issue is that here
{{oldEntry.getExecutionGraphIn
flinkbot edited a comment on pull request #17345:
URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717
## CI report:
* 70e18ce30aa0dbb1df85d84e35c9dbaeca6ff71f Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17450:
URL: https://github.com/apache/flink/pull/17450#issuecomment-939949291
## CI report:
* 459111838bfa4cd32499535d6d89636f4aa8a024 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17441:
URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036
## CI report:
* d9f0f38dae789f563798b84266f7adbdf7daa0a3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17441:
URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036
## CI report:
* d9f0f38dae789f563798b84266f7adbdf7daa0a3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425566#comment-17425566
]
Ryan Skraba edited comment on FLINK-24476 at 10/11/21, 2:55 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-24508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LI Zhennan updated FLINK-24508:
---
Summary: Examples: add ThrottledMapper, a walkaround for deadlock under
heavy iteration feedback loa
[
https://issues.apache.org/jira/browse/FLINK-24508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LI Zhennan updated FLINK-24508:
---
Summary: Examples: Add ThrottledMapper in flink-examples, a walkaround for
deadlock under heavy iter
[
https://issues.apache.org/jira/browse/FLINK-24508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LI Zhennan updated FLINK-24508:
---
Summary: Examples: Add ThrottledMapper, a walkaround for deadlock under
heavy iteration feedback loa
flinkbot edited a comment on pull request #17450:
URL: https://github.com/apache/flink/pull/17450#issuecomment-939949291
## CI report:
* a27b45f90f31067656d64a3ec0a9d20d0c60402e Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
[
https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22533:
---
Labels: auto-deprioritized-major pull-request-available (was:
auto-deprioritized-major)
>
igalshilman opened a new pull request #274:
URL: https://github.com/apache/flink-statefun/pull/274
### This PR introduces custom metrics to the embedded SDK.
```java
public interface FunctionTypeScopedMetrics {
/**
* Retrieves (or creates) a counter metric with t
[
https://issues.apache.org/jira/browse/FLINK-24508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LI Zhennan updated FLINK-24508:
---
Description:
Hi,
Flink has a deadlock case and can be caused by the combination of Flink's
backpre
LI Zhennan created FLINK-24508:
--
Summary: Add ThrottledMapper in flink-examples
Key: FLINK-24508
URL: https://issues.apache.org/jira/browse/FLINK-24508
Project: Flink
Issue Type: Improvement
CrynetLogistics commented on a change in pull request #17345:
URL: https://github.com/apache/flink/pull/17345#discussion_r726179851
##
File path:
flink-connectors/flink-connector-aws/src/test/java/org/apache/flink/streaming/connectors/kinesis/async/testutils/KinesaliteContainer.java
#
CrynetLogistics commented on a change in pull request #17345:
URL: https://github.com/apache/flink/pull/17345#discussion_r726179851
##
File path:
flink-connectors/flink-connector-aws/src/test/java/org/apache/flink/streaming/connectors/kinesis/async/testutils/KinesaliteContainer.java
#
[
https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427168#comment-17427168
]
Igal Shilman edited comment on FLINK-22533 at 10/11/21, 2:38 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-24503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427169#comment-17427169
]
Chesnay Schepler commented on FLINK-24503:
--
I agree with [~nanmu42], that is al
CrynetLogistics commented on a change in pull request #17345:
URL: https://github.com/apache/flink/pull/17345#discussion_r726174745
##
File path:
flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/async/KinesisDataStreamsSinkWriter.java
##
zentol edited a comment on pull request #17402:
URL: https://github.com/apache/flink/pull/17402#issuecomment-940074506
> Also it would be great if we could have a test case, that this is fully
compatible with the 1.14 KryoSerializer, but this would be quite tricky to do.
Only simple approa
[
https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427168#comment-17427168
]
Igal Shilman commented on FLINK-22533:
--
[~nferrario] check out the branch again,
y
[
https://issues.apache.org/jira/browse/FLINK-2497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427167#comment-17427167
]
LI Zhennan edited comment on FLINK-2497 at 10/11/21, 2:31 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-2497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427167#comment-17427167
]
LI Zhennan commented on FLINK-2497:
---
This issue may related with FLIP-15:
https://cwik
CrynetLogistics commented on a change in pull request #17345:
URL: https://github.com/apache/flink/pull/17345#discussion_r726172890
##
File path:
flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/async/KinesisDataStreamsSinkConfig.java
##
zentol commented on a change in pull request #17402:
URL: https://github.com/apache/flink/pull/17402#discussion_r726172216
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
##
@@ -67,6 +69,35 @@
* This serializer is i
CrynetLogistics commented on a change in pull request #17345:
URL: https://github.com/apache/flink/pull/17345#discussion_r726170830
##
File path:
flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/async/KinesisDataStreamsSinkConfig.java
##
CrynetLogistics commented on a change in pull request #17345:
URL: https://github.com/apache/flink/pull/17345#discussion_r726170284
##
File path: flink-connectors/flink-connector-aws/pom.xml
##
@@ -0,0 +1,120 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xs
[
https://issues.apache.org/jira/browse/FLINK-24431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-24431.
---
Resolution: Fixed
> [Kinesis][EFO] EAGER registration strategy does not work when job fails
zentol commented on a change in pull request #17402:
URL: https://github.com/apache/flink/pull/17402#discussion_r726164495
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
##
@@ -67,6 +69,35 @@
* This serializer is i
dannycranmer merged pull request #17429:
URL: https://github.com/apache/flink/pull/17429
--
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-un
dannycranmer merged pull request #17430:
URL: https://github.com/apache/flink/pull/17430
--
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-un
zentol commented on a change in pull request #17402:
URL: https://github.com/apache/flink/pull/17402#discussion_r726166373
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
##
@@ -86,6 +117,23 @@
configureKryoL
dannycranmer merged pull request #17431:
URL: https://github.com/apache/flink/pull/17431
--
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-un
zentol commented on a change in pull request #17402:
URL: https://github.com/apache/flink/pull/17402#discussion_r726164495
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
##
@@ -67,6 +69,35 @@
* This serializer is i
zentol commented on a change in pull request #17402:
URL: https://github.com/apache/flink/pull/17402#discussion_r726162667
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
##
@@ -45,6 +45,8 @@
import org.slf4j.Logger;
zentol commented on pull request #17402:
URL: https://github.com/apache/flink/pull/17402#issuecomment-940074506
> Also it would be great if we could have a test case, that this is fully
compatible with the 1.14 KryoSerializer, but this would be quite tricky to do.
Only simple approach I ca
[
https://issues.apache.org/jira/browse/FLINK-24503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427153#comment-17427153
]
LI Zhennan edited comment on FLINK-24503 at 10/11/21, 2:17 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-24503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427153#comment-17427153
]
LI Zhennan commented on FLINK-24503:
Hi [~xtsong],
I am sorry to say I failed to ag
[
https://issues.apache.org/jira/browse/FLINK-22533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427147#comment-17427147
]
Igal Shilman commented on FLINK-22533:
--
Thanks [~nferrario] for testing this out!
flinkbot edited a comment on pull request #17449:
URL: https://github.com/apache/flink/pull/17449#issuecomment-939885083
## CI report:
* ba3a44f49e95701183b5c43a77d4dd7cbbd95ae9 Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
flinkbot edited a comment on pull request #17443:
URL: https://github.com/apache/flink/pull/17443#issuecomment-939267795
## CI report:
* d7825ee175e5228e6cdbb4f50f2a3b9ab5383d09 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Francesco Guardiani created FLINK-24507:
---
Summary: Cleanup all the various date/time/timestamp utils
Key: FLINK-24507
URL: https://issues.apache.org/jira/browse/FLINK-24507
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Francesco Guardiani reassigned FLINK-24500:
---
Assignee: Francesco Guardiani
> Move SqlDateTimeUtils to table-common
> ---
[
https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-24483:
---
Description:
We should document:
* What constitute of the Public API, what do
Public/Public
flinkbot edited a comment on pull request #17429:
URL: https://github.com/apache/flink/pull/17429#issuecomment-938517460
## CI report:
* fa6fc9c67a6e3bf181d3c992ee8586e445af0776 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-23117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427125#comment-17427125
]
Gabriel Nes commented on FLINK-23117:
-
It seems that we got this problem with our pr
[
https://issues.apache.org/jira/browse/FLINK-23117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabriel Nes updated FLINK-23117:
Attachment: image-2021-10-11-10-23-14-069.png
> TaskExecutor.allocateSlot is a logical error
> ---
[
https://issues.apache.org/jira/browse/FLINK-23117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabriel Nes updated FLINK-23117:
Attachment: image-2021-10-11-10-16-17-977.png
> TaskExecutor.allocateSlot is a logical error
> ---
[
https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427119#comment-17427119
]
David Morávek commented on FLINK-21383:
---
I guess we should either do that or have
[
https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427119#comment-17427119
]
David Morávek edited comment on FLINK-21383 at 10/11/21, 1:12 PM:
[
https://issues.apache.org/jira/browse/FLINK-23117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabriel Nes updated FLINK-23117:
Attachment: image-2021-10-11-10-11-28-390.png
> TaskExecutor.allocateSlot is a logical error
> ---
flinkbot edited a comment on pull request #16606:
URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748
## CI report:
* 061a4e7bb03dc54f0b909350bc01ec5936d08080 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
RocMarshal edited a comment on pull request #17352:
URL: https://github.com/apache/flink/pull/17352#issuecomment-932249100
Thanks @Airblader for the review.
Hi, @wuchong , @xintongsong @twalthr @dawidwys @pnowojski @fsk119 . Could
you help me to merge it if there are nothing inappropri
[
https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427108#comment-17427108
]
JING ZHANG edited comment on FLINK-24501 at 10/11/21, 12:58 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427110#comment-17427110
]
Yang Wang commented on FLINK-21383:
---
I agree with you that Flink cluster may not have
[
https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427108#comment-17427108
]
JING ZHANG edited comment on FLINK-24501 at 10/11/21, 12:53 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427108#comment-17427108
]
JING ZHANG commented on FLINK-24501:
There are two solutions for the problem:
# sav
[
https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427106#comment-17427106
]
Liu commented on FLINK-24501:
-
+1 for the first solution. Recomputing watermark can cause th
pnowojski commented on a change in pull request #35:
URL: https://github.com/apache/flink-benchmarks/pull/35#discussion_r726071489
##
File path:
src/main/java/org/apache/flink/benchmark/MultiInputCheckpointingTimeBenchmark.java
##
@@ -0,0 +1,189 @@
+/*
+ * Licensed to the Apac
[
https://issues.apache.org/jira/browse/FLINK-24417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-24417.
Resolution: Implemented
Implemented in:
* master
**
2dff05df22d540f82afe375fe39b0782f7855
flinkbot edited a comment on pull request #17441:
URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036
## CI report:
* d9f0f38dae789f563798b84266f7adbdf7daa0a3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
dawidwys closed pull request #17403:
URL: https://github.com/apache/flink/pull/17403
--
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-unsubs
flinkbot edited a comment on pull request #17441:
URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036
## CI report:
* d9f0f38dae789f563798b84266f7adbdf7daa0a3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17403:
URL: https://github.com/apache/flink/pull/17403#issuecomment-932072806
## CI report:
* fcac54ef9400ce97f10b1a1f190d523311ef9973 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-24503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427086#comment-17427086
]
Xintong Song commented on FLINK-24503:
--
[~nanmu42],
Thanks for reporting this.
I t
flinkbot edited a comment on pull request #17450:
URL: https://github.com/apache/flink/pull/17450#issuecomment-939949291
## CI report:
* a27b45f90f31067656d64a3ec0a9d20d0c60402e Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17449:
URL: https://github.com/apache/flink/pull/17449#issuecomment-939885083
## CI report:
* ba3a44f49e95701183b5c43a77d4dd7cbbd95ae9 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17450:
URL: https://github.com/apache/flink/pull/17450#issuecomment-939949291
## CI report:
* a27b45f90f31067656d64a3ec0a9d20d0c60402e Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17449:
URL: https://github.com/apache/flink/pull/17449#issuecomment-939885083
## CI report:
* ba3a44f49e95701183b5c43a77d4dd7cbbd95ae9 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #17443:
URL: https://github.com/apache/flink/pull/17443#issuecomment-939267795
## CI report:
* 178f04c20bd675903e22638afe425fe9e38f426c Azure:
[CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul
dawidwys edited a comment on pull request #17404:
URL: https://github.com/apache/flink/pull/17404#issuecomment-939956996
Closed in 8a28c039e830b74a25a3504347ec4553a09fcc89
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
dawidwys commented on pull request #17404:
URL: https://github.com/apache/flink/pull/17404#issuecomment-939956996
Close in 8a28c039e830b74a25a3504347ec4553a09fcc89
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
dawidwys closed pull request #17404:
URL: https://github.com/apache/flink/pull/17404
--
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-unsubs
101 - 200 of 324 matches
Mail list logo
