dev  

Messages by Thread

• [jira] [Created] (FLINK-1254) Optimizer bug during pipeline breaker placement Stephan Ewen (JIRA)
• Re: Question Streaming API - window(win_length,slide_step) Gyula Fora
• [jira] [Created] (FLINK-1253) Tests occasionally die with GarbageCollectionOverhead exceeded Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1252) Add a serializer for Date Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1251) CollectionInputFormat is not able to handle Enums Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1250) Wrong config key for taskmanager heartbeat timeout Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1249) Add custom partitioner for CoGroup Stephan Ewen (JIRA)
• Heartbeat lost Kruse, Sebastian
  • Re: Heartbeat lost Stephan Ewen
  • RE: Heartbeat lost Kruse, Sebastian
  • Re: Heartbeat lost Stephan Ewen
  • RE: Heartbeat lost Kruse, Sebastian
  • Re: Heartbeat lost Stephan Ewen
  • Re: Heartbeat lost Flavio Pompermaier
• [jira] [Created] (FLINK-1248) Manually built docu doesn't apply CSS/images Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-1247) Links in documentation broken Till Rohrmann (JIRA)
• Too many files with unapproved license in master branch Henry Saputra
  • Re: Too many files with unapproved license in master branch Márton Balassi
  • Re: Too many files with unapproved license in master branch Stephan Ewen
  • Re: Too many files with unapproved license in master branch Stephan Ewen
  • Re: Too many files with unapproved license in master branch Henry Saputra
  • Re: Too many files with unapproved license in master branch Henry Saputra
• [jira] [Created] (FLINK-1246) Flaky test RecoveryITCase Stephan Ewen (JIRA)
• Problem with starting Flink "start-local.sh" on Server Saied Tehrani
  • Re: Problem with starting Flink "start-local.sh" on Server Fabian Hueske
• [jira] [Created] (FLINK-1245) Introduce TypeHints for Java API operators Timo Walther (JIRA)
• [flink-graph] Tests failing on Windows Dániel Bali
  • Re: [flink-graph] Tests failing on Windows Stephan Ewen
  • Re: [flink-graph] Tests failing on Windows Dániel Bali
  • Re: [flink-graph] Tests failing on Windows Markus Holzemer
  • Re: [flink-graph] Tests failing on Windows Vasiliki Kalavri
  • Re: [flink-graph] Tests failing on Windows Dániel Bali
• [ANNOUNCE] Welcome Vasia Kalavri as a new committer Kostas Tzoumas
  • Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Sebastian Schelter
  • AW: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Markl, Volker, Prof. Dr.
  • Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Gyula Fora
  • Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Chiwan Park
  • Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Fabian Hueske
  • Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Stephan Ewen
  • Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Vasiliki Kalavri
  • Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Hermann Gábor
  • Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Aljoscha Krettek
  • Re: [ANNOUNCE] Welcome Vasia Kalavri as a new committer Till Rohrmann
• [jira] [Created] (FLINK-1244) setCombinable() clunky to use Chesnay Schepler (JIRA)
• Flink Maven Configuration Sebastian Kunert
  • Re: Flink Maven Configuration Stephan Ewen
  • Re: Flink Maven Configuration Sebastian Kunert
  • Re: Flink Maven Configuration Stephan Ewen
  • Re: Flink Maven Configuration Sebastian Kunert
• [jira] [Created] (FLINK-1243) Remove JVM MaxPermSize parameter when we use Java 8 Kousuke Saruta (JIRA)
• [jira] [Created] (FLINK-1242) Streaming examples Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1241) Record processing counter for Dashboard Stefano Bortoli (JIRA)
• Re: [GitHub] incubator-flink pull request: [scala] Self-contained build for sca... Ufuk Celebi
  • Re: [GitHub] incubator-flink pull request: [scala] Self-contained build for sca... Ufuk Celebi
• [jira] [Created] (FLINK-1240) We cannot use sortGroup on a global reduce Aljoscha Krettek (JIRA)
• [jira] [Created] (FLINK-1239) Fix iteration example stucking with large input JIRA
• [jira] [Created] (FLINK-1238) Add a way to deactivate the "mutable object safe mode" Stephan Ewen (JIRA)
• Flink Java 8 Lambdas will work again with future Eclipse compilers Timo Walther
  • Re: Flink Java 8 Lambdas will work again with future Eclipse compilers Stephan Ewen
  • Re: Flink Java 8 Lambdas will work again with future Eclipse compilers Fabian Hueske
