dev  

Messages by Thread

• • Re: [VOTE] Graduate Flink from the Incubator Chiwan Park
  • Re: [VOTE] Graduate Flink from the Incubator Asterios Katsifodimos
  • Re: [VOTE] Graduate Flink from the Incubator Kostas Tzoumas
• Support for Total Order Partitioner ? Kirschnick, Johannes
  • Re: Support for Total Order Partitioner ? Fabian Hueske
  • AW: Support for Total Order Partitioner ? Kirschnick, Johannes
• Stringable Hashmap keys on POJOs Paris Carbone
  • Re: Stringable Hashmap keys on POJOs Aljoscha Krettek
  • Re: Stringable Hashmap keys on POJOs Stephan Ewen
  • Re: Stringable Hashmap keys on POJOs Robert Metzger
  • Re: Stringable Hashmap keys on POJOs Stephan Ewen
  • Re: Stringable Hashmap keys on POJOs Paris Carbone
  • Re: Stringable Hashmap keys on POJOs Paris Carbone
  • Re: Stringable Hashmap keys on POJOs Aljoscha Krettek
• [jira] [Created] (FLINK-1301) Several files without proper license headers Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1300) Duplicate class DataInputViewStream Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1299) Remove default values for JobManager and TaskManager heap sizes Ufuk Celebi (JIRA)
• [jira] [Created] (FLINK-1298) Consolidate Handling of User Code ClassLoader Aljoscha Krettek (JIRA)
• [jira] [Created] (FLINK-1297) Add support for tracking statistics of intermediate results Alexander Alexandrov (JIRA)
• Re: [GitHub] incubator-flink pull request: Add support for Subclasses, Interfac... Ufuk Celebi
• Statistics collection for optimization Alexander Alexandrov
  • Re: Statistics collection for optimization Ufuk Celebi
  • Re: Statistics collection for optimization Kostas Tzoumas
  • Re: Statistics collection for optimization Robert Metzger
  • Re: Statistics collection for optimization Alexander Alexandrov
  • Re: Statistics collection for optimization Robert Metzger
  • Re: Statistics collection for optimization Ufuk Celebi
  • Re: Statistics collection for optimization Alexander Alexandrov
  • Re: Statistics collection for optimization Fabian Hueske
  • Re: Statistics collection for optimization Márton Balassi
  • Re: Statistics collection for optimization Robert Metzger
  • Re: Statistics collection for optimization Henry Saputra
• [jira] [Created] (FLINK-1296) Add support for very large record for sorting Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1295) Add option to Flink client to start a YARN session per job Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1294) Add Performance and Tuning Guide to documentation Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1293) Add support for out-of-place aggregations Viktor Rosenfeld (JIRA)
• ScalaTest for IntelliJ Felix Neutatz
  • Re: ScalaTest for IntelliJ Stephan Ewen
  • Re: ScalaTest for IntelliJ Felix Neutatz
  • Re: ScalaTest for IntelliJ Chiwan Park
  • Re: ScalaTest for IntelliJ Felix Neutatz
  • Re: ScalaTest for IntelliJ Chiwan Park
  • Re: ScalaTest for IntelliJ Stephan Ewen
  • Re: ScalaTest for IntelliJ Robert Metzger
  • Re: ScalaTest for IntelliJ Sean Owen
  • Re: ScalaTest for IntelliJ Ufuk Celebi
  • Re: ScalaTest for IntelliJ Kostas Tzoumas
• InputFormat API and current scanned row count Flavio Pompermaier
  • Re: InputFormat API and current scanned row count Fabian Hueske
  • Re: InputFormat API and current scanned row count Flavio Pompermaier
  • Re: InputFormat API and current scanned row count Fabian Hueske
• [DISCUSS] Graduation of Flink from the Incubator Kostas Tzoumas
  • Re: [DISCUSS] Graduation of Flink from the Incubator Fabian Hueske
  • Re: [DISCUSS] Graduation of Flink from the Incubator Stephan Ewen
  • Re: [DISCUSS] Graduation of Flink from the Incubator Sebastian Schelter
  • Re: [DISCUSS] Graduation of Flink from the Incubator Robert Metzger
  • Re: [DISCUSS] Graduation of Flink from the Incubator Ufuk Celebi
  • Re: [DISCUSS] Graduation of Flink from the Incubator Vasiliki Kalavri
  • Re: [DISCUSS] Graduation of Flink from the Incubator Henry Saputra
  • Re: [DISCUSS] Graduation of Flink from the Incubator Sean Owen
  • Re: [DISCUSS] Graduation of Flink from the Incubator Alan Gates
