dev

Messages by Date

2014/11/20 [jira] [Created] (FLINK-1264) Custom partitioners are not properly forwarded to teh runtime Stephan Ewen (JIRA)
2014/11/20 [jira] [Created] (FLINK-1263) Manual Partition operations are considered to keep data types constant Stephan Ewen (JIRA)
2014/11/20 [ANNOUNCE] Welcome Timo Walther as a new committer Robert Metzger
2014/11/20 [jira] [Created] (FLINK-1262) inconsistency between CsvReader.java and TupleGenerator.java Chen Xu (JIRA)
2014/11/20 [jira] [Created] (FLINK-1261) Handling of full temporary directories at startup and runtime Ufuk Celebi (JIRA)
2014/11/19 [jira] [Created] (FLINK-1260) Add custom partitioning to documentation Fabian Hueske (JIRA)
2014/11/19 [jira] [Created] (FLINK-1259) FilterFunction can modify data Fabian Hueske (JIRA)
2014/11/19 Re: [flink-graph] Tests failing on Windows Dániel Bali
2014/11/19 [jira] [Created] (FLINK-1258) Merge iterative and non-iterative tasks Ufuk Celebi (JIRA)
2014/11/19 [jira] [Created] (FLINK-1257) Binary input/output format which use the type serializer to read/write binary data Till Rohrmann (JIRA)
2014/11/19 Re: Hi / Aggregation support Viktor Rosenfeld
2014/11/19 [jira] [Created] (FLINK-1256) Use Kryo for user code object serialization Till Rohrmann (JIRA)
2014/11/19 Re: Heartbeat lost Stephan Ewen
2014/11/19 [jira] [Created] (FLINK-1255) Problems with generic types in Scala API Sebastian Schelter (JIRA)
2014/11/19 RE: Heartbeat lost Kruse, Sebastian
2014/11/19 [jira] [Created] (FLINK-1254) Optimizer bug during pipeline breaker placement Stephan Ewen (JIRA)
2014/11/19 Re: Question Streaming API - window(win_length,slide_step) Gyula Fora
2014/11/19 [jira] [Created] (FLINK-1253) Tests occasionally die with GarbageCollectionOverhead exceeded Stephan Ewen (JIRA)
2014/11/18 [jira] [Created] (FLINK-1252) Add a serializer for Date Robert Metzger (JIRA)
2014/11/18 [jira] [Created] (FLINK-1251) CollectionInputFormat is not able to handle Enums Robert Metzger (JIRA)
2014/11/18 Re: Heartbeat lost Flavio Pompermaier
2014/11/18 [jira] [Created] (FLINK-1250) Wrong config key for taskmanager heartbeat timeout Stephan Ewen (JIRA)
2014/11/18 Re: Heartbeat lost Stephan Ewen
2014/11/18 RE: Heartbeat lost Kruse, Sebastian
2014/11/18 [jira] [Created] (FLINK-1249) Add custom partitioner for CoGroup Stephan Ewen (JIRA)
2014/11/18 Re: Heartbeat lost Stephan Ewen
2014/11/18 Heartbeat lost Kruse, Sebastian
2014/11/17 [jira] [Created] (FLINK-1248) Manually built docu doesn't apply CSS/images Chesnay Schepler (JIRA)
2014/11/17 Re: Too many files with unapproved license in master branch Henry Saputra
2014/11/17 [jira] [Created] (FLINK-1247) Links in documentation broken Till Rohrmann (JIRA)
2014/11/17 Re: Too many files with unapproved license in master branch Henry Saputra
2014/11/17 Re: Too many files with unapproved license in master branch Stephan Ewen
2014/11/17 Re: Too many files with unapproved license in master branch Márton Balassi
2014/11/17 Re: Too many files with unapproved license in master branch Stephan Ewen
2014/11/17 Too many files with unapproved license in master branch Henry Saputra
2014/11/17 Re: [flink-graph] Tests failing on Windows Vasiliki Kalavri
2014/11/17 [jira] [Created] (FLINK-1246) Flaky test RecoveryITCase Stephan Ewen (JIRA)
2014/11/16 Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Till Rohrmann
2014/11/15 Re: Problem with starting Flink "start-local.sh" on Server Fabian Hueske
2014/11/15 Problem with starting Flink "start-local.sh" on Server Saied Tehrani
2014/11/15 Re: Flink Maven Configuration Sebastian Kunert
2014/11/14 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/14 Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
2014/11/14 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/14 [jira] [Created] (FLINK-1245) Introduce TypeHints for Java API operators Timo Walther (JIRA)
2014/11/14 Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Aljoscha Krettek
2014/11/14 Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
2014/11/14 Re: [flink-graph] Tests failing on Windows Markus Holzemer
2014/11/14 Re: [flink-graph] Tests failing on Windows Dániel Bali
2014/11/14 Re: [flink-graph] Tests failing on Windows Stephan Ewen
2014/11/14 [flink-graph] Tests failing on Windows Dániel Bali
2014/11/14 Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Hermann Gábor
2014/11/14 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/14 Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Vasiliki Kalavri
2014/11/14 Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Stephan Ewen
2014/11/14 Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Fabian Hueske
2014/11/14 Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Chiwan Park
2014/11/14 Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Gyula Fora
2014/11/14 AW: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Markl, Volker, Prof. Dr.
2014/11/14 Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Sebastian Schelter
2014/11/14 [ANNOUNCE] Welcome Vasia Kalavri as a new committer Kostas Tzoumas
2014/11/14 Re: Flink Maven Configuration Stephan Ewen
2014/11/14 Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
2014/11/14 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/14 Re: Flink Maven Configuration Sebastian Kunert
2014/11/14 [jira] [Created] (FLINK-1244) setCombinable() clunky to use Chesnay Schepler (JIRA)
2014/11/14 Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
2014/11/14 Re: Flink Maven Configuration Stephan Ewen
2014/11/14 Flink Maven Configuration Sebastian Kunert
2014/11/13 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/13 Re: HBase 0.98 addon for Flink 0.8 fhueske
2014/11/13 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/13 Re: HBase 0.98 addon for Flink 0.8 fhueske
2014/11/13 [jira] [Created] (FLINK-1243) Remove JVM MaxPermSize parameter when we use Java 8 Kousuke Saruta (JIRA)
2014/11/13 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/13 [jira] [Created] (FLINK-1242) Streaming examples Stephan Ewen (JIRA)
2014/11/13 [jira] [Created] (FLINK-1241) Record processing counter for Dashboard Stefano Bortoli (JIRA)
2014/11/13 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/13 Re: Issues with Java 8 Lambda Expressions Stephan Ewen
2014/11/13 Re: [GitHub] incubator-flink pull request: [scala] Self-contained build for sca... Ufuk Celebi
2014/11/13 Re: Issues with Java 8 Lambda Expressions Ufuk Celebi
2014/11/13 Re: Issues with Java 8 Lambda Expressions Timo Walther
2014/11/13 Re: [GitHub] incubator-flink pull request: [scala] Self-contained build for sca... Ufuk Celebi
2014/11/13 [jira] [Created] (FLINK-1240) We cannot use sortGroup on a global reduce Aljoscha Krettek (JIRA)
2014/11/12 [jira] [Created] (FLINK-1239) Fix iteration example stucking with large input JIRA
2014/11/12 Re: Flink Java 8 Lambdas will work again with future Eclipse compilers Fabian Hueske
2014/11/12 Re: Flink Java 8 Lambdas will work again with future Eclipse compilers Stephan Ewen
2014/11/12 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/12 Re: HBase 0.98 addon for Flink 0.8 Robert Metzger
2014/11/12 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/12 [jira] [Created] (FLINK-1238) Add a way to deactivate the "mutable object safe mode" Stephan Ewen (JIRA)
2014/11/12 Flink Java 8 Lambdas will work again with future Eclipse compilers Timo Walther
2014/11/12 [jira] [Created] (FLINK-1237) Add custom partitioners for shuffle steps Till Rohrmann (JIRA)
2014/11/12 [jira] [Created] (FLINK-1236) Add support for localization of Hadoop Input Splits Robert Metzger (JIRA)
2014/11/12 [jira] [Created] (FLINK-1235) Compiler rejectes non-nested iterations in constant path of an Iteration. Stephan Ewen (JIRA)
2014/11/12 Re: FYI: Talk at the Amsterdam Hadoop User Group Robert Metzger
2014/11/12 Re: KNIME Integration of Flink Arvid Heise
2014/11/12 FYI: Talk at the Amsterdam Hadoop User Group Stephan Ewen
2014/11/11 Re: Type extraction with generic variables Vasiliki Kalavri
2014/11/11 [jira] [Created] (FLINK-1234) Make Hadoop2 profile default Robert Metzger (JIRA)
2014/11/11 Re: Flink on Tez Kostas Tzoumas
2014/11/10 Re: Flink on Tez sirinath
2014/11/10 Re: Flink on Tez Henry Saputra
2014/11/10 [jira] [Created] (FLINK-1233) Flaky Test AggregateITCase Stephan Ewen (JIRA)
2014/11/10 [jira] [Created] (FLINK-1232) Allow I/O spill file writers to work with futures/callbacks Stephan Ewen (JIRA)
2014/11/10 [jira] [Created] (FLINK-1231) Add test for streaming remote execution JIRA
2014/11/10 Re: Flink on Tez Kostas Tzoumas
2014/11/10 Re: Coarse-grained FT implementation Stephan Ewen
2014/11/10 Re: Embeded Use Stephan Ewen
2014/11/10 [jira] [Created] (FLINK-1230) Add embedded collection execution to documentation Stephan Ewen (JIRA)
2014/11/10 [jira] [Created] (FLINK-1229) Synchronize WebClient arguments with command line arguments Timo Walther (JIRA)
2014/11/10 Re: KNIME Integration of Flink Stephan Ewen
2014/11/10 Re: [jira] [Created] (FLINK-1228) Add REST Interface to JobManager Flavio Pompermaier
2014/11/10 [jira] [Created] (FLINK-1228) Add REST Interface to JobManager Arvid Heise (JIRA)
2014/11/10 KNIME Integration of Flink Arvid Heise
2014/11/10 [jira] [Created] (FLINK-1227) KeySelector can't implement ResultTypeQueryable Chesnay Schepler (JIRA)
2014/11/10 [jira] [Created] (FLINK-1226) No way to give Configuration to DataSource Fabian Hueske (JIRA)
2014/11/10 Re: Type extraction with generic variables Stephan Ewen
2014/11/10 Re: Help with .getExecutionEnvironment() method Stephan Ewen
2014/11/10 Re: Hi / Aggregation support Viktor Rosenfeld
2014/11/10 Re: Hi / Aggregation support Stephan Ewen
2014/11/10 Re: Hi / Aggregation support Fabian Hueske
2014/11/10 Re: Collection serializers Márton Balassi
2014/11/10 Re: Flink on Tez Fabian Hueske
2014/11/10 Re: Hi / Aggregation support Gyula Fora
2014/11/10 Re: Type extraction with generic variables Timo Walther
2014/11/10 Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
2014/11/10 Re: Hi / Aggregation support Aljoscha Krettek
2014/11/10 Re: Hi / Aggregation support Viktor Rosenfeld
2014/11/10 Collection serializers Stephan Ewen
2014/11/09 Re: Flink on Tez sirinath
2014/11/09 Re: beginner Till Rohrmann
2014/11/09 Re: beginner Chiwan Park
2014/11/09 beginner navya sri nizamkari
2014/11/09 Re: Flink on Tez Sean Owen
2014/11/09 Re: Flink on Tez Flavio Pompermaier
2014/11/09 Re: Flink on Tez Kostas Tzoumas
2014/11/09 Re: Flink on Tez Kostas Tzoumas
2014/11/08 Re: Flink on Tez Flavio Pompermaier
2014/11/08 Re: Type extraction with generic variables Vasiliki Kalavri
2014/11/08 Re: Flink on Tez Aljoscha Krettek
2014/11/08 RE: Flink on Tez sirinath
2014/11/08 Re: Embeded Use sirinath
2014/11/08 Re: Embeded Use Stephan Ewen
2014/11/07 RE: Flink on Tez Bikas Saha
2014/11/07 Embeded Use sirinath
2014/11/07 Re: Help with .getExecutionEnvironment() method Gyula Fóra
2014/11/07 Re: Flink on Tez Arun Murthy
2014/11/07 Re: Coarse-grained FT implementation Henry Saputra
2014/11/07 Re: Coarse-grained FT implementation Kostas Tzoumas
2014/11/07 Flink on Tez Kostas Tzoumas
2014/11/07 Re: Coarse-grained FT implementation Henry Saputra
2014/11/07 [jira] [Created] (FLINK-1225) Quickstart does not work Timo Walther (JIRA)
2014/11/07 Re: Help with .getExecutionEnvironment() method Aljoscha Krettek
2014/11/07 Re: Help with .getExecutionEnvironment() method Gyula Fóra
2014/11/07 Re: Help with .getExecutionEnvironment() method Aljoscha Krettek
2014/11/07 [jira] [Created] (FLINK-1224) Fix .getExecutionEnvironment of the StreamingExecutionEnvironment to return proper context Gyula Fora (JIRA)
2014/11/07 Help with .getExecutionEnvironment() method Gyula Fóra
2014/11/07 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/07 Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
2014/11/07 Re: Making Fink More HFT / Trading Friendly Gyula Fora
2014/11/07 Making Fink More HFT / Trading Friendly sirinath
2014/11/07 Re: Make Streaming Interoperable with Reactive Streams, Java Streams and Rx Gyula Fora
2014/11/06 Re: Make Streaming Interoperable with Reactive Streams, Java Streams and Rx sirinath
2014/11/06 Re: Make Streaming Interoperable with Reactive Streams, Java Streams and Rx Gyula Fora
2014/11/06 Make Streaming Interoperable with Reactive Streams, Java Streams and Rx sirinath
2014/11/06 Re: Streaming groupby and aggregation by field expressions Viktor Rosenfeld
2014/11/06 Re: Introduction Stephan Ewen
2014/11/06 [jira] [Created] (FLINK-1223) Allow value escaping in CSV files Johannes (JIRA)
2014/11/06 Introduction Kirschnick, Johannes
2014/11/06 [jira] [Created] (FLINK-1222) Let tasks finish as soon as their data is sent Stephan Ewen (JIRA)
2014/11/06 [jira] [Created] (FLINK-1221) Use program source line of invocation as the default function name Stephan Ewen (JIRA)
2014/11/06 [jira] [Created] (FLINK-1220) Make INFO logging more verbose Stephan Ewen (JIRA)
2014/11/06 [jira] [Created] (FLINK-1219) Add support for Apache Tez as execution engine Kostas Tzoumas (JIRA)
2014/11/05 Re: Issues with Java 8 Lambda Expressions Stephan Ewen
2014/11/05 [jira] [Created] (FLINK-1218) Don't use "new Integer". Use "Integer.valueOf" instead. Kousuke Saruta (JIRA)
2014/11/05 [jira] [Created] (FLINK-1217) Keepalive option should be set to sockets in Client and Server Kousuke Saruta (JIRA)
2014/11/05 Re: Streaming groupby and aggregation by field expressions Fabian Hueske
2014/11/05 Re: Streaming groupby and aggregation by field expressions Gyula Fora
2014/11/05 Re: Streaming groupby and aggregation by field expressions Fabian Hueske
2014/11/05 Streaming groupby and aggregation by field expressions Gyula Fóra
2014/11/05 [jira] [Created] (FLINK-1216) Quickstart projects should have flink dependencies in scope "provided" Stephan Ewen (JIRA)
2014/11/05 Re: Unit testing Flink programs / DataSet operations Stephan Ewen
2014/11/05 Re: Unit testing Flink programs / DataSet operations Viktor Rosenfeld
2014/11/05 Re: Unit testing Flink programs / DataSet operations Stephan Ewen
2014/11/05 [jira] [Created] (FLINK-1215) FileSystem.initOutPathLocalFS can lead to race condition Aljoscha Krettek (JIRA)
2014/11/05 Unit testing Flink programs / DataSet operations Viktor Rosenfled
2014/11/05 [jira] [Created] (FLINK-1214) Prevent partitioning pushdown unless partitions fields match exactly Stephan Ewen (JIRA)
2014/11/05 [jira] [Created] (FLINK-1213) Add .gitattributes to normalize EOL character. Kousuke Saruta (JIRA)
2014/11/05 [jira] [Created] (FLINK-1212) Interpreter directive in shell scripts should be "/usr/bin/env bash" instead of "/bin/bash" Kousuke Saruta (JIRA)
2014/11/05 [jira] [Created] (FLINK-1211) EOL character of Windows Batch files should be CRLF Kousuke Saruta (JIRA)
2014/11/04 Re: [FLINK-1040] Make type() call in projections optional Stephan Ewen
2014/11/04 Re: [FLINK-1040] Make type() call in projections optional Fabian Hueske
2014/11/04 Re: Coarse-grained FT implementation Ufuk Celebi
2014/11/04 Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Henry Saputra
2014/11/04 Re: Incubator PMC/Board report for Nov 2014 ([ppmc]) Ted Dunning
2014/11/04 Re: Hi / Aggregation support Fabian Hueske
2014/11/04 [jira] [Created] (FLINK-1210) Improve Error Message in Delta Iteratione when Next Workset does not Depend on Workset. Stephan Ewen (JIRA)
2014/11/04 Re: Hi / Aggregation support viktor.rosenfeld
2014/11/04 Re: Blog post for release 0.7.0 Flavio Pompermaier