[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16496136#comment-16496136
]
yanxiaobin edited comment on FLINK-8500 at 5/31/18 5:42 AM:
[~tzulitai]
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16496136#comment-16496136
]
yanxiaobin commented on FLINK-8500:
---
[~tzulitai] thanks, greate.
> Get the timestamp of the Kafka
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16496068#comment-16496068
]
Tzu-Li (Gordon) Tai commented on FLINK-8500:
[~Backlight]
Yes, we're currently going for a
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16496006#comment-16496006
]
yanxiaobin commented on FLINK-8500:
---
So far, it can solve the current problems, but in the long run,
[
https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441630#comment-16441630
]
Ted Yu edited comment on FLINK-7525 at 5/31/18 1:41 AM:
Hopefully FLIP-6 would be
[
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=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=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
[
https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495510#comment-16495510
]
Rong Rong commented on FLINK-9430:
--
Hi [~suez1224], I think [~twalthr] and I had this discussion in a
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495490#comment-16495490
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user bowenli86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495491#comment-16495491
]
ASF GitHub Bot commented on FLINK-9476:
---
Github user bowenli86 commented on a diff in the pull
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
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
[
https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495470#comment-16495470
]
ASF GitHub Bot commented on FLINK-6469:
---
Github user StephanEwen commented on the issue:
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=16495448#comment-16495448
]
ASF GitHub Bot commented on FLINK-8873:
---
Github user bowenli86 commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495400#comment-16495400
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user kisimple commented on a diff in the pull
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=16495395#comment-16495395
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user kisimple commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-7836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495353#comment-16495353
]
ASF GitHub Bot commented on FLINK-7836:
---
Github user asfgit closed the pull request at:
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
[
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=16495303#comment-16495303
]
ASF GitHub Bot commented on FLINK-9413:
---
Github user zhangminglei commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495255#comment-16495255
]
ASF GitHub Bot commented on FLINK-9444:
---
Github user tragicjun commented on the issue:
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=16495252#comment-16495252
]
ASF GitHub Bot commented on FLINK-9464:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495248#comment-16495248
]
Till Rohrmann commented on FLINK-9461:
--
If {{flink-table}} would only contain some interfaces
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=16495241#comment-16495241
]
ASF GitHub Bot commented on FLINK-9464:
---
Github user zentol commented on a diff in the pull
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=16495233#comment-16495233
]
Fabian Hueske commented on FLINK-9461:
--
Why should the API depend on the connector? All our
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495219#comment-16495219
]
Alexander Gardner commented on FLINK-8707:
--
Hi Piotr
Apologies again, all my time on
[
https://issues.apache.org/jira/browse/FLINK-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495208#comment-16495208
]
ASF GitHub Bot commented on FLINK-9464:
---
Github user tillrohrmann commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495198#comment-16495198
]
Tzu-Li (Gordon) Tai commented on FLINK-8500:
+1 to proceed with at least an incremental fix
[
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 -
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495193#comment-16495193
]
Dawid Wysakowicz commented on FLINK-9215:
-
Closed in 1.5.1 via:
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495187#comment-16495187
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user tzulitai commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495183#comment-16495183
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user asfgit closed the pull request at:
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=16495178#comment-16495178
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user tillrohrmann commented on a diff in the pull
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495172#comment-16495172
]
ASF GitHub Bot commented on FLINK-7836:
---
Github user tillrohrmann commented on the issue:
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=16495170#comment-16495170
]
Till Rohrmann commented on FLINK-9461:
--
Logically, it does not make sense to couple a connector with
[
https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495170#comment-16495170
]
Till Rohrmann edited comment on FLINK-9461 at 5/30/18 1:38 PM:
---
Logically,
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495164#comment-16495164
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495167#comment-16495167
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495165#comment-16495165
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495168#comment-16495168
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495166#comment-16495166
]
ASF GitHub Bot commented on FLINK-7789:
---
Github user pnowojski commented on a diff in the pull
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_r191760364
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperatorTest.java
---
@@ -212,6 +212,20 @@ public
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
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495159#comment-16495159
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user StefanRRichter commented on a diff in the pull
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495157#comment-16495157
]
ASF GitHub Bot commented on FLINK-9410:
---
Github user tillrohrmann commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495150#comment-16495150
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user sihuazhou commented on the issue:
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=16495146#comment-16495146
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user dawidwys commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495143#comment-16495143
]
ASF GitHub Bot commented on FLINK-9215:
---
Github user dawidwys commented on a diff in the pull
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=16495140#comment-16495140
]
Till Rohrmann commented on FLINK-9480:
--
I can totally see the benefits of speeding up rescaling
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=16495115#comment-16495115
]
ASF GitHub Bot commented on FLINK-9413:
---
Github user tillrohrmann commented on a diff in the pull
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
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=16495113#comment-16495113
]
ASF GitHub Bot commented on FLINK-9413:
---
Github user zhangminglei commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16495092#comment-16495092
]
ASF GitHub Bot commented on FLINK-8873:
---
Github user dawidwys commented on the issue:
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?
---
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6089
@zentol PR is updated!
---
[
https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495089#comment-16495089
]
ASF GitHub Bot commented on FLINK-9413:
---
GitHub user zhangminglei opened a pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495082#comment-16495082
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user medcv commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495084#comment-16495084
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user medcv commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495083#comment-16495083
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user medcv commented on a diff in the pull request:
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
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=16495079#comment-16495079
]
ASF GitHub Bot commented on FLINK-9451:
---
Github user medcv commented on the issue:
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6089
@zentol Thanks! found them :)
---
[
https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16495077#comment-16495077
]
ASF GitHub Bot commented on FLINK-9423:
---
Github user StefanRRichter commented on a diff in the pull
1 - 100 of 183 matches
Mail list logo
