Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / dataArtisans/cascading-flink issues and pull requests

#74 - Bump junit from 4.11 to 4.13.1

Pull Request - State: open - Opened by dependabot[bot] over 4 years ago
Labels: dependencies

#73 - [SECURITY] Use HTTPS to resolve dependencies in Maven Build

Pull Request - State: closed - Opened by JLLeitschuh about 5 years ago

#72 - Cascading-Flink not working with EMR Flink 1.3.2

Issue - State: open - Opened by mehikmat over 6 years ago

#71 - Cannot merge pipes from ORC file

Issue - State: open - Opened by Pierre-Antoine almost 8 years ago

#71 - Cannot merge pipes from ORC file

Issue - State: open - Opened by Pierre-Antoine almost 8 years ago

#70 - Trying out cascading 3.2

Pull Request - State: open - Opened by cchepelov over 8 years ago - 4 comments

#70 - Trying out cascading 3.2

Pull Request - State: open - Opened by cchepelov over 8 years ago - 4 comments

#68 - use cascading 3.1.0 final release

Pull Request - State: closed - Opened by fs111 over 8 years ago - 1 comment

#67 - set the platform version automatically during build

Pull Request - State: closed - Opened by fs111 almost 9 years ago - 5 comments

#66 - use Flink 1.0.3 and Cascading 3.1.0-wip-60

Pull Request - State: closed - Opened by fs111 almost 9 years ago - 1 comment

#66 - use Flink 1.0.3 and Cascading 3.1.0-wip-60

Pull Request - State: closed - Opened by fs111 almost 9 years ago - 1 comment

#65 - use standard versioning major.minor.bugfix

Pull Request - State: closed - Opened by fs111 almost 9 years ago - 2 comments

#65 - use standard versioning major.minor.bugfix

Pull Request - State: closed - Opened by fs111 almost 9 years ago - 2 comments

#64 - tag for 0.2 release is missing

Issue - State: closed - Opened by fs111 almost 9 years ago - 1 comment

#64 - tag for 0.2 release is missing

Issue - State: closed - Opened by fs111 almost 9 years ago - 1 comment

#63 - Fix for Issue #61

Pull Request - State: closed - Opened by kkrugler almost 9 years ago - 2 comments

#63 - Fix for Issue #61

Pull Request - State: closed - Opened by kkrugler almost 9 years ago - 2 comments

#62 - Pass JobConf to Schemes, not Configuration

Issue - State: open - Opened by kkrugler almost 9 years ago

#62 - Pass JobConf to Schemes, not Configuration

Issue - State: open - Opened by kkrugler almost 9 years ago

#60 - Use ConcurrentHashMap for Accumulators

Issue - State: closed - Opened by kkrugler almost 9 years ago - 2 comments

#60 - Use ConcurrentHashMap for Accumulators

Issue - State: closed - Opened by kkrugler almost 9 years ago - 2 comments

#59 - Push a 0.3 release

Issue - State: closed - Opened by kkrugler almost 9 years ago - 9 comments

#59 - Push a 0.3 release

Issue - State: closed - Opened by kkrugler almost 9 years ago - 9 comments

#58 - Source and shuffle parallelism settings don't seem to work

Issue - State: open - Opened by kkrugler almost 9 years ago

#58 - Source and shuffle parallelism settings don't seem to work

Issue - State: open - Opened by kkrugler almost 9 years ago

#57 - Support finer-grained control over parallelism

Issue - State: open - Opened by kkrugler almost 9 years ago - 1 comment

#57 - Support finer-grained control over parallelism

Issue - State: open - Opened by kkrugler almost 9 years ago - 1 comment

#56 - Sorting with GroupBy doesn't work

Issue - State: closed - Opened by kkrugler almost 9 years ago - 5 comments

#56 - Sorting with GroupBy doesn't work

Issue - State: closed - Opened by kkrugler almost 9 years ago - 5 comments

#55 - Create default Configuration in no-arg FlinkFlowProcess constructor

Issue - State: closed - Opened by kkrugler almost 9 years ago - 1 comment

#54 - Bump version in master to 0.2-SNAPSHOT (or later)

Issue - State: closed - Opened by kkrugler almost 9 years ago - 3 comments

#54 - Bump version in master to 0.2-SNAPSHOT (or later)

Issue - State: closed - Opened by kkrugler almost 9 years ago - 3 comments

#53 - Example WordCount program should specify SinkMode.REPLACE for outTap

Issue - State: closed - Opened by kkrugler almost 9 years ago - 1 comment

#52 - exclude *TestCase.java from surefire configuration

Issue - State: closed - Opened by kkrugler almost 9 years ago - 1 comment

#52 - exclude *TestCase.java from surefire configuration

Issue - State: closed - Opened by kkrugler almost 9 years ago - 1 comment

#51 - setNumSinkParts is currently ignored

Issue - State: closed - Opened by kkrugler almost 9 years ago - 2 comments

#51 - setNumSinkParts is currently ignored

Issue - State: closed - Opened by kkrugler almost 9 years ago - 2 comments

#50 - Make BATCH the default execution mode and add a parameter switch to PIPELINED

Issue - State: closed - Opened by fhueske almost 9 years ago - 1 comment

#50 - Make BATCH the default execution mode and add a parameter switch to PIPELINED

Issue - State: closed - Opened by fhueske almost 9 years ago - 1 comment

#49 - Obtaining Flink plan with './bin/flink info' throws ClassCastException

Issue - State: closed - Opened by fhueske almost 9 years ago - 1 comment
Labels: bug

#49 - Obtaining Flink plan with './bin/flink info' throws ClassCastException

