[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

2015-04-17 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500478#comment-14500478 ] Henry Saputra commented on FLINK-1320: -- Hi Niraj, no worries, just misunderstanding =

[GitHub] flink pull request: [docs] Change doc layout

2015-04-17 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/606#issuecomment-94047840 +1 Love 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 this feature enab

[jira] [Commented] (FLINK-1907) Scala Interactive Shell

2015-04-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500372#comment-14500372 ] Robert Metzger commented on FLINK-1907: --- Hey [~nikst], I gave you "Contributor" per

[jira] [Updated] (FLINK-1907) Scala Interactive Shell

2015-04-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1907: -- Assignee: Nikolaas Steenbergen > Scala Interactive Shell > --- > >

[GitHub] flink pull request: [docs] Change doc layout

2015-04-17 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/606#issuecomment-94044855 It looks much better. I'm +1 for merging it immediately like this. Once its merged, I would propose to make some minor changes: - The "beta" badge is not separate

[GitHub] flink pull request: [FLINK-1900] add missing '

2015-04-17 Thread FelixNeutatz
Github user FelixNeutatz closed the pull request at: https://github.com/apache/flink/pull/608 --- 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

[jira] [Commented] (FLINK-1900) Table API documentation example does not work

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500288#comment-14500288 ] ASF GitHub Bot commented on FLINK-1900: --- Github user FelixNeutatz closed the pull re

[GitHub] flink pull request: [docs] Change doc layout

2015-04-17 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/606#issuecomment-94031487 I like the new docs layout :-) --- 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 no

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500183#comment-14500183 ] ASF GitHub Bot commented on FLINK-1820: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-1820] CSVReader: In case of an empty st...

2015-04-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r28610833 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java --- @@ -42,6 +42,10 @@ public int parseField(byte[] bytes, int startPos, int

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500181#comment-14500181 ] ASF GitHub Bot commented on FLINK-1820: --- Github user fhueske commented on a diff in

[GitHub] flink pull request: [FLINK-1820] CSVReader: In case of an empty st...

2015-04-17 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r28610838 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java --- @@ -41,6 +41,10 @@ public int parseField(byte[] bytes, int startPos, int

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500174#comment-14500174 ] ASF GitHub Bot commented on FLINK-1820: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500175#comment-14500175 ] ASF GitHub Bot commented on FLINK-1820: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500176#comment-14500176 ] ASF GitHub Bot commented on FLINK-1820: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-1820] CSVReader: In case of an empty st...

2015-04-17 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r28610575 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/LongParser.java --- @@ -33,6 +33,19 @@ public int parseField(byte[] bytes, int startPos, int limi

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500172#comment-14500172 ] ASF GitHub Bot commented on FLINK-1820: --- Github user mxm commented on a diff in the

[GitHub] flink pull request: [FLINK-1820] CSVReader: In case of an empty st...

2015-04-17 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r28610548 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java --- @@ -49,7 +53,7 @@ public int parseField(byte[] bytes, int startPos, int lim

[GitHub] flink pull request: [FLINK-1820] CSVReader: In case of an empty st...

2015-04-17 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r28610571 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java --- @@ -37,7 +37,20 @@ public int parseField(byte[] bytes, int startPos, int limit

[GitHub] flink pull request: [FLINK-1820] CSVReader: In case of an empty st...

2015-04-17 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r28610577 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/ShortParser.java --- @@ -36,7 +36,20 @@ public int parseField(byte[] bytes, int startPos, int lim

[GitHub] flink pull request: [FLINK-1820] CSVReader: In case of an empty st...

2015-04-17 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/566#discussion_r28610554 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java --- @@ -48,7 +52,7 @@ public int parseField(byte[] bytes, int startPos, int limi

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500173#comment-14500173 ] ASF GitHub Bot commented on FLINK-1820: --- Github user mxm commented on a diff in the

[jira] [Created] (FLINK-1907) Scala Interactive Shell

2015-04-17 Thread Nikolaas Steenbergen (JIRA)
Nikolaas Steenbergen created FLINK-1907: --- Summary: Scala Interactive Shell Key: FLINK-1907 URL: https://issues.apache.org/jira/browse/FLINK-1907 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500123#comment-14500123 ] ASF GitHub Bot commented on FLINK-1514: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-04-17 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/408#issuecomment-94020543 Thanks @balidani! I'll try to review asap :-) --- 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

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

2015-04-17 Thread niraj rai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500113#comment-14500113 ] niraj rai commented on FLINK-1320: -- Hi Henry, Sorry for breaking protocol of the project

[jira] [Commented] (FLINK-1900) Table API documentation example does not work

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500098#comment-14500098 ] ASF GitHub Bot commented on FLINK-1900: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [FLINK-1900] add missing '

2015-04-17 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/608#issuecomment-94017417 Didn't autoclose, could you please close it manually @FelixNeutatz? Thanks. --- If your project is set up for it, you can reply to this email and have your reply appear o

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500085#comment-14500085 ] ASF GitHub Bot commented on FLINK-1514: --- Github user balidani commented on the pull

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-04-17 Thread balidani
Github user balidani commented on the pull request: https://github.com/apache/flink/pull/408#issuecomment-94015915 Okay, I updated the PR and Travis passed. --- 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

[GitHub] flink pull request: [FLINK-1885] [gelly] Added bulk execution mode...

2015-04-17 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/598#issuecomment-94013714 Aha I see! I totally misunderstood your intention :-) I'll take a look as soon as I finish a few more reviews. Thanks! --- If your project is set up for it, you can repl

[jira] [Commented] (FLINK-1885) Bulk mode for gelly

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500077#comment-14500077 ] ASF GitHub Bot commented on FLINK-1885: --- Github user vasia commented on the pull req

[GitHub] flink pull request: Ml branch

2015-04-17 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/579#issuecomment-94012543 Three minor comments. Otherwise it looks really good :-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[GitHub] flink pull request: Ml branch

2015-04-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r28605175 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala --- @@ -0,0 +1,177 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

2015-04-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r28605215 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala --- @@ -0,0 +1,177 @@ +/* + * Licensed to

[GitHub] flink pull request: Ml branch

2015-04-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/579#discussion_r28605205 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala --- @@ -0,0 +1,177 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-1885) Bulk mode for gelly

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14500024#comment-14500024 ] ASF GitHub Bot commented on FLINK-1885: --- Github user markus-h commented on the pull

[GitHub] flink pull request: [FLINK-1885] [gelly] Added bulk execution mode...

2015-04-17 Thread markus-h
Github user markus-h commented on the pull request: https://github.com/apache/flink/pull/598#issuecomment-94008273 Hi @vasia, thanks for your comments! I thought about this extension in a different way. Whenever you have a graph that is too big to process it with delta iteration y

[jira] [Commented] (FLINK-1885) Bulk mode for gelly

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499949#comment-14499949 ] ASF GitHub Bot commented on FLINK-1885: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-1885] [gelly] Added bulk execution mode...

2015-04-17 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/598#issuecomment-94002207 Hi @markus-h! I see the point in having a bulk iteration in Gelly, however I'm not sure I would add it as a "mode" in vertex-centric iteration. VertexCentricIteration im

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

2015-04-17 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499913#comment-14499913 ] Henry Saputra commented on FLINK-1320: -- Understood =) Sorry, I was not trying to impl

[jira] [Updated] (FLINK-1320) Add an off-heap variant of the managed memory

2015-04-17 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra updated FLINK-1320: - Assignee: niraj rai (was: Maximilian Michels) > Add an off-heap variant of the managed memory > -

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

2015-04-17 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499898#comment-14499898 ] Maximilian Michels commented on FLINK-1320: --- Absolutely, let's keep it open. We

[jira] [Commented] (FLINK-1758) Extend Gelly's neighborhood methods

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499896#comment-14499896 ] ASF GitHub Bot commented on FLINK-1758: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-1758][gelly] Neighborhood Methods Exten...

2015-04-17 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/576#issuecomment-93996607 Hi @andralungu! Thanks for the quick update ^^ The result looks good, but I have a few more comments/suggestions (apart from the inline ones). - +1 for the `grou

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

2015-04-17 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499884#comment-14499884 ] Henry Saputra commented on FLINK-1320: -- Ah ok, thanks for the update [~mxm], let's ke

[jira] [Commented] (FLINK-1875) Add figure to documentation describing slots and parallelism

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499877#comment-14499877 ] ASF GitHub Bot commented on FLINK-1875: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1875] Add figure explaining slots and p...

2015-04-17 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/604#issuecomment-93993725 The issue seems to be fixed --- 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

[jira] [Closed] (FLINK-1887) Fix the message in runtime exception

2015-04-17 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-1887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-1887. - Resolution: Fixed Fix Version/s: 0.9 Fixed via f7ec859. > Fix the message in runtime excep

[GitHub] flink pull request: fixed a few typos in internal_general_arch.md

2015-04-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/602 --- 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 enabl

[jira] [Commented] (FLINK-1887) Fix the message in runtime exception

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499862#comment-14499862 ] ASF GitHub Bot commented on FLINK-1887: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-1887]Fix the message in runtime excepti...

2015-04-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/599 --- 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 enabl

[jira] [Commented] (FLINK-1670) Collect method for streaming

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499860#comment-14499860 ] ASF GitHub Bot commented on FLINK-1670: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1670] Made DataStream iterable

2015-04-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/581#issuecomment-93991530 What about reworking this as a library function and add it to flink-contrib? Make this a special streaming sink and a local util that is used in the program that recei

[GitHub] flink pull request: [FLINK-1758][gelly] Neighborhood Methods Exten...

2015-04-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/576#discussion_r28594561 --- Diff: docs/gelly_guide.md --- @@ -316,28 +327,49 @@ DataSet> verticesWithSum = graph.reduceOnNeighbors( new SumValues(), Edge

[GitHub] flink pull request: [FLINK-1758][gelly] Neighborhood Methods Exten...

2015-04-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/576#discussion_r28595115 --- Diff: flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/EdgeDirection.java --- @@ -20,10 +20,10 @@ /** * The EdgeDirection is

[jira] [Commented] (FLINK-1758) Extend Gelly's neighborhood methods

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499854#comment-14499854 ] ASF GitHub Bot commented on FLINK-1758: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-1758) Extend Gelly's neighborhood methods

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499844#comment-14499844 ] ASF GitHub Bot commented on FLINK-1758: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-1891) Add isEmpty check when the input dir

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499851#comment-14499851 ] ASF GitHub Bot commented on FLINK-1891: --- Github user matadorhong commented on a diff

[GitHub] flink pull request: [FLINK-1891]Add the input storageDirectory emp...

2015-04-17 Thread matadorhong
Github user matadorhong commented on a diff in the pull request: https://github.com/apache/flink/pull/601#discussion_r28594789 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java --- @@ -64,15 +64,19 @@ * @return the storage directory used by

[jira] [Commented] (FLINK-1758) Extend Gelly's neighborhood methods

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499846#comment-14499846 ] ASF GitHub Bot commented on FLINK-1758: --- Github user vasia commented on a diff in th

[GitHub] flink pull request: [FLINK-1670] Made DataStream iterable

2015-04-17 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/581#issuecomment-93988704 @ggevay this PR has been a bit quiet lately, what do you think about the comments? --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-1670) Collect method for streaming

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499845#comment-14499845 ] ASF GitHub Bot commented on FLINK-1670: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [FLINK-1758][gelly] Neighborhood Methods Exten...

2015-04-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/576#discussion_r28594425 --- Diff: docs/gelly_guide.md --- @@ -282,25 +290,28 @@ The following code will collect the out-edges for each vertex and apply the `Sel {% highlight java %

[jira] [Commented] (FLINK-1758) Extend Gelly's neighborhood methods

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499841#comment-14499841 ] ASF GitHub Bot commented on FLINK-1758: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-1887) Fix the message in runtime exception

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499840#comment-14499840 ] ASF GitHub Bot commented on FLINK-1887: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [FLINK-1758][gelly] Neighborhood Methods Exten...

2015-04-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/576#discussion_r28594318 --- Diff: docs/gelly_guide.md --- @@ -282,25 +290,28 @@ The following code will collect the out-edges for each vertex and apply the `Sel {% highlight java %

[GitHub] flink pull request: fixed a few typos in internal_general_arch.md

2015-04-17 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/602#issuecomment-93988336 Merging. --- 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 enable

[GitHub] flink pull request: [FLINK-1887]Fix the message in runtime excepti...

2015-04-17 Thread mbalassi
Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/599#issuecomment-93988402 Merging. --- 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 enable

[GitHub] flink pull request: [FLINK-1758][gelly] Neighborhood Methods Exten...

2015-04-17 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/576#discussion_r28594064 --- Diff: docs/gelly_guide.md --- @@ -269,7 +269,15 @@ Neighborhood Methods Neighborhood methods allow vertices to perform an aggregation on their fir

[jira] [Commented] (FLINK-1758) Extend Gelly's neighborhood methods

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499837#comment-14499837 ] ASF GitHub Bot commented on FLINK-1758: --- Github user vasia commented on a diff in th

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499835#comment-14499835 ] ASF GitHub Bot commented on FLINK-1297: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-04-17 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/605#issuecomment-93987722 +1 for Stephans suggestion to make it a library in flink-contrib. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499833#comment-14499833 ] ASF GitHub Bot commented on FLINK-1297: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-04-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/605#discussion_r28593902 --- Diff: flink-core/pom.xml --- @@ -63,6 +63,19 @@ under the License. guava ${guava.version}

[jira] [Commented] (FLINK-1885) Bulk mode for gelly

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499830#comment-14499830 ] ASF GitHub Bot commented on FLINK-1885: --- Github user markus-h commented on the pull

[GitHub] flink pull request: [FLINK-1885] [gelly] Added bulk execution mode...

2015-04-17 Thread markus-h
Github user markus-h commented on the pull request: https://github.com/apache/flink/pull/598#issuecomment-93987347 There is no specific usecase, but when you try to process big graphs locally you often run out of memory with delta iterations. But the reason I needed this change is

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499816#comment-14499816 ] ASF GitHub Bot commented on FLINK-1297: --- Github user tammymendt commented on a diff

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499815#comment-14499815 ] ASF GitHub Bot commented on FLINK-1297: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-04-17 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/605#discussion_r28593066 --- Diff: flink-core/pom.xml --- @@ -63,6 +63,19 @@ under the License. guava ${guava.version}

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-04-17 Thread tammymendt
Github user tammymendt commented on a diff in the pull request: https://github.com/apache/flink/pull/605#discussion_r28593077 --- Diff: flink-core/pom.xml --- @@ -63,6 +63,19 @@ under the License. guava ${guava.version}

[jira] [Commented] (FLINK-1885) Bulk mode for gelly

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499810#comment-14499810 ] ASF GitHub Bot commented on FLINK-1885: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1885] [gelly] Added bulk execution mode...

2015-04-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/598#issuecomment-93985063 Interesting idea. Are there use cases that require that, or is that basically to allow for an easy comparison of the bulk vs delta performance? --- If your project is

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-04-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/605#issuecomment-93984865 I think this is nice work. It would be easier to add and maintain this, if it were not hardwired into the core flink classes, but if we could make this like a

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499809#comment-14499809 ] ASF GitHub Bot commented on FLINK-1297: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [docs] Change doc layout

2015-04-17 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/606#issuecomment-93984370 Very difficult to visualize all the changes with screenshots but it takes a few seconds to build the website. From your Flink source directory: `git fetch https://gith

[jira] [Commented] (FLINK-1856) Add required imports to Scala API examples

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499792#comment-14499792 ] ASF GitHub Bot commented on FLINK-1856: --- Github user aljoscha commented on the pull

[jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499790#comment-14499790 ] ASF GitHub Bot commented on FLINK-1297: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-1856][doc] Add notice about implicit Ty...

2015-04-17 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/591#issuecomment-93983053 Not without a lot of changes because TypeInformation is not defined in Scala. I could change every occurrence of TypeInformation in the Scala API by something li

[GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo...

2015-04-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/605#discussion_r28591824 --- Diff: flink-core/pom.xml --- @@ -63,6 +63,19 @@ under the License. guava ${guava.version}

[GitHub] flink pull request: [docs] Change doc layout

2015-04-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/606#issuecomment-93982293 Is there a way a preview version uploaded somewhere, or a screenshot, or do I need to build the docs myself? --- If your project is set up for it, you can reply to th

[GitHub] flink pull request: [FLINK-1856][doc] Add notice about implicit Ty...

2015-04-17 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/591#issuecomment-93981945 Is there a way to improve the Scala Compiler's error message as well? Via an annotation: http://www.scala-lang.org/api/2.11.5/index.html#scala.annotation.implicitNotFo

[jira] [Commented] (FLINK-1856) Add required imports to Scala API examples

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499783#comment-14499783 ] ASF GitHub Bot commented on FLINK-1856: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-1799) Scala API does not support generic arrays

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499772#comment-14499772 ] ASF GitHub Bot commented on FLINK-1799: --- Github user aljoscha commented on the pull

[GitHub] flink pull request: [FLINK-1799][scala] Fix handling of generic ar...

2015-04-17 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/582#issuecomment-93980529 I added the test case @tillrohrmann suggested. Also helped me find a bug. :relieved: --- If your project is set up for it, you can reply to this email and have your repl

[jira] [Commented] (FLINK-1890) Add withReadFields or sth. similar to Scala API

2015-04-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499758#comment-14499758 ] Stephan Ewen commented on FLINK-1890: - I think the {{readFields}} are not evaluated by

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-04-17 Thread balidani
Github user balidani commented on the pull request: https://github.com/apache/flink/pull/408#issuecomment-93977860 Hi @andralungu! I just talked to Vasia, and I'll do a rebase today. Cheers! --- If your project is set up for it, you can reply to this email and have your r

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499749#comment-14499749 ] ASF GitHub Bot commented on FLINK-1514: --- Github user balidani commented on the pull

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

2015-04-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499726#comment-14499726 ] ASF GitHub Bot commented on FLINK-1514: --- Github user andralungu commented on the pul

[GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite...

2015-04-17 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/408#issuecomment-93975508 Hi @balidani :) This PR has not been updated in a while now. Are you facing any issues? In that case I would like to help. Otherwise, if you're busy maybe it ma

  1   2   >