[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14504119#comment-14504119
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/408#issuecomment-94606828
Hi @balidani!
I pulled your changes and made some improvements, mainly to the examples,
so that they are consistent with the rest of Gelly's examples. You can see my
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503979#comment-14503979
]
ASF GitHub Bot commented on FLINK-1297:
---
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/605#discussion_r28739811
--- Diff:
flink-core/src/main/java/org/apache/flink/statistics/OperatorStatistics.java ---
@@ -0,0 +1,154 @@
+/*
+ * Licensed to the Apache Software Fo
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 Soft
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503927#comment-14503927
]
ASF GitHub Bot commented on FLINK-703:
--
Github user fhueske commented on the pull requ
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/572#issuecomment-94591244
Thanks for the prompt update and the good work!
Will try the PR and merge it if everything works fine :-)
---
If your project is set up for it, you can reply to this e
[
https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503920#comment-14503920
]
ASF GitHub Bot commented on FLINK-1486:
---
Github user fhueske commented on the pull r
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 and
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503801#comment-14503801
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/609#issuecomment-94581541
@DarkKnightCZ that sounds strange. The TM should not terminate itself if it
cannot connect to the JM unless the maximum registration duration has been
configured. Is
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503788#comment-14503788
]
Jonathan Hasenburg commented on FLINK-1719:
---
I will write my Bachelor Thesis abo
[
https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503665#comment-14503665
]
ASF GitHub Bot commented on FLINK-1758:
---
Github user andralungu commented on the pul
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 t
[
https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503349#comment-14503349
]
Nikolaas Steenbergen commented on FLINK-1907:
-
Hey, I don't know if im doing t
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
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503224#comment-14503224
]
ASF GitHub Bot commented on FLINK-703:
--
Github user chiwanpark commented on the pull r
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`.
*
[
https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503147#comment-14503147
]
ASF GitHub Bot commented on FLINK-1486:
---
Github user mxm commented on the pull reque
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 <- s
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/572#discussion_r28699341
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java
---
@@ -1063,6 +1065,33 @@ public void reduce(Iterable> v
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503030#comment-14503030
]
ASF GitHub Bot commented on FLINK-1799:
---
Github user aljoscha 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-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503018#comment-14503018
]
ASF GitHub Bot commented on FLINK-703:
--
Github user fhueske commented on the pull requ
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 y
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14503011#comment-14503011
]
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_r28697764
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/Keys.java ---
@@ -274,24 +274,31 @@ private static int
countNestedElementsBefore(Compos
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 reduce(Iterable> valu
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502997#comment-14502997
]
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-tabpanel&focusedCommentId=14502998#comment-14502998
]
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_r28696965
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/JoinITCase.java
---
@@ -663,6 +663,39 @@ public void
testNonPojoToVerifyNestedTupl
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
testNonPojoToVerifyNestedTupl
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502995#comment-14502995
]
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_r28696843
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/GroupReduceITCase.java
---
@@ -1063,6 +1065,33 @@ public void reduce(Iterable> valu
[
https://issues.apache.org/jira/browse/FLINK-1867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502967#comment-14502967
]
ASF GitHub Bot commented on FLINK-1867:
---
GitHub user aljoscha opened a pull request:
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 raise-test-t
[
https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502939#comment-14502939
]
Robert Metzger commented on FLINK-1914:
---
I have to admit its not very prominent, but
[
https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502932#comment-14502932
]
Zoltán Zvara commented on FLINK-1914:
-
There is a warn! Thanks!
> Wrong FS while star
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-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502909#comment-14502909
]
Till Rohrmann commented on FLINK-1745:
--
Hi Chiwan and Raghav,
cool that you two want
[
https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502906#comment-14502906
]
ASF GitHub Bot commented on FLINK-1799:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502901#comment-14502901
]
Robert Metzger commented on FLINK-1914:
---
Hi,
thank you for the feedback.
The Yarn cl
[
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-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502900#comment-14502900
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user StephanEwen commented on the pu
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.
U
[
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-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502897#comment-14502897
]
ASF GitHub Bot commented on FLINK-1799:
---
Github user StephanEwen commented on a diff
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-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502885#comment-14502885
]
ASF GitHub Bot commented on FLINK-1758:
---
Github user andralungu commented on the pul
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
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:
- th
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 hav
[
https://issues.apache.org/jira/browse/FLINK-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502870#comment-14502870
]
ASF GitHub Bot commented on FLINK-1906:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502792#comment-14502792
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user DarkKnightCZ commented on a dif
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 manager
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502783#comment-14502783
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user DarkKnightCZ commented on the p
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-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502763#comment-14502763
]
Till Rohrmann commented on FLINK-1746:
--
Hi Raghav, cool that you picked the topic up
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-tabpanel&focusedCommentId=14502736#comment-14502736
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502737#comment-14502737
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/609#issuecomment-9159
As far as I understood it, the goal of the change is to wait until the JM
has been started before starting the TMs.
So the TMs would not start if the JM failed to star
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-tabpanel&focusedCommentId=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-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502733#comment-14502733
]
ASF GitHub Bot commented on FLINK-377:
--
Github user rmetzger commented on the pull req
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
wrote:
> I just ran it on the cluster. Wo
[
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-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502729#comment-14502729
]
ASF GitHub Bot commented on FLINK-377:
--
Github user aljoscha commented on the pull req
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-tabpanel&focusedCommentId=14502728#comment-14502728
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user tillrohrmann commented on the p
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 wrote:
[
https://issues.apache.org/jira/browse/FLINK-1883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502712#comment-14502712
]
ASF GitHub Bot commented on FLINK-1883:
---
Github user andralungu commented on the pul
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 up
[
https://issues.apache.org/jira/browse/FLINK-1871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502694#comment-14502694
]
ASF GitHub Bot commented on FLINK-1871:
---
Github user andralungu commented on the pul
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-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502686#comment-14502686
]
Chiwan Park commented on FLINK-1745:
I suggest a scenario of KNN like following:
{cod
[
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
> ---
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502620#comment-14502620
]
Chiwan Park commented on FLINK-1745:
[~raghav.chalapa...@gmail.com] Hi. We can collabo
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502581#comment-14502581
]
Raghav Chalapathy commented on FLINK-1746:
--
thanks
raghav
> Add linear discrim
[
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
[
https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502580#comment-14502580
]
Robert Metzger commented on FLINK-1746:
---
Hi,
I gave you "Contributor" permissions in
[
https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502576#comment-14502576
]
Raghav Chalapathy commented on FLINK-1746:
--
Hi Till
I would like to start workin
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502562#comment-14502562
]
Raghav Chalapathy commented on FLINK-1745:
--
Hi Chiwan
Would like to colloborate
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502558#comment-14502558
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull reque
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 feat
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502555#comment-14502555
]
ASF GitHub Bot commented on FLINK-377:
--
Github user aljoscha commented on the pull req
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-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502551#comment-14502551
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull reque
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 senten
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502545#comment-14502545
]
ASF GitHub Bot commented on FLINK-377:
--
Github user rmetzger commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502547#comment-14502547
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user tammymendt commented on the pul
Github user tammymendt commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-94401122
Hey, thanks for the quick feedback. I agree with separating the
contribution as a library, however I have a question. The reason I have used a
specialized method in the
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502546#comment-14502546
]
ASF GitHub Bot commented on FLINK-1908:
---
Github user mxm commented on the pull reque
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 to
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502544#comment-14502544
]
ASF GitHub Bot commented on FLINK-377:
--
Github user aljoscha commented on the pull req
1 - 100 of 111 matches
Mail list logo
