[
https://issues.apache.org/jira/browse/FLINK-1474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-1474.
Resolution: Not a Problem
Turned out that the problem was caused by the FilterFunction and not the
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305397#comment-14305397
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user vasia commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/265#issuecomment-72886847
Other comments on the API breaking.
If not, I'd merge it...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305468#comment-14305468
]
ASF GitHub Bot commented on FLINK-1442:
---
Github user hsaputra commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305494#comment-14305494
]
ASF GitHub Bot commented on FLINK-1396:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/363
[FLINK-1396][FLINK-1303] Hadoop Input/Output directly in API
This adds methods on ExecutionEnvironment for reading with Hadoop
Input/OutputFormat.
This also adds support in the Scala
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/335#issuecomment-72883525
@balidani that's OK :)
@cebe we've got the acknowledgement for you, thanks!
@andralungu has submitted hers today.
---
If your project is set up for it, you can
GitHub user flinkqa opened a pull request:
https://github.com/apache/flink/pull/362
Qa bot
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink qa-bot
Alternatively you can review and apply these changes as the patch
[
https://issues.apache.org/jira/browse/FLINK-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305450#comment-14305450
]
ASF GitHub Bot commented on FLINK-1318:
---
Github user fhueske commented on the pull
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/344#discussion_r24097257
--- Diff:
flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingMemoryArchivist.scala
---
@@ -31,10 +31,11 @@ trait
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/362#issuecomment-72886592
Sorry guys, I was confused with the different repositories. I'll close it
again.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305411#comment-14305411
]
ASF GitHub Bot commented on FLINK-1318:
---
Github user mxm commented on the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/344#discussion_r24072128
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala
---
@@ -25,48 +25,82 @@ import
[
https://issues.apache.org/jira/browse/FLINK-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14304867#comment-14304867
]
ASF GitHub Bot commented on FLINK-1442:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14304848#comment-14304848
]
ASF GitHub Bot commented on FLINK-1442:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/344#discussion_r24072204
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala
---
@@ -25,48 +25,82 @@ import
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/344#discussion_r24072529
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala
---
@@ -25,48 +25,82 @@ import
[
https://issues.apache.org/jira/browse/FLINK-823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-823.
-
Resolution: Fixed
Assignee: Fabian Hueske
Fixed with
Till Rohrmann created FLINK-1475:
Summary: Minimize log output of yarn test cases
Key: FLINK-1475
URL: https://issues.apache.org/jira/browse/FLINK-1475
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305858#comment-14305858
]
Fabian Hueske commented on FLINK-837:
-
[~StephanEwen] Is this issue solved with the
[
https://issues.apache.org/jira/browse/FLINK-1296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-1296.
Resolution: Fixed
Fixed in 482565608414fea8df7ed86d5d9a8d90fdfcd4f7
Add support for very large
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/363#discussion_r24117856
--- Diff: docs/hadoop_compatibility.md ---
@@ -52,56 +63,70 @@ Add the following dependency to your `pom.xml` to use
the Hadoop Compatibility L
###
[
https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305914#comment-14305914
]
ASF GitHub Bot commented on FLINK-1396:
---
Github user fhueske commented on a diff in
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/358#issuecomment-72937500
Thank you.
Thats good to hear.
On 04.02.2015, at 21:56, Daniel Warneke notificati...@github.com wrote:
Tested the code and everything works
[
https://issues.apache.org/jira/browse/FLINK-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305936#comment-14305936
]
ASF GitHub Bot commented on FLINK-592:
--
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-454.
---
Resolution: Duplicate
Is subsumed by issues around FLINK-986 to cache intermediate results.
Add
[
https://issues.apache.org/jira/browse/FLINK-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305934#comment-14305934
]
ASF GitHub Bot commented on FLINK-592:
--
Github user warneke commented on the pull
Github user warneke commented on the pull request:
https://github.com/apache/flink/pull/358#issuecomment-72937077
Tested the code and everything works as expected now. Great job!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305977#comment-14305977
]
ASF GitHub Bot commented on FLINK-377:
--
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305905#comment-14305905
]
ASF GitHub Bot commented on FLINK-1396:
---
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/363#discussion_r24117603
--- Diff: docs/hadoop_compatibility.md ---
@@ -38,9 +39,19 @@ This document shows how to use existing Hadoop MapReduce
code with Flink. Please
###
[
https://issues.apache.org/jira/browse/FLINK-1462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14306036#comment-14306036
]
Vasia Kalavri commented on FLINK-1462:
--
I'm definitely planning to add some pictures
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305996#comment-14305996
]
Adnan Khan commented on FLINK-1388:
---
I'll work on this one.
POJO support for
[
https://issues.apache.org/jira/browse/FLINK-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1180:
-
Summary: Add support for Hadoop MapReduce.* API Mappers and Reducers (was:
Expose Map and Reduce
[
https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305910#comment-14305910
]
ASF GitHub Bot commented on FLINK-1396:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305921#comment-14305921
]
ASF GitHub Bot commented on FLINK-1396:
---
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/363#discussion_r24118164
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -458,6 +461,67 @@ public CsvReader readCsvFile(String filePath)
[
https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305956#comment-14305956
]
ASF GitHub Bot commented on FLINK-1396:
---
Github user fhueske commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/363#issuecomment-72939364
Looks good.
Besides the typos and inline comments, you could also move the
`HadoopInputFormatTest` and the `HadoopIOFormatsITCase` to flink-java and
flink-tests.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/358
---
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
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/344#discussion_r24093420
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala
---
@@ -25,48 +25,82 @@ import
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/344#discussion_r24093445
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala
---
@@ -25,48 +25,82 @@ import
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/344#discussion_r24093429
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala
---
@@ -25,48 +25,82 @@ import
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/344#discussion_r24093436
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/MemoryArchivist.scala
---
@@ -25,48 +25,82 @@ import
[
https://issues.apache.org/jira/browse/FLINK-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305359#comment-14305359
]
ASF GitHub Bot commented on FLINK-1442:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305358#comment-14305358
]
ASF GitHub Bot commented on FLINK-1442:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305357#comment-14305357
]
ASF GitHub Bot commented on FLINK-1442:
---
Github user mxm commented on a diff in the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/317#issuecomment-72832512
+1 for removing unnecessary ExecutionGraph information before archiving.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/344#issuecomment-72832200
Ah ok perfect that you already addressed the minor issues.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14304882#comment-14304882
]
ASF GitHub Bot commented on FLINK-1442:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14304893#comment-14304893
]
ASF GitHub Bot commented on FLINK-1442:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305052#comment-14305052
]
ASF GitHub Bot commented on FLINK-1201:
---
Github user balidani commented on the pull
Github user balidani commented on the pull request:
https://github.com/apache/flink/pull/335#issuecomment-72851434
Sorry, I will only be able to fill the form on Sunday, my internet
connection is horrible here. Is that ok?
Daniel
On Feb 2, 2015 3:53 PM, Carsten Brandt
[
https://issues.apache.org/jira/browse/FLINK-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305091#comment-14305091
]
ASF GitHub Bot commented on FLINK-1471:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305120#comment-14305120
]
ASF GitHub Bot commented on FLINK-1471:
---
Github user rmetzger commented on a diff in
Robert Metzger created FLINK-1473:
-
Summary: Simplify SplittableIterator interface
Key: FLINK-1473
URL: https://issues.apache.org/jira/browse/FLINK-1473
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-1473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1473.
---
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/7ac6447f
Github user rmetzger closed the pull request at:
https://github.com/apache/flink/pull/338
---
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
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/359#discussion_r24085603
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -680,10 +680,20 @@ private static void
[
https://issues.apache.org/jira/browse/FLINK-1473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305141#comment-14305141
]
Robert Metzger commented on FLINK-1473:
---
Code from
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/338#issuecomment-72861601
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/7ac6447f.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/358#issuecomment-72856331
Thank you for the good feedback!
@mxm and I updated the pull request and addressed your concerns.
I'm now running the tests on Travis. If they pass I'm going
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/354#issuecomment-72857627
I think that this only happens for the primitive types. I think this is by
design.
If you want to inspect generic parameters, Scala forces you to use the
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/359#discussion_r24085111
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -680,10 +680,20 @@ private static void
[
https://issues.apache.org/jira/browse/FLINK-1471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305116#comment-14305116
]
ASF GitHub Bot commented on FLINK-1471:
---
Github user twalthr commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/359#discussion_r24085204
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -680,10 +680,20 @@ private static void
Fabian Hueske created FLINK-1474:
Summary: Cross produces wrong results for non-tiny inputs
Key: FLINK-1474
URL: https://issues.apache.org/jira/browse/FLINK-1474
Project: Flink
Issue Type:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/358#issuecomment-72870536
@warneke Thanks for reporting. If the above issues have been resolved, I
suggest to merge the changes.
---
If your project is set up for it, you can reply to this email and
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/344#issuecomment-72831706
It is true that thorough programming is always the best, but Option
encourages you to apply a more functional programming style which in many cases
results in safer
[
https://issues.apache.org/jira/browse/FLINK-592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-592.
--
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/48d8dd5a
Add
[
https://issues.apache.org/jira/browse/FLINK-592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14305192#comment-14305192
]
ASF GitHub Bot commented on FLINK-592:
--
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14304900#comment-14304900
]
ASF GitHub Bot commented on FLINK-1376:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14304953#comment-14304953
]
Till Rohrmann commented on FLINK-1303:
--
{code}
val hadoopIF = new
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/360
[FLINK1443] Add support for replicating input formats.
InputFormats can be wrapped by a ReplicatingInputFormat which takes care
that the full input of the wrapped input format is read in each
[
https://issues.apache.org/jira/browse/FLINK-228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-228.
---
Resolution: Duplicate
Duplicate of FLINK-1466
Evaluate HCatalog
-
[
https://issues.apache.org/jira/browse/FLINK-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1466:
-
Description:
HCatalog is a metadata repository and InputFormat to make Hive tables
accessible to
xuhong created FLINK-1476:
-
Summary: Flink VS Spark on loop test
Key: FLINK-1476
URL: https://issues.apache.org/jira/browse/FLINK-1476
Project: Flink
Issue Type: Test
Affects Versions: 0.8,
77 matches
Mail list logo