• [jira] [Created] (FLINK-1292) Allow for longer normalized keys Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1291) Remove GC options from JobManager and TaskManager scripts Stephan Ewen (JIRA)
• New Flink website layout and frontage Kostas Tzoumas
  • Re: New Flink website layout and frontage Kostas Tzoumas
  • Re: New Flink website layout and frontage Aljoscha Krettek
  • Re: New Flink website layout and frontage Stephan Ewen
  • Re: New Flink website layout and frontage Gyula Fora
  • Re: New Flink website layout and frontage Vasiliki Kalavri
  • Re: New Flink website layout and frontage Max Michels
  • Re: New Flink website layout and frontage Timo Walther
  • Re: New Flink website layout and frontage Markl, Volker, Prof. Dr.
  • Re: New Flink website layout and frontage Fabian Hueske
  • Re: New Flink website layout and frontage Till Rohrmann
  • Re: New Flink website layout and frontage Suneel Marthi
  • Re: New Flink website layout and frontage Henry Saputra
  • Re: New Flink website layout and frontage Kostas Tzoumas
  • Re: New Flink website layout and frontage Ufuk Celebi
  • Re: New Flink website layout and frontage Márton Balassi
  • Re: New Flink website layout and frontage Kostas Tzoumas
  • Re: New Flink website layout and frontage Kirschnick, Johannes
  • Re: New Flink website layout and frontage Kirschnick, Johannes
• Samoa on Flink Vasiliki Kalavri
  • Re: Samoa on Flink Paris Carbone
  • Re: Samoa on Flink Márton Balassi
  • Re: Samoa on Flink Fabian Hueske
  • Re: Samoa on Flink Paris Carbone
  • Re: Samoa on Flink Vasiliki Kalavri
• [jira] [Created] (FLINK-1290) Optimizer prunes all candidates when unable to reuse sort properties Stephan Ewen (JIRA)
• Channel indexing with pointwise connection pattern Gyula Fora
  • Re: Channel indexing with pointwise connection pattern Stephan Ewen
  • Re: Channel indexing with pointwise connection pattern Gyula Fora
  • Re: Channel indexing with pointwise connection pattern Stephan Ewen
• [jira] [Created] (FLINK-1289) Broken links to k-means examples in website Vasia Kalavri (JIRA)
• [jira] [Created] (FLINK-1288) YARN ApplicationMaster sometimes fails to allocate the specified number of workers Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1287) Improve File Input Split assignment Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1286) Failures and bad error message in CollectionInputFormat Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1285) Make execution mode configurable Ufuk Celebi (JIRA)
• [jira] [Created] (FLINK-1284) Uniform random sampling operator over windows Paris Carbone (JIRA)
• [jira] [Created] (FLINK-1283) Update website layout and frontpage content Kostas Tzoumas (JIRA)
• [jira] [Created] (FLINK-1282) Update layout of documentation Kostas Tzoumas (JIRA)
• [jira] [Created] (FLINK-1281) Update website layout Kostas Tzoumas (JIRA)
• [jira] [Created] (FLINK-1280) Rework StreamInvokables to use the PactDriver interface for better future integration Gyula Fora (JIRA)
• [jira] [Created] (FLINK-1279) Change default partitioning setting for low parallelism stream sources from forward to distribute Gyula Fora (JIRA)
• Program crashes trying to read JSON file Anirvan BASU
  • Re: Program crashes trying to read JSON file Stefano Bortoli
  • Re: Program crashes trying to read JSON file Anirvan BASU
  • Re: Program crashes trying to read JSON file Anirvan BASU
  • Re: Program crashes trying to read JSON file Felix Neutatz
  • Re: Program crashes trying to read JSON file Stephan Ewen
• [jira] [Created] (FLINK-1278) Remove the Record special code paths Stephan Ewen (JIRA)
• Custom Partitioners Syntax Stephan Ewen
  • Re: Custom Partitioners Syntax Fabian Hueske
  • Re: Custom Partitioners Syntax Stephan Ewen
  • Re: Custom Partitioners Syntax Till Rohrmann
  • Re: Custom Partitioners Syntax Stephan Ewen
• [jira] [Created] (FLINK-1277) Support sort order for coGroup inputs Till Rohrmann (JIRA)
• Projects page on Flink web page Kruse, Sebastian
  • Re: Projects page on Flink web page Robert Metzger
  • Re: Projects page on Flink web page Stephan Ewen
  • Re: Projects page on Flink web page Markl, Volker, Prof. Dr.
  • Re: Projects page on Flink web page Kostas Tzoumas
  • Re: Projects page on Flink web page Henry Saputra
  • Re: Projects page on Flink web page Robert Metzger
• 0.7.1 maintenance release Ufuk Celebi
  • Re: 0.7.1 maintenance release Márton Balassi
  • Re: 0.7.1 maintenance release Robert Metzger
  • Re: 0.7.1 maintenance release Stephan Ewen
  • Re: 0.7.1 maintenance release Ufuk Celebi
  • Re: 0.7.1 maintenance release Fabian Hueske
  • Re: 0.7.1 maintenance release Henry Saputra
  • Re: 0.7.1 maintenance release Till Rohrmann
  • Re: 0.7.1 maintenance release Kostas Tzoumas
  • Re: 0.7.1 maintenance release Robert Metzger
  • Re: 0.7.1 maintenance release Márton Balassi
  • Re: 0.7.1 maintenance release Ufuk Celebi
  • Re: 0.7.1 maintenance release Till Rohrmann
  • Re: 0.7.1 maintenance release Stephan Ewen
  • Re: 0.7.1 maintenance release Robert Metzger
  • Re: 0.7.1 maintenance release Ufuk Celebi
  • Re: 0.7.1 maintenance release Fabian Hueske
  • Re: 0.7.1 maintenance release Márton Balassi