Issue - State: closed - Opened by fhueske almost 9 years ago - 1 comment
Labels: bug

#48 - junit dependency should use test scope

Pull Request - State: closed - Opened by fs111 almost 9 years ago - 1 comment

#48 - junit dependency should use test scope

Pull Request - State: closed - Opened by fs111 almost 9 years ago - 1 comment

#47 - quick-fix of group name in maven example

Pull Request - State: closed - Opened by fs111 almost 9 years ago - 1 comment

#47 - quick-fix of group name in maven example

Pull Request - State: closed - Opened by fs111 almost 9 years ago - 1 comment

#46 - translateHashJoin should allow Joiner subclasses

Issue - State: closed - Opened by themodernlife about 9 years ago - 4 comments

#46 - translateHashJoin should allow Joiner subclasses

Issue - State: closed - Opened by themodernlife about 9 years ago - 4 comments

#45 - Copy methods of DefinedTupleSerializer do not handle null properly

Issue - State: closed - Opened by twalthr about 9 years ago - 1 comment

#45 - Copy methods of DefinedTupleSerializer do not handle null properly

Issue - State: closed - Opened by twalthr about 9 years ago - 1 comment

#44 - Tests fail on master

Issue - State: closed - Opened by rmetzger about 9 years ago - 2 comments

#44 - Tests fail on master

Issue - State: closed - Opened by rmetzger about 9 years ago - 2 comments

#43 - Release cascading-flink 0.1 to maven central

Issue - State: closed - Opened by rmetzger about 9 years ago - 7 comments

#43 - Release cascading-flink 0.1 to maven central

Issue - State: closed - Opened by rmetzger about 9 years ago - 7 comments

#42 - Check CoGroup BufferJoin with inputs of different types

Issue - State: open - Opened by fhueske over 9 years ago

#41 - Add checks for Flink union when exact types are required.

Issue - State: open - Opened by fhueske over 9 years ago

#41 - Add checks for Flink union when exact types are required.

Issue - State: open - Opened by fhueske over 9 years ago

#40 - Fix parallelism of HashJoin operators

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment

#40 - Fix parallelism of HashJoin operators

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment

#39 - Deploy Cascading on Flink to Maven Central

Issue - State: closed - Opened by rmetzger over 9 years ago - 5 comments

#38 - Add travis to project

Pull Request - State: closed - Opened by rmetzger over 9 years ago - 6 comments

#38 - Add travis to project

Pull Request - State: closed - Opened by rmetzger over 9 years ago - 6 comments

#37 - Fix project after commit 0ee0c1f on apache/flink

Pull Request - State: closed - Opened by rmetzger over 9 years ago - 1 comment

#36 - Build failure on Mac

Issue - State: closed - Opened by kkrugler over 9 years ago - 9 comments

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

Issue - State: open - Opened by fhueske over 9 years ago
Labels: enhancement, execution

#34 - Consistent naming of Flink operators

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement

#34 - Consistent naming of Flink operators

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement

#33 - Compile CoGroup without GroupReduce operator

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#33 - Compile CoGroup without GroupReduce operator

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#32 - Add Debug messages about Flinks Type System

Issue - State: open - Opened by fhueske over 9 years ago
Labels: enhancement

#32 - Add Debug messages about Flinks Type System

Issue - State: open - Opened by fhueske over 9 years ago
Labels: enhancement

#31 - Compile GroupBy to GroupReduce without explicit partition and sortPartition steps

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#31 - Compile GroupBy to GroupReduce without explicit partition and sortPartition steps

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#30 - Add support for negative field indicies with Fields.UNKNOWN

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment

#30 - Add support for negative field indicies with Fields.UNKNOWN

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment

#29 - Check if generic Tuple serialization can be moved from Kryo to Cascading's own serialization

Issue - State: open - Opened by fhueske over 9 years ago - 3 comments
Labels: enhancement, execution

#29 - Check if generic Tuple serialization can be moved from Kryo to Cascading's own serialization

Issue - State: open - Opened by fhueske over 9 years ago - 3 comments
Labels: enhancement, execution

#28 - Customize CoGroup and Join cascades for n-ary Joins and CoGroups

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#28 - Customize CoGroup and Join cascades for n-ary Joins and CoGroups

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#27 - package names should be lowercase

Issue - State: closed - Opened by fs111 over 9 years ago - 1 comment

#27 - package names should be lowercase

Issue - State: closed - Opened by fs111 over 9 years ago - 1 comment

#26 - compile error with current HEAD

Issue - State: closed - Opened by fs111 over 9 years ago - 4 comments

#26 - compile error with current HEAD

Issue - State: closed - Opened by fs111 over 9 years ago - 4 comments

#25 - Add tests with typed fields

Issue - State: open - Opened by fhueske over 9 years ago

#25 - Add tests with typed fields

Issue - State: open - Opened by fhueske over 9 years ago

#24 - Use Flink native serializers for Writable and WritableComparable types

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#24 - Use Flink native serializers for Writable and WritableComparable types

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#23 - Register known Tuple field types with Kryo

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#23 - Register known Tuple field types with Kryo

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#22 - Improve serialization of Tuple[] for n-ary Joins and CoGroups

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#22 - Improve serialization of Tuple[] for n-ary Joins and CoGroups

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#21 - Add lightweight runtime strategies for binary cogroup

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#21 - Add lightweight runtime strategies for binary cogroup

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#20 - Add lightweight runtime strategies for binary hashjoin

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#20 - Add lightweight runtime strategies for binary hashjoin

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment
Labels: enhancement, execution

#19 - Add Apache License file

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment

#19 - Add Apache License file

Issue - State: closed - Opened by fhueske over 9 years ago - 1 comment