GitHub user hsaputra opened a pull request:
https://github.com/apache/flink/pull/443
Fix typos in iterations.md file
-) Remove extra "solution" word.
-) Change propagete to propagate.
You can merge this pull request into a Git repository by running:
$ git pull https://gith
[
https://issues.apache.org/jira/browse/FLINK-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340357#comment-14340357
]
ASF GitHub Bot commented on FLINK-1615:
---
GitHub user Elbehery opened a pull request:
GitHub user Elbehery opened a pull request:
https://github.com/apache/flink/pull/442
[FLINK-1615] [java api] SimpleTweetInputFormat
This is a contribution with a TweetInputFormat, Jira
[FLINK-1615](https://issues.apache.org/jira/browse/FLINK-1615).
This commit contains, the
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/210
---
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-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340266#comment-14340266
]
ASF GitHub Bot commented on FLINK-1219:
---
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/189#discussion_r25512719
--- Diff:
flink-staging/flink-tez/src/main/java/org/apache/flink/tez/client/RemoteTezEnvironment.java
---
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the Ap
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/189#discussion_r25512682
--- Diff:
flink-staging/flink-tez/src/main/java/org/apache/flink/tez/client/RemoteTezEnvironment.java
---
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340267#comment-14340267
]
ASF GitHub Bot commented on FLINK-1219:
---
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/189#discussion_r25512269
--- Diff: flink-staging/flink-tez/pom.xml ---
@@ -0,0 +1,159 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSche
[
https://issues.apache.org/jira/browse/FLINK-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340263#comment-14340263
]
ASF GitHub Bot commented on FLINK-1219:
---
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/189#discussion_r25512228
--- Diff: flink-staging/flink-tez/pom.xml ---
@@ -0,0 +1,159 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSche
[
https://issues.apache.org/jira/browse/FLINK-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340264#comment-14340264
]
ASF GitHub Bot commented on FLINK-1219:
---
Github user rmetzger commented on a diff in
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/210#issuecomment-76408746
If there are no objections, I will merge this once Travis passes.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
Vasia Kalavri created FLINK-1616:
Summary: Action "list -r" gives IOException when there are running
jobs
Key: FLINK-1616
URL: https://issues.apache.org/jira/browse/FLINK-1616
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340225#comment-14340225
]
ASF GitHub Bot commented on FLINK-1219:
---
Github user ktzoumas commented on the pull
Github user ktzoumas commented on the pull request:
https://github.com/apache/flink/pull/189#issuecomment-76407035
I tested this on a 25-node cluster with WordCount and the modified TPC-H
query on generated TPC-H data of scale 1000. I also added docs.
---
If your project is set up f
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340151#comment-14340151
]
ASF GitHub Bot commented on FLINK-1587:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/440#issuecomment-76399944
Thanks for the revision @andralungu! Looks 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
[
https://issues.apache.org/jira/browse/FLINK-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-1569:
---
Assignee: Aljoscha Krettek
> Object reuse mode is not working with KeySelector functi
[
https://issues.apache.org/jira/browse/FLINK-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340116#comment-14340116
]
Max Michels commented on FLINK-1610:
It works with Java 8 if you remove the test scope
[
https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340111#comment-14340111
]
ASF GitHub Bot commented on FLINK-1528:
---
Github user balidani commented on the pull
Github user balidani commented on the pull request:
https://github.com/apache/flink/pull/420#issuecomment-76391973
I made the changes @vasia suggested
---
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 n
[
https://issues.apache.org/jira/browse/FLINK-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340093#comment-14340093
]
Max Michels commented on FLINK-1610:
Seems to be a Java 8 related issue. It builds fin
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/210#issuecomment-76385275
I moved the `writeInto(ByteBuf buf)` method to the subclasses of
`AbstractID` used by `NettyMessage`. This is the only context where the method
is being used and the subclasse
GitHub user balidani opened a pull request:
https://github.com/apache/flink/pull/441
[FLINK-1522][FLINK-1576] Updated LabelPropagationExample and test
Hi!
I converted the Label Propagation example to the conventional format, where
the main program takes (optional) arguments
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14340005#comment-14340005
]
ASF GitHub Bot commented on FLINK-1522:
---
GitHub user balidani opened a pull request:
mustafa elbehery created FLINK-1615:
---
Summary: Introduces a new InputFormat for Tweets
Key: FLINK-1615
URL: https://issues.apache.org/jira/browse/FLINK-1615
Project: Flink
Issue Type: New F
Robert Metzger created FLINK-1614:
-
Summary: JM Webfrontend doesn't always show the correct state of
Tasks
Key: FLINK-1614
URL: https://issues.apache.org/jira/browse/FLINK-1614
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14339918#comment-14339918
]
Robert Metzger commented on FLINK-1613:
---
How about removing the {{createRemoteEnviro
29 matches
Mail list logo