• [jira] [Created] (FLINK-1237) Add custom partitioners for shuffle steps Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1236) Add support for localization of Hadoop Input Splits Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1235) Compiler rejectes non-nested iterations in constant path of an Iteration. Stephan Ewen (JIRA)
• FYI: Talk at the Amsterdam Hadoop User Group Stephan Ewen
  • Re: FYI: Talk at the Amsterdam Hadoop User Group Robert Metzger
• [jira] [Created] (FLINK-1234) Make Hadoop2 profile default Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1233) Flaky Test AggregateITCase Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1232) Allow I/O spill file writers to work with futures/callbacks Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1231) Add test for streaming remote execution JIRA
• [jira] [Created] (FLINK-1230) Add embedded collection execution to documentation Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1229) Synchronize WebClient arguments with command line arguments Timo Walther (JIRA)
• [jira] [Created] (FLINK-1228) Add REST Interface to JobManager Arvid Heise (JIRA)
  • Re: [jira] [Created] (FLINK-1228) Add REST Interface to JobManager Flavio Pompermaier
• KNIME Integration of Flink Arvid Heise
  • Re: KNIME Integration of Flink Stephan Ewen
  • Re: KNIME Integration of Flink Arvid Heise
• [jira] [Created] (FLINK-1227) KeySelector can't implement ResultTypeQueryable Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-1226) No way to give Configuration to DataSource Fabian Hueske (JIRA)
• Collection serializers Stephan Ewen
  • Re: Collection serializers Márton Balassi
• beginner navya sri nizamkari
  • Re: beginner Chiwan Park
  • Re: beginner Till Rohrmann
• Embeded Use sirinath
  • Re: Embeded Use Stephan Ewen
  • Re: Embeded Use sirinath
  • Re: Embeded Use Stephan Ewen
• Flink on Tez Kostas Tzoumas
  • Re: Flink on Tez Arun Murthy
  • RE: Flink on Tez Bikas Saha
  • RE: Flink on Tez sirinath
  • Re: Flink on Tez Aljoscha Krettek
  • Re: Flink on Tez Flavio Pompermaier
  • Re: Flink on Tez Kostas Tzoumas
  • Re: Flink on Tez Kostas Tzoumas
  • Re: Flink on Tez Flavio Pompermaier
  • Re: Flink on Tez Sean Owen
  • Re: Flink on Tez sirinath
  • Re: Flink on Tez Fabian Hueske
  • Re: Flink on Tez Kostas Tzoumas
  • Re: Flink on Tez Henry Saputra
  • Re: Flink on Tez sirinath
  • Re: Flink on Tez Kostas Tzoumas
• [jira] [Created] (FLINK-1225) Quickstart does not work Timo Walther (JIRA)
• [jira] [Created] (FLINK-1224) Fix .getExecutionEnvironment of the StreamingExecutionEnvironment to return proper context Gyula Fora (JIRA)
• Help with .getExecutionEnvironment() method Gyula Fóra
  • Re: Help with .getExecutionEnvironment() method Aljoscha Krettek
  • Re: Help with .getExecutionEnvironment() method Gyula Fóra
  • Re: Help with .getExecutionEnvironment() method Aljoscha Krettek
  • Re: Help with .getExecutionEnvironment() method Gyula Fóra
  • Re: Help with .getExecutionEnvironment() method Stephan Ewen
• Making Fink More HFT / Trading Friendly sirinath
  • Re: Making Fink More HFT / Trading Friendly Gyula Fora
• Make Streaming Interoperable with Reactive Streams, Java Streams and Rx sirinath
  • Re: Make Streaming Interoperable with Reactive Streams, Java Streams and Rx Gyula Fora
  • Re: Make Streaming Interoperable with Reactive Streams, Java Streams and Rx sirinath
  • Re: Make Streaming Interoperable with Reactive Streams, Java Streams and Rx Gyula Fora
