[jira] [Assigned] (FLINK-1443) Add replicated data source

2015-01-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1443: Assignee: Fabian Hueske Add replicated data source --

[jira] [Assigned] (FLINK-1105) Add support for locally sorted output

2015-01-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1105: Assignee: Fabian Hueske Add support for locally sorted output

[jira] [Resolved] (FLINK-1168) Support multi-character field delimiters in CSVInputFormats

2015-01-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1168. -- Resolution: Fixed Fixed with 0548a93dfc555a5403590f147d4850c730facaf6 Support multi-character

[jira] [Updated] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

2015-01-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1342: - Priority: Major (was: Minor) Fix Version/s: 0.8.1 0.9 Quickstart's

[jira] [Commented] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

2015-01-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14289913#comment-14289913 ] Fabian Hueske commented on FLINK-1342: -- This is also true for all dependencies which

[jira] [Resolved] (FLINK-1406) Windows compatibility

2015-01-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1406. -- Resolution: Fixed Fix Version/s: 0.9 Fixed in 96585f149c8d100f3d8fce2bb737743695f20c12

[jira] [Closed] (FLINK-1474) Cross produces wrong results for non-tiny inputs

2015-02-04 Thread Fabian Hueske (JIRA)
[ 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

[jira] [Resolved] (FLINK-823) Improve Semantic Annotations

2015-02-04 Thread Fabian Hueske (JIRA)
[ 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

[jira] [Commented] (FLINK-837) Allow FunctionAnnotations on Methods

2015-02-04 Thread Fabian Hueske (JIRA)
[ 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

[jira] [Closed] (FLINK-1296) Add support for very large record for sorting

2015-02-04 Thread Fabian Hueske (JIRA)
[ 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

[jira] [Closed] (FLINK-454) Add ProgramInput/OutputFormats

2015-02-04 Thread Fabian Hueske (JIRA)
[ 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

[jira] [Updated] (FLINK-1388) POJO support for writeAsCsv

2015-02-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1388: - Assignee: Adnan Khan POJO support for writeAsCsv ---

[jira] [Updated] (FLINK-1180) Add support for Hadoop MapReduce.* API Mappers and Reducers

2015-02-04 Thread Fabian Hueske (JIRA)
[ 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

[jira] [Closed] (FLINK-178) Memory-Temping Data Sink / Source

2015-02-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-178. --- Resolution: Duplicate Is subsumed by issues around FLINK-986 to cache intermediate results.

[jira] [Commented] (FLINK-1390) java.lang.ClassCastException: X cannot be cast to X

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310629#comment-14310629 ] Fabian Hueske commented on FLINK-1390: -- The possibly related issue FLINK-1438 has

[jira] [Commented] (FLINK-1476) Flink VS Spark on loop test

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14310626#comment-14310626 ] Fabian Hueske commented on FLINK-1476: -- For a fair comparison, all system should get

[jira] [Updated] (FLINK-1476) Flink VS Spark on loop test

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1476: - Priority: Minor (was: Critical) Flink VS Spark on loop test ---

[jira] [Created] (FLINK-1474) Cross produces wrong results for non-tiny inputs

2015-02-04 Thread Fabian Hueske (JIRA)
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:

[jira] [Resolved] (FLINK-1443) Add replicated data source

2015-02-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1443. -- Resolution: Implemented Fix Version/s: 0.9 Implemented in

[jira] [Resolved] (FLINK-1318) Make quoted String parsing optional and configurable for CSVInputFormats

2015-02-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1318. -- Resolution: Fixed Fix Version/s: 0.9 Fixed in 2665cf4e2a9e33e0e94ac7e0b7518a10445febbb

[jira] [Commented] (FLINK-1476) Flink VS Spark on loop test

2015-02-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14306879#comment-14306879 ] Fabian Hueske commented on FLINK-1476: -- Hi Xuhong, your memory configuration does

[jira] [Resolved] (FLINK-1445) Add support to enforce local input split assignment

2015-02-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1445. -- Resolution: Duplicate Duplicate of FLINK-1478 Add support to enforce local input split

[jira] [Commented] (FLINK-1388) POJO support for writeAsCsv

2015-02-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14308934#comment-14308934 ] Fabian Hueske commented on FLINK-1388: -- Hi, the PojoTypeInfo contains all

[jira] [Assigned] (FLINK-1478) Add strictly local input split assignment

2015-02-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1478: Assignee: Fabian Hueske Add strictly local input split assignment

[jira] [Resolved] (FLINK-1485) Typo in Documentation - Join with Join-Function

2015-02-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1485. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with

[jira] [Resolved] (FLINK-1490) Incorrect local output sort for tuple position keys with nested tuples

2015-02-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1490. -- Resolution: Fixed Assignee: Fabian Hueske Fixed in

[jira] [Updated] (FLINK-100) Pact API Proposal: Add keyless CoGroup (send all to a single group)

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-100: Priority: Minor (was: Major) Pact API Proposal: Add keyless CoGroup (send all to a single group)

[jira] [Commented] (FLINK-1219) Add support for Apache Tez as execution engine

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14311019#comment-14311019 ] Fabian Hueske commented on FLINK-1219: -- Is this a duplicate of FLINK-972? Add

[jira] [Updated] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1418: - Priority: Minor (was: Major) Make 'print()' output on the client command line, rather than on

[jira] [Updated] (FLINK-1414) Remove quickstart-*.sh from git source and put them to the website's svn

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1414: - Priority: Minor (was: Major) Remove quickstart-*.sh from git source and put them to the

[jira] [Updated] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1321: - Priority: Minor (was: Major) New web interface, contains parts from WebInfoServer and WebClient

[jira] [Updated] (FLINK-1340) Project restructure

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1340: - Priority: Minor (was: Major) Project restructure --- Key:

[jira] [Closed] (FLINK-98) Temp Files are not removed if job fails

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-98?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-98. -- Resolution: Duplicate Duplicate of FLINK-1483 Temp Files are not removed if job fails

[jira] [Updated] (FLINK-1256) Use Kryo for user code object serialization

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1256: - Priority: Minor (was: Major) Use Kryo for user code object serialization

[jira] [Updated] (FLINK-1278) Remove the Record special code paths

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1278: - Priority: Minor (was: Major) Remove the Record special code paths

[jira] [Updated] (FLINK-1294) Add Performance and Tuning Guide to documentation

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1294: - Priority: Minor (was: Major) Add Performance and Tuning Guide to documentation

[jira] [Updated] (FLINK-1180) Add support for Hadoop MapReduce.* API Mappers and Reducers

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1180: - Priority: Minor (was: Major) Add support for Hadoop MapReduce.* API Mappers and Reducers

[jira] [Updated] (FLINK-1309) Upload Flink logo with Flink name

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1309: - Priority: Minor (was: Major) Upload Flink logo with Flink name

[jira] [Updated] (FLINK-1116) Packaged Scala Examples do not work due to missing test data

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1116: - Priority: Minor (was: Major) Packaged Scala Examples do not work due to missing test data

[jira] [Updated] (FLINK-685) Add support for semi-joins

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-685: Priority: Minor (was: Major) Add support for semi-joins --

[jira] [Updated] (FLINK-687) Add support for outer-joins

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-687: Priority: Minor (was: Major) Add support for outer-joins ---

[jira] [Updated] (FLINK-603) Add Spargel GAS pattern

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-603: Priority: Minor (was: Major) Add Spargel GAS pattern ---

[jira] [Updated] (FLINK-788) Enable combiner for Reduce with Broadcast Variable

2015-02-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-788: Priority: Minor (was: Major) Enable combiner for Reduce with Broadcast Variable

[jira] [Created] (FLINK-1408) Add group sorting with expression key

2015-01-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1408: Summary: Add group sorting with expression key Key: FLINK-1408 URL: https://issues.apache.org/jira/browse/FLINK-1408 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-1112) Add GroupSorting with KeySelectors

2015-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1112. -- Resolution: Fixed Fixed with f83db149c28ab3472a3307429b9380eb3c903616 Add GroupSorting with

[jira] [Updated] (FLINK-1112) Add GroupSorting with KeySelectors

2015-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1112: - Fix Version/s: 0.8.1 0.9 Add GroupSorting with KeySelectors

[jira] [Updated] (FLINK-1271) Extend HadoopOutputFormat and HadoopInputFormat to handle Void.class

2015-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1271: - Fix Version/s: (was: 0.8) 0.8.1 0.9 Extend

[jira] [Closed] (FLINK-1408) Add group sorting with expression key

2015-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1408. Resolution: Invalid Feature is already implemented. Add group sorting with expression key

[jira] [Commented] (FLINK-1405) Startup fails under Windows

2015-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14279164#comment-14279164 ] Fabian Hueske commented on FLINK-1405: -- Good to know :-) Thanks again for reporting!

[jira] [Resolved] (FLINK-1405) Startup fails under Windows

2015-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1405. -- Resolution: Fixed Fix Version/s: 0.8.1 0.9 Fixed with

[jira] [Commented] (FLINK-1098) flatArray() operator that converts arrays to elements

2015-01-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14282286#comment-14282286 ] Fabian Hueske commented on FLINK-1098: -- I like the idea +1 flatArray() operator

[jira] [Commented] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

2015-01-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14282360#comment-14282360 ] Fabian Hueske commented on FLINK-1418: -- I agree, printing to the TMs std-out is

[jira] [Commented] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations

2015-01-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14282393#comment-14282393 ] Fabian Hueske commented on FLINK-1419: -- I think it is fine to make files in the DC

[jira] [Commented] (FLINK-655) Rename DataSet.withBroadcastSet(DataSet, String) method

2015-01-16 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14280030#comment-14280030 ] Fabian Hueske commented on FLINK-655: - Aren't we going for two methods? 1.

[jira] [Commented] (FLINK-1405) Startup fails under Windows

2015-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14278561#comment-14278561 ] Fabian Hueske commented on FLINK-1405: -- Ah, thanks for pointing to the wildcard bug

[jira] [Assigned] (FLINK-1405) Startup fails under Windows

2015-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1405: Assignee: Fabian Hueske Startup fails under Windows ---

[jira] [Commented] (FLINK-1398) A new DataSet function: extractElementFromTuple

2015-01-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14277226#comment-14277226 ] Fabian Hueske commented on FLINK-1398: -- I am not sure how useful / how much needed

[jira] [Commented] (FLINK-1407) Enable log output (error level) for test cases

2015-01-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14279240#comment-14279240 ] Fabian Hueske commented on FLINK-1407: -- disabling error level logging for tests with

[jira] [Commented] (FLINK-1343) Branching Join Program Deadlocks

2015-02-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14314326#comment-14314326 ] Fabian Hueske commented on FLINK-1343: -- After looking into the execution plan of

[jira] [Assigned] (FLINK-1461) Add sortPartition operator

2015-02-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1461: Assignee: Fabian Hueske Add sortPartition operator --

[jira] [Created] (FLINK-1509) Streaming Group Reduce Combiner

2015-02-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1509: Summary: Streaming Group Reduce Combiner Key: FLINK-1509 URL: https://issues.apache.org/jira/browse/FLINK-1509 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-1574) Flink fails due to non-initialized RuntimeContext in CombiningUnilateralSortMerger

2015-02-17 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1574: Summary: Flink fails due to non-initialized RuntimeContext in CombiningUnilateralSortMerger Key: FLINK-1574 URL: https://issues.apache.org/jira/browse/FLINK-1574

[jira] [Created] (FLINK-1565) Document object reuse behavior

2015-02-17 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1565: Summary: Document object reuse behavior Key: FLINK-1565 URL: https://issues.apache.org/jira/browse/FLINK-1565 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1452) Add flink-contrib maven module and README.md with the rules

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14293219#comment-14293219 ] Fabian Hueske commented on FLINK-1452: -- I am +1 for a place to add contributions, but

[jira] [Resolved] (FLINK-1458) Interfaces and abstract classes are not valid types

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1458. -- Resolution: Duplicate Duplicate of FLINK-1369 Interfaces and abstract classes are not valid

[jira] [Commented] (FLINK-1458) Interfaces and abstract classes are not valid types

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294182#comment-14294182 ] Fabian Hueske commented on FLINK-1458: -- Yes, this is a limitation at the moment but

[jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294506#comment-14294506 ] Fabian Hueske commented on FLINK-1450: -- So Reduce is kind of a special case of Fold

[jira] [Resolved] (FLINK-846) Semantic Annotations - Inconsistencies

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-846. - Resolution: Implemented Implemented in de8e066ccbd0a31e5746bc0bee524a48bba3a552 Semantic

[jira] [Closed] (FLINK-1156) Bug in Constant Fields Annotation (Semantic Properties)

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1156. Resolution: Fixed Fixed in de8e066ccbd0a31e5746bc0bee524a48bba3a552 Bug in Constant Fields

[jira] [Resolved] (FLINK-1457) RAT check fails on Windows

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1457. -- Resolution: Fixed Fixed in 06c2c35a2c165b6a612b0be6d00d99f287330dc7 Thanks for the patch!

[jira] [Commented] (FLINK-1396) Add hadoop input formats directly to the user API.

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294517#comment-14294517 ] Fabian Hueske commented on FLINK-1396: -- +1 for having direct API methods for

[jira] [Resolved] (FLINK-1329) Enable constant field definitions for Pojo DataTypes

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1329. -- Resolution: Implemented Implemented in de8e066ccbd0a31e5746bc0bee524a48bba3a552 Enable

[jira] [Resolved] (FLINK-1328) Rework Constant Field Annotations

2015-01-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1328. -- Resolution: Fixed Fixed in de8e066ccbd0a31e5746bc0bee524a48bba3a552 Rework Constant Field

[jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api

2015-01-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14291714#comment-14291714 ] Fabian Hueske commented on FLINK-1450: -- I believe this is equivalent (or very

[jira] [Created] (FLINK-1438) ClassCastException for Custom InputSplit in local mode

2015-01-23 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1438: Summary: ClassCastException for Custom InputSplit in local mode Key: FLINK-1438 URL: https://issues.apache.org/jira/browse/FLINK-1438 Project: Flink Issue

[jira] [Resolved] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations

2015-02-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1419. -- Resolution: Fixed Fix Version/s: 0.8.1 0.9 Fixed in

[jira] [Commented] (FLINK-1452) Add flink-contrib maven module and README.md with the rules

2015-01-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14298630#comment-14298630 ] Fabian Hueske commented on FLINK-1452: -- +1 Add flink-contrib maven module and

[jira] [Updated] (FLINK-796) Add documentation about input formats and TypeQueryable to website

2015-01-31 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-796: Assignee: (was: Fabian Hueske) Add documentation about input formats and TypeQueryable to

[jira] [Assigned] (FLINK-1444) Add data properties for data sources

2015-01-31 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1444: Assignee: Fabian Hueske Add data properties for data sources

[jira] [Created] (FLINK-1466) Add InputFormat to read from (Hive) tables stored in MetaStore

2015-01-31 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1466: Summary: Add InputFormat to read from (Hive) tables stored in MetaStore Key: FLINK-1466 URL: https://issues.apache.org/jira/browse/FLINK-1466 Project: Flink

[jira] [Closed] (FLINK-1511) Scala classes not identified as Pojos

2015-02-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1511. Resolution: Not a Problem Scala classes not identified as Pojos

[jira] [Created] (FLINK-1511) Scala classes not identified as Pojos

2015-02-11 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1511: Summary: Scala classes not identified as Pojos Key: FLINK-1511 URL: https://issues.apache.org/jira/browse/FLINK-1511 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1343) Branching Join Program Deadlocks

2015-02-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315846#comment-14315846 ] Fabian Hueske commented on FLINK-1343: -- Very nice! Does that mean we can get rid of

[jira] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method

2015-02-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316102#comment-14316102 ] Fabian Hueske commented on FLINK-1514: -- [~balidani] needs to have the contributor

[jira] [Created] (FLINK-1494) Build fails on BlobCacheTest

2015-02-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1494: Summary: Build fails on BlobCacheTest Key: FLINK-1494 URL: https://issues.apache.org/jira/browse/FLINK-1494 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-1494) Build fails on BlobCacheTest

2015-02-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1494. Resolution: Not a Problem The build failure was caused by not cleaned up artefacts, i.e., not

[jira] [Commented] (FLINK-703) Use complete element as join key.

2015-02-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14313163#comment-14313163 ] Fabian Hueske commented on FLINK-703: - I propose wildcard field expressions ( {{*}} and

[jira] [Updated] (FLINK-1538) GSoC project: Spatial Data Processing Library

2015-02-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1538: - Summary: GSoC project: Spatial Data Processing Library (was: Spatial Data Processing Library)

[jira] [Closed] (FLINK-228) Evaluate HCatalog

2015-02-04 Thread Fabian Hueske (JIRA)
[ 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 -

[jira] [Updated] (FLINK-1466) Add InputFormat to read HCatalog tables

2015-02-04 Thread Fabian Hueske (JIRA)
[ 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

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14371050#comment-14371050 ] Fabian Hueske commented on FLINK-1754: -- This deadlock bug is certainly critical and

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14369956#comment-14369956 ] Fabian Hueske commented on FLINK-1754: -- [~hsaputra] Should be the same as FLINK-1343

[jira] [Updated] (FLINK-1664) Forbid sorting on POJOs

2015-03-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1664: - Summary: Forbid sorting on POJOs (was: Fix sorting on POJO fields) Forbid sorting on POJOs

[jira] [Created] (FLINK-1665) Add optional annotations for POJOs to specify the order of fields

2015-03-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1665: Summary: Add optional annotations for POJOs to specify the order of fields Key: FLINK-1665 URL: https://issues.apache.org/jira/browse/FLINK-1665 Project: Flink

[jira] [Created] (FLINK-1663) Add a FIFO job scheduler to the JobManager

2015-03-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1663: Summary: Add a FIFO job scheduler to the JobManager Key: FLINK-1663 URL: https://issues.apache.org/jira/browse/FLINK-1663 Project: Flink Issue Type: New

[jira] [Created] (FLINK-1664) Fix sorting on POJO fields

2015-03-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1664: Summary: Fix sorting on POJO fields Key: FLINK-1664 URL: https://issues.apache.org/jira/browse/FLINK-1664 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1666) Clean-up Field Expression Code

2015-03-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1666: Summary: Clean-up Field Expression Code Key: FLINK-1666 URL: https://issues.apache.org/jira/browse/FLINK-1666 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-1664) Forbid sorting on POJOs

2015-03-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1664: Assignee: Fabian Hueske Forbid sorting on POJOs ---

[jira] [Resolved] (FLINK-1628) Strange behavior of where function during a join

2015-03-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1628. -- Resolution: Fixed Fixed with b0a57c32fc68d4a1369e5ece25d3a6e986ee1e2a Strange behavior of

[jira] [Commented] (FLINK-1388) POJO support for writeAsCsv

2015-03-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14357234#comment-14357234 ] Fabian Hueske commented on FLINK-1388: -- Watch out, PojoTypeInformation is not

  1   2   3   4   5   6   7   8   9   10   >