[
https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14946268#comment-14946268
]
Sachin Goel commented on FLINK-2730:
I implemented a better version of it, and here ar
[
https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14946200#comment-14946200
]
ASF GitHub Bot commented on FLINK-2066:
---
Github user WangCHX commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14946202#comment-14946202
]
ASF GitHub Bot commented on FLINK-2066:
---
Github user WangCHX commented on a diff in
Github user WangCHX commented on a diff in the pull request:
https://github.com/apache/flink/pull/1223#discussion_r41349716
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -199,6 +199,31 @@ public int getNumberOfExecutionRetries() {
[
https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14946199#comment-14946199
]
ASF GitHub Bot commented on FLINK-2066:
---
Github user WangCHX commented on a diff in
Github user WangCHX commented on a diff in the pull request:
https://github.com/apache/flink/pull/1223#discussion_r41349706
--- Diff: flink-core/src/main/java/org/apache/flink/api/common/Plan.java ---
@@ -303,6 +303,13 @@ public int getNumberOfExecutionRetries() {
}
Github user WangCHX commented on a diff in the pull request:
https://github.com/apache/flink/pull/1223#discussion_r41349717
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -199,6 +199,31 @@ public int getNumberOfExecutionRetries() {
Github user WangCHX commented on a diff in the pull request:
https://github.com/apache/flink/pull/1223#discussion_r41349100
--- Diff: docs/apis/programming_guide.md ---
@@ -1992,6 +1992,8 @@ With the closure cleaner disabled, it might happen
that an anonymous user functi
[
https://issues.apache.org/jira/browse/FLINK-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14946185#comment-14946185
]
ASF GitHub Bot commented on FLINK-2066:
---
Github user WangCHX commented on a diff in
Ted Yu created FLINK-2827:
-
Summary: Potential resource leak in
TwitterSource#loadAuthenticationProperties()
Key: FLINK-2827
URL: https://issues.apache.org/jira/browse/FLINK-2827
Project: Flink
Issu
Ted Yu created FLINK-2826:
-
Summary: transformed is modified in
BroadcastVariableMaterialization#decrementReferenceInternal without proper
locking
Key: FLINK-2826
URL: https://issues.apache.org/jira/browse/FLINK-2826
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945980#comment-14945980
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1205#issuecomment-146030951
Okay, I understand 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 not have t
[
https://issues.apache.org/jira/browse/FLINK-2825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax closed FLINK-2825.
--
Resolution: Fixed
> FlinkClient.killTopology fails due to missing leader session ID
> --
[
https://issues.apache.org/jira/browse/FLINK-2825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945959#comment-14945959
]
Matthias J. Sax commented on FLINK-2825:
Fixed via b489c367385453404671d0136ea59a9
[
https://issues.apache.org/jira/browse/FLINK-2283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-2283.
-
Resolution: Fixed
Fix Version/s: 0.10
Implemented via 225704b, a76d963 and c414ea9.
> Make
[
https://issues.apache.org/jira/browse/FLINK-2812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-2812.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via e494c27.
> KeySelectorUtil.getSelectorForK
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945689#comment-14945689
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user ankurcha commented on the pull
Github user ankurcha commented on the pull request:
https://github.com/apache/flink/pull/948#issuecomment-145987456
@hsaputra Added javadoc.
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945677#comment-14945677
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user aalexandrov commented on the pu
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-145984551
It could be that the test is not executed for Scala 2.11.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945675#comment-14945675
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user twalthr commented on the pull r
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-145983873
I think the NullPointerException was due to a wrong array to list
conversion. I don't know why this is related to the Scala version.
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945655#comment-14945655
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1205#issuecomment-145979805
Hey @chiwanpark,
this is how the Java method works, i.e. creates a `CsvReader ` object and
returns the graph when calling the appropriate types methods. I only kept thi
Matthias J. Sax created FLINK-2825:
--
Summary: FlinkClient.killTopology fails due to missing leader
session ID
Key: FLINK-2825
URL: https://issues.apache.org/jira/browse/FLINK-2825
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945633#comment-14945633
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user aalexandrov commented on the pu
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-145974916
@mxm The issue is probably related to Scala 2.10, since the two passing
builds have `Dscala-2.11`. I'll investigate tonight if I can get a hold on the
PR commits (Git
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945621#comment-14945621
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-145972139
I agree. We need to have a proper handling of eager execution, and why
exactly it shouldn't be allowed. The client exits is not a very good
explanation from the u
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945612#comment-14945612
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1205#issuecomment-145970361
I'm worrying about the name of method `fromCsvReader`. It seems that the
method should receive `CsvReader` object and read graph data from the reader
object. Why we d
[
https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945531#comment-14945531
]
Dawid Wysakowicz edited comment on FLINK-2156 at 10/6/15 6:34 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945531#comment-14945531
]
Dawid Wysakowicz commented on FLINK-2156:
-
Hi,
This can be my first open-source c
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945528#comment-14945528
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-145957532
Thanks a lot @twalthr for rebasing the pull request. There is an issue with
the Scalashell test. Not sure why it only occurs in some builds.
---
If your project is set up fo
[
https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945522#comment-14945522
]
ASF GitHub Bot commented on FLINK-2156:
---
GitHub user dawidwys opened a pull request:
GitHub user dawidwys opened a pull request:
https://github.com/apache/flink/pull/1234
[FLINK-2156] Scala modules cannot create logging file
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dawidwys/flink master
Alternatively you
[
https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Godek updated FLINK-2731:
---
Comment: was deleted
(was: [~rmetzger] yes he did. due to lack of time I wasn't able to start yet,
so
[
https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945506#comment-14945506
]
Piotr Godek commented on FLINK-2731:
[~rmetzger] yes he did. due to lack of time I was
[
https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945507#comment-14945507
]
Piotr Godek commented on FLINK-2731:
[~rmetzger] yes he did. due to lack of time I was
[
https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945502#comment-14945502
]
Robert Metzger commented on FLINK-2731:
---
[~sachingoel0101], did you talk to [~iampet
[
https://issues.apache.org/jira/browse/FLINK-2797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945495#comment-14945495
]
ASF GitHub Bot commented on FLINK-2797:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1214#issuecomment-145949994
@sachingoel0101 You're right. The detached YARN execution mode is broken
for jobs which use eager execution and build other jobs using the results.
However, the detached YAR
Gyula Fora created FLINK-2824:
-
Summary: Iteration feedback partitioning does not work as expected
Key: FLINK-2824
URL: https://issues.apache.org/jira/browse/FLINK-2824
Project: Flink
Issue Type:
Github user ktzoumas commented on the pull request:
https://github.com/apache/flink/pull/1208#issuecomment-145936851
I addressed the comments above, added the content for Scala, reworked the
iterations section, added content to the windows section, and made the
DataStream API guide al
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945433#comment-14945433
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1205#issuecomment-145939652
Thanks so much for the review @fhueske!
I agree with your comments. I will rename the parameter to `readVertices`,
make it mandatory, and better explain it on the docs.
[
https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945424#comment-14945424
]
ASF GitHub Bot commented on FLINK-2779:
---
Github user ktzoumas commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945366#comment-14945366
]
ASF GitHub Bot commented on FLINK-2731:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1233#issuecomment-145929720
Yes, I will look at it today. Thanks! Looks great from the screenshots.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
[
https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945363#comment-14945363
]
ASF GitHub Bot commented on FLINK-2731:
---
GitHub user sachingoel0101 opened a pull re
GitHub user sachingoel0101 opened a pull request:
https://github.com/apache/flink/pull/1233
[FLINK-2731][web-dashboard] Adds access to Job Manager stdout and log.
This adds minimalist support for accessing Job manager logs and stdout
files to the new web frontend.
Right now, to
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/1231
---
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 enable
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1205#issuecomment-145921072
Hi, you might have noticed, I got a bit confused about the `vertexValue`
parameter and how it affects the graph creation. I made a proposal inline to
rename that paramet
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945312#comment-14945312
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945298#comment-14945298
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user fhueske commented on a diff in
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1231#issuecomment-145918421
I manually merged it, could you please close the PR? :smile:
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1205#discussion_r41287202
--- Diff: docs/libs/gelly_guide.md ---
@@ -194,6 +194,27 @@ val edgeTuples = env.readCsvFile[String, String,
Double]("path/to/edge/input")
val grap
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945294#comment-14945294
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1205#discussion_r41287032
--- Diff:
flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala
---
@@ -126,6 +126,122 @@ object Graph {
wrapGraph
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1205#discussion_r41287065
--- Diff:
flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala
---
@@ -126,6 +126,122 @@ object Graph {
wrapGraph
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945293#comment-14945293
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945286#comment-14945286
]
Martin Liesenberg commented on FLINK-2732:
--
Sorry, I am a bit behind schedule, bu
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-145915740
Conflicts solved again ;)
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945261#comment-14945261
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945259#comment-14945259
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1205#discussion_r41284820
--- Diff:
flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala
---
@@ -126,6 +126,122 @@ object Graph {
wrapGraph
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945276#comment-14945276
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user twalthr commented on the pull r
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1205#discussion_r41284938
--- Diff:
flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala
---
@@ -126,6 +126,122 @@ object Graph {
wrapGraph
[
https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945256#comment-14945256
]
ASF GitHub Bot commented on FLINK-2785:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1205#discussion_r41284498
--- Diff: docs/libs/gelly_guide.md ---
@@ -194,6 +194,27 @@ val edgeTuples = env.readCsvFile[String, String,
Double]("path/to/edge/input")
val grap
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1232
[FLINK-2819] Add Windowed Join/CoGroup Operator Based on Tagged Union
Right now, this does everything in memory, so the JVM will blow if data
for one key becomes too large.
You can merge this p
[
https://issues.apache.org/jira/browse/FLINK-2819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945257#comment-14945257
]
ASF GitHub Bot commented on FLINK-2819:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945249#comment-14945249
]
ASF GitHub Bot commented on FLINK-1472:
---
Github user qmlmoon closed the pull request
Github user qmlmoon closed the pull request at:
https://github.com/apache/flink/pull/439
---
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 enab
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1160#issuecomment-145907305
Hi @zentol, thanks for this effort!
I found a few classes that could be renamed as well. Otherwise, the PR
looks good.
Thanks
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945231#comment-14945231
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945216#comment-14945216
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41280897
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashMatchIteratorITCase.java
---
@@ -498,15 +491,15 @@ public void te
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41280840
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashMatchIteratorITCase.java
---
@@ -528,31 +521,29 @@ public void te
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945215#comment-14945215
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41280793
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashMatchIteratorITCase.java
---
@@ -562,21 +553,21 @@ public void te
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945214#comment-14945214
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945213#comment-14945213
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41280692
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashMatchIteratorITCase.java
---
@@ -608,10 +599,10 @@ public void te
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945209#comment-14945209
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41280716
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashMatchIteratorITCase.java
---
@@ -639,11 +630,11 @@ public String
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945212#comment-14945212
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945207#comment-14945207
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41280660
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashMatchIteratorITCase.java
---
@@ -663,21 +654,21 @@ public String
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41280618
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashMatchIteratorITCase.java
---
@@ -692,24 +683,24 @@ public void jo
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945208#comment-14945208
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41280556
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashMatchIteratorITCase.java
---
@@ -725,7 +716,7 @@ public void join
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945205#comment-14945205
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41279695
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingHashMatchIteratorITCase.java
---
@@ -608,10 +601,10 @@ public void testB
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41280508
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/NonReusingHashMatchIteratorITCase.java
---
@@ -735,33 +726,31 @@ public void se
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41279751
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingHashMatchIteratorITCase.java
---
@@ -562,21 +555,21 @@ public void testB
[
https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14945201#comment-14945201
]
ASF GitHub Bot commented on FLINK-2479:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1160#discussion_r41280171
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/ReusingHashMatchIteratorITCase.java
---
@@ -735,33 +728,31 @@ public void setRe
1 - 100 of 314 matches
Mail list logo
