[
https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291540#comment-14291540
]
ASF GitHub Bot commented on FLINK-1376:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/317#issuecomment-71423347
I am looking into this right now and testing it locally. Seems to work so
far. Will try to give a vote by tomorrow...
---
If your project is set up for it, you can re
[
https://issues.apache.org/jira/browse/FLINK-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291477#comment-14291477
]
ASF GitHub Bot commented on FLINK-1446:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/336#issuecomment-71416590
+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 have this feature
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/337#issuecomment-71412124
Does this mean that we now have multiple hadoop dependencies in the class
path? The ones that are part of the Flink lib directory, plus the ones in the
HADOOP_CLASSPAT
[
https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291435#comment-14291435
]
ASF GitHub Bot commented on FLINK-1433:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-1451:
--
Description: Currently the streaming FileSourceFunction does not support
parallelism greater tha
Márton Balassi created FLINK-1451:
-
Summary: Enable parallel execution of streaming file sources
Key: FLINK-1451
URL: https://issues.apache.org/jira/browse/FLINK-1451
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-1081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1081.
---
Resolution: Fixed
> Add HDFS file-stream source for streaming
> --
[
https://issues.apache.org/jira/browse/FLINK-1081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291272#comment-14291272
]
ASF GitHub Bot commented on FLINK-1081:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/226
---
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
[
https://issues.apache.org/jira/browse/FLINK-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291265#comment-14291265
]
Max Michels edited comment on FLINK-1424 at 1/25/15 8:52 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291265#comment-14291265
]
Max Michels commented on FLINK-1424:
[~cebe] The commit you mention makes it possible
[
https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1381.
---
Resolution: Fixed
> Only one output splitter supported per operator
>
[
https://issues.apache.org/jira/browse/FLINK-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291217#comment-14291217
]
Robert Metzger commented on FLINK-1447:
---
Cool, thank you for taking a closer look in
[
https://issues.apache.org/jira/browse/FLINK-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1446:
-
Assignee: Robert Metzger
> Make KryoSerializer.createInstance() return new instances inst
[
https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291166#comment-14291166
]
ASF GitHub Bot commented on FLINK-1381:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/332
---
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
[
https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291154#comment-14291154
]
ASF GitHub Bot commented on FLINK-1433:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/337#issuecomment-71378388
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-1448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291142#comment-14291142
]
Rahul Mahindrakar commented on FLINK-1448:
--
Wow you fixed all of them!
Great.
[
https://issues.apache.org/jira/browse/FLINK-1448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1448.
---
Resolution: Fixed
Assignee: Robert Metzger
Resovled in http://svn.apache.org/r1654661
>
[
https://issues.apache.org/jira/browse/FLINK-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291133#comment-14291133
]
ASF GitHub Bot commented on FLINK-1424:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/331#issuecomment-71376859
@mxm: Since you have some experience with the CliFrontend now, would you
mind looking into https://issues.apache.org/jira/browse/FLINK-1424 as well?
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-1428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291132#comment-14291132
]
Robert Metzger commented on FLINK-1428:
---
Would be cool if you could provide a patch
[
https://issues.apache.org/jira/browse/FLINK-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1431.
---
Resolution: Fixed
Resolved in http://svn.apache.org/r1654662
> Add news mailing list to websi
[
https://issues.apache.org/jira/browse/FLINK-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1431:
-
Assignee: Robert Metzger
> Add news mailing list to website
> ---
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/335#issuecomment-71376640
Thank you.
Looks good. History is preserved and you addressed my comments.
+1 for merging it.
---
If your project is set up for it, you can reply to this ema
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291129#comment-14291129
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user rmetzger commented on the pull
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/337
[FLINK-1433] Add HADOOP_CLASSPATH to start scripts
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink FLINK-1433
Alternatively you
[
https://issues.apache.org/jira/browse/FLINK-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291127#comment-14291127
]
ASF GitHub Bot commented on FLINK-1433:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291118#comment-14291118
]
Robert Metzger commented on FLINK-1441:
---
Merged in http://svn.apache.org/r1654660
>
[
https://issues.apache.org/jira/browse/FLINK-1441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291117#comment-14291117
]
Robert Metzger commented on FLINK-1441:
---
Hi Rahul,
thank you for the patch. I'll mer
[
https://issues.apache.org/jira/browse/FLINK-1441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1441:
--
Assignee: Rahul Mahindrakar
> Documentation SVN checkout link is wrong
> ---
[
https://issues.apache.org/jira/browse/FLINK-532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-532.
Resolution: Won't Fix
Thank you. I'm closing the issue.
> (Chained Map) Tasks simply keep in state R
[
https://issues.apache.org/jira/browse/FLINK-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291114#comment-14291114
]
Mathias Peters commented on FLINK-532:
--
I did not encounter this issue anymore in "rec
[
https://issues.apache.org/jira/browse/FLINK-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291109#comment-14291109
]
ASF GitHub Bot commented on FLINK-1446:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/336
[FLINK-1446] Fix Kryo createInstance() method
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink FLINK-1446
Alternatively you can r
[
https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291102#comment-14291102
]
ASF GitHub Bot commented on FLINK-1434:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/334#issuecomment-71374393
Now it is +1 for merge on my side.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1449.
-
Resolution: Duplicate
This is a duplicate of FlINK-1429.
> Extend Streaming guide to include the
Gyula Fora created FLINK-1450:
-
Summary: Add Fold operator to the Streaming api
Key: FLINK-1450
URL: https://issues.apache.org/jira/browse/FLINK-1450
Project: Flink
Issue Type: New Feature
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/335
Add flink-gelly to flink-addons (with commit history)
Hi everyone,
here's the new PR for the graph api.
I have addressed the comments of #326 and looking forward to additional
feedback!
-V.
Gyula Fora created FLINK-1449:
-
Summary: Extend Streaming guide to include the Scala API
Key: FLINK-1449
URL: https://issues.apache.org/jira/browse/FLINK-1449
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-1409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1409.
-
Resolution: Fixed
> Connected datastream functionality broken since the introduction of
> intermediate re
[
https://issues.apache.org/jira/browse/FLINK-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291075#comment-14291075
]
Rahul Mahindrakar commented on FLINK-1447:
--
See these errors. Need to investigat
Rahul Mahindrakar created FLINK-1448:
Summary: Documentation Clone your repository Link is wrong
Key: FLINK-1448
URL: https://issues.apache.org/jira/browse/FLINK-1448
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291065#comment-14291065
]
Robert Metzger commented on FLINK-1447:
---
On the Ubuntu Firefox browser, can you acti
[
https://issues.apache.org/jira/browse/FLINK-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rahul Mahindrakar updated FLINK-1447:
-
Attachment: Capture.PNG
I cannot see this with my Ubuntu 14.04 firefox browser. This is v
[
https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291061#comment-14291061
]
Robert Metzger commented on FLINK-629:
--
I'll track the fix here: https://issues.apache
Robert Metzger created FLINK-1446:
-
Summary: Make KryoSerializer.createInstance() return new instances
instead of null
Key: FLINK-1446
URL: https://issues.apache.org/jira/browse/FLINK-1446
Project: Fl
Rahul Mahindrakar created FLINK-1447:
Summary: Flink Web Submission Client does not work on Ubuntu 14.04
firefox browser
Key: FLINK-1447
URL: https://issues.apache.org/jira/browse/FLINK-1447
Proje
[
https://issues.apache.org/jira/browse/FLINK-629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291060#comment-14291060
]
Robert Metzger commented on FLINK-629:
--
Cool. I'm glad its working. I'll push the fix
[
https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291048#comment-14291048
]
ASF GitHub Bot commented on FLINK-1434:
---
Github user gyfora commented on a diff in t
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/334#discussion_r23503616
--- Diff: flink-addons/flink-streaming/flink-streaming-core/pom.xml ---
@@ -48,6 +48,12 @@ under the License.
${project.version}
[
https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291047#comment-14291047
]
ASF GitHub Bot commented on FLINK-1434:
---
Github user gyfora commented on a diff in t
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/334#discussion_r23503611
--- Diff:
flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamGraph.java
---
@@ -536,4 +549,79 @@ public long
[
https://issues.apache.org/jira/browse/FLINK-1441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291044#comment-14291044
]
Max Michels commented on FLINK-1441:
Thank you, we will merge this as soon as possible
[
https://issues.apache.org/jira/browse/FLINK-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291043#comment-14291043
]
ASF GitHub Bot commented on FLINK-1330:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/333#issuecomment-71366786
This looks good.
---
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
ena
[
https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291042#comment-14291042
]
ASF GitHub Bot commented on FLINK-1434:
---
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/334#discussion_r23503540
--- Diff:
flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamGraph.java
---
@@ -536,4 +549,79 @@ public lon
[
https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291041#comment-14291041
]
ASF GitHub Bot commented on FLINK-1434:
---
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/334#discussion_r23503538
--- Diff: flink-addons/flink-streaming/flink-streaming-core/pom.xml ---
@@ -48,6 +48,12 @@ under the License.
${project.version}
[
https://issues.apache.org/jira/browse/FLINK-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291040#comment-14291040
]
ASF GitHub Bot commented on FLINK-1389:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/301#issuecomment-71366480
Okay. Let me implement a different approach that allows users to overwrite
a method to put anything they want for the file name.
---
If your project is set up for it, yo
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/301#issuecomment-71366397
To be honest, I find this additional option more confusing than helpful.
---
If your project is set up for it, you can reply to this email and have your
reply appear on G
[
https://issues.apache.org/jira/browse/FLINK-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291039#comment-14291039
]
ASF GitHub Bot commented on FLINK-1389:
---
Github user fhueske commented on the pull r
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/301#issuecomment-71366256
The only reason why I added the two variants is that I want to give users
freedom to choose between these two variants. Its one more line of code that
might (someday) mak
[
https://issues.apache.org/jira/browse/FLINK-1389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291038#comment-14291038
]
ASF GitHub Bot commented on FLINK-1389:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291033#comment-14291033
]
Robert Metzger commented on FLINK-1444:
---
I've prototyped something like this here:
[
https://issues.apache.org/jira/browse/FLINK-1330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14291031#comment-14291031
]
ASF GitHub Bot commented on FLINK-1330:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/333#issuecomment-71365114
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 an
73 matches
Mail list logo
