[
https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15116688#comment-15116688
]
ramkrishna.s.vasudevan commented on FLINK-3135:
---
[~fhueske]
Is there any way to assign an
[
https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15116864#comment-15116864
]
Fabian Hueske commented on FLINK-3135:
--
[~ram_krish] I gave you JIRA contributor permissions. You can
[
https://issues.apache.org/jira/browse/FLINK-3261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115129#comment-15115129
]
ASF GitHub Bot commented on FLINK-3261:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1537#issuecomment-174491828
Good fix.
I think if we want to be on the super safe side, actually all tasks should
always report back to the JobManager that they received the
[
https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115174#comment-15115174
]
Gabor Gevay commented on FLINK-2246:
I have added a commit to
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1546#discussion_r50694061
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.java
---
@@ -60,6 +60,7 @@ public static
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1544#issuecomment-174515248
Initially, I thought it makes sense to separate the code generation from
the optimization (and thus from Calcite). So that we could replace Calcite
easily at any time.
[
https://issues.apache.org/jira/browse/FLINK-3282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115239#comment-15115239
]
ASF GitHub Bot commented on FLINK-3282:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115251#comment-15115251
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user tillrohrmann commented on the pull request:
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/1545#issuecomment-174524019
No problem :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3287:
--
Environment: HDP version 2.2.9.0-3393
> Flink Kafka Consumer fails due to Curator version
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115205#comment-15115205
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115258#comment-15115258
]
ASF GitHub Bot commented on FLINK-3261:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1547#issuecomment-174523218
Makes sense to me, +1
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
[
https://issues.apache.org/jira/browse/FLINK-3285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115282#comment-15115282
]
ASF GitHub Bot commented on FLINK-3285:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115373#comment-15115373
]
ASF GitHub Bot commented on FLINK-3209:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115372#comment-15115372
]
ASF GitHub Bot commented on FLINK-3285:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115374#comment-15115374
]
ASF GitHub Bot commented on FLINK-3274:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115155#comment-15115155
]
ASF GitHub Bot commented on FLINK-3261:
---
Github user senorcarbone commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115250#comment-15115250
]
ASF GitHub Bot commented on FLINK-3271:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115259#comment-15115259
]
Till Rohrmann commented on FLINK-3286:
--
+1
> Remove JDEB Debian Package code from flink-dist
>
[
https://issues.apache.org/jira/browse/FLINK-3286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115264#comment-15115264
]
Robert Metzger commented on FLINK-3286:
---
+1
> Remove JDEB Debian Package code from flink-dist
>
[
https://issues.apache.org/jira/browse/FLINK-3255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115262#comment-15115262
]
ASF GitHub Bot commented on FLINK-3255:
---
Github user asfgit closed the pull request at:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1526#issuecomment-174521559
Looks good, +1 to merge!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
[
https://issues.apache.org/jira/browse/FLINK-3274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115364#comment-15115364
]
ASF GitHub Bot commented on FLINK-3274:
---
Github user rmetzger commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1541#issuecomment-174539538
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
[
https://issues.apache.org/jira/browse/FLINK-3274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115362#comment-15115362
]
ASF GitHub Bot commented on FLINK-3274:
---
Github user fhueske commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1541#issuecomment-174539785
This PR also addresses https://issues.apache.org/jira/browse/FLINK-3280
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1512#issuecomment-174541023
Will merge this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1541#issuecomment-174541071
Will merge this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1547#issuecomment-174540977
Will merge this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-174492669
I have added a commit to this PR that adds the chained version of
`ReduceCombineDriver`. (It doesn't have the sort-based code, only the
hash-based.)
---
If your
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1545#issuecomment-174510830
awesome, thank you. I'll merge it
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115201#comment-15115201
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user rmetzger commented on a diff in the pull
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1545#issuecomment-174512560
Sorry about that :8ball:
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1546#issuecomment-174520820
The `JobManagerITCase` is completely commented out. I guess this is a
testing artifact.
---
If your project is set up for it, you can reply to this email and
Stephan Ewen created FLINK-3286:
---
Summary: Remove JDEB Debian Package code from flink-dist
Key: FLINK-3286
URL: https://issues.apache.org/jira/browse/FLINK-3286
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3255.
---
> Chaining behavior should not depend on parallelism
> --
[
https://issues.apache.org/jira/browse/FLINK-3255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3255.
-
Resolution: Fixed
Fixed via 7ee719f7e577728fa253f64ad5bd15881b6ddd25
> Chaining behavior should
[
https://issues.apache.org/jira/browse/FLINK-3255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-3255:
Fix Version/s: (was: 0.10.1)
1.0.0
> Chaining behavior should not depend on
[
https://issues.apache.org/jira/browse/FLINK-3255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-3255:
Affects Version/s: (was: 1.0.0)
0.10.1
> Chaining behavior should not
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1528
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115261#comment-15115261
]
ASF GitHub Bot commented on FLINK-3246:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115368#comment-15115368
]
ASF GitHub Bot commented on FLINK-3161:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115389#comment-15115389
]
ASF GitHub Bot commented on FLINK-3198:
---
GitHub user kl0u opened a pull request:
GitHub user ggevay opened a pull request:
https://github.com/apache/flink/pull/1545
[hotfix] [docs] Add missing licenses to programming guide redirects.
The recently added files `flink/docs/apis/programming_guide.md` and
`flink/docs/apis/streaming_guide.md` (in
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1537#issuecomment-174505573
@senorcarbone Yes, it works correctly with the timeouts, the job can just
hang for a long time, especially in tests this occurred several times.
---
If your project
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/1546#discussion_r50694370
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/wordcount/WordCount.java
---
@@ -60,6 +60,7 @@ public static void
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115235#comment-15115235
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1537#issuecomment-174521106
The default timeout is 10 minutes. That is too long time to recognize that
a checkpoint was started pre-maturely ;-)
---
If your project is set up for it, you can
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1512#issuecomment-174538575
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
[
https://issues.apache.org/jira/browse/FLINK-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115359#comment-15115359
]
ASF GitHub Bot commented on FLINK-3209:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1531#issuecomment-174540899
Will merge this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Robert Metzger created FLINK-3288:
-
Summary: KafkaConsumer (0.8) fails with UnknownException
Key: FLINK-3288
URL: https://issues.apache.org/jira/browse/FLINK-3288
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115371#comment-15115371
]
ASF GitHub Bot commented on FLINK-3135:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1530#issuecomment-174540760
Thanks for the PR! Looks good!
Will merge it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/1548
FLINK-3198: Renames and documents the getDataSet() method in Grouping.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink groupBy_renaming
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115138#comment-15115138
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on the pull request:
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/1537#issuecomment-174500162
Looks cool.
Just so I understand exactly, what is wrong again if the Coordinator simply
aborts expired checkpoint attempts? Wouldn't the protocol be the same,
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1546#issuecomment-174518267
Thank you for this patch. The idea is good, but I think it needs a bit of
improvement:
- The value is pulled in a fairly complicated way though all the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1537#issuecomment-174523012
Normally (except in this kind of situation), checkpoints progress and need
no aggressive timeout as a guard. On the other hand, full checkpoints with huge
state
[
https://issues.apache.org/jira/browse/FLINK-3261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115280#comment-15115280
]
ASF GitHub Bot commented on FLINK-3261:
---
Github user StephanEwen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115341#comment-15115341
]
Stephan Ewen commented on FLINK-3287:
-
So, we need to shade curator into the kafka-connector jars?
>
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1523#issuecomment-174540358
I'm not familiar with `pdsh` but is there a way to pass the
`FLINK_SSH_OPTS` on?
---
If your project is set up for it, you can reply to this email and have your
reply
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1544#issuecomment-174518788
Yes, my initial idea was also to separate between 1) translating to the
correct job structure and 2) translation to actual DataSet program. So
basically the same
[
https://issues.apache.org/jira/browse/FLINK-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3246.
-
Resolution: Fixed
Fixed via 37787ca51da2071fa3678e131c50b110509b5827
> Consolidate maven project
[
https://issues.apache.org/jira/browse/FLINK-3285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115274#comment-15115274
]
ASF GitHub Bot commented on FLINK-3285:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115200#comment-15115200
]
ASF GitHub Bot commented on FLINK-2523:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/1546
FLINK-2523: making the task cancellation interval configurable.
FLINK-2523: Makes the task cancellation interval configurable.
You can merge this pull request into a Git repository by running:
$
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1547
[FLINK-3285][maven] skip deployment of flink-java8 module
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink FLINK-3285
Alternatively you
[
https://issues.apache.org/jira/browse/FLINK-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3246.
---
> Consolidate maven project names with *-parent suffix
>
[
https://issues.apache.org/jira/browse/FLINK-3267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3267.
-
Resolution: Fixed
Fixed via ed3810b1282dfba80d63b1f43a0c202925a3b11c
> Disable reference
[
https://issues.apache.org/jira/browse/FLINK-3286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas reassigned FLINK-3286:
-
Assignee: Kostas
> Remove JDEB Debian Package code from flink-dist
>
[
https://issues.apache.org/jira/browse/FLINK-3261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115324#comment-15115324
]
ASF GitHub Bot commented on FLINK-3261:
---
Github user senorcarbone commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115245#comment-15115245
]
ASF GitHub Bot commented on FLINK-3271:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1543#issuecomment-174519860
The idea sounds very good. The `lib` folder should not pack the Hadoop
classes into the same uberjar as Flink, but have separate fat jars for Flink
and the Hadoop
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1543#issuecomment-174520036
If this is the approach you suggest to go for, please open a JIRA for
this...
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-3261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115265#comment-15115265
]
ASF GitHub Bot commented on FLINK-3261:
---
Github user senorcarbone commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115260#comment-15115260
]
ASF GitHub Bot commented on FLINK-3256:
---
Github user StephanEwen commented on the pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1518
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-3267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115263#comment-15115263
]
ASF GitHub Bot commented on FLINK-3267:
---
Github user asfgit closed the pull request at:
Github user abhishekagarwal87 commented on the pull request:
https://github.com/apache/flink/pull/1543#issuecomment-174524448
Sure. Let me try this out locally and I will get back to you.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Robert Metzger created FLINK-3287:
-
Summary: Flink Kafka Consumer fails due to Curator version conflict
Key: FLINK-3287
URL: https://issues.apache.org/jira/browse/FLINK-3287
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115406#comment-15115406
]
ASF GitHub Bot commented on FLINK-3198:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1548#issuecomment-174545126
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1526
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1542#discussion_r50714080
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/complex/ComplexIntegrationTest.java
---
@@ -214,6 +214,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115455#comment-15115455
]
ASF GitHub Bot commented on FLINK-3178:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-3284.
--
Resolution: Fixed
7338474
> Broken web link: Hadoop compatibility in Flink
>
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1465#discussion_r50721087
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/NullAwareComparator.scala
---
@@ -0,0 +1,231 @@
+/*
+ *
GitHub user sksamuel opened a pull request:
https://github.com/apache/flink/pull/1549
Removed spark repl detection code from closure cleaner
I think this code is left over from when the code was copied from the spark
repo.
You can merge this pull request into a Git repository by
[
https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115423#comment-15115423
]
ASF GitHub Bot commented on FLINK-2523:
---
Github user kl0u commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115529#comment-15115529
]
ASF GitHub Bot commented on FLINK-3178:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1542#discussion_r50720691
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/complex/ComplexIntegrationTest.java
---
@@ -214,6 +214,7 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115582#comment-15115582
]
ASF GitHub Bot commented on FLINK-3140:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paris Carbone resolved FLINK-3256.
--
Resolution: Fixed
> Invalid execution graph cleanup for jobs with colocation groups
>
[
https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115579#comment-15115579
]
ASF GitHub Bot commented on FLINK-3140:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115417#comment-15115417
]
ASF GitHub Bot commented on FLINK-3178:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115418#comment-15115418
]
ASF GitHub Bot commented on FLINK-3178:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1542#issuecomment-174547617
Looks good, with one inline question.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
1 - 100 of 183 matches
Mail list logo
