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
[
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
[
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-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
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=14291039#comment-14291039
]
ASF GitHub Bot commented on FLINK-1389:
---
Github user fhueske commented on the pull r
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
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
[
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 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-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_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=14291042#comment-14291042
]
ASF GitHub Bot commented on FLINK-1434:
---
Github user rmetzger commented on a diff in
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-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
[
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-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
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=14291048#comment-14291048
]
ASF GitHub Bot commented on FLINK-1434:
---
Github user gyfora commented on a diff in t
[
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
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=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
[
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-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
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=14291075#comment-14291075
]
Rahul Mahindrakar commented on FLINK-1447:
--
See these errors. Need to investigat
[
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
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
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-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
[
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
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-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 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-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:
[
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-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-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-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: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-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:
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-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 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-1431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1431:
-
Assignee: Robert Metzger
> Add news mailing list to website
> ---
[
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-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
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-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
[
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-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.
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-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 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-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
[
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-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-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-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-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:
-
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-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
[
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
> --
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-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
[
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
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
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
[
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/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-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
73 matches
Mail list logo
