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

[ 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

[ 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

[ 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] [Commented] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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-1180) Add support for Hadoop MapReduce.* API Mappers and Reducers

[ 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] [Commented] (FLINK-1390) java.lang.ClassCastException: X cannot be cast to X

[ 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] [Updated] (FLINK-1476) Flink VS Spark on loop test

[ 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

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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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] [Updated] (FLINK-100) Pact API Proposal: Add keyless CoGroup (send all to a single group)

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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-1180) Add support for Hadoop MapReduce.* API Mappers and Reducers

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

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

[ 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

[ 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

[ 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

[ 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-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

[ 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

[ 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

[ 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-1398) A new DataSet function: extractElementFromTuple

[ 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

[ 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

[ 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] [Created] (FLINK-1574) Flink fails due to non-initialized RuntimeContext in CombiningUnilateralSortMerger

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

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

[ 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

[ 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

[ 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

[ 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

[ 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)

[ 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

[ 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.

[ 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

[ 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

[ 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

[ 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

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

[ 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

[ 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

[ 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

[ 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

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

[ 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] [Commented] (FLINK-1343) Branching Join Program Deadlocks

[ 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

[ 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

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

[ 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.

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

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

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

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

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

[ 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

[ 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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14357234#comment-14357234 ] Fabian Hueske edited comment on FLINK-1388 at 3/11/15 5:21 PM:

[jira] [Resolved] (FLINK-1654) Wrong scala example of POJO type in documentation

[ https://issues.apache.org/jira/browse/FLINK-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1654. -- Resolution: Fixed FIxed with fd9ca4defd54fa150d33d042471e381e0a0a1164 Wrong scala example of

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

[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14357577#comment-14357577 ] Fabian Hueske commented on FLINK-1388: -- That is right, but the OutputFormat itself is

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

[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14357866#comment-14357866 ] Fabian Hueske commented on FLINK-1388: -- It just won't work and throw an exception

[jira] [Created] (FLINK-1656) Fix ForwardedField documentation for operators with iterator input

Fabian Hueske created FLINK-1656: Summary: Fix ForwardedField documentation for operators with iterator input Key: FLINK-1656 URL: https://issues.apache.org/jira/browse/FLINK-1656 Project: Flink

[jira] [Commented] (FLINK-1656) Fix ForwardedField documentation for operators with iterator input

[ https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14350263#comment-14350263 ] Fabian Hueske commented on FLINK-1656: -- Right, that's a good point. +1 limiting to

[jira] [Assigned] (FLINK-1272) Add a reduceWithKey function

[ https://issues.apache.org/jira/browse/FLINK-1272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1272: Assignee: Fabian Hueske (was: Suneel Marthi) Add a reduceWithKey function

[jira] [Commented] (FLINK-1272) Add a reduceWithKey function

[ https://issues.apache.org/jira/browse/FLINK-1272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14355629#comment-14355629 ] Fabian Hueske commented on FLINK-1272: -- OK, thanks! Add a reduceWithKey function

[jira] [Created] (FLINK-1683) Scheduling preferences for non-unary tasks are not correctly computed

Fabian Hueske created FLINK-1683: Summary: Scheduling preferences for non-unary tasks are not correctly computed Key: FLINK-1683 URL: https://issues.apache.org/jira/browse/FLINK-1683 Project: Flink

[jira] [Updated] (FLINK-1682) Port Record-API based optimizer tests to new Java API

[ https://issues.apache.org/jira/browse/FLINK-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1682: - Issue Type: Sub-task (was: Task) Parent: FLINK-1681 Port Record-API based optimizer

[jira] [Created] (FLINK-1682) Port Record-API based optimizer tests to new Java API

Fabian Hueske created FLINK-1682: Summary: Port Record-API based optimizer tests to new Java API Key: FLINK-1682 URL: https://issues.apache.org/jira/browse/FLINK-1682 Project: Flink Issue

[jira] [Resolved] (FLINK-1683) Scheduling preferences for non-unary tasks are not correctly computed

[ https://issues.apache.org/jira/browse/FLINK-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1683. -- Resolution: Fixed Fixed in 0.9 with 07a9a56c1726b4a7aeb3e682b887d77ab1b0e440 Fixed in 0.8 with

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

[ https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14358878#comment-14358878 ] Fabian Hueske commented on FLINK-1388: -- Sure you can do that. I thought it might be a

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

[ https://issues.apache.org/jira/browse/FLINK-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1343: - Assignee: (was: Fabian Hueske) Branching Join Program Deadlocks

  1   2   3   4   5   6   7   8   9   10   >