flink-user mailing list archives: July 2015

Site index · List index
Message list« Previous · 1 · 2 · 3 · Next »Thread · Author · Date
Re: open multiple file from list of uri
Michele Bertoni   Re: open multiple file from list of uri Tue, 14 Jul, 16:42
Stephan Ewen     Re: open multiple file from list of uri Tue, 14 Jul, 16:50
Michele Bertoni       Re: open multiple file from list of uri Tue, 14 Jul, 21:42
Stephan Ewen         Re: open multiple file from list of uri Wed, 15 Jul, 11:16
Michele Bertoni           Re: open multiple file from list of uri Wed, 15 Jul, 22:03
Stephan Ewen             Re: open multiple file from list of uri Fri, 17 Jul, 14:56
Robert Schmidtke Order groups by their keys Wed, 15 Jul, 12:56
Fabian Hueske   Re: Order groups by their keys Wed, 15 Jul, 13:30
Matthias J. Sax   Re: Order groups by their keys Wed, 15 Jul, 13:32
Fabian Hueske     Re: Order groups by their keys Wed, 15 Jul, 13:39
hagersaleh       Re: Order groups by their keys Sun, 19 Jul, 13:01
Wendong Flink Kafka runtime error Wed, 15 Jul, 18:45
Wendong   Re: Flink Kafka runtime error Wed, 15 Jul, 19:01
Stephan Ewen     Re: Flink Kafka runtime error Fri, 17 Jul, 16:00
Wendong       Re: Flink Kafka runtime error Fri, 17 Jul, 17:59
Vinh June Flink Scala performance Wed, 15 Jul, 21:44
Aljoscha Krettek   Re: Flink Scala performance Thu, 16 Jul, 05:42
Vinh June     Re: Flink Scala performance Thu, 16 Jul, 06:54
Maximilian Michels       Re: Flink Scala performance Thu, 16 Jul, 08:16
Vinh June         Re: Flink Scala performance Thu, 16 Jul, 09:35
Ufuk Celebi           Re: Flink Scala performance Thu, 16 Jul, 09:50
Vinh June             Re: Flink Scala performance Thu, 16 Jul, 10:23
Chiwan Park               Re: Flink Scala performance Thu, 16 Jul, 10:40
Stephan Ewen       Re: Flink Scala performance Thu, 16 Jul, 10:17
Vinh June         Re: Flink Scala performance Thu, 16 Jul, 12:06
Stephan Ewen           Re: Flink Scala performance Thu, 16 Jul, 13:09
Vinh June             Re: Flink Scala performance Thu, 16 Jul, 13:34
Stephan Ewen               Re: Flink Scala performance Thu, 16 Jul, 14:48
Vinh June                 Re: Flink Scala performance Thu, 16 Jul, 15:53
Stephan Ewen                   Re: Flink Scala performance Fri, 17 Jul, 07:14
Vinh June                     Re: Flink Scala performance Sat, 18 Jul, 21:22
Michele Bertoni                       Re: Flink Scala performance Sun, 19 Jul, 05:59
Wendong Flink Kafka example in Scala Thu, 16 Jul, 00:45
Anwar Rizal   Re: Flink Kafka example in Scala Thu, 16 Jul, 02:57
Wendong     Re: Flink Kafka example in Scala Thu, 16 Jul, 04:36
Anwar Rizal       Re: Flink Kafka example in Scala Thu, 16 Jul, 06:36
Aljoscha Krettek         Re: Flink Kafka example in Scala Thu, 16 Jul, 08:45
Wendong           Re: Flink Kafka example in Scala Thu, 16 Jul, 17:37
Gyula Fóra             Re: Flink Kafka example in Scala Thu, 16 Jul, 17:44
Wendong               Re: Flink Kafka example in Scala Thu, 16 Jul, 19:04
Aljoscha Krettek                 Re: Flink Kafka example in Scala Fri, 17 Jul, 06:42
Till Rohrmann                   Re: Flink Kafka example in Scala Fri, 17 Jul, 08:45
Wendong                     Re: Flink Kafka example in Scala Fri, 17 Jul, 22:40
Till Rohrmann                       Re: Flink Kafka example in Scala Mon, 20 Jul, 07:42
Anwar Rizal                         Re: Flink Kafka example in Scala Mon, 20 Jul, 08:23
Till Rohrmann                           Re: Flink Kafka example in Scala Mon, 20 Jul, 08:28
Anwar Rizal                             Re: Flink Kafka example in Scala Mon, 20 Jul, 08:37
Stephan Ewen                               Re: Flink Kafka example in Scala Mon, 20 Jul, 08:48
Wendong                         Re: Flink Kafka example in Scala Tue, 21 Jul, 00:21
Till Rohrmann                           Re: Flink Kafka example in Scala Tue, 21 Jul, 08:03
Wendong                   Re: Flink Kafka example in Scala Fri, 17 Jul, 22:23
Martin Junghanns Containment Join Support Thu, 16 Jul, 07:39
Fabian Hueske   Re: Containment Join Support Thu, 16 Jul, 22:26
Stephan Ewen     Re: Containment Join Support Fri, 17 Jul, 09:17
Martin Junghanns       Re: Containment Join Support Fri, 17 Jul, 10:25
Vasiliki Kalavri         Re: Containment Join Support Sat, 18 Jul, 21:15
Philipp Goetze Submitting jobs from within Scala code Thu, 16 Jul, 09:01
Till Rohrmann   Re: Submitting jobs from within Scala code Thu, 16 Jul, 09:12
Philipp Goetze     Re: Submitting jobs from within Scala code Thu, 16 Jul, 09:23
Till Rohrmann       Re: Submitting jobs from within Scala code Thu, 16 Jul, 09:45
Stephan Ewen         Re: Submitting jobs from within Scala code Thu, 16 Jul, 10:27
Philipp Goetze         Re: Submitting jobs from within Scala code Thu, 16 Jul, 11:20
Till Rohrmann           Re: Submitting jobs from within Scala code Thu, 16 Jul, 12:22
LINZ, Arnaud No accumulator results in streaming Thu, 16 Jul, 12:21
Stephan Ewen   Re: No accumulator results in streaming Fri, 17 Jul, 07:18
Juan Fumero Cluster execution -jar files- Thu, 16 Jul, 14:04
Juan Fumero   Re: Cluster execution -jar files- Thu, 16 Jul, 14:06
Matthias J. Sax     Re: Cluster execution -jar files- Thu, 16 Jul, 14:50
LINZ, Arnaud getIndexOfThisSubtask : starts at 0 or 1 ? Thu, 16 Jul, 14:22
Ufuk Celebi   Re: getIndexOfThisSubtask : starts at 0 or 1 ? Thu, 16 Jul, 14:35
Fwd: Re: Submitting jobs from within Scala code
Philipp Goetze   Fwd: Re: Submitting jobs from within Scala code Thu, 16 Jul, 14:35
Till Rohrmann     Re: Re: Submitting jobs from within Scala code Thu, 16 Jul, 15:35
Philipp Goetze       Re: Submitting jobs from within Scala code Thu, 16 Jul, 15:45
Till Rohrmann         Re: Submitting jobs from within Scala code Thu, 16 Jul, 15:56
Stephan Ewen           Re: Submitting jobs from within Scala code Fri, 17 Jul, 15:04
Till Rohrmann             Re: Submitting jobs from within Scala code Fri, 17 Jul, 15:32
Chenliang (Liang, DataSight) One improvement suggestion: “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected after mistaking delete Fri, 17 Jul, 06:27
Maximilian Michels   Re: One improvement suggestion: “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected after mistaking delete Fri, 17 Jul, 13:16
Flavio Pompermaier HDFS directory rename Fri, 17 Jul, 08:02
fhue...@gmail.com   Re: HDFS directory rename Fri, 17 Jul, 08:08
Flavio Pompermaier     Re: HDFS directory rename Fri, 17 Jul, 09:17
Stephan Ewen       Re: HDFS directory rename Tue, 21 Jul, 13:13
Flavio Pompermaier         Re: HDFS directory rename Wed, 22 Jul, 09:04
Fabian Hueske           Re: HDFS directory rename Wed, 22 Jul, 10:49
Flavio Pompermaier             Re: HDFS directory rename Wed, 22 Jul, 11:10
Fabian Hueske               Re: HDFS directory rename Wed, 22 Jul, 11:17
Maximilian Alber Scala: registerAggregationConvergenceCriterion Fri, 17 Jul, 13:43
Till Rohrmann   Re: Scala: registerAggregationConvergenceCriterion Fri, 17 Jul, 14:13
Maximilian Alber     Re: Scala: registerAggregationConvergenceCriterion Fri, 17 Jul, 14:20
Bill Sparks Map and Reduce cycle Fri, 17 Jul, 14:07
Fabian Hueske   Re: Map and Reduce cycle Fri, 17 Jul, 14:19
Maximilian Alber Nested Iterations Outlook Fri, 17 Jul, 14:26
Maximilian Michels   Re: Nested Iterations Outlook Mon, 20 Jul, 08:50
Maximilian Alber     Re: Nested Iterations Outlook Mon, 20 Jul, 10:11
Maximilian Michels       Re: Nested Iterations Outlook Mon, 20 Jul, 11:06
Maximilian Alber         Re: Nested Iterations Outlook Mon, 20 Jul, 13:31
Maximilian Michels           Re: Nested Iterations Outlook Mon, 20 Jul, 14:02
Maximilian Alber             Re: Nested Iterations Outlook Mon, 20 Jul, 14:15
Maximilian Michels               Re: Nested Iterations Outlook Mon, 20 Jul, 15:53
Stephan Ewen                 Re: Nested Iterations Outlook Wed, 22 Jul, 12:20
Maximilian Michels                   Re: Nested Iterations Outlook Wed, 22 Jul, 12:46
Maximilian Alber                     Re: Nested Iterations Outlook Wed, 22 Jul, 13:40
LINZ, Arnaud Streaming window : count with timeout ? Fri, 17 Jul, 15:30
Matthias J. Sax   Re: Streaming window : count with timeout ? Fri, 17 Jul, 15:39
Flavio Pompermaier Flink deadLetters Fri, 17 Jul, 16:30
Till Rohrmann   Re: Flink deadLetters Fri, 17 Jul, 17:04
Flavio Pompermaier     Re: Flink deadLetters Sat, 18 Jul, 09:41
Till Rohrmann       Re: Flink deadLetters Mon, 20 Jul, 07:34
Stephan Ewen         Re: Flink deadLetters Tue, 21 Jul, 13:05
Ufuk Celebi           Re: Flink deadLetters Tue, 21 Jul, 14:20
Flavio Pompermaier             Re: Flink deadLetters Tue, 21 Jul, 15:45
Ufuk Celebi               Re: Flink deadLetters Tue, 21 Jul, 15:48
Lydia Ickler HBase on 4 machine cluster - OutOfMemoryError Fri, 17 Jul, 22:50
Stephan Ewen   Re: HBase on 4 machine cluster - OutOfMemoryError Sat, 18 Jul, 13:38
Lydia Ickler     Re: HBase on 4 machine cluster - OutOfMemoryError Sat, 18 Jul, 13:47
Stephan Ewen       Re: HBase on 4 machine cluster - OutOfMemoryError Sun, 19 Jul, 16:11
Madabhattula Rajesh Kumar Run Time Exception Sun, 19 Jul, 14:36
Sachin Goel   Re: Run Time Exception Sun, 19 Jul, 14:56
Madabhattula Rajesh Kumar     Re: Run Time Exception Sun, 19 Jul, 17:59
Chiwan Park       Re: Run Time Exception Sun, 19 Jul, 18:19
Madabhattula Rajesh Kumar         Re: Run Time Exception Sun, 19 Jul, 18:46
Ufuk Celebi           Re: Run Time Exception Sun, 19 Jul, 21:28
Pa Rö loop break operation Mon, 20 Jul, 09:25
Sachin Goel   Re: loop break operation Mon, 20 Jul, 09:30
Pa Rö     Re: loop break operation Mon, 20 Jul, 09:50
Sachin Goel       Re: loop break operation Mon, 20 Jul, 10:16
Pa Rö         Re: loop break operation Mon, 20 Jul, 10:54
Fabian Hueske           Re: loop break operation Mon, 20 Jul, 10:58
Pa Rö             Re: loop break operation Mon, 20 Jul, 17:57
Shivani Ghatge Too few memory segments provided exception Mon, 20 Jul, 12:04
Maximilian Michels   Re: Too few memory segments provided exception Mon, 20 Jul, 12:14
Till Rohrmann     Re: Too few memory segments provided exception Mon, 20 Jul, 12:22
Shivani Ghatge     Re: Too few memory segments provided exception Mon, 20 Jul, 12:23
Andra Lungu       Re: Too few memory segments provided exception Mon, 20 Jul, 12:35
Maximilian Michels       Re: Too few memory segments provided exception Mon, 20 Jul, 12:41
Vasiliki Kalavri         Re: Too few memory segments provided exception Mon, 20 Jul, 13:15
Andra Lungu           Re: Too few memory segments provided exception Mon, 20 Jul, 13:29
Vasiliki Kalavri             Re: Too few memory segments provided exception Mon, 20 Jul, 13:40
Shivani Ghatge           Re: Too few memory segments provided exception Mon, 20 Jul, 13:43
Shivani Ghatge             Re: Too few memory segments provided exception Mon, 20 Jul, 13:45
Vasiliki Kalavri               Re: Too few memory segments provided exception Mon, 20 Jul, 14:00
Shivani Ghatge               Re: Too few memory segments provided exception Mon, 20 Jul, 14:02
Shivani Ghatge                 Re: Too few memory segments provided exception Mon, 20 Jul, 14:04
Ufuk Celebi           Re: Too few memory segments provided exception Mon, 20 Jul, 14:20
hagersaleh I want use count() method in this link but when write but not found in dataset why Mon, 20 Jul, 21:36
Wendong Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Tue, 21 Jul, 04:41
Wendong   Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Tue, 21 Jul, 05:10
Maximilian Michels     Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Tue, 21 Jul, 08:21
Wendong       Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Tue, 21 Jul, 16:41
Wendong         Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Tue, 21 Jul, 21:57
Hawin Jiang           Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Tue, 21 Jul, 22:32
Wendong             Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Wed, 22 Jul, 00:16
Hawin Jiang               RE: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Wed, 22 Jul, 07:59
Till Rohrmann                 Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Wed, 22 Jul, 08:12
Stephan Ewen                   Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Wed, 22 Jul, 09:06
Wendong                     Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Fri, 24 Jul, 05:30
Stephan Ewen                       Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Fri, 24 Jul, 09:14
Robert Metzger                         Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Fri, 24 Jul, 09:17
Wendong                           Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Sat, 25 Jul, 01:10
Robert Metzger                             Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Mon, 27 Jul, 10:36
Wendong                               Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Tue, 28 Jul, 00:01
Robert Metzger                                 Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Tue, 28 Jul, 07:45
Wendong                                   Re: Flink Kafka cannot find org/I0Itec/zkclient/serialize/ZkSerializer Thu, 30 Jul, 05:48
Michele Bertoni sorted cogroup Tue, 21 Jul, 05:27
Till Rohrmann   Re: sorted cogroup Tue, 21 Jul, 08:01
hagersaleh when write this code display error no interface expected here public static class MyCoGrouper extends CoGroupFunction Tue, 21 Jul, 12:53
hagersaleh   Re: when write this code display error no interface expected here public static class MyCoGrouper extends CoGroupFunction Tue, 21 Jul, 20:40
Re: Informing the runtime about data already repartitioned using "output contracts"
Stephan Ewen   Re: Informing the runtime about data already repartitioned using "output contracts" Tue, 21 Jul, 13:27
Re: JobManager is no longer reachable
Stephan Ewen   Re: JobManager is no longer reachable Tue, 21 Jul, 13:29
Flavio Pompermaier     Re: JobManager is no longer reachable Tue, 21 Jul, 14:02
Stephan Ewen       Re: JobManager is no longer reachable Tue, 21 Jul, 14:09
Flavio Pompermaier         Re: JobManager is no longer reachable Tue, 21 Jul, 15:27
Stephan Ewen           Re: JobManager is no longer reachable Tue, 21 Jul, 15:36
Pa Rö filter as termination condition Tue, 21 Jul, 15:05
Stephan Ewen   Re: filter as termination condition Wed, 22 Jul, 12:16
Sachin Goel     Re: filter as termination condition Wed, 22 Jul, 12:23
Till Rohrmann       Re: filter as termination condition Wed, 22 Jul, 12:38
Re: Best way to write data to HDFS by Flink
Robert Metzger   Re: Best way to write data to HDFS by Flink Wed, 22 Jul, 08:54
Stefano Bortoli MongoOutputFormat does not write back to collection Wed, 22 Jul, 12:26
Stefano Bortoli   Re: MongoOutputFormat does not write back to collection Wed, 22 Jul, 13:53
Stefano Bortoli     Re: MongoOutputFormat does not write back to collection Wed, 22 Jul, 14:48
Stefano Bortoli       Re: MongoOutputFormat does not write back to collection Wed, 22 Jul, 15:11
Stephan Ewen       Re: MongoOutputFormat does not write back to collection Wed, 22 Jul, 15:11
Stefano Bortoli         Re: MongoOutputFormat does not write back to collection Thu, 23 Jul, 10:44
Stephan Ewen           Re: MongoOutputFormat does not write back to collection Thu, 23 Jul, 11:31
Stefano Bortoli             Re: MongoOutputFormat does not write back to collection Thu, 23 Jul, 11:55
Lydia Ickler Job stuck at "Assigning split to host..." Thu, 23 Jul, 12:12
Ufuk Celebi   Re: Job stuck at "Assigning split to host..." Thu, 23 Jul, 12:41
Lydia Ickler     Re: Job stuck at "Assigning split to host..." Thu, 23 Jul, 12:44
Flavio Pompermaier       Re: Job stuck at "Assigning split to host..." Thu, 23 Jul, 12:49
Ufuk Celebi       Re: Job stuck at "Assigning split to host..." Thu, 23 Jul, 12:50
Lydia Ickler         Re: Job stuck at "Assigning split to host..." Thu, 23 Jul, 12:56
Ufuk Celebi           Re: Job stuck at "Assigning split to host..." Thu, 23 Jul, 13:11
Lydia Ickler             Re: Job stuck at "Assigning split to host..." Thu, 23 Jul, 13:34
Lydia Ickler               Re: Job stuck at "Assigning split to host..." Thu, 23 Jul, 13:35
Ufuk Celebi                 Re: Job stuck at "Assigning split to host..." Thu, 23 Jul, 14:38
Ufuk Celebi                   Re: Job stuck at "Assigning split to host..." Mon, 27 Jul, 09:45
Lydia Ickler                     Re: Job stuck at "Assigning split to host..." Mon, 27 Jul, 09:48
Juan Fumero Cluster Execution - log Thu, 23 Jul, 13:10
Stephan Ewen   Re: Cluster Execution - log Thu, 23 Jul, 13:31
Juan Fumero     Re: Cluster Execution - log Thu, 23 Jul, 13:40
Stefano Bortoli starting flink job from bash script with maven Fri, 24 Jul, 07:51
Stephan Ewen   Re: starting flink job from bash script with maven Fri, 24 Jul, 08:01
Stefano Bortoli     Re: starting flink job from bash script with maven Fri, 24 Jul, 08:44
Stephan Ewen       Re: starting flink job from bash script with maven Fri, 24 Jul, 09:09
Stefano Bortoli         Re: starting flink job from bash script with maven Fri, 24 Jul, 09:17
Stefano Bortoli           Re: starting flink job from bash script with maven Fri, 24 Jul, 09:31
Stephan Ewen             Re: starting flink job from bash script with maven Fri, 24 Jul, 09:36
Michele Bertoni Yarn configuration Fri, 24 Jul, 13:58
Robert Metzger   Re: Yarn configuration Fri, 24 Jul, 14:38
Michele Bertoni     Re: Yarn configuration Mon, 27 Jul, 09:02
Michele Bertoni       Re: Yarn configuration Mon, 27 Jul, 09:07
Fabian Hueske         Re: Yarn configuration Mon, 27 Jul, 09:19
Michele Bertoni           Re: Yarn configuration Mon, 27 Jul, 09:29
Robert Metzger             Re: Yarn configuration Mon, 27 Jul, 12:56
Michele Bertoni               Re: Yarn configuration Mon, 27 Jul, 15:19
Robert Metzger                 Re: Yarn configuration Mon, 27 Jul, 17:16
Henry Saputra [ANNOUNCE] Distributed stream and graph processing with Apache Flink Bay Area meetup Sun, 26 Jul, 23:30
Flavio Pompermaier Pass not serializable objects to Flink transformation functions Mon, 27 Jul, 08:05
Till Rohrmann   Re: Pass not serializable objects to Flink transformation functions Mon, 27 Jul, 08:30
Philipp Goetze NullPointerException when working with Windows Tue, 28 Jul, 12:02
Ufuk Celebi   Re: NullPointerException when working with Windows Tue, 28 Jul, 13:29
Aljoscha Krettek     Re: NullPointerException when working with Windows Tue, 28 Jul, 14:12
Philipp Goetze     Re: NullPointerException when working with Windows Tue, 28 Jul, 14:16
Juan Fumero Options for the JVM in the TaskManagers Wed, 29 Jul, 11:40
Robert Metzger   Re: Options for the JVM in the TaskManagers Wed, 29 Jul, 11:58
wangzhijiang999 thread model issue in TaskManager Thu, 30 Jul, 02:02
Fabian Hueske   Re: thread model issue in TaskManager Thu, 30 Jul, 10:10
Message list« Previous · 1 · 2 · 3 · Next »Thread · Author · Date
Box list
Jun 2019325
May 2019421
Apr 2019653
Mar 2019575
Feb 2019555
Jan 2019595
Dec 2018401
Nov 2018655
Oct 2018698
Sep 2018761
Aug 2018787
Jul 2018841
Jun 2018658
May 2018580
Apr 2018612
Mar 2018634
Feb 2018533
Jan 2018597
Dec 2017525
Nov 2017474
Oct 2017527
Sep 2017645
Aug 2017737
Jul 2017476
Jun 2017670
May 2017474
Apr 2017415
Mar 2017508
Feb 2017582
Jan 2017576
Dec 2016405
Nov 2016598
Oct 2016506
Sep 2016451
Aug 2016596
Jul 2016463
Jun 2016454
May 2016701
Apr 2016741
Mar 2016614
Feb 2016655
Jan 2016443
Dec 2015322
Nov 2015487
Oct 2015330
Sep 2015401
Aug 2015252
Jul 2015433
Jun 2015446
May 2015274
Apr 2015204
Mar 2015154
Feb 2015123
Jan 201574
Dec 201488
Nov 2014243
Oct 2014124
Sep 201464