Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/457
---
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-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14349652#comment-14349652
]
ASF GitHub Bot commented on FLINK-1628:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/458
[FLINK-1628] Fix partitioning properties for Joins and CoGroups.
Fix partitioning properties for Joins and CoGroups and some smaller bugs on
the way.
You can merge this pull request into a Git repos
[
https://issues.apache.org/jira/browse/FLINK-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14349592#comment-14349592
]
Henry Saputra commented on FLINK-1651:
--
Here is the JStack of the hang process in my
[
https://issues.apache.org/jira/browse/FLINK-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14349592#comment-14349592
]
Henry Saputra edited comment on FLINK-1651 at 3/5/15 11:11 PM:
-
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/457#issuecomment-77469917
Thx @tillrohrmann, @uce for the review!
Will merge once it passes the build
---
If your project is set up for it, you can reply to this email and have your
reply appe
Gyula Fora created FLINK-1655:
-
Summary: Rename StreamInvokable to StreamOperator
Key: FLINK-1655
URL: https://issues.apache.org/jira/browse/FLINK-1655
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1640.
--
Resolution: Fixed
Fixed by 8f321c7299155990d4e4341f3831a843535219e8
> FileOutputFormat writes t
[
https://issues.apache.org/jira/browse/FLINK-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14349165#comment-14349165
]
ASF GitHub Bot commented on FLINK-1640:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/453
---
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-1572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348807#comment-14348807
]
Robert Metzger commented on FLINK-1572:
---
How about removing the files of a failed jo
[
https://issues.apache.org/jira/browse/FLINK-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu reassigned FLINK-1632:
--
Assignee: Andra Lungu
> Use DataSet's count() and collect() to simplify Gelly methods
> ---
[
https://issues.apache.org/jira/browse/FLINK-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-1429:
-
Assignee: Márton Balassi
> Add documentation for streaming scala api
> --
[
https://issues.apache.org/jira/browse/FLINK-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348723#comment-14348723
]
Robert Metzger commented on FLINK-1414:
---
I think the best approach here is to lazily
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348716#comment-14348716
]
ASF GitHub Bot commented on FLINK-1637:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/450#issuecomment-77361454
Well. I'm reducing the number of files because its a good idea in general
to remove the `flink-hbase` and `flink-streaming-connectors` from dist.
And I'm going to cha
[
https://issues.apache.org/jira/browse/FLINK-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348714#comment-14348714
]
Robert Metzger commented on FLINK-1642:
---
As per offline discussion with [~till.rohrm
[
https://issues.apache.org/jira/browse/FLINK-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1642.
---
Resolution: Invalid
> Flakey YARNSessionCapacitySchedulerITCase
>
[
https://issues.apache.org/jira/browse/FLINK-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1649.
-
Resolution: Fixed
Fixed via 482766e949d69e282ed862bd97f2a8378b2f699e
> Give a good error message
[
https://issues.apache.org/jira/browse/FLINK-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348707#comment-14348707
]
Robert Metzger commented on FLINK-1601:
---
The errors reported by Till in the comment
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348710#comment-14348710
]
ASF GitHub Bot commented on FLINK-1650:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1650.
-
Resolution: Fixed
Fixed via eae2166dd6cce5651d9bea4fdc2f8ac6a176841a
> Suppress Akka's Netty Shut
[
https://issues.apache.org/jira/browse/FLINK-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1601.
---
Resolution: Cannot Reproduce
> Sometimes the YARNSessionFIFOITCase fails on Travis
> -
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348709#comment-14348709
]
ASF GitHub Bot commented on FLINK-1650:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348708#comment-14348708
]
ASF GitHub Bot commented on FLINK-1649:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/455
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/455#issuecomment-77360696
I addressed your comments and merged the pull request.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/456
---
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-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Péter Szabó reassigned FLINK-1595:
--
Assignee: Péter Szabó
> Add a complex integration test for Streaming API
>
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348700#comment-14348700
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-77358774
Those are very good points! Having an annotation for POJO fields to define
their order in the PojoTypeInfo (and therefore the order in which the fields
are mapped to CSV f
[
https://issues.apache.org/jira/browse/FLINK-1601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348685#comment-14348685
]
Stephan Ewen commented on FLINK-1601:
-
[~rmetzger] Any insight where this may come fro
[
https://issues.apache.org/jira/browse/FLINK-1572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348675#comment-14348675
]
Stephan Ewen commented on FLINK-1572:
-
Can we always remove the output directory? What
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348616#comment-14348616
]
ASF GitHub Bot commented on FLINK-1512:
---
Github user teabot commented on the pull re
Github user teabot commented on the pull request:
https://github.com/apache/flink/pull/426#issuecomment-77347164
I like that this request adds what I would consider to be a very useful
feature. Data is often stored in text delimited formats and one of the nice
features of Flink is the
[
https://issues.apache.org/jira/browse/FLINK-1627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348596#comment-14348596
]
Ufuk Celebi commented on FLINK-1627:
I ran 20 builds on Travis over night, all of whic
[
https://issues.apache.org/jira/browse/FLINK-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348594#comment-14348594
]
ASF GitHub Bot commented on FLINK-1605:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/454#issuecomment-77344732
I know, the stuff is very complicated.
I've documented the setup here:
https://cwiki.apache.org/confluence/display/FLINK/Dependency+Shading+in+Flink
Please le
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348592#comment-14348592
]
ASF GitHub Bot commented on FLINK-1637:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/450#issuecomment-77344362
I am confused. Which change do you mean? My understanding was the
following: we are going to build with openjdk6 to resolve the issue *instead*
of reducing the number of files
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348591#comment-14348591
]
ASF GitHub Bot commented on FLINK-1637:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/450#issuecomment-77344029
No, the change is not yet merged to master and there is an unresolved issue
with it.
The affected user needs the feature until next Tuesday .. so I have a few
da
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348589#comment-14348589
]
ASF GitHub Bot commented on FLINK-1637:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/450#issuecomment-77343809
I agree. Reducing the number of files would just postpone the problem
anyways.
This PR can be closed then, right?
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348585#comment-14348585
]
Robert Metzger commented on FLINK-1166:
---
TODO: add a check which checks out a quicks
[
https://issues.apache.org/jira/browse/FLINK-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348547#comment-14348547
]
ASF GitHub Bot commented on FLINK-1649:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348548#comment-14348548
]
ASF GitHub Bot commented on FLINK-1649:
---
Github user uce commented on the pull reque
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/456#discussion_r25853770
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/shipping/OutputCollector.java
---
@@ -49,50 +48,33 @@
* @param writers List of a
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/456#issuecomment-77341364
:1 looks good. I think we should merge this to master and release-0.8.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348543#comment-14348543
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/408#issuecomment-77341085
Not sure why the last Travis check failed because the pom.xml seems to be
the correct one.
But apart from that, this looks very nice and compliant with the vert
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/457#issuecomment-77340443
+1 good 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
ena
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348538#comment-14348538
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user andralungu commented on a diff
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/408#discussion_r25853291
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java
---
@@ -0,0 +1,374 @@
+/*
+ * Licensed to
Github user andralungu commented on a diff in the pull request:
https://github.com/apache/flink/pull/408#discussion_r25852832
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSAGreedyGraphColoringExample.java
---
@@ -0,0 +1,212 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348530#comment-14348530
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user andralungu commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348521#comment-14348521
]
ASF GitHub Bot commented on FLINK-1650:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/455#issuecomment-77337668
+1, as well. I agree with Till regarding the log4j-test file. If you add it
there as well, don't forget to add it to `tools/log4j-travis.log` as well.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-1370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348473#comment-14348473
]
Maximilian Michels commented on FLINK-1370:
---
By the way, here is a shortcut to t
[
https://issues.apache.org/jira/browse/FLINK-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348461#comment-14348461
]
Maximilian Michels commented on FLINK-1648:
---
+1
Very useful if you want to run
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348378#comment-14348378
]
ASF GitHub Bot commented on FLINK-1587:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348375#comment-14348375
]
ASF GitHub Bot commented on FLINK-1587:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348376#comment-14348376
]
ASF GitHub Bot commented on FLINK-1587:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/440#discussion_r25846333
--- Diff:
flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/DegreesWithExceptionITCase.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licen
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/440#discussion_r25846311
--- Diff:
flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/DegreesWithExceptionITCase.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licen
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/440#discussion_r25846323
--- Diff:
flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/DegreesWithExceptionITCase.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348373#comment-14348373
]
ASF GitHub Bot commented on FLINK-1587:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348370#comment-14348370
]
ASF GitHub Bot commented on FLINK-1512:
---
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/426#discussion_r25846058
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java ---
@@ -64,15 +66,25 @@
private transient int commentCount;
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/440#issuecomment-77324311
Hi Andra, if you are using ```print()``` only because you need a sink in
your job, then I think you could also use ```dataset.output(new
DiscardingOutputFormat())```.
[
https://issues.apache.org/jira/browse/FLINK-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348353#comment-14348353
]
ASF GitHub Bot commented on FLINK-1650:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/455#issuecomment-77322274
Maybe we should also turn off the DefaultChannelPipeline in the
log4j-test.properties files, which don't turn logging off, if we don't want the
```RejectedExecutionEx
[
https://issues.apache.org/jira/browse/FLINK-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14348345#comment-14348345
]
Chiwan Park commented on FLINK-1654:
[~aljoscha] Okay, I will send a pull request with
73 matches
Mail list logo