• [jira] [Created] (FLINK-1223) Allow value escaping in CSV files Johannes (JIRA)
• [jira] [Created] (FLINK-1222) Let tasks finish as soon as their data is sent Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1221) Use program source line of invocation as the default function name Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1220) Make INFO logging more verbose Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1219) Add support for Apache Tez as execution engine Kostas Tzoumas (JIRA)
• [jira] [Created] (FLINK-1218) Don't use "new Integer". Use "Integer.valueOf" instead. Kousuke Saruta (JIRA)
• [jira] [Created] (FLINK-1217) Keepalive option should be set to sockets in Client and Server Kousuke Saruta (JIRA)
• Streaming groupby and aggregation by field expressions Gyula Fóra
  • Re: Streaming groupby and aggregation by field expressions Fabian Hueske
  • Re: Streaming groupby and aggregation by field expressions Gyula Fora
  • Re: Streaming groupby and aggregation by field expressions Fabian Hueske
  • Re: Streaming groupby and aggregation by field expressions Viktor Rosenfeld
• [jira] [Created] (FLINK-1216) Quickstart projects should have flink dependencies in scope "provided" Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1215) FileSystem.initOutPathLocalFS can lead to race condition Aljoscha Krettek (JIRA)
• Unit testing Flink programs / DataSet operations Viktor Rosenfled
  • Re: Unit testing Flink programs / DataSet operations Stephan Ewen
  • Re: Unit testing Flink programs / DataSet operations Viktor Rosenfeld
  • Re: Unit testing Flink programs / DataSet operations Stephan Ewen
• [jira] [Created] (FLINK-1214) Prevent partitioning pushdown unless partitions fields match exactly Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1213) Add .gitattributes to normalize EOL character. Kousuke Saruta (JIRA)
• [jira] [Created] (FLINK-1212) Interpreter directive in shell scripts should be "/usr/bin/env bash" instead of "/bin/bash" Kousuke Saruta (JIRA)
• [jira] [Created] (FLINK-1211) EOL character of Windows Batch files should be CRLF Kousuke Saruta (JIRA)
• [jira] [Created] (FLINK-1210) Improve Error Message in Delta Iteratione when Next Workset does not Depend on Workset. Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1209) Forgetting to close an iteration leads to a confusing error message Stephan Ewen (JIRA)
• Blog post for release 0.7.0 Kostas Tzoumas
  • Re: Blog post for release 0.7.0 Flavio Pompermaier
  • Re: Blog post for release 0.7.0 Flavio Pompermaier
• Regular Flink meetup in Berlin Kostas Tzoumas
• [jira] [Created] (FLINK-1208) Skip comment lines in CSV input format. Allow user to specify comment character. Aljoscha Krettek (JIRA)
• [FLINK-1040] Make type() call in projections optional Chen Xu
  • Re: [FLINK-1040] Make type() call in projections optional Fabian Hueske
  • Re: [FLINK-1040] Make type() call in projections optional Stephan Ewen
• Coarse-grained FT implementation Márton Balassi
  • Re: Coarse-grained FT implementation Ufuk Celebi
  • Re: Coarse-grained FT implementation Henry Saputra
  • Re: Coarse-grained FT implementation Kostas Tzoumas
  • Re: Coarse-grained FT implementation Henry Saputra
  • Re: Coarse-grained FT implementation Stephan Ewen
• [jira] [Created] (FLINK-1207) Switch ContextEnvironment to Environment factory Stephan Ewen (JIRA)
• Static context environment Stephan Ewen
  • Re: Static context environment Aljoscha Krettek
  • Re: Static context environment Ufuk Celebi
• [jira] [Created] (FLINK-1206) Add option to the web client to specify default parallelism for a program Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1205) LibraryCacheManager should track execution IDs of library registrations Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1204) Fix streaming example builds to provide self-contained jars JIRA
• [jira] [Created] (FLINK-1203) ClassCast exceptions in parallel tests (Surefire Bug?) Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1202) Failed file outputs should remove partially complete files Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1201) Graph API for Flink Kostas Tzoumas (JIRA)
• HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
  • Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
  • Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
  • Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
  • Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Robert Metzger
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 fhueske
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 fhueske
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Stephan Ewen
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske
  • Re: HBase 0.98 addon for Flink 0.8 Flavio Pompermaier
  • Re: HBase 0.98 addon for Flink 0.8 Fabian Hueske

• Earlier messages
• Later messages