dev  

Messages by Thread

• [jira] [Created] (FLINK-1163) Scala DataSet cannot be used within iterations because it is not serializable Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1162) Cannot serialize Scala classes with Avro serializer Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1161) Modify streaming api type extractor classes to allow java 8 lambdas Gyula Fora (JIRA)
• [jira] [Created] (FLINK-1160) Modify record readers to allow publishing events to specific inputs (instead of broadcast) in the union record reader Gyula Fora (JIRA)
• [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Fabian Hueske
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Henry Saputra
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Kostas Tzoumas
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Aljoscha Krettek
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Till Rohrmann
  • Re: [VOTE] Release Apache Flink 0.7.0 (incubating) (RC1) Robert Metzger
• [jira] [Created] (FLINK-1159) Case style anonymous functions not supported by Scala API Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1158) Logging property files missing in project created by archetypes Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1157) Document TaskManager Slots Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1156) Bug in Constant Fields Annotation (Semantic Properties) Aljoscha Krettek (JIRA)
• [jira] [Created] (FLINK-1155) Add Squirrel Logo to Flink website Robert Metzger (JIRA)
• a question about Exactly once processing cY
  • Re: a question about Exactly once processing cY
  • Re: a question about Exactly once processing Gyula Fóra
  • 回复： a question about Exactly once processing cY
  • Re: 回复： a question about Exactly once processing Paris Carbone
  • 回复： 回复： a question about Exactly once processing cY
  • Re: 回复： a question about Exactly once processing Stephan Ewen
• [jira] [Created] (FLINK-1154) YarnTaskManagerRunner does not shut down Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-1153) Yarn container does not terminate if Flink's yarn client is terminated before the application master is completely started Till Rohrmann (JIRA)
• documentation 0.7 typo graphael
  • Re: documentation 0.7 typo Robert Metzger
• [jira] [Created] (FLINK-1152) Failed task cancellation leads to NullPointerException Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1151) CollectionDataSource does not provide statistics Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1150) FilterNode set estimated data size to unknown Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1149) Operators cannot adapt DOP for NonParallelInputs Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1148) Create a writeAsCsv(path, writemode) variant Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1147) TypeInference on POJOs Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1146) Add a way to provide types for generic type variables Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1145) POJO Type extractor bug with type variables Stephan Ewen (JIRA)
• Warnings about POJOs Stephan Ewen
  • Re: Warnings about POJOs Aljoscha Krettek
• [jira] [Created] (FLINK-1144) Jobmanager Webfrontend task-totals are incorrect Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1143) Forced to use Solution Set Maximilian Alber (JIRA)
• Marking affected and fixed versions in JIRA Ufuk Celebi
  • Re: Marking affected and fixed versions in JIRA Fabian Hueske
• [jira] [Created] (FLINK-1142) Log IOManager temp path directories Ufuk Celebi (JIRA)
• Re: [jira] [Commented] (FLINK-1141) Selfjoin fails after DataSet exceeds certain size Stephan Ewen
• Please help testing the 0.7.0-incubating release candidate Robert Metzger
  • Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
  • Re: Please help testing the 0.7.0-incubating release candidate Leonidas Fegaras
  • Re: Please help testing the 0.7.0-incubating release candidate Henry Saputra
  • Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
  • Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
  • Re: Please help testing the 0.7.0-incubating release candidate Aljoscha Krettek
  • Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
  • Re: Please help testing the 0.7.0-incubating release candidate Stephan Ewen
  • Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
  • Re: Please help testing the 0.7.0-incubating release candidate Stephan Ewen
  • Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
  • Re: Please help testing the 0.7.0-incubating release candidate Fabian Hueske
  • Re: Please help testing the 0.7.0-incubating release candidate Robert Metzger
• [jira] [Created] (FLINK-1141) Selfjoin fails after DataSet exceeds certain size Robert Waury (JIRA)
• Minor change to the versioning scheme Robert Metzger
  • Re: Minor change to the versioning scheme Robert Metzger
  • Re: Minor change to the versioning scheme Fabian Hueske
  • Re: Minor change to the versioning scheme Stephan Ewen
  • Re: Minor change to the versioning scheme Kostas Tzoumas
  • Re: Minor change to the versioning scheme Ufuk Celebi
  • Re: Minor change to the versioning scheme Till Rohrmann
  • Re: Minor change to the versioning scheme Henry Saputra
• [jira] [Created] (FLINK-1140) Add a flatmap that returns an Iterable instead of aggregation to a collector JIRA
• Flink streaming benchmark and comparison numbers? Henry Saputra
  • Re: Flink streaming benchmark and comparison numbers? Márton Balassi
  • Re: Flink streaming benchmark and comparison numbers? Henry Saputra
  • Re: Flink streaming benchmark and comparison numbers? Kostas Tzoumas
• [jira] [Created] (FLINK-1139) HadoopOutputFormat fails for DOP > 1 Fabian Hueske (JIRA)
• load broadcast set into searchable set Martin Neumann
  • Re: load broadcast set into searchable set Stephan Ewen
  • Re: load broadcast set into searchable set Martin Neumann
  • Re: load broadcast set into searchable set Stephan Ewen
• Dependencies of streaming connectors Stephan Ewen
  • Re: Dependencies of streaming connectors Márton Balassi
  • Re: Dependencies of streaming connectors Stephan Ewen
• [jira] [Created] (FLINK-1138) Allow users to specify methods instead of fields in key expressions Robert Metzger (JIRA)
• Hackathon Stockholm - Agenda and Topics Stephan Ewen
  • Re: Hackathon Stockholm - Agenda and Topics Aljoscha Krettek
  • Re: Hackathon Stockholm - Agenda and Topics Vasiliki Kalavri
  • Re: Hackathon Stockholm - Agenda and Topics Stephan Ewen
  • Re: Hackathon Stockholm - Agenda and Topics Vasiliki Kalavri
  • Re: Hackathon Stockholm - Agenda and Topics Paris Carbone
  • Re: Hackathon Stockholm - Agenda and Topics Paris Carbone
  • Re: Hackathon Stockholm - Agenda and Topics Vasiliki Kalavri
  • Re: Hackathon Stockholm - Agenda and Topics Gyula Fóra
• [jira] [Created] (FLINK-1137) Add a way to configure mutable object safe mode versus object reuse Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1136) Put new Flink Logo in Web Frontends Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink" Timo Walther (JIRA)
• [jira] [Created] (FLINK-1134) On the client side, the JVM does not terminate using RemoteCollectorOutputFormat Fabian Tschirschnitz (JIRA)
• [jira] [Created] (FLINK-1133) Type extractor cannot determine type of function Stephan Ewen (JIRA)
• Eclipse issue after latest dependency rework pr Gyula Fóra
  • Re: Eclipse issue after latest dependency rework pr Stephan Ewen
  • Re: Eclipse issue after latest dependency rework pr Gyula Fora
  • Re: Eclipse issue after latest dependency rework pr Márton Balassi
  • Re: Eclipse issue after latest dependency rework pr Fabian Hueske
  • Re: Eclipse issue after latest dependency rework pr Stephan Ewen
  • Re: Eclipse issue after latest dependency rework pr Stephan Ewen
  • Re: Eclipse issue after latest dependency rework pr Stephan Ewen
  • Re: Eclipse issue after latest dependency rework pr Fabian Hueske
• Apache Flink meetup in bay area by Robert and Ufuk Henry Saputra
  • Re: Apache Flink meetup in bay area by Robert and Ufuk Robert Metzger
  • Re: Apache Flink meetup in bay area by Robert and Ufuk Ufuk Celebi
  • Re: Apache Flink meetup in bay area by Robert and Ufuk Márton Balassi
• Keeping the reference to PACT compiler and Nephele names? Henry Saputra
  • Re: Keeping the reference to PACT compiler and Nephele names? Ufuk Celebi
  • Re: Keeping the reference to PACT compiler and Nephele names? Kostas Tzoumas
  • Re: Keeping the reference to PACT compiler and Nephele names? Henry Saputra
• Shading Guava Dependency Stephan Ewen
  • Re: Shading Guava Dependency Stephan Ewen
• Clean up dependencies in streaming connectors Stephan Ewen
  • Re: Clean up dependencies in streaming connectors Gyula Fóra
  • Re: Clean up dependencies in streaming connectors Stephan Ewen
  • Re: Clean up dependencies in streaming connectors Gyula Fora
  • Re: Clean up dependencies in streaming connectors Stephan Ewen
  • Re: Clean up dependencies in streaming connectors Márton Balassi
  • Re: Clean up dependencies in streaming connectors Stephan Ewen
  • Re: Clean up dependencies in streaming connectors Márton Balassi
• [jira] [Created] (FLINK-1132) Scala API has no partition operators Aljoscha Krettek (JIRA)
• [jira] [Created] (FLINK-1131) Scala API has no first(n) operation Aljoscha Krettek (JIRA)
• Basic lambda prototype :) Gyula Fóra
  • Re: Basic lambda prototype :) Márton Balassi
  • Re: Basic lambda prototype :) Ufuk Celebi
  • Re: Basic lambda prototype :) Stephan Ewen
  • Re: Basic lambda prototype :) Kostas Tzoumas
  • Re: Basic lambda prototype :) Paris Carbone
• [jira] [Created] (FLINK-1130) It is confusing what version a quickstart.sh is for. Aljoscha Krettek (JIRA)
  • Re: [jira] [Created] (FLINK-1130) It is confusing what version a quickstart.sh is for. Ufuk Celebi
• [DISCUSS] Policy on keeping layer alternatives in sync Fabian Hueske
  • Re: [DISCUSS] Policy on keeping layer alternatives in sync Ufuk Celebi
  • Re: [DISCUSS] Policy on keeping layer alternatives in sync Robert Metzger
  • Re: [DISCUSS] Policy on keeping layer alternatives in sync Kostas Tzoumas
  • Re: [DISCUSS] Policy on keeping layer alternatives in sync Chesnay Schepler
  • Re: [DISCUSS] Policy on keeping layer alternatives in sync Aljoscha Krettek
  • Re: [DISCUSS] Policy on keeping layer alternatives in sync Fabian Hueske
• [jira] [Created] (FLINK-1129) The Plan Visualizer Cuts of the Lower Part of Certain Operators Aljoscha Krettek (JIRA)
• [jira] [Created] (FLINK-1128) We should also change Website to use Kramdown as Markdown Engine Aljoscha Krettek (JIRA)
• [jira] [Created] (FLINK-1127) Utility library Ufuk Celebi (JIRA)
• [jira] [Created] (FLINK-1126) Add suggestion for using large TupleX types Ufuk Celebi (JIRA)
• [jira] [Created] (FLINK-1125) JobManager exception shown incompletely in TaskManager logs Ufuk Celebi (JIRA)
• [jira] [Created] (FLINK-1124) Merge error on TaskManager overview page Ufuk Celebi (JIRA)
• [jira] [Created] (FLINK-1123) Add First-N operator to Scala API Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1122) Add execute(String jobName) to StreamExecutionEnvironment JIRA
• Question about Re-Partition Operator Aljoscha Krettek
  • Re: Question about Re-Partition Operator Fabian Hueske
  • Re: Question about Re-Partition Operator Aljoscha Krettek
  • Re: Question about Re-Partition Operator Fabian Hueske
  • Re: Question about Re-Partition Operator Aljoscha Krettek
• [jira] [Created] (FLINK-1121) Add minBy and maxBy operators to the streaming api Gyula Fora (JIRA)
• Streaming reduce discussion Gyula Fóra
  • Re: Streaming reduce discussion Fabian Hueske
  • Re: Streaming reduce discussion Gyula Fóra
  • Re: Streaming reduce discussion Fabian Hueske
• [jira] [Created] (FLINK-1120) Extend support for explict data set shuffling to Scala API Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1119) StreamComponentTest fails with NoResourceAvailableException Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1118) Exclude Java Crash Log Files from License Header Check Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1117) Clean up Avro Project Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1116) Packaged Scala Examples do not work due to missing test data Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1115) Spurious Test Failures due to failing file output streams Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1114) ScalaStyle prevents projects from being built individually Stephan Ewen (JIRA)
• Extended License entries. Stephan Ewen
• [jira] [Created] (FLINK-1113) Clean up JQuery Dependencies Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1112) Add GroupSorting with KeySelectors Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-1111) Move Basic and Array Type Information into "flink-core" Project Stephan Ewen (JIRA)
• grouping and sort grouping with KeySelector Martin Neumann
  • Re: grouping and sort grouping with KeySelector Fabian Hueske
• Minor project website issue Hermann Gábor
  • Re: Minor project website issue Aljoscha Krettek
• [jira] [Created] (FLINK-1110) Add a serial collection-based execution mode Stephan Ewen (JIRA)
• [jira] [Created] (FLINK-1109) Add IntelliJ/Eclipe setup guide for developers Ufuk Celebi (JIRA)
• Adding a serial collection-based execution mode Stephan Ewen
  • Re: Adding a serial collection-based execution mode Ufuk Celebi
  • Re: Adding a serial collection-based execution mode Till Rohrmann
  • Re: Adding a serial collection-based execution mode Aljoscha Krettek
  • Re: Adding a serial collection-based execution mode Stephan Ewen
  • Re: Adding a serial collection-based execution mode Stephan Ewen
  • Re: Adding a serial collection-based execution mode Ufuk Celebi
  • Re: Adding a serial collection-based execution mode Stephan Ewen
  • Re: Adding a serial collection-based execution mode Stephan Ewen
  • Re: Adding a serial collection-based execution mode Aljoscha Krettek
  • Re: Adding a serial collection-based execution mode Fabian Hueske
  • Re: Adding a serial collection-based execution mode Till Rohrmann
  • Re: Adding a serial collection-based execution mode Gyula Fóra
• [jira] [Created] (FLINK-1108) Logo files for Flink Linda Gavin (JIRA)
• [jira] [Created] (FLINK-1107) Document how to use Avro files and the Hadoop Input Format Wrappers Robert Metzger (JIRA)
• load avro example Martin Neumann
  • Re: load avro example Stephan Ewen
  • Re: load avro example Martin Neumann
  • Re: load avro example Robert Metzger
• [jira] [Created] (FLINK-1106) Deprecate old Record API Robert Metzger (JIRA)
• [jira] [Created] (FLINK-1105) Add support for locally sorted output Fabian Hueske (JIRA)
• [VOTE] [RESULT] Style of Flink squirrel logo for website and public accounts Fabian Hueske
• Change in the JobManager API Stephan Ewen
  • Re: Change in the JobManager API Stephan Ewen
  • Re: Change in the JobManager API Stephan Ewen
  • Re: Change in the JobManager API Márton Balassi

• Earlier messages
• Later messages