dev
Thread
Date
Earlier messages
Later messages
Messages by Date
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Viktor Rosenfeld
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Stephan Ewen
2014/12/05
Re: Stringable Hashmap keys on POJOs
Stephan Ewen
2014/12/05
Re: Samoa on Flink
Vasiliki Kalavri
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Stefano Bortoli
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Szabó Péter
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Felix Neutatz
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Paris Carbone
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Márton Balassi
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Timo Walther
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Alexander Alexandrov
2014/12/05
[jira] [Created] (FLINK-1302) JDBCInputFormat does not implement NonParallelInput interface
Robert Metzger (JIRA)
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Vasiliki Kalavri
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Gyula Fora
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Aljoscha Krettek
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Sebastian Schelter
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Fabian Hueske
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Kostas Tzoumas
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Robert Metzger
2014/12/05
Re: [VOTE] Graduate Flink from the Incubator
Flavio Pompermaier
2014/12/05
[VOTE] Graduate Flink from the Incubator
Kostas Tzoumas
2014/12/05
Re: Support for Total Order Partitioner ?
Fabian Hueske
2014/12/05
Re: Stringable Hashmap keys on POJOs
Robert Metzger
2014/12/05
Re: Stringable Hashmap keys on POJOs
Stephan Ewen
2014/12/04
Support for Total Order Partitioner ?
Kirschnick, Johannes
2014/12/04
Re: Stringable Hashmap keys on POJOs
Aljoscha Krettek
2014/12/04
Stringable Hashmap keys on POJOs
Paris Carbone
2014/12/04
Re: Statistics collection for optimization
Henry Saputra
2014/12/04
[jira] [Created] (FLINK-1301) Several files without proper license headers
Fabian Hueske (JIRA)
2014/12/03
[jira] [Created] (FLINK-1300) Duplicate class DataInputViewStream
Stephan Ewen (JIRA)
2014/12/03
Re: New Flink website layout and frontage
Kostas Tzoumas
2014/12/03
[jira] [Created] (FLINK-1299) Remove default values for JobManager and TaskManager heap sizes
Ufuk Celebi (JIRA)
2014/12/03
Re: Samoa on Flink
Paris Carbone
2014/12/03
Re: Statistics collection for optimization
Robert Metzger
2014/12/03
Re: Samoa on Flink
Fabian Hueske
2014/12/03
Re: 0.7.1 maintenance release
Márton Balassi
2014/12/02
Re: Statistics collection for optimization
Márton Balassi
2014/12/02
Re: InputFormat API and current scanned row count
Fabian Hueske
2014/12/02
Re: InputFormat API and current scanned row count
Flavio Pompermaier
2014/12/02
Re: InputFormat API and current scanned row count
Fabian Hueske
2014/12/02
Re: Statistics collection for optimization
Fabian Hueske
2014/12/02
Re: [DISCUSS] Graduation of Flink from the Incubator
Alan Gates
2014/12/02
[jira] [Created] (FLINK-1298) Consolidate Handling of User Code ClassLoader
Aljoscha Krettek (JIRA)
2014/12/02
Re: Statistics collection for optimization
Alexander Alexandrov
2014/12/02
Re: Enhance Flink's monitoring capabilities
aalexandrov
2014/12/02
[jira] [Created] (FLINK-1297) Add support for tracking statistics of intermediate results
Alexander Alexandrov (JIRA)
2014/12/02
Re: [GitHub] incubator-flink pull request: Add support for Subclasses, Interfac...
Ufuk Celebi
2014/12/02
Re: Statistics collection for optimization
Ufuk Celebi
2014/12/02
Re: Statistics collection for optimization
Robert Metzger
2014/12/02
Re: Statistics collection for optimization
Alexander Alexandrov
2014/12/02
Re: Statistics collection for optimization
Robert Metzger
2014/12/02
Re: Statistics collection for optimization
Kostas Tzoumas
2014/12/02
Re: Statistics collection for optimization
Ufuk Celebi
2014/12/02
Statistics collection for optimization
Alexander Alexandrov
2014/12/01
Re: [DISCUSS] Graduation of Flink from the Incubator
Henry Saputra
2014/12/01
Re: New Flink website layout and frontage
Henry Saputra
2014/12/01
Re: 0.7.1 maintenance release
Fabian Hueske
2014/12/01
Re: 0.7.1 maintenance release
Ufuk Celebi
2014/12/01
[jira] [Created] (FLINK-1296) Add support for very large record for sorting
Stephan Ewen (JIRA)
2014/12/01
Re: 0.7.1 maintenance release
Robert Metzger
2014/12/01
[jira] [Created] (FLINK-1295) Add option to Flink client to start a YARN session per job
Robert Metzger (JIRA)
2014/12/01
Re: 0.7.1 maintenance release
Stephan Ewen
2014/12/01
[jira] [Created] (FLINK-1294) Add Performance and Tuning Guide to documentation
Robert Metzger (JIRA)
2014/12/01
Re: 0.7.1 maintenance release
Till Rohrmann
2014/12/01
Re: 0.7.1 maintenance release
Ufuk Celebi
2014/12/01
Re: Projects page on Flink web page
Robert Metzger
2014/12/01
Re: 0.7.1 maintenance release
Márton Balassi
2014/12/01
Re: 0.7.1 maintenance release
Robert Metzger
2014/11/28
Re: ScalaTest for IntelliJ
Ufuk Celebi
2014/11/28
Re: ScalaTest for IntelliJ
Sean Owen
2014/11/28
Re: [DISCUSS] Graduation of Flink from the Incubator
Vasiliki Kalavri
2014/11/28
Re: ScalaTest for IntelliJ
Kostas Tzoumas
2014/11/28
Re: ScalaTest for IntelliJ
Robert Metzger
2014/11/28
Re: ScalaTest for IntelliJ
Stephan Ewen
2014/11/28
Re: [DISCUSS] Graduation of Flink from the Incubator
Ufuk Celebi
2014/11/28
Re: ScalaTest for IntelliJ
Chiwan Park
2014/11/28
Re: [DISCUSS] Graduation of Flink from the Incubator
Robert Metzger
2014/11/28
Re: ScalaTest for IntelliJ
Felix Neutatz
2014/11/28
Re: ScalaTest for IntelliJ
Chiwan Park
2014/11/28
[jira] [Created] (FLINK-1293) Add support for out-of-place aggregations
Viktor Rosenfeld (JIRA)
2014/11/28
Re: ScalaTest for IntelliJ
Felix Neutatz
2014/11/28
Re: ScalaTest for IntelliJ
Stephan Ewen
2014/11/28
ScalaTest for IntelliJ
Felix Neutatz
2014/11/28
Re: New Flink website layout and frontage
Timo Walther
2014/11/28
Re: New Flink website layout and frontage
Suneel Marthi
2014/11/28
Re: New Flink website layout and frontage
Till Rohrmann
2014/11/28
InputFormat API and current scanned row count
Flavio Pompermaier
2014/11/28
Re: [DISCUSS] Graduation of Flink from the Incubator
Sebastian Schelter
2014/11/27
Re: [DISCUSS] Graduation of Flink from the Incubator
Stephan Ewen
2014/11/27
Re: [DISCUSS] Graduation of Flink from the Incubator
Fabian Hueske
2014/11/27
Re: New Flink website layout and frontage
Fabian Hueske
2014/11/27
Re: New Flink website layout and frontage
Markl, Volker, Prof. Dr.
2014/11/27
Re: New Flink website layout and frontage
Kirschnick, Johannes
2014/11/27
Re: New Flink website layout and frontage
Kirschnick, Johannes
2014/11/27
Re: New Flink website layout and frontage
Max Michels
2014/11/27
Re: New Flink website layout and frontage
Vasiliki Kalavri
2014/11/27
Re: New Flink website layout and frontage
Gyula Fora
2014/11/27
[DISCUSS] Graduation of Flink from the Incubator
Kostas Tzoumas
2014/11/27
Re: New Flink website layout and frontage
Stephan Ewen
2014/11/27
Re: New Flink website layout and frontage
Aljoscha Krettek
2014/11/27
[jira] [Created] (FLINK-1292) Allow for longer normalized keys
Stephan Ewen (JIRA)
2014/11/27
[jira] [Created] (FLINK-1291) Remove GC options from JobManager and TaskManager scripts
Stephan Ewen (JIRA)
2014/11/27
Re: New Flink website layout and frontage
Kostas Tzoumas
2014/11/27
New Flink website layout and frontage
Kostas Tzoumas
2014/11/27
Re: Samoa on Flink
Márton Balassi
2014/11/27
Re: Compression of network traffic
Stephan Ewen
2014/11/27
Re: Compression of network traffic
Viktor Rosenfeld
2014/11/27
Re: Samoa on Flink
Paris Carbone
2014/11/27
Samoa on Flink
Vasiliki Kalavri
2014/11/27
[jira] [Created] (FLINK-1290) Optimizer prunes all candidates when unable to reuse sort properties
Stephan Ewen (JIRA)
2014/11/27
Re: Hi / Aggregation support
Aljoscha Krettek
2014/11/27
Re: Hi / Aggregation support
Fabian Hueske
2014/11/27
Re: Hi / Aggregation support
Fabian Hueske
2014/11/27
Re: Hi / Aggregation support
Aljoscha Krettek
2014/11/27
Re: Hi / Aggregation support
Viktor Rosenfeld
2014/11/27
Re: Channel indexing with pointwise connection pattern
Stephan Ewen
2014/11/27
Re: Channel indexing with pointwise connection pattern
Gyula Fora
2014/11/27
Re: Channel indexing with pointwise connection pattern
Stephan Ewen
2014/11/27
Re: Compression of network traffic
Stephan Ewen
2014/11/26
Channel indexing with pointwise connection pattern
Gyula Fora
2014/11/26
Re: Compression of network traffic
Viktor Rosenfeld
2014/11/26
[jira] [Created] (FLINK-1289) Broken links to k-means examples in website
Vasia Kalavri (JIRA)
2014/11/26
[jira] [Created] (FLINK-1288) YARN ApplicationMaster sometimes fails to allocate the specified number of workers
Robert Metzger (JIRA)
2014/11/26
[jira] [Created] (FLINK-1287) Improve File Input Split assignment
Robert Metzger (JIRA)
2014/11/26
[jira] [Created] (FLINK-1286) Failures and bad error message in CollectionInputFormat
Stephan Ewen (JIRA)
2014/11/26
Re: Java Primitive Collections in Flink
Sean Owen
2014/11/26
[jira] [Created] (FLINK-1285) Make execution mode configurable
Ufuk Celebi (JIRA)
2014/11/26
Re: Enhance Flink's monitoring capabilities
Robert Metzger
2014/11/26
[jira] [Created] (FLINK-1284) Uniform random sampling operator over windows
Paris Carbone (JIRA)
2014/11/26
[jira] [Created] (FLINK-1283) Update website layout and frontpage content
Kostas Tzoumas (JIRA)
2014/11/26
[jira] [Created] (FLINK-1282) Update layout of documentation
Kostas Tzoumas (JIRA)
2014/11/26
[jira] [Created] (FLINK-1281) Update website layout
Kostas Tzoumas (JIRA)
2014/11/26
Re: Program crashes trying to read JSON file
Stephan Ewen
2014/11/26
Re: Program crashes trying to read JSON file
Felix Neutatz
2014/11/26
Re: Program crashes trying to read JSON file
Anirvan BASU
2014/11/25
[jira] [Created] (FLINK-1280) Rework StreamInvokables to use the PactDriver interface for better future integration
Gyula Fora (JIRA)
2014/11/25
[jira] [Created] (FLINK-1279) Change default partitioning setting for low parallelism stream sources from forward to distribute
Gyula Fora (JIRA)
2014/11/25
Re: Projects page on Flink web page
Henry Saputra
2014/11/25
Re: Compression of network traffic
Daniel Warneke
2014/11/25
Re: Program crashes trying to read JSON file
Anirvan BASU
2014/11/25
Re: Compression of network traffic
Stephan Ewen
2014/11/25
Re: Program crashes trying to read JSON file
Stefano Bortoli
2014/11/25
Program crashes trying to read JSON file
Anirvan BASU
2014/11/25
Re: Java Primitive Collections in Flink
samkum
2014/11/25
Re: Java Primitive Collections in Flink
sirinath
2014/11/25
Re: Java Primitive Collections in Flink
Sean Owen
2014/11/25
Re: Java Primitive Collections in Flink
sirinath
2014/11/25
[jira] [Created] (FLINK-1278) Remove the Record special code paths
Stephan Ewen (JIRA)
2014/11/25
Re: Projects page on Flink web page
Kostas Tzoumas
2014/11/25
Re: 0.7.1 maintenance release
Kostas Tzoumas
2014/11/25
Re: Compression of network traffic
Viktor Rosenfeld
2014/11/24
Re: Custom Partitioners Syntax
Stephan Ewen
2014/11/24
Re: Hi / Aggregation support
Fabian Hueske
2014/11/24
Re: 0.7.1 maintenance release
Till Rohrmann
2014/11/24
Re: Custom Partitioners Syntax
Till Rohrmann
2014/11/24
Re: Custom Partitioners Syntax
Stephan Ewen
2014/11/24
Re: Custom Partitioners Syntax
Fabian Hueske
2014/11/24
Custom Partitioners Syntax
Stephan Ewen
2014/11/24
Re: 0.7.1 maintenance release
Henry Saputra
2014/11/24
Re: Projects page on Flink web page
Markl, Volker, Prof. Dr.
2014/11/24
Re: Projects page on Flink web page
Stephan Ewen
2014/11/24
Re: Projects page on Flink web page
Robert Metzger
2014/11/24
[jira] [Created] (FLINK-1277) Support sort order for coGroup inputs
Till Rohrmann (JIRA)
2014/11/24
Re: 0.7.1 maintenance release
Fabian Hueske
2014/11/24
Projects page on Flink web page
Kruse, Sebastian
2014/11/24
Re: 0.7.1 maintenance release
Ufuk Celebi
2014/11/24
Re: 0.7.1 maintenance release
Stephan Ewen
2014/11/24
Re: 0.7.1 maintenance release
Robert Metzger
2014/11/24
Re: 0.7.1 maintenance release
Márton Balassi
2014/11/24
0.7.1 maintenance release
Ufuk Celebi
2014/11/24
Re: Compression of network traffic
Ufuk Celebi
2014/11/24
Re: Compression of network traffic
Stephan Ewen
2014/11/24
Re: Compression of network traffic
Sebastian Schelter
2014/11/24
Re: Compression of network traffic
Stephan Ewen
2014/11/23
[jira] [Created] (FLINK-1276) Misspelled class name SlotAvailabilityListener.java
Suneel Marthi (JIRA)
2014/11/23
Re: Enhance Flink's monitoring capabilities
Ufuk Celebi
2014/11/23
Re: Compression of network traffic
Ufuk Celebi
2014/11/23
[jira] [Created] (FLINK-1275) Add support to compress network I/O
Ufuk Celebi (JIRA)
2014/11/23
Re: Compression of network traffic
Robert Metzger
2014/11/22
Re: Enhance Flink's monitoring capabilities
Fabian Hueske
2014/11/22
[jira] [Created] (FLINK-1274) Make Flink Streaming's FileSourceFunction type generic
JIRA
2014/11/22
[jira] [Created] (FLINK-1273) Add the "Void" type to the basic types.
Stephan Ewen (JIRA)
2014/11/22
[jira] [Created] (FLINK-1272) Add a "reduceWithKey" function
Stephan Ewen (JIRA)
2014/11/22
[jira] [Created] (FLINK-1271) Extend HadoopOutputFormat and HadoopInputFormat to handle Void.class
Felix Neutatz (JIRA)
2014/11/21
Enhance Flink's monitoring capabilities
Nils E
2014/11/21
[jira] [Created] (FLINK-1270) FileSystem.get() doesn't support relative paths
Chesnay Schepler (JIRA)
2014/11/21
[jira] [Created] (FLINK-1269) Easy way to "group count" dataset
Sebastian Schelter (JIRA)
2014/11/21
Re: Translate one Java API operator to multiple common API operators?
Fabian Hueske
2014/11/21
Re: Translate one Java API operator to multiple common API operators?
Fabian Hueske
2014/11/21
Compression of network traffic
Viktor Rosenfeld
2014/11/21
Translate one Java API operator to multiple common API operators?
Viktor Rosenfeld
2014/11/21
Re: [ANNOUNCE] Welcome Timo Walther as a new committer
Till Rohrmann
2014/11/21
[jira] [Created] (FLINK-1268) FileOutputFormat with overwrite does not clear local output directories
Till Rohrmann (JIRA)
2014/11/21
[jira] [Created] (FLINK-1267) Add crossGroup operator
Fabian Hueske (JIRA)
2014/11/20
[jira] [Created] (FLINK-1266) Generalize Flink's DistributedFileSystemClass to a Hadoop FileSystem wrapper
Robert Metzger (JIRA)
2014/11/20
Re: [ANNOUNCE] Welcome Timo Walther as a new committer
Fabian Hueske
2014/11/20
[jira] [Created] (FLINK-1265) configure() not called with usercode classloader as context classloader
Fabian Hueske (JIRA)
2014/11/20
Re: [ANNOUNCE] Welcome Timo Walther as a new committer
Chiwan Park
2014/11/20
Re: [ANNOUNCE] Welcome Timo Walther as a new committer
Vasiliki Kalavri
2014/11/20
Re: [ANNOUNCE] Welcome Timo Walther as a new committer
Henry Saputra
Earlier messages
Later messages