beam-user mailing list archives: May 2016

Site index · List index
Message listThread · Author · Date
Re: KafkaIO Usage & Sample Code
amir bahmanyari   Re: KafkaIO Usage & Sample Code Sun, 01 May, 23:38
Frances Perry     Re: KafkaIO Usage & Sample Code Mon, 02 May, 01:12
Jean-Baptiste Onofré       Re: KafkaIO Usage & Sample Code Mon, 02 May, 05:29
Dan Halperin         Re: KafkaIO Usage & Sample Code Mon, 02 May, 07:00
Amir Bahmanyari           Re: KafkaIO Usage & Sample Code Mon, 02 May, 07:17
Dan Halperin             Re: KafkaIO Usage & Sample Code Mon, 02 May, 07:22
Dan Halperin               Re: KafkaIO Usage & Sample Code Mon, 02 May, 07:23
amir bahmanyari                 Re: KafkaIO Usage & Sample Code Mon, 02 May, 15:26
Dan Halperin                   Re: KafkaIO Usage & Sample Code Mon, 02 May, 16:43
Thomas Groh                     Re: KafkaIO Usage & Sample Code Mon, 02 May, 17:02
amir bahmanyari                       Re: KafkaIO Usage & Sample Code Mon, 02 May, 17:52
amir bahmanyari                         Re: KafkaIO Usage & Sample Code Mon, 02 May, 17:54
Jean-Baptiste Onofré                         Re: KafkaIO Usage & Sample Code Mon, 02 May, 18:26
Thomas Groh                           Re: KafkaIO Usage & Sample Code Mon, 02 May, 18:41
amir bahmanyari                             Re: KafkaIO Usage & Sample Code Wed, 04 May, 19:57
Raghu Angadi                               Re: KafkaIO Usage & Sample Code Thu, 05 May, 00:34
amir bahmanyari                               Re: KafkaIO Usage & Sample Code Thu, 05 May, 14:10
Raghu Angadi                                 Re: KafkaIO Usage & Sample Code Thu, 05 May, 20:14
amir bahmanyari                                   Re: KafkaIO Usage & Sample Code Fri, 06 May, 08:06
Jean-Baptiste Onofré           Re: KafkaIO Usage & Sample Code Mon, 02 May, 07:42
Jean-Baptiste Onofré           Re: KafkaIO Usage & Sample Code Mon, 02 May, 10:45
kaniska Mandal Whats the recommended approach to run parallel operations inside ParDo ? Thu, 05 May, 18:09
Lukasz Cwik   Re: Whats the recommended approach to run parallel operations inside ParDo ? Thu, 05 May, 21:04
kaniska Mandal     Re: Whats the recommended approach to run parallel operations inside ParDo ? Fri, 06 May, 02:52
Lukasz Cwik       Re: Whats the recommended approach to run parallel operations inside ParDo ? Fri, 06 May, 16:12
org.apache.kafka.common.serialization.ByteArrayDeserializer not found
amir bahmanyari   org.apache.kafka.common.serialization.ByteArrayDeserializer not found Fri, 06 May, 08:19
Aljoscha Krettek     Re: org.apache.kafka.common.serialization.ByteArrayDeserializer not found Fri, 06 May, 09:17
Aljoscha Krettek       Re: org.apache.kafka.common.serialization.ByteArrayDeserializer not found Fri, 06 May, 09:25
Raghu Angadi         Re: org.apache.kafka.common.serialization.ByteArrayDeserializer not found Fri, 06 May, 16:23
amir bahmanyari         Re: org.apache.kafka.common.serialization.ByteArrayDeserializer not found Fri, 06 May, 16:24
[No Subject]
amir bahmanyari   [No Subject] Sun, 08 May, 04:31
amir bahmanyari     How to set groupId in KafkaIO.Read() Sun, 08 May, 04:34
Raghu Angadi       Re: How to set groupId in KafkaIO.Read() Sun, 08 May, 04:50
amir bahmanyari         Re: How to set groupId in KafkaIO.Read() Sun, 08 May, 08:43
Raghu Angadi           Re: How to set groupId in KafkaIO.Read() Sun, 08 May, 23:04
Raghu Angadi             Re: How to set groupId in KafkaIO.Read() Mon, 09 May, 01:35
amir bahmanyari               Re: How to set groupId in KafkaIO.Read() Mon, 09 May, 02:48
amir bahmanyari                 Re: How to set groupId in KafkaIO.Read() Mon, 09 May, 06:37
amir bahmanyari                   Re: How to set groupId in KafkaIO.Read() Mon, 09 May, 08:43
Aljoscha Krettek     Re: Sun, 08 May, 05:05
Aljoscha Krettek       Re: Sun, 08 May, 05:06
Punit Naik Direct Runner Example Mon, 09 May, 10:56
Jean-Baptiste Onofré   RE: Direct Runner Example Mon, 09 May, 11:36
Frances Perry     Re: Direct Runner Example Mon, 09 May, 14:32
amir bahmanyari       Re: Direct Runner Example Mon, 09 May, 19:51
Dan Halperin         Re: Direct Runner Example Wed, 11 May, 00:26
Punit Naik           Re: Direct Runner Example Wed, 11 May, 06:29
Punit Naik             Re: Direct Runner Example Wed, 11 May, 06:30
Maximilian Michels               Re: Direct Runner Example Wed, 11 May, 09:29
Punit Naik       Re: Direct Runner Example Wed, 25 May, 06:45
Beam-Kafka in a Flink Cluster Integration Development Guideline
amir bahmanyari   Beam-Kafka in a Flink Cluster Integration Development Guideline Mon, 09 May, 19:17
Maximilian Michels     Re: Beam-Kafka in a Flink Cluster Integration Development Guideline Tue, 10 May, 14:03
Aljoscha Krettek       Re: Beam-Kafka in a Flink Cluster Integration Development Guideline Tue, 10 May, 15:21
Beam sdk packages changed to Beam runners?
amir bahmanyari   Beam sdk packages changed to Beam runners? Mon, 09 May, 19:30
Lukasz Cwik     Re: Beam sdk packages changed to Beam runners? Mon, 09 May, 19:53
amir bahmanyari       Re: Beam sdk packages changed to Beam runners? Mon, 09 May, 19:55
Lukasz Cwik         Re: Beam sdk packages changed to Beam runners? Mon, 09 May, 19:57
KafkaIO call WithoutMetadata is currently not supported?
amir bahmanyari   KafkaIO call WithoutMetadata is currently not supported? Mon, 09 May, 22:11
Frances Perry     Re: KafkaIO call WithoutMetadata is currently not supported? Mon, 16 May, 04:48
Maximilian Michels       Re: KafkaIO call WithoutMetadata is currently not supported? Tue, 17 May, 12:00
DoFn Deserialize issue
amir bahmanyari   DoFn Deserialize issue Mon, 09 May, 23:06
Lukasz Cwik     Re: DoFn Deserialize issue Mon, 09 May, 23:13
amir bahmanyari       Re: DoFn Deserialize issue Tue, 10 May, 00:07
Lukasz Cwik         Re: DoFn Deserialize issue Tue, 10 May, 00:20
Robert Bradshaw           Re: DoFn Deserialize issue Tue, 10 May, 00:32
amir bahmanyari           Re: DoFn Deserialize issue Tue, 10 May, 00:38
amir bahmanyari             Re: DoFn Deserialize issue Tue, 10 May, 00:42
amir bahmanyari               Re: DoFn Deserialize issue Tue, 10 May, 00:58
Overlapping classes warnings when creating the fat jar for Flink Cluster
amir bahmanyari   Overlapping classes warnings when creating the fat jar for Flink Cluster Tue, 10 May, 01:08
Maximilian Michels     Re: Overlapping classes warnings when creating the fat jar for Flink Cluster Tue, 10 May, 14:15
amir bahmanyari       Re: Overlapping classes warnings when creating the fat jar for Flink Cluster Tue, 10 May, 15:25
Maximilian Michels         Re: Overlapping classes warnings when creating the fat jar for Flink Cluster Tue, 10 May, 18:10
Learnt lessons to share
amir bahmanyari   Learnt lessons to share Tue, 10 May, 22:52
Frank Wilson Threads and ThreadLocal variables in Dataflow Wed, 11 May, 10:26
Jean-Baptiste Onofré   Re: Threads and ThreadLocal variables in Dataflow Wed, 11 May, 13:55
Lukasz Cwik     Re: Threads and ThreadLocal variables in Dataflow Wed, 11 May, 16:19
Frances Perry       Re: Threads and ThreadLocal variables in Dataflow Wed, 11 May, 16:27
Frank Wilson       Re: Threads and ThreadLocal variables in Dataflow Thu, 12 May, 14:55
kaniska Mandal Beam-Flink-Runner example using Protocol Buffer Fri, 13 May, 22:00
Frances Perry   Re: Beam-Flink-Runner example using Protocol Buffer Fri, 13 May, 22:33
Maximilian Michels     Re: Beam-Flink-Runner example using Protocol Buffer Tue, 17 May, 10:04
Jesse Anderson Removing a Window From a PCollection Tue, 17 May, 18:44
Frances Perry   Re: Removing a Window From a PCollection Tue, 17 May, 18:54
Jesse Anderson     Re: Removing a Window From a PCollection Tue, 17 May, 18:57
Jesse Anderson       Re: Removing a Window From a PCollection Tue, 17 May, 20:47
Frances Perry         Re: Removing a Window From a PCollection Tue, 17 May, 22:14
Jesse Anderson DoFN Lambda Wed, 18 May, 00:40
Ben Chambers   Re: DoFN Lambda Wed, 18 May, 00:51
Jesse Anderson     Re: DoFN Lambda Wed, 18 May, 01:08
Frances Perry       Re: DoFN Lambda Wed, 18 May, 04:19
Jesse Anderson         Re: DoFN Lambda Wed, 18 May, 15:03
Frances Perry           Re: DoFN Lambda Thu, 19 May, 18:36
Robert Bradshaw         Re: DoFN Lambda Tue, 24 May, 20:19
Ismaël Mejía issue with reusing spark context in spark runner Wed, 18 May, 10:28
Amit Sela   Re: issue with reusing spark context in spark runner Wed, 18 May, 10:33
Ismaël Mejía     Re: issue with reusing spark context in spark runner Wed, 18 May, 12:04
Jean-Baptiste Onofré     Re: issue with reusing spark context in spark runner Wed, 18 May, 12:30
Ismaël Mejía       Re: issue with reusing spark context in spark runner Wed, 18 May, 13:40
Amit Sela         Re: issue with reusing spark context in spark runner Wed, 18 May, 13:50
Jean-Baptiste Onofré         Re: issue with reusing spark context in spark runner Wed, 18 May, 13:51
Amit Sela           Re: issue with reusing spark context in spark runner Wed, 18 May, 13:52
Jesse Anderson Collecting Results to Executing Process Wed, 18 May, 17:48
Frances Perry   Re: Collecting Results to Executing Process Thu, 19 May, 18:26
Frances Perry     Re: Collecting Results to Executing Process Thu, 19 May, 18:48
Amit Sela       Re: Collecting Results to Executing Process Thu, 19 May, 19:51
Frances Perry         Re: Collecting Results to Executing Process Fri, 20 May, 04:05
Aljoscha Krettek           Re: Collecting Results to Executing Process Fri, 20 May, 05:56
Amit Sela             Re: Collecting Results to Executing Process Fri, 20 May, 07:15
Jesse Anderson               Re: Collecting Results to Executing Process Fri, 20 May, 13:55
Ismaël Mejía                 Re: Collecting Results to Executing Process Fri, 20 May, 14:37
Davor Bonaci                   Re: Collecting Results to Executing Process Fri, 20 May, 18:20
Jesse Anderson                     Re: Collecting Results to Executing Process Fri, 20 May, 18:28
Ismaël Mejía Problem with Pipeline In Flink Runner Thu, 19 May, 16:32
Maximilian Michels   Re: Problem with Pipeline In Flink Runner Thu, 19 May, 16:52
Aljoscha Krettek     Re: Problem with Pipeline In Flink Runner Thu, 19 May, 17:31
amir bahmanyari       Re: Problem with Pipeline In Flink Runner Thu, 19 May, 23:22
Frances Perry         Re: Problem with Pipeline In Flink Runner Fri, 20 May, 03:57
Ismaël Mejía       Re: Problem with Pipeline In Flink Runner Fri, 20 May, 07:22
Maximilian Michels         Re: Problem with Pipeline In Flink Runner Fri, 20 May, 08:06
Ismaël Mejía           Re: Problem with Pipeline In Flink Runner Fri, 20 May, 09:07
Jean-Baptiste Onofré             Re: Problem with Pipeline In Flink Runner Fri, 20 May, 11:59
Aljoscha Krettek               Re: Problem with Pipeline In Flink Runner Fri, 20 May, 12:56
Ismaël Mejía                 Re: Problem with Pipeline In Flink Runner Fri, 20 May, 15:05
Jean-Baptiste Onofré         Re: Problem with Pipeline In Flink Runner Fri, 20 May, 08:36
Jesse Anderson Writing Out List<String> Fri, 20 May, 04:00
Kenneth Knowles   Re: Writing Out List<String> Fri, 20 May, 04:23
Jesse Anderson     Re: Writing Out List<String> Fri, 20 May, 04:32
Kenneth Knowles       Re: Writing Out List<String> Fri, 20 May, 18:46
Jesse Anderson         Re: Writing Out List<String> Fri, 20 May, 20:46
Kenneth Knowles           Re: Writing Out List<String> Fri, 20 May, 20:54
Jesse Anderson             Re: Writing Out List<String> Sat, 21 May, 01:48
Jesse Anderson               Re: Writing Out List<String> Tue, 24 May, 20:40
Kenneth Knowles                 Re: Writing Out List<String> Tue, 24 May, 21:01
Stadin, Benjamin Force pipe executions to run on same node Sat, 21 May, 14:22
Jean-Baptiste Onofré   Re: Force pipe executions to run on same node Sat, 21 May, 16:59
Stadin, Benjamin     Re: Force pipe executions to run on same node Sun, 22 May, 21:01
Stadin, Benjamin       Re: Force pipe executions to run on same node Mon, 23 May, 13:44
Jean-Baptiste Onofré       Re: Force pipe executions to run on same node Mon, 23 May, 13:47
Jesse Anderson         Re: Force pipe executions to run on same node Mon, 23 May, 17:22
Stadin, Benjamin           Re: Force pipe executions to run on same node Mon, 23 May, 18:08
Jesse Anderson             Re: Force pipe executions to run on same node Mon, 23 May, 19:59
Davor Bonaci               Re: Force pipe executions to run on same node Mon, 23 May, 20:44
Stadin, Benjamin               Re: Force pipe executions to run on same node Mon, 23 May, 21:44
Emanuele Cesena       Re: Force pipe executions to run on same node Mon, 23 May, 17:32
Convert a Storm Topology into a Apache Beam Model
amir bahmanyari   Convert a Storm Topology into a Apache Beam Model Sun, 22 May, 21:56
kaniska Mandal     Re: Convert a Storm Topology into a Apache Beam Model Mon, 23 May, 23:15
Tyler Akidau       Re: Convert a Storm Topology into a Apache Beam Model Wed, 25 May, 17:34
Error reading field 'topic_metadata'
amir bahmanyari   Error reading field 'topic_metadata' Mon, 23 May, 22:32
Raghu Angadi     Re: Error reading field 'topic_metadata' Mon, 23 May, 22:59
amir bahmanyari       Re: Error reading field 'topic_metadata' Tue, 24 May, 00:03
Raghu Angadi         Re: Error reading field 'topic_metadata' Tue, 24 May, 00:46
amir bahmanyari           Re: Error reading field 'topic_metadata' Tue, 24 May, 07:55
Ryan Madsen Generating a historically-consistent join Tue, 24 May, 01:47
Mark Shields   Re: Generating a historically-consistent join Tue, 24 May, 16:00
Robertson Williams expected a valid 'gs://' path but was given '/tmp/tmpLocation' Tue, 24 May, 10:24
Robertson Williams   Re: expected a valid 'gs://' path but was given '/tmp/tmpLocation' Tue, 24 May, 10:48
Davor Bonaci     Re: expected a valid 'gs://' path but was given '/tmp/tmpLocation' Tue, 24 May, 11:52
Robertson Williams       Re: expected a valid 'gs://' path but was given '/tmp/tmpLocation' Wed, 25 May, 08:08
Punit Naik         Re: expected a valid 'gs://' path but was given '/tmp/tmpLocation' Wed, 25 May, 09:27
David Olsen Parallelism Tue, 24 May, 14:38
Jean-Baptiste Onofré   Re: Parallelism Tue, 24 May, 14:43
Thomas Groh     Re: Parallelism Tue, 24 May, 17:28
Jean-Baptiste Onofré       Re: Parallelism Tue, 24 May, 18:41
David Olsen         Re: Parallelism Wed, 25 May, 15:41
Thomas Groh           Re: Parallelism Wed, 25 May, 18:36
David Olsen             Re: Parallelism Thu, 26 May, 15:37
Punit Naik SparkPipelineRunner ERROR Wed, 25 May, 07:14
Amit Sela   Re: SparkPipelineRunner ERROR Wed, 25 May, 07:31
Punit Naik     Re: SparkPipelineRunner ERROR Wed, 25 May, 07:44
Amit Sela       Re: SparkPipelineRunner ERROR Wed, 25 May, 07:47
Punit Naik         Re: SparkPipelineRunner ERROR Wed, 25 May, 07:57
Amit Sela           Re: SparkPipelineRunner ERROR Wed, 25 May, 08:00
Ismaël Mejía             Re: SparkPipelineRunner ERROR Wed, 25 May, 08:01
Punit Naik               Re: SparkPipelineRunner ERROR Wed, 25 May, 08:34
Punit Naik                 Re: SparkPipelineRunner ERROR Wed, 25 May, 09:36
Punit Naik                   Re: SparkPipelineRunner ERROR Wed, 25 May, 09:47
Stephan Buys Question from a data analytics/log management dude Wed, 25 May, 11:43
Maximilian Michels   Re: Question from a data analytics/log management dude Wed, 25 May, 12:58
Jean-Baptiste Onofré   Re: Question from a data analytics/log management dude Wed, 25 May, 14:14
Stephan Buys     Re: Question from a data analytics/log management dude Thu, 26 May, 07:53
Stephan Buys       Another question re dataflow architecture. (was Re: Question from a data analytics/log management dude) Thu, 26 May, 13:00
David Olsen InProcessPipelineRunner seems to hang with log printed 'Finalizing write operation' Wed, 25 May, 15:58
Thomas Groh   Re: InProcessPipelineRunner seems to hang with log printed 'Finalizing write operation' Wed, 25 May, 17:52
Thomas Groh     Re: InProcessPipelineRunner seems to hang with log printed 'Finalizing write operation' Wed, 25 May, 20:53
David Olsen       Re: InProcessPipelineRunner seems to hang with log printed 'Finalizing write operation' Thu, 26 May, 15:33
Thomas Groh         Re: InProcessPipelineRunner seems to hang with log printed 'Finalizing write operation' Mon, 30 May, 18:06
Beam Flink vs Beam Spark Benchmarking
amir bahmanyari   Beam Flink vs Beam Spark Benchmarking Thu, 26 May, 23:19
Ismaël Mejía     Re: Beam Flink vs Beam Spark Benchmarking Fri, 27 May, 08:22
Jean-Baptiste Onofré       Re: Beam Flink vs Beam Spark Benchmarking Fri, 27 May, 08:33
amir bahmanyari         Re: Beam Flink vs Beam Spark Benchmarking Fri, 27 May, 19:02
amir bahmanyari         Re: Beam Flink vs Beam Spark Benchmarking Fri, 27 May, 21:48
Kaniska Gmail           Re: Beam Flink vs Beam Spark Benchmarking Fri, 27 May, 23:08
Aljoscha Krettek             Re: Beam Flink vs Beam Spark Benchmarking Sat, 28 May, 08:05
Pawel Szczur Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Fri, 27 May, 18:52
Aljoscha Krettek   Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Sat, 28 May, 10:45
Pawel Szczur     Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Sat, 28 May, 23:50
Aljoscha Krettek       Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Sun, 29 May, 13:59
Pawel Szczur         Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Sun, 29 May, 16:20
Aljoscha Krettek           Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Mon, 30 May, 15:13
Pawel Szczur             Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Mon, 30 May, 23:15
Aljoscha Krettek               Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Tue, 31 May, 09:55
Pawel Szczur                 Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Tue, 31 May, 12:40
Pawel Szczur                   Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Tue, 31 May, 12:51
Pawel Szczur                     Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Tue, 31 May, 13:47
Maximilian Michels                       Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Tue, 31 May, 14:47
Aljoscha Krettek                       Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Tue, 31 May, 14:48
Jean-Baptiste Onofré                       Re: Items not groupped correctly - CoGroupByKey - FlinkPipelienRunner Tue, 31 May, 14:49
Pawel Szczur TextIO with .withoutSharding() writing a only one shard of data and ignoring the rest Sun, 29 May, 23:38
Jean-Baptiste Onofré   Re: TextIO with .withoutSharding() writing a only one shard of data and ignoring the rest Tue, 31 May, 16:46
Kenneth Knowles [ANNOUNCE] Beam-related talks this week, in and around Strata+Hadoop World Mon, 30 May, 17:10
Jean-Baptiste Onofré   Re: [ANNOUNCE] Beam-related talks this week, in and around Strata+Hadoop World Mon, 30 May, 18:22
Amit Sela     Re: [ANNOUNCE] Beam-related talks this week, in and around Strata+Hadoop World Mon, 30 May, 18:32
Jean-Baptiste Onofré       Re: [ANNOUNCE] Beam-related talks this week, in and around Strata+Hadoop World Mon, 30 May, 19:10
Re: Beam presentation materials
Ismaël Mejía   Re: Beam presentation materials Tue, 31 May, 22:15
Frances Perry     Re: Beam presentation materials Tue, 31 May, 23:38
Emanuele Cesena       Re: Beam presentation materials Tue, 31 May, 23:59
Message listThread · Author · Date
Box list
Jan 201999
Dec 2018150
Nov 201899
Oct 2018172
Sep 2018152
Aug 2018181
Jul 2018147
Jun 2018186
May 2018139
Apr 201879
Mar 2018126
Feb 2018164
Jan 2018187
Dec 2017112
Nov 2017150
Oct 2017201
Sep 201783
Aug 201799
Jul 2017118
Jun 2017239
May 2017212
Apr 2017134
Mar 2017102
Feb 201795
Jan 2017109
Dec 201665
Nov 2016115
Oct 201650
Sep 201676
Aug 201679
Jul 2016100
Jun 2016148
May 2016216
Apr 201652
Mar 201691
Feb 20165