Issues

• Cascading-Flink not working with EMR Flink 1.3.2

  dataArtisans/cascading-flink#72 · Filter by author mehikmat opened on Aug 8, 2018

• Cannot merge pipes from ORC file

  dataArtisans/cascading-flink#71 · Filter by author Pierre-Antoine opened on Apr 3, 2017

• stepsAreLocal() of FlinkFlow class is always returning false, even when job runs in local.

  dataArtisans/cascading-flink#69 · Filter by author ghost opened on Oct 19, 2016

• Pass JobConf to Schemes, not Configuration

  dataArtisans/cascading-flink#62 · Filter by author kkrugler opened on May 9, 2016

• Source and shuffle parallelism settings don't seem to work

  dataArtisans/cascading-flink#58 · Filter by author kkrugler opened on Apr 28, 2016

• Support finer-grained control over parallelism

  dataArtisans/cascading-flink#57 · Filter by author kkrugler opened on Apr 27, 2016
  1

• Check CoGroup BufferJoin with inputs of different types

  dataArtisans/cascading-flink#42 · Filter by author fhueske opened on Nov 10, 2015

• Add checks for Flink union when exact types are required.

  dataArtisans/cascading-flink#41 · Filter by author fhueske opened on Oct 30, 2015

• Check if it is possible to enable Flink's object-reuse mode

  enhancementexecution
  dataArtisans/cascading-flink#35 · Filter by author fhueske opened on Sep 20, 2015

• Add Debug messages about Flinks Type System

  enhancement
  dataArtisans/cascading-flink#32 · Filter by author fhueske opened on Sep 19, 2015

• Check if generic Tuple serialization can be moved from Kryo to Cascading's own serialization

  enhancementexecution
  dataArtisans/cascading-flink#29 · Filter by author fhueske opened on Sep 14, 2015
  3

• Add tests with typed fields

  dataArtisans/cascading-flink#25 · Filter by author fhueske opened on Aug 27, 2015

• Add support for full and right outer hash joins

  enhancementexecution
  dataArtisans/cascading-flink#5 · Filter by author fhueske opened on Jul 14, 2015
  2