[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16496174#comment-16496174
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user kisimple commented on a diff i
Github user kisimple commented on a diff in the pull request:
https://github.com/apache/flink/pull/6091#discussion_r192001515
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
---
@@ -648,6 +662,52 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16496136#comment-16496136
]
yanxiaobin edited comment on FLINK-8500 at 5/31/18 5:42 AM:
[
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16496136#comment-16496136
]
yanxiaobin commented on FLINK-8500:
---
[~tzulitai] thanks, greate.
> Get the timestam
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16496092#comment-16496092
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user Aitozi commented on the issue:
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/6104
@bowenli86 thanks for review, i have fix the error according to the comment
and add the unit test in CEPITCase, please help review it again. cc @kl0u
---
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16496068#comment-16496068
]
Tzu-Li (Gordon) Tai commented on FLINK-8500:
[~Backlight]
Yes, we're current
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16496006#comment-16496006
]
yanxiaobin commented on FLINK-8500:
---
So far, it can solve the current problems, but in
[
https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16441630#comment-16441630
]
Ted Yu edited comment on FLINK-7525 at 5/31/18 1:41 AM:
Hopefully
[
https://issues.apache.org/jira/browse/FLINK-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9150:
--
Component/s: Build System
> Prepare for Java 10
> ---
>
> Key: FLINK-9150
>
[
https://issues.apache.org/jira/browse/FLINK-7689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495654#comment-16495654
]
ASF GitHub Bot commented on FLINK-7689:
---
Github user pabloem commented on the issue
Github user pabloem commented on the issue:
https://github.com/apache/flink/pull/4725
@fhueske @asicoe is this PR still current / ongoing? I'm willing to driving
it to the end if there's anything left to do.. : ) - Or perhaps it's almost
ready to merge?
---
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495589#comment-16495589
]
ASF GitHub Bot commented on FLINK-8500:
---
GitHub user FredTing opened a pull request
GitHub user FredTing opened a pull request:
https://github.com/apache/flink/pull/6105
[FLINK-8500] Get the timestamp of the Kafka message from kafka consumer
## What is the purpose of the change
This pull request make the Kafka timestamp and timestampType available in
the m
[
https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495510#comment-16495510
]
Rong Rong commented on FLINK-9430:
--
Hi [~suez1224], I think [~twalthr] and I had this di
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495490#comment-16495490
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user bowenli86 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495491#comment-16495491
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user bowenli86 commented on a diff
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6104#discussion_r191858415
--- Diff: docs/dev/libs/cep.md ---
@@ -1524,7 +1524,52 @@ In `CEP` the order in which elements are processed
matters. To guarantee that el
To gu
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6104#discussion_r191857843
--- Diff: docs/dev/libs/cep.md ---
@@ -1524,7 +1524,52 @@ In `CEP` the order in which elements are processed
matters. To guarantee that el
To gu
[
https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495470#comment-16495470
]
ASF GitHub Bot commented on FLINK-6469:
---
Github user StephanEwen commented on the i
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5448
Will try and take a look at this soon... Sorry for the delay.
What I would consider very important is that users who don't change their
configuration do not get different behavior all of
[
https://issues.apache.org/jira/browse/FLINK-8873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495448#comment-16495448
]
ASF GitHub Bot commented on FLINK-8873:
---
Github user bowenli86 commented on the iss
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5649
When I was developing KeyedProcessFunction, I initially wondered why
there's no tests for KeyedStream, and researched and realized that they were
actually mixed with DataStream tests.
I t
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495400#comment-16495400
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user kisimple commented on a diff i
Github user kisimple commented on a diff in the pull request:
https://github.com/apache/flink/pull/6091#discussion_r191835482
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AsyncDataStream.scala
---
@@ -71,6 +71,9 @@ object AsyncDataStream {
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495395#comment-16495395
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user kisimple commented on a diff i
Github user kisimple commented on a diff in the pull request:
https://github.com/apache/flink/pull/6091#discussion_r191834614
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
---
@@ -648,6 +662,52 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495355#comment-16495355
]
ASF GitHub Bot commented on FLINK-9476:
---
GitHub user Aitozi opened a pull request:
GitHub user Aitozi opened a pull request:
https://github.com/apache/flink/pull/6104
[FLINK-9476]Emit late elements in CEP as sideOutPut
Now, when use with Eventtime in CEP library, elements come later than
watermark will be dropped,we can put it in side Output with outPutTag
You ca
[
https://issues.apache.org/jira/browse/FLINK-7836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495353#comment-16495353
]
ASF GitHub Bot commented on FLINK-7836:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5593
---
[
https://issues.apache.org/jira/browse/FLINK-7836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-7836.
--
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed via b6448015f485b5051e5e920b82b4b3ee71c5597
[
https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-5789:
-
Assignee: Kostas Kloudas
> Make Bucketing Sink independent of Hadoop's FileSystem
>
[
https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495303#comment-16495303
]
ASF GitHub Bot commented on FLINK-9413:
---
Github user zhangminglei commented on a di
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6103#discussion_r191814673
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputChannelDeploymentDescriptor.java
---
@@ -103,9 +103,7 @@ public String t
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495255#comment-16495255
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user tragicjun commented on the iss
Github user tragicjun commented on the issue:
https://github.com/apache/flink/pull/6082
I encountered another exception working with string type in Avro map/array,
any advice whether I should open a separate issue or just reusing this one.
---
[
https://issues.apache.org/jira/browse/FLINK-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495252#comment-16495252
]
ASF GitHub Bot commented on FLINK-9464:
---
Github user tillrohrmann commented on a di
[
https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495248#comment-16495248
]
Till Rohrmann commented on FLINK-9461:
--
If {{flink-table}} would only contain some i
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6093#discussion_r191794378
--- Diff: flink-connectors/flink-connector-filesystem/pom.xml ---
@@ -67,13 +67,6 @@ under the License.
-
[
https://issues.apache.org/jira/browse/FLINK-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495241#comment-16495241
]
ASF GitHub Bot commented on FLINK-9464:
---
Github user zentol commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6093#discussion_r191792861
--- Diff: flink-connectors/flink-connector-filesystem/pom.xml ---
@@ -67,13 +67,6 @@ under the License.
-
-
[
https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495233#comment-16495233
]
Fabian Hueske commented on FLINK-9461:
--
Why should the API depend on the connector?
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495219#comment-16495219
]
Alexander Gardner commented on FLINK-8707:
--
Hi Piotr
Apologies again, all my ti
[
https://issues.apache.org/jira/browse/FLINK-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495208#comment-16495208
]
ASF GitHub Bot commented on FLINK-9464:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/6093
I've updated the PR @zentol and removed the version and scope tags from all
`flink-test-utils-junit` dependencies in all modules. The scope and version is
now defined in the dependency managemen
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495198#comment-16495198
]
Tzu-Li (Gordon) Tai commented on FLINK-8500:
+1 to proceed with at least an i
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz resolved FLINK-9215.
-
Resolution: Fixed
Fix Version/s: 1.6.0
> TaskManager Releasing - org.apache.flink
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495193#comment-16495193
]
Dawid Wysakowicz commented on FLINK-9215:
-
Closed in 1.5.1 via: e1cce3634e09726d7
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495187#comment-16495187
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user tzulitai commented on the issu
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/6043
@cjolif do you think it would be possible that with a clean cut using a
REST implementation, we no longer need to have separate modules anymore for ES
6.x, 7.x, 8.x or so on?
i.e., it would only
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495183#comment-16495183
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5879
---
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495178#comment-16495178
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r191772629
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,511 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-7836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495172#comment-16495172
]
ASF GitHub Bot commented on FLINK-7836:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/5593
Thanks for the reminder @yanghua. I forgot about it and will merge it now.
Thanks again for your contributions. Flink wouldn't be what it is without you!
---
[
https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495170#comment-16495170
]
Till Rohrmann commented on FLINK-9461:
--
Logically, it does not make sense to couple
[
https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495170#comment-16495170
]
Till Rohrmann edited comment on FLINK-9461 at 5/30/18 1:38 PM:
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495164#comment-16495164
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495167#comment-16495167
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495165#comment-16495165
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495168#comment-16495168
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495166#comment-16495166
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on a diff
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6091#discussion_r191760364
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
---
@@ -212,6 +212,20 @@ public sta
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6091#discussion_r191768245
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AsyncDataStream.scala
---
@@ -71,6 +71,9 @@ object AsyncDataStream {
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6091#discussion_r191757079
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
---
@@ -212,6 +212,20 @@ public sta
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6091#discussion_r191768672
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncFunction.scala
---
@@ -46,4 +48,16 @@ trait AsyncFunction[I
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6091#discussion_r191767070
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
---
@@ -648,6 +662,52 @@ public voi
[
https://issues.apache.org/jira/browse/FLINK-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-9366:
---
Assignee: Dawid Wysakowicz
> Distribute Cache only works for client-accessible files
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495159#comment-16495159
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user StefanRRichter commented on a
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6062#discussion_r191768328
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java
---
@@ -0,0 +1,511 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495157#comment-16495157
]
ASF GitHub Bot commented on FLINK-9410:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/6087
Thanks for opening the PR @zhangminglei. I agree with @sihuazhou that it's
not as easy as replacing `x` with `xAsync`. As @sihuazhou pointed out, we have
to react to asynchronous Yarn messages d
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495150#comment-16495150
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user sihuazhou commented on the iss
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5879
@dawidwys It's ok with me, the unrelated change should be a minor java doc
hot fix.
---
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495146#comment-16495146
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user dawidwys commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495143#comment-16495143
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user dawidwys commented on a diff i
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/5879
Thanks @sihuazhou for the contribution. LGTM for me though I would remove
the unrelated change if it is ok with you.
---
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/5879#discussion_r191764153
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java ---
@@ -304,7 +305,8 @@ public int getMaxParallelism() {
/**
[
https://issues.apache.org/jira/browse/FLINK-9480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495140#comment-16495140
]
Till Rohrmann commented on FLINK-9480:
--
I can totally see the benefits of speeding u
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5721
---
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/5721
merging
---
[
https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495115#comment-16495115
]
ASF GitHub Bot commented on FLINK-9413:
---
Github user tillrohrmann commented on a di
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6103#discussion_r191753857
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputChannelDeploymentDescriptor.java
---
@@ -103,9 +103,7 @@ public String t
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6103
@tillrohrmann Could you take a look on this PR ? Thank you.
---
[
https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495113#comment-16495113
]
ASF GitHub Bot commented on FLINK-9413:
---
Github user zhangminglei commented on the
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495093#comment-16495093
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user medcv commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495092#comment-16495092
]
ASF GitHub Bot commented on FLINK-8873:
---
Github user dawidwys commented on the issu
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6089
@zentol PR is updated!
---
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/5649
@bowenli86 What's your opinion? If you are ok with not merging it, could
you close this PR?
---
[
https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495089#comment-16495089
]
ASF GitHub Bot commented on FLINK-9413:
---
GitHub user zhangminglei opened a pull req
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/6103
[FLINK-9413] [distributed coordination] Tasks can fail with Partitionâ¦
â¦NotFoundException if consumer deployment takes too long
## What is the purpose of the change
Tasks can fa
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495082#comment-16495082
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user medcv commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495083#comment-16495083
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user medcv commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495084#comment-16495084
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user medcv commented on a diff in t
Github user medcv commented on a diff in the pull request:
https://github.com/apache/flink/pull/6089#discussion_r191740715
--- Diff: flink-end-to-end-tests/test-scripts/elasticsearch-common.sh ---
@@ -75,6 +76,8 @@ function verify_result {
}
function shutdown_elastic
Github user medcv commented on a diff in the pull request:
https://github.com/apache/flink/pull/6089#discussion_r191740903
--- Diff: flink-end-to-end-tests/test-scripts/test_quickstarts.sh ---
@@ -18,29 +18,38 @@
Github user medcv commented on a diff in the pull request:
https://github.com/apache/flink/pull/6089#discussion_r191740667
--- Diff: flink-end-to-end-tests/test-scripts/elasticsearch-common.sh ---
@@ -56,13 +56,14 @@ function verify_elasticsearch_process_exist {
function
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16495079#comment-16495079
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user medcv commented on the issue:
1 - 100 of 176 matches
Mail list logo