• [jira] [Created] (FLINK-1276) Misspelled class name SlotAvailabilityListener.java Suneel Marthi (JIRA)
• [jira] [Created] (FLINK-1275) Add support to compress network I/O Ufuk Celebi (JIRA)
• [jira] [Created] (FLINK-1274) Make Flink Streaming's FileSourceFunction type generic JIRA
• [jira] [Created] (FLINK-1273) Add the "Void" type to the basic types. Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1272) Add a "reduceWithKey" function Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1271) Extend HadoopOutputFormat and HadoopInputFormat to handle Void.class Felix Neutatz (JIRA)
• Enhance Flink's monitoring capabilities Nils E
  • Re: Enhance Flink's monitoring capabilities Fabian Hueske
  • Re: Enhance Flink's monitoring capabilities Ufuk Celebi
  • Re: Enhance Flink's monitoring capabilities Robert Metzger
  • Re: Enhance Flink's monitoring capabilities aalexandrov
  • Re: Enhance Flink's monitoring capabilities Robert Metzger
  • Re: Enhance Flink's monitoring capabilities Henry Saputra
  • Re: Enhance Flink's monitoring capabilities Stephan Ewen
  • Re: Enhance Flink's monitoring capabilities Henry Saputra
  • Re: Enhance Flink's monitoring capabilities Henry Saputra
  • Re: Enhance Flink's monitoring capabilities Robert Metzger
  • Re: Enhance Flink's monitoring capabilities Henry Saputra
  • Fwd: Enhance Flink's monitoring capabilities Alexander Alexandrov
• [jira] [Created] (FLINK-1270) FileSystem.get() doesn't support relative paths Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-1269) Easy way to "group count" dataset Sebastian Schelter (JIRA)
• Compression of network traffic Viktor Rosenfeld
  • Re: Compression of network traffic Robert Metzger
  • Re: Compression of network traffic Ufuk Celebi
  • Re: Compression of network traffic Stephan Ewen
  • Re: Compression of network traffic Sebastian Schelter
  • Re: Compression of network traffic Stephan Ewen
  • Re: Compression of network traffic Ufuk Celebi
  • Re: Compression of network traffic Viktor Rosenfeld
  • Re: Compression of network traffic Stephan Ewen
  • Re: Compression of network traffic Daniel Warneke
  • Re: Compression of network traffic Viktor Rosenfeld
  • Re: Compression of network traffic Stephan Ewen
  • Re: Compression of network traffic Viktor Rosenfeld
  • Re: Compression of network traffic Stephan Ewen
• Translate one Java API operator to multiple common API operators? Viktor Rosenfeld
  • Re: Translate one Java API operator to multiple common API operators? Fabian Hueske
  • Re: Translate one Java API operator to multiple common API operators? Fabian Hueske
• [jira] [Created] (FLINK-1268) FileOutputFormat with overwrite does not clear local output directories Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1267) Add crossGroup operator Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1266) Generalize Flink's DistributedFileSystemClass to a Hadoop FileSystem wrapper Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1265) configure() not called with usercode classloader as context classloader Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1264) Custom partitioners are not properly forwarded to teh runtime Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1263) Manual Partition operations are considered to keep data types constant Stephan Ewen (JIRA)
• [ANNOUNCE] Welcome Timo Walther as a new committer Robert Metzger
  • Re: [ANNOUNCE] Welcome Timo Walther as a new committer Henry Saputra
  • Re: [ANNOUNCE] Welcome Timo Walther as a new committer Vasiliki Kalavri
  • Re: [ANNOUNCE] Welcome Timo Walther as a new committer Chiwan Park
  • Re: [ANNOUNCE] Welcome Timo Walther as a new committer Fabian Hueske
  • Re: [ANNOUNCE] Welcome Timo Walther as a new committer Till Rohrmann
• [jira] [Created] (FLINK-1262) inconsistency between CsvReader.java and TupleGenerator.java Chen Xu (JIRA)
• [jira] [Created] (FLINK-1261) Handling of full temporary directories at startup and runtime Ufuk Celebi (JIRA)
• [jira] [Created] (FLINK-1260) Add custom partitioning to documentation Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1259) FilterFunction can modify data Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1258) Merge iterative and non-iterative tasks Ufuk Celebi (JIRA)
• [jira] [Created] (FLINK-1257) Binary input/output format which use the type serializer to read/write binary data Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1256) Use Kryo for user code object serialization Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1255) Problems with generic types in Scala API Sebastian Schelter (JIRA)

• Earlier messages
• Later messages