[
https://issues.apache.org/jira/browse/FLINK-1103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi resolved FLINK-1103.
---
Resolution: Fixed
Resolved here:
https://github.com/apache/incubator-flink/commit/97a7322f039c
Márton Balassi created FLINK-1140:
-
Summary: Add a flatmap that returns an Iterable instead of
aggregation to a collector
Key: FLINK-1140
URL: https://issues.apache.org/jira/browse/FLINK-1140
Project
Github user fhueske closed the pull request at:
https://github.com/apache/incubator-flink/pull/136
---
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 featu
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/142#discussion_r18546835
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -318,7 +328,7 @@
* Default number of seconds
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/143#discussion_r18539170
--- Diff:
flink-addons/flink-hadoop-compatibility/src/test/java/org/apache/flink/test/hadoopcompatibility/mapred/HadoopReduceCombineFunctionITCase.java
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/143#discussion_r18535782
--- Diff:
flink-addons/flink-hadoop-compatibility/src/test/java/org/apache/flink/test/hadoopcompatibility/mapred/HadoopReduceCombineFunctionITCase.java
[
https://issues.apache.org/jira/browse/FLINK-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1106.
---
Resolution: Fixed
Fix Version/s: 0.7-incubating
Assignee: Robert Metzger
> Dep
[
https://issues.apache.org/jira/browse/FLINK-1103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14162130#comment-14162130
]
Márton Balassi commented on FLINK-1103:
---
Actually String[] is sufficient as seen her
Github user rmetzger commented on the pull request:
https://github.com/apache/incubator-flink/pull/143#issuecomment-58219696
Very nice. With tests and documentation.
I have one open question, otherwise, its good to merge.
---
If your project is set up for it, you can reply to this
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/143#discussion_r18533375
--- Diff:
flink-addons/flink-hadoop-compatibility/src/test/java/org/apache/flink/test/hadoopcompatibility/mapred/HadoopReduceCombineFunctionITCase.java
[
https://issues.apache.org/jira/browse/FLINK-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14161988#comment-14161988
]
ASF GitHub Bot commented on FLINK-1106:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-flink/pull/144
---
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 featur
Github user fhueske commented on the pull request:
https://github.com/apache/incubator-flink/pull/144#issuecomment-58194964
+1
---
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-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14161949#comment-14161949
]
ASF GitHub Bot commented on FLINK-1106:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-1110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14161946#comment-14161946
]
ASF GitHub Bot commented on FLINK-1110:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/139#discussion_r18523098
--- Diff:
flink-examples/flink-java-examples/src/main/java/org/apache/flink/example/java/environments/CollectionExecutionExample.java
---
@@ -0,
[
https://issues.apache.org/jira/browse/FLINK-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14161926#comment-14161926
]
ASF GitHub Bot commented on FLINK-1106:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/144#issuecomment-58191927
+1
---
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-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14161899#comment-14161899
]
ASF GitHub Bot commented on FLINK-1106:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/incubator-flink/pull/144
[FLINK-1106] Deprecate Record API
Do you agree?
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/incubator-flink deprecatedReco
[
https://issues.apache.org/jira/browse/FLINK-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14161892#comment-14161892
]
ASF GitHub Bot commented on FLINK-1107:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/incubator-flink/pull/131#issuecomment-58187994
I included this PR in my PR #143 to built on top of the documentation.
---
If your project is set up for it, you can reply to this email and have your
reply appe
GitHub user fhueske opened a pull request:
https://github.com/apache/incubator-flink/pull/143
Added wrappers for Hadoop functions
Tests and documentation included. Also tested on cluster.
I hijacked @twalthr's PR #131 to build the documentation of the Hadoop
function wrappe
[
https://issues.apache.org/jira/browse/FLINK-1110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14161859#comment-14161859
]
ASF GitHub Bot commented on FLINK-1110:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/139#discussion_r18518034
--- Diff:
flink-examples/flink-java-examples/src/main/java/org/apache/flink/example/java/environments/CollectionExecutionExample.java
---
@@ -0,0 +
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/142#discussion_r18512444
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -318,7 +328,7 @@
* Default number of secon
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/142#discussion_r18507333
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -318,7 +328,7 @@
* Default number of seconds
GitHub user StephanEwen opened a pull request:
https://github.com/apache/incubator-flink/pull/142
Add coarse-grained fault tolerance
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StephanEwen/incubator-flink fault
Alternatively
28 matches
Mail list logo
