rmetzger commented on a change in pull request #14499:
URL: https://github.com/apache/flink/pull/14499#discussion_r551760064
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/security/FlinkUserSecurityManagerTest.java
##
@@ -0,0 +1,187 @@
+/*
+ * Licensed to t
twalthr closed pull request #14420:
URL: https://github.com/apache/flink/pull/14420
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
rmetzger commented on a change in pull request #14499:
URL: https://github.com/apache/flink/pull/14499#discussion_r551774866
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java
##
@@ -490,4 +490,25 @@
[
https://issues.apache.org/jira/browse/FLINK-19981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-19981.
Fix Version/s: 1.13.0
Resolution: Fixed
Fixed in 1.13.0: d2e9aeb55d5c7bfaa65f92163a142f5320
flinkbot edited a comment on pull request #14502:
URL: https://github.com/apache/flink/pull/14502#issuecomment-751570047
## CI report:
* 9c9fde37681a4de283125f06437be9e8d5b5de7a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258744#comment-17258744
]
zlzhang0122 commented on FLINK-20735:
-
[~trohrmann] Thanks for your reply. Indeed On
flinkbot edited a comment on pull request #8952:
URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324
## CI report:
* d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN
* 8b920eb9c1f70c08f663154e15c60f6ed331394b Azure:
[FAILURE](https://dev.azure.com/apache-flin
flinkbot edited a comment on pull request #14506:
URL: https://github.com/apache/flink/pull/14506#issuecomment-751662858
## CI report:
* fb616e97afc33ccbd931d353d8726de9778902f6 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14556:
URL: https://github.com/apache/flink/pull/14556#issuecomment-754461446
## CI report:
* 0df2351e80ba1484393fbc8bb45875fefc619114 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
xiaoHoly commented on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-754492059
hi,@PatrickRen . Do you have a good idea to judge that the stop offset is
not specified?.all Stopping offset is initialized as
NoStoppingOffsetsInitializer object.there is not
xiaoHoly commented on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-754492541
hi,@becketqin WDYT?
This is an automated message from the Apache Git Service.
To respond to the message, pleas
curcur commented on a change in pull request #14546:
URL: https://github.com/apache/flink/pull/14546#discussion_r551790228
##
File path:
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/subtask/job-checkpoints-subtask.component.html
##
@@ -91,6 +91,7 @@
P
curcur commented on pull request #14546:
URL: https://github.com/apache/flink/pull/14546#issuecomment-754495311
> The changes generally LGTM but not to spotless :) Please fix formatting.
> I ran a test job and I think aggregation can be added later as a separate
PR.
hoops, forget
dawidwys commented on a change in pull request #14312:
URL: https://github.com/apache/flink/pull/14312#discussion_r551790684
##
File path: docs/dev/datastream_execution_mode.md
##
@@ -1,8 +1,6 @@
---
title: "Execution Mode (Batch/Streaming)"
-nav-id: datastream_execution_mode
becketqin opened a new pull request #14557:
URL: https://github.com/apache/flink/pull/14557
## What is the purpose of the change
This patch is a band-aid patch that prevent NPE thrown from SourceOperator
after it is closed.
The root cause of the NPE is in the out of order mailbox
[
https://issues.apache.org/jira/browse/FLINK-20781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20781:
---
Labels: pull-request-available test-stability (was: test-stability)
> UnalignedCheckpointIT
flinkbot commented on pull request #14557:
URL: https://github.com/apache/flink/pull/14557#issuecomment-754498276
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
dawidwys commented on pull request #14312:
URL: https://github.com/apache/flink/pull/14312#issuecomment-754499351
What is the plan for mixed keyed/non-keyed inputs in multiple inputs? If I
am not mistaken the implementation in the `StreamMultipleInputProcessorFactory`
is not complete and i
flinkbot edited a comment on pull request #14506:
URL: https://github.com/apache/flink/pull/14506#issuecomment-751662858
## CI report:
* fb616e97afc33ccbd931d353d8726de9778902f6 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
rmetzger commented on a change in pull request #14499:
URL: https://github.com/apache/flink/pull/14499#discussion_r551774866
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java
##
@@ -490,4 +490,25 @@
flinkbot commented on pull request #14557:
URL: https://github.com/apache/flink/pull/14557#issuecomment-754510928
## CI report:
* 4d66e1dd7d08d10ffb01a48912657d365e37fed8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-18795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258772#comment-17258772
]
Tang Yan commented on FLINK-18795:
--
[~mgergely] Is this new feature included in Flink1.
PatrickRen commented on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-754512467
@xiaoHoly What about `instanceof NoStoppingOffsetInitializer`?
It is indeed possible that a user provides a custom `OffsetsInitializer`
which is semantically equivale
[
https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258774#comment-17258774
]
Till Rohrmann commented on FLINK-20833:
---
Thanks for creating this ticket [~Zhenqiu
rkhachatryan commented on a change in pull request #14546:
URL: https://github.com/apache/flink/pull/14546#discussion_r551808435
##
File path:
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/subtask/job-checkpoints-subtask.component.html
##
@@ -91,6 +91,7 @@
rmetzger commented on a change in pull request #14499:
URL: https://github.com/apache/flink/pull/14499#discussion_r551809166
##
File path:
flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java
##
@@ -210,7 +211,12 @@ public String getDescription() th
[
https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-19970:
Assignee: Dawid Wysakowicz
> State leak in CEP Operators (expired events/keys not
flinkbot edited a comment on pull request #14557:
URL: https://github.com/apache/flink/pull/14557#issuecomment-754510928
## CI report:
* 4d66e1dd7d08d10ffb01a48912657d365e37fed8 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
rmetzger commented on a change in pull request #14499:
URL: https://github.com/apache/flink/pull/14499#discussion_r551763905
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/security/FlinkUserSecurityManager.java
##
@@ -0,0 +1,168 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-20845:
Assignee: Nick Burkard
> Drop support for Scala 2.11
> --
[
https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258785#comment-17258785
]
Aljoscha Krettek commented on FLINK-20309:
--
Another one:
https://dev.azure.com
xiaoHoly commented on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-754526783
@PatrickRen SGTM
This is an automated message from the Apache Git Service.
To respond to the message, please lo
rmetzger commented on a change in pull request #14499:
URL: https://github.com/apache/flink/pull/14499#discussion_r551822019
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/security/FlinkUserSecurityManagerTest.java
##
@@ -0,0 +1,187 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258789#comment-17258789
]
Aljoscha Krettek commented on FLINK-13414:
--
[~NickBurkard] or [~bobanahalf]: if
aljoscha commented on a change in pull request #14312:
URL: https://github.com/apache/flink/pull/14312#discussion_r551824176
##
File path: docs/dev/datastream_execution_mode.md
##
@@ -1,8 +1,6 @@
---
title: "Execution Mode (Batch/Streaming)"
-nav-id: datastream_execution_mode
rmetzger commented on a change in pull request #14499:
URL: https://github.com/apache/flink/pull/14499#discussion_r551824883
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
##
@@ -705,9 +715,11 @@ public final void canc
rmetzger commented on a change in pull request #14499:
URL: https://github.com/apache/flink/pull/14499#discussion_r551828818
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
##
@@ -527,38 +528,48 @@ protected void before
echauchot opened a new pull request #14558:
URL: https://github.com/apache/flink/pull/14558
## What is the purpose of the change
Make _MiniClusterJobClient#getAccumulators()_ non-blocking in Streaming mode
## Brief change log
Get the serialized accumulators from the exec
tillrohrmann commented on a change in pull request #14554:
URL: https://github.com/apache/flink/pull/14554#discussion_r551830902
##
File path: docs/deployment/ha/kubernetes_ha.md
##
@@ -52,6 +52,10 @@ In order to identify the Flink cluster, you have to specify
a `kubernetes.cl
flinkbot commented on pull request #14558:
URL: https://github.com/apache/flink/pull/14558#issuecomment-754536948
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
aljoscha commented on a change in pull request #14544:
URL: https://github.com/apache/flink/pull/14544#discussion_r551832278
##
File path: pom.xml
##
@@ -822,53 +822,6 @@ under the License.
-
- scala-2.11
-
[
https://issues.apache.org/jira/browse/FLINK-20845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20845:
---
Labels: pull-request-available (was: )
> Drop support for Scala 2.11
>
[
https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258801#comment-17258801
]
Till Rohrmann commented on FLINK-20735:
---
When using a session cluster, then you ca
[
https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258801#comment-17258801
]
Till Rohrmann edited comment on FLINK-20735 at 1/5/21, 10:09 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258801#comment-17258801
]
Till Rohrmann edited comment on FLINK-20735 at 1/5/21, 10:10 AM:
-
tillrohrmann commented on a change in pull request #14553:
URL: https://github.com/apache/flink/pull/14553#discussion_r551836428
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphDeploymentTest.java
##
@@ -742,25 +731,11 @@ private
tillrohrmann commented on a change in pull request #14553:
URL: https://github.com/apache/flink/pull/14553#discussion_r551837596
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerUtils.java
##
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache
flinkbot edited a comment on pull request #14312:
URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739
## CI report:
* bd7ba18d9ef4db8a86ec315bb4ed3a333a7ac01c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536
## CI report:
* 665de48bdcb5dd56e9fc415183f324e5d7a15e38 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14557:
URL: https://github.com/apache/flink/pull/14557#issuecomment-754510928
## CI report:
* 4d66e1dd7d08d10ffb01a48912657d365e37fed8 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #14558:
URL: https://github.com/apache/flink/pull/14558#issuecomment-754543918
## CI report:
* 44801100ae245f2cd0d10d24830552b87164f072 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
wenlong88 commented on a change in pull request #14478:
URL: https://github.com/apache/flink/pull/14478#discussion_r551806728
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGlobalGroupAggregate.java
###
tillrohrmann commented on pull request #14553:
URL: https://github.com/apache/flink/pull/14553#issuecomment-754545450
Thanks for the review @zentol. I've addressed your comments and pushed an
update. Merging once AZP gives green light.
-
[
https://issues.apache.org/jira/browse/FLINK-20801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-20801:
-
Fix Version/s: (was: 1.11.2)
> Using asynchronous methods in operators causes serial
[
https://issues.apache.org/jira/browse/FLINK-18795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258805#comment-17258805
]
Chesnay Schepler commented on FLINK-18795:
--
[~Tang Yan] yes, it is included in
[
https://issues.apache.org/jira/browse/FLINK-18795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18795:
-
Fix Version/s: 1.12.0
> Support for HBase 2
> ---
>
> Ke
aljoscha opened a new pull request #14559:
URL: https://github.com/apache/flink/pull/14559
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
flinkbot commented on pull request #14559:
URL: https://github.com/apache/flink/pull/14559#issuecomment-754549406
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
zentol commented on a change in pull request #14559:
URL: https://github.com/apache/flink/pull/14559#discussion_r551844811
##
File path: docs/flinkDev/ide_setup.md
##
@@ -106,6 +106,7 @@ formatting on saving with these steps:
5. Install the [Save Actions
plugin](https://pl
zentol commented on a change in pull request #14559:
URL: https://github.com/apache/flink/pull/14559#discussion_r551844811
##
File path: docs/flinkDev/ide_setup.md
##
@@ -106,6 +106,7 @@ formatting on saving with these steps:
5. Install the [Save Actions
plugin](https://pl
zentol commented on a change in pull request #14559:
URL: https://github.com/apache/flink/pull/14559#discussion_r551844811
##
File path: docs/flinkDev/ide_setup.md
##
@@ -106,6 +106,7 @@ formatting on saving with these steps:
5. Install the [Save Actions
plugin](https://pl
zentol commented on pull request #14409:
URL: https://github.com/apache/flink/pull/14409#issuecomment-754552033
@paul8263 I'll take it from here ;)
This is an automated message from the Apache Git Service.
To respond to the m
flinkbot edited a comment on pull request #14312:
URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739
## CI report:
* bd7ba18d9ef4db8a86ec315bb4ed3a333a7ac01c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14409:
URL: https://github.com/apache/flink/pull/14409#issuecomment-747440606
## CI report:
* 128420a804db724f7687c541dee8cbfb94adb9a0 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163
## CI report:
* f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN
* f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN
* fd8cbf90a807292b0db7b85bda26f1e717b8
flinkbot edited a comment on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536
## CI report:
* 665de48bdcb5dd56e9fc415183f324e5d7a15e38 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14553:
URL: https://github.com/apache/flink/pull/14553#issuecomment-754074657
## CI report:
* b98fae5ddc22f64ce6aecd5ad667fd75aa8dda62 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14558:
URL: https://github.com/apache/flink/pull/14558#issuecomment-754543918
## CI report:
* 44801100ae245f2cd0d10d24830552b87164f072 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #14559:
URL: https://github.com/apache/flink/pull/14559#issuecomment-754553061
## CI report:
* 2d15ec725d3efa062d8520d5afbbd92c212062b9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
KarmaGYZ opened a new pull request #14560:
URL: https://github.com/apache/flink/pull/14560
## What is the purpose of the change
Refactor dynamic SlotID.
In FLINK-14189, we specified that the SlotID whose slot number is -1
represents the dynamic slot. However, the SlotID with a
[
https://issues.apache.org/jira/browse/FLINK-20837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20837:
---
Labels: pull-request-available (was: )
> Refactor dynamic SlotID
> ---
flinkbot commented on pull request #14560:
URL: https://github.com/apache/flink/pull/14560#issuecomment-754554960
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
tillrohrmann closed pull request #14425:
URL: https://github.com/apache/flink/pull/14425
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 g
[
https://issues.apache.org/jira/browse/FLINK-19773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-19773.
-
Fix Version/s: 1.13.0
Resolution: Fixed
Fixed via 13b7b3e6050ee716d01c9d3d74d08702f93953a
tillrohrmann commented on pull request #14425:
URL: https://github.com/apache/flink/pull/14425#issuecomment-754558779
Really good work @mareksabo!
This is an automated message from the Apache Git Service.
To respond to the me
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551855298
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551856516
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551856697
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
KarmaGYZ opened a new pull request #14561:
URL: https://github.com/apache/flink/pull/14561
## What is the purpose of the change
In FLINK-14188 and FLINK-14189, the TaskExecutor will derive and register to
ResourceManager with the total/default slot resource profile. We need to pa
flinkbot edited a comment on pull request #14409:
URL: https://github.com/apache/flink/pull/14409#issuecomment-747440606
## CI report:
* 128420a804db724f7687c541dee8cbfb94adb9a0 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20836:
---
Labels: pull-request-available (was: )
> Register TaskManager with total and default slot r
flinkbot edited a comment on pull request #14531:
URL: https://github.com/apache/flink/pull/14531#issuecomment-752828536
## CI report:
* 21c6c5cfdbaa95cb8d99274f69b9190ca8aec0c5 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14553:
URL: https://github.com/apache/flink/pull/14553#issuecomment-754074657
## CI report:
* b98fae5ddc22f64ce6aecd5ad667fd75aa8dda62 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14559:
URL: https://github.com/apache/flink/pull/14559#issuecomment-754553061
## CI report:
* 2d15ec725d3efa062d8520d5afbbd92c212062b9 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #14560:
URL: https://github.com/apache/flink/pull/14560#issuecomment-754563038
## CI report:
* a4504bda6bf4e1b38aefb248bc8355bc7864f496 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551858801
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
curcur commented on a change in pull request #14546:
URL: https://github.com/apache/flink/pull/14546#discussion_r551859021
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java
##
@@ -297,6 +297,11 @@ pu
flinkbot commented on pull request #14561:
URL: https://github.com/apache/flink/pull/14561#issuecomment-754563356
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-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258834#comment-17258834
]
zlzhang0122 commented on FLINK-20735:
-
[~trohrmann] Yep, this's exactly what I mean.
curcur commented on pull request #14546:
URL: https://github.com/apache/flink/pull/14546#issuecomment-754567585
I re-tested after updates.
This is an automated message from the Apache Git Service.
To respond to the message, p
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551863451
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551865672
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551865672
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
klion26 commented on pull request #13488:
URL: https://github.com/apache/flink/pull/13488#issuecomment-754570820
@StephanEwen thanks for the review.
@carp84 @NicoK Do you have any more comments?
If there are no more comments, could anyone of you approve this then I can
merge it. than
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551866588
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551866779
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551867412
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
MarkSfik commented on a change in pull request #403:
URL: https://github.com/apache/flink-web/pull/403#discussion_r551867894
##
File path: _posts/2020-12-22-pulsar-flink-connector-270.md
##
@@ -0,0 +1,171 @@
+---
+layout: post
+title: "What's New in Pulsar Flink Connector 2.7
[
https://issues.apache.org/jira/browse/FLINK-20735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258843#comment-17258843
]
Till Rohrmann commented on FLINK-20735:
---
With the current implementation this is n
flinkbot edited a comment on pull request #14508:
URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163
## CI report:
* f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN
* f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN
* fd8cbf90a807292b0db7b85bda26f1e717b8
1 - 100 of 342 matches
Mail list logo