beam-commits mailing list archives: December 2017

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · Next »Thread · Author · Date
Ron Mahoney (JIRA) [jira] [Created] (BEAM-3284) Python SDK, dataflow runner, the method modify_job_status is calling the wrong API endpoint Mon, 04 Dec, 20:00
Łukasz Gajowy (JIRA) [jira] [Assigned] (BEAM-1603) Enable programmatic execution of spark pipelines. Tue, 12 Dec, 19:47
Łukasz Gajowy (JIRA) [jira] [Commented] (BEAM-1603) Enable programmatic execution of spark pipelines. Tue, 12 Dec, 19:49
Łukasz Gajowy (JIRA) [jira] [Comment Edited] (BEAM-1603) Enable programmatic execution of spark pipelines. Tue, 12 Dec, 19:50
Łukasz Gajowy (JIRA) [jira] [Created] (BEAM-3359) Unable to change "flinkMaster" from "[auto]" in TestFlinkRunner Fri, 15 Dec, 12:57
Łukasz Gajowy (JIRA) [jira] [Commented] (BEAM-2396) Support adding jars to spark runner Tue, 19 Dec, 14:36
Łukasz Gajowy (JIRA) [jira] [Created] (BEAM-3370) Add ability to stage directories with compiled classes to Flink Tue, 19 Dec, 15:51
Łukasz Gajowy (JIRA) [jira] [Commented] (BEAM-3370) Add ability to stage directories with compiled classes to Flink Tue, 19 Dec, 15:58
Łukasz Gajowy (JIRA) [jira] [Created] (BEAM-3371) Add ability to stage directories with compiled classes to Spark Tue, 19 Dec, 16:15
Łukasz Gajowy (JIRA) [jira] [Commented] (BEAM-3371) Add ability to stage directories with compiled classes to Spark Tue, 19 Dec, 16:16
Łukasz Gajowy (JIRA) [jira] [Created] (BEAM-3379) PAssert not successful when running IOITs with Flink runner Wed, 20 Dec, 19:47
Łukasz Gajowy (JIRA) [jira] [Updated] (BEAM-3379) PAssert not successful when running IOITs with Flink runner Wed, 20 Dec, 19:48
Ismaël Mejía (JIRA) [jira] [Resolved] (BEAM-3244) Flink runner does not respect ParDo's lifecycle on case of exceptions Fri, 01 Dec, 13:34
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-3157) BeamSql transform should support other PCollection types Fri, 01 Dec, 14:53
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-3157) BeamSql transform should support other PCollection types Fri, 01 Dec, 15:50
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-3291) Add Kinesis Sink Tue, 05 Dec, 15:13
Ismaël Mejía (JIRA) [jira] [Assigned] (BEAM-3291) Add Kinesis Sink Thu, 07 Dec, 10:50
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-3291) Add Kinesis Write transform Tue, 12 Dec, 08:52
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-3349) Update Flink runner to use Flink 1.4.0 Thu, 14 Dec, 08:54
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-3349) Update Flink runner to use Flink 1.4.0 Thu, 14 Dec, 09:15
Ismaël Mejía (JIRA) [jira] [Assigned] (BEAM-3340) Update Flink Runner to Flink 1.4.0 Thu, 14 Dec, 09:22
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-3340) Update Flink Runner to Flink 1.4.0 Thu, 14 Dec, 09:23
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-3340) Update Flink Runner to Flink 1.4.0 Thu, 14 Dec, 09:26
Ismaël Mejía (JIRA) [jira] [Assigned] (BEAM-3340) Update Flink Runner to Flink 1.4.0 Mon, 18 Dec, 12:54
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-3340) Update Flink Runner to Flink 1.4.0 Mon, 18 Dec, 12:54
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-3373) Add support for a local emulator on KinesisIO Tue, 19 Dec, 17:33
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-3373) Add withProperties method to KinesisIO Fri, 22 Dec, 14:53
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-3373) Add withProperties method to KinesisIO Fri, 22 Dec, 14:57
Ismaël Mejía (JIRA) [jira] [Updated] (BEAM-3373) Add withProperties method to KinesisIO Fri, 22 Dec, 14:58
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-3373) Add withProperties method to KinesisIO Fri, 22 Dec, 14:59
Ismaël Mejía (JIRA) [jira] [Created] (BEAM-3396) Update docker development images to use the Gradle build Thu, 28 Dec, 08:48
Ismaël Mejía (JIRA) [jira] [Commented] (BEAM-3394) Trying to run Apache Beam 2.3.0-SNAPSHOT pipeline on Spark 2.2.1 standalone cluster and I am facing some ClassCastException. Thu, 28 Dec, 10:29
Jean-Baptiste Onofré (JIRA) [jira] [Created] (BEAM-3278) Direct runner could display the watermark for debugging Fri, 01 Dec, 07:01
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-3110) The transform Read(UnboundedKafkaSource) is currently not supported Sun, 03 Dec, 06:43
Jean-Baptiste Onofré (JIRA) [jira] [Created] (BEAM-3282) MqttIO reader should use receive with timeout Mon, 04 Dec, 05:18
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-3290) Construct iterators directly if possible to allow spilling to disk Thu, 07 Dec, 00:29
Jean-Baptiste Onofré (JIRA) [jira] [Created] (BEAM-3312) Add IO convenient "with" methods Thu, 07 Dec, 00:52
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-3314) RedisIO: RedisConnectionConfiguration withEndpoint does not set host correctly. Thu, 07 Dec, 17:00
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-3319) Cannot build Apache Beam due to Apex Runner test failing Sat, 09 Dec, 06:00
Jean-Baptiste Onofré (JIRA) [jira] [Updated] (BEAM-14) Add declarative DSLs (XML & JSON) Mon, 11 Dec, 14:05
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-14) Add declarative DSLs (XML & JSON) Mon, 11 Dec, 14:07
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-14) Add declarative DSLs (XML & JSON) Mon, 11 Dec, 14:11
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-3349) Update Flink runner to use Flink 1.4.0 Thu, 14 Dec, 09:05
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-3349) Update Flink runner to use Flink 1.4.0 Thu, 14 Dec, 09:06
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-3346) Add projections to MongoDb IO Thu, 14 Dec, 09:06
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-1920) Add Spark 2.x support in Spark runner Mon, 18 Dec, 10:48
Jean-Baptiste Onofré (JIRA) [jira] [Resolved] (BEAM-3340) Update Flink Runner to Flink 1.4.0 Mon, 18 Dec, 15:55
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-3373) Add support for a local emulator on KinesisIO Tue, 19 Dec, 17:39
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-3390) unable to serialize org.apache.beam.sdk.io.jdbc.JdbcIO$Read$ReadFn Fri, 22 Dec, 06:49
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-3390) unable to serialize org.apache.beam.sdk.io.jdbc.JdbcIO$Read$ReadFn Fri, 22 Dec, 06:49
Jean-Baptiste Onofré (JIRA) [jira] [Assigned] (BEAM-3394) Trying to run Apache Beam 2.3.0-SNAPSHOT pipeline on Spark 2.2.1 standalone cluster and I am facing some ClassCastException. Mon, 25 Dec, 08:43
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-3394) Trying to run Apache Beam 2.3.0-SNAPSHOT pipeline on Spark 2.2.1 standalone cluster and I am facing some ClassCastException. Mon, 25 Dec, 08:44
Jean-Baptiste Onofré (JIRA) [jira] [Commented] (BEAM-3394) Trying to run Apache Beam 2.3.0-SNAPSHOT pipeline on Spark 2.2.1 standalone cluster and I am facing some ClassCastException. Mon, 25 Dec, 08:45
Jean-Baptiste Onofré (JIRA) [jira] [Comment Edited] (BEAM-3394) Trying to run Apache Beam 2.3.0-SNAPSHOT pipeline on Spark 2.2.1 standalone cluster and I am facing some ClassCastException. Mon, 25 Dec, 08:45
María GH (JIRA) [jira] [Created] (BEAM-3315) PipelineOptions format documentation needs to be corrected Thu, 07 Dec, 23:27
María GH (JIRA) [jira] [Created] (BEAM-3377) assert_that Wed, 20 Dec, 02:14
María GH (JIRA) [jira] [Updated] (BEAM-3377) assert_that not working for streaming Wed, 20 Dec, 02:18
María GH (JIRA) [jira] [Updated] (BEAM-3377) assert_that not working for streaming Wed, 20 Dec, 02:19
María GH (JIRA) [jira] [Created] (BEAM-3382) Validate count for trigger AfterCount Thu, 21 Dec, 07:50
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3060) Add performance tests for commonly used file-based I/O PTransforms Fri, 01 Dec, 00:08
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3142) Fix proto generation in Python 3 Fri, 01 Dec, 00:16
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3143) Fix type inference in Python 3 for generators Fri, 01 Dec, 00:17
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3143) Fix type inference in Python 3 for generators Fri, 01 Dec, 00:21
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3143) Fix type inference in Python 3 for generators Fri, 01 Dec, 00:25
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3143) Fix type inference in Python 3 for generators Fri, 01 Dec, 00:28
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2083) Develop a Go SDK for Beam Fri, 01 Dec, 00:30
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3153) Allow streaming processing time domain timers in Beam Python DirectRunner Fri, 01 Dec, 00:51
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1872) implement Reshuffle transform in python, make it experimental in Java Fri, 01 Dec, 04:03
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1872) implement Reshuffle transform in python, make it experimental in Java Fri, 01 Dec, 04:03
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1872) implement Reshuffle transform in python, make it experimental in Java Fri, 01 Dec, 04:03
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1872) implement Reshuffle transform in python, make it experimental in Java Fri, 01 Dec, 04:03
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1872) implement Reshuffle transform in python, make it experimental in Java Fri, 01 Dec, 04:03
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1872) implement Reshuffle transform in python, make it experimental in Java Fri, 01 Dec, 04:03
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3143) Fix type inference in Python 3 for generators Fri, 01 Dec, 04:32
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3143) Fix type inference in Python 3 for generators Fri, 01 Dec, 04:34
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3243) multiple anonymous DoFn lead to conflicting names Fri, 01 Dec, 08:29
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3187) Spark runner does not respect ParDo's lifecycle on case of exceptions Fri, 01 Dec, 10:24
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3187) Spark runner does not respect ParDo's lifecycle on case of exceptions Fri, 01 Dec, 10:24
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3187) Spark runner does not respect ParDo's lifecycle on case of exceptions Fri, 01 Dec, 10:25
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3244) Flink runner does not respect ParDo's lifecycle on case of exceptions Fri, 01 Dec, 10:52
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3244) Flink runner does not respect ParDo's lifecycle on case of exceptions Fri, 01 Dec, 10:52
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3187) Spark runner does not respect ParDo's lifecycle on case of exceptions Fri, 01 Dec, 10:52
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3244) Flink runner does not respect ParDo's lifecycle on case of exceptions Fri, 01 Dec, 13:33
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3244) Flink runner does not respect ParDo's lifecycle on case of exceptions Fri, 01 Dec, 13:34
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3187) Spark runner does not respect ParDo's lifecycle on case of exceptions Fri, 01 Dec, 13:38
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3171) convert a join into lookup Fri, 01 Dec, 18:25
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3171) convert a join into lookup Fri, 01 Dec, 18:30
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3171) convert a join into lookup Fri, 01 Dec, 18:30
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3171) convert a join into lookup Fri, 01 Dec, 18:58
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3041) Add portable Python SDK container setup support Fri, 01 Dec, 19:43
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2728) Extension for sketch-based statistics Fri, 01 Dec, 21:04
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2728) Extension for sketch-based statistics Fri, 01 Dec, 21:11
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2083) Develop a Go SDK for Beam Fri, 01 Dec, 22:37
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-2083) Develop a Go SDK for Beam Fri, 01 Dec, 22:37
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3041) Add portable Python SDK container setup support Fri, 01 Dec, 23:33
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-3041) Add portable Python SDK container setup support Fri, 01 Dec, 23:33
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1630) Add Splittable DoFn to Python SDK Sat, 02 Dec, 00:28
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1630) Add Splittable DoFn to Python SDK Sat, 02 Dec, 00:28
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1630) Add Splittable DoFn to Python SDK Sat, 02 Dec, 00:28
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1630) Add Splittable DoFn to Python SDK Sat, 02 Dec, 00:28
Message list1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · Next »Thread · Author · Date
Box list
Jul 2019283
Jun 2019332
May 2019464
Apr 2019336
Mar 2019259
Feb 2019367
Jan 2019518
Dec 2018368
Nov 2018448
Oct 20184197
Sep 20184689
Aug 20184453
Jul 20184320
Jun 20186163
May 20185547
Apr 20185962
Mar 20184479
Feb 20181955
Jan 20182670
Dec 20171428
Nov 20172364
Oct 20171972
Sep 20172095
Aug 20172291
Jul 20172998
Jun 20172879
May 20175577
Apr 20175171
Mar 20174068
Feb 20172908
Jan 20171848
Dec 20163374
Nov 20162900
Oct 20162712
Sep 20161298
Aug 20161500
Jul 20161550
Jun 20161725
May 20161092
Apr 20161731
Mar 20161158
Feb 2016294