[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14504119#comment-14504119
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503927#comment-14503927
]
ASF GitHub Bot commented on FLINK-703:
--
Github user fhueske commented on the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/605#discussion_r28739333
--- Diff:
flink-core/src/main/java/org/apache/flink/statistics/heavyhitters/IHeavyHitter.java
---
@@ -0,0 +1,37 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503961#comment-14503961
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503801#comment-14503801
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503979#comment-14503979
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user fhueske commented on a diff in
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/372#issuecomment-94590741
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 fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/605#discussion_r28739811
--- Diff:
flink-core/src/main/java/org/apache/flink/statistics/OperatorStatistics.java ---
@@ -0,0 +1,154 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503665#comment-14503665
]
ASF GitHub Bot commented on FLINK-1758:
---
Github user andralungu commented on the
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/576#issuecomment-94572014
Apart from the fact that I don't agree with those two methods having the
same name, everything else was updated.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503788#comment-14503788
]
Jonathan Hasenburg commented on FLINK-1719:
---
I will write my Bachelor Thesis
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/596#issuecomment-94438358
@vasia ,
The library method matches Spargel now. I also refactored the randomised
edges test a bit.
Tell me what you think!
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502729#comment-14502729
]
ASF GitHub Bot commented on FLINK-377:
--
Github user aljoscha commented on the pull
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/600#issuecomment-94432522
Hi @vasia ,
The general guidelines were added.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-1871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502694#comment-14502694
]
ASF GitHub Bot commented on FLINK-1871:
---
Github user andralungu commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/609#issuecomment-94442619
The TaskManager uses an exponential backoff strategy to resolve connection
problems with the JobManager.
On Mon, Apr 20, 2015 at 11:07 AM, Max
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-94443054
I just ran it on the cluster. Works like a charm. :smile:
For word count, python takes 12 minutes, java about 2:40. But this should
be expected, I guess.
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502728#comment-14502728
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/609#issuecomment-9121
The TaskManager's maximum registration duration is configured by the config
value ```taskmanager.maxRegistrationDuration```. The default value is set to
infinity for
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502737#comment-14502737
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502686#comment-14502686
]
Chiwan Park commented on FLINK-1745:
I suggest a scenario of KNN like following:
[
https://issues.apache.org/jira/browse/FLINK-1883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502712#comment-14502712
]
ASF GitHub Bot commented on FLINK-1883:
---
Github user andralungu commented on the
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502733#comment-14502733
]
ASF GitHub Bot commented on FLINK-377:
--
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-94443599
Can you give me a +1 in the discussion on the ML as well?
On Mon, Apr 20, 2015 at 2:46 PM, Aljoscha Krettek notificati...@github.com
wrote:
I just
Github user DarkKnightCZ commented on the pull request:
https://github.com/apache/flink/pull/609#issuecomment-94451193
@tillrohrmann
The problem that occurred was that JM bound the IP:PORT with some delay, so
TMs failed to start, since they couldn't connect.
When i tried
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502783#comment-14502783
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user DarkKnightCZ commented on the
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502792#comment-14502792
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user DarkKnightCZ commented on a
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502734#comment-14502734
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/609#discussion_r28685121
--- Diff: flink-dist/src/main/flink-bin/bin/start-cluster.sh ---
@@ -37,6 +37,26 @@ fi
# cluster mode, bring up job manager locally and a task manager on
[
https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raghav Chalapathy reassigned FLINK-1733:
Assignee: Raghav Chalapathy
Add PCA to machine learning library
Robert Metzger created FLINK-1913:
-
Summary: Document how to access data in HCatalog
Key: FLINK-1913
URL: https://issues.apache.org/jira/browse/FLINK-1913
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502736#comment-14502736
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user tillrohrmann commented on the
Github user DarkKnightCZ commented on a diff in the pull request:
https://github.com/apache/flink/pull/609#discussion_r28688289
--- Diff: flink-dist/src/main/flink-bin/bin/start-cluster.sh ---
@@ -37,6 +37,26 @@ fi
# cluster mode, bring up job manager locally and a task
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502545#comment-14502545
]
ASF GitHub Bot commented on FLINK-377:
--
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502547#comment-14502547
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user tammymendt commented on the
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502546#comment-14502546
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user mxm commented on the pull
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-94403584
yes that is correct.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502620#comment-14502620
]
Chiwan Park commented on FLINK-1745:
[~raghav.chalapa...@gmail.com] Hi. We can
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park reassigned FLINK-1745:
--
Assignee: Chiwan Park
Add k-nearest-neighbours algorithm to machine learning library
[
https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502763#comment-14502763
]
Till Rohrmann commented on FLINK-1746:
--
Hi Raghav, cool that you picked the topic up
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/606#discussion_r28671427
--- Diff: docs/setup/local_setup.md ---
@@ -20,11 +20,11 @@ specific language governing permissions and limitations
under the License.
--
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-94402978
I was referring to the way that communication is handled between the java
host and the generic language client: Communication between them is not based
on a fixed set of
[
https://issues.apache.org/jira/browse/FLINK-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-1843:
-
Assignee: Maximilian Michels
Job History gets cleared too fast
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502562#comment-14502562
]
Raghav Chalapathy commented on FLINK-1745:
--
Hi Chiwan
Would like to colloborate
[
https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502580#comment-14502580
]
Robert Metzger commented on FLINK-1746:
---
Hi,
I gave you Contributor permissions in
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/112#issuecomment-94392457
I think we can close this pull request.
This PR is not adding new methods for getting metrics from the system. It
is using the (legacy?) JobManager profiling
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/606#discussion_r28671249
--- Diff: docs/setup/local_setup.md ---
@@ -20,11 +20,11 @@ specific language governing permissions and limitations
under the License.
--
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-94397131
All issues that I'm aware of are resolved.
---
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
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502558#comment-14502558
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raghav Chalapathy reassigned FLINK-1746:
Assignee: Raghav Chalapathy
Add linear discriminant analysis to machine learning
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/606#issuecomment-94393362
Why did you remove the Disqus comments from the pages?
---
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 zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-94402062
@aljoscha Timeout is removed. Data transfer is still done with mapped file,
access to these files is synchronized using TCP. Im not sure what you mean with
your last
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502551#comment-14502551
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502576#comment-14502576
]
Raghav Chalapathy commented on FLINK-1746:
--
Hi Till
I would like to start
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/609#issuecomment-94401080
Thanks for the pull request. Seems to work fine. I was wondering, shouldn't
the task managers repeatably try to build up a connection to the job manager?
For me, that seems
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502544#comment-14502544
]
ASF GitHub Bot commented on FLINK-377:
--
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-94400959
I'll test it again on a cluster. Could you please elaborate a bit. Is the
timeout still in? Communication is through TCP instead of the mapped files. but
still with the
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-94401023
I wrote to the mailinglist to discuss the state of this PR
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Péter Szabó reassigned FLINK-1911:
--
Assignee: Péter Szabó
DataStream and DataSet projection is out of sync
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/582#issuecomment-94392757
Any more thoughts? Otherwise I would like to merge this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502520#comment-14502520
]
ASF GitHub Bot commented on FLINK-1799:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502534#comment-14502534
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502967#comment-14502967
]
ASF GitHub Bot commented on FLINK-1867:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502870#comment-14502870
]
ASF GitHub Bot commented on FLINK-1906:
---
Github user StephanEwen commented on the
Zoltán Zvara created FLINK-1914:
---
Summary: Wrong FS while starting YARN session without correct
HADOOP_HOME
Key: FLINK-1914
URL: https://issues.apache.org/jira/browse/FLINK-1914
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502885#comment-14502885
]
ASF GitHub Bot commented on FLINK-1758:
---
Github user andralungu commented on the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/582#discussion_r28691764
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java
---
@@ -143,6 +143,18 @@ else if (type instanceof Class?
[
https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502901#comment-14502901
]
Robert Metzger commented on FLINK-1914:
---
Hi,
thank you for the feedback.
The Yarn
[
https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502906#comment-14502906
]
ASF GitHub Bot commented on FLINK-1799:
---
Github user aljoscha commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/572#discussion_r28696843
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java
---
@@ -1063,6 +1065,33 @@ public void
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/576#issuecomment-94461019
Hi @vasia ,
The inline comments have been addressed, I still have the big comment to
look at :)
One thing(or two ^^) that could be discussed:
-
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/611#issuecomment-94457892
Good addition, +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
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/572#discussion_r28696976
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/JoinITCase.java
---
@@ -663,6 +663,39 @@ public void
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/572#discussion_r28696965
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/JoinITCase.java
---
@@ -663,6 +663,39 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502996#comment-14502996
]
ASF GitHub Bot commented on FLINK-703:
--
Github user fhueske commented on a diff in the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/572#discussion_r28696934
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java
---
@@ -1063,6 +1065,33 @@ public void
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-94464757
Keeping the accumulators from each task separately is something that we
want to change anyways in the main system. Then, this would not need special
casing.
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502900#comment-14502900
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-1260:
Assignee: (was: Chesnay Schepler)
Add custom partitioning to documentation
[
https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502897#comment-14502897
]
ASF GitHub Bot commented on FLINK-1799:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502997#comment-14502997
]
ASF GitHub Bot commented on FLINK-703:
--
Github user fhueske commented on a diff in the
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/582#discussion_r28692599
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java
---
@@ -143,6 +143,18 @@ else if (type instanceof Class?
[
https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502932#comment-14502932
]
Zoltán Zvara commented on FLINK-1914:
-
There is a warn! Thanks!
Wrong FS while
[
https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502939#comment-14502939
]
Robert Metzger commented on FLINK-1914:
---
I have to admit its not very prominent, but
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/612
[FLINK-1867/1880] Raise test timeouts in hope of fixing Travis fails
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink
[
https://issues.apache.org/jira/browse/FLINK-1422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-1422:
Assignee: (was: Chesnay Schepler)
Missing usage example for withParameters
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14502909#comment-14502909
]
Till Rohrmann commented on FLINK-1745:
--
Hi Chiwan and Raghav,
cool that you two want
Till Rohrmann created FLINK-1915:
Summary: Faulty plan selection by optimizer
Key: FLINK-1915
URL: https://issues.apache.org/jira/browse/FLINK-1915
Project: Flink
Issue Type: Bug
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/572#issuecomment-94482477
Thanks for the update. Looks really good!
I have just a few inline comments. Once these are resolved, I would try the
code and merge it if everything works.
---
If
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/372#issuecomment-94502825
I've updated the pull request. I decided to implement the concise method:
```
sinkId:taskId output - sink id provided, parallelism 1
sinkId output - sink
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503224#comment-14503224
]
ASF GitHub Bot commented on FLINK-703:
--
Github user chiwanpark commented on the pull
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/572#issuecomment-94512484
I updated this PR. Thanks for advice. :)
* Remove `setParallelism(1)` in test code.
* Simplify `testGroupReduceWithAtomicValue` in `GroupReduceITCase`.
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/572#discussion_r28697764
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/Keys.java ---
@@ -274,24 +274,31 @@ private static int
[
https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503147#comment-14503147
]
ASF GitHub Bot commented on FLINK-1486:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503045#comment-14503045
]
ASF GitHub Bot commented on FLINK-703:
--
Github user chiwanpark commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503011#comment-14503011
]
ASF GitHub Bot commented on FLINK-703:
--
Github user fhueske commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503018#comment-14503018
]
ASF GitHub Bot commented on FLINK-703:
--
Github user fhueske commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/582#issuecomment-94483743
I fixed @StephanEwen's complaint. It was incorrect but the type class of
TypeInformation does not seem to be used in any places where it matters.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503030#comment-14503030
]
ASF GitHub Bot commented on FLINK-1799:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14503349#comment-14503349
]
Nikolaas Steenbergen commented on FLINK-1907:
-
Hey, I don't know if im doing
100 matches
Mail list logo
