beam-commits mailing list archives: September 2017

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · Next »Thread · Author · Date
Etienne Chauchot (JIRA) [jira] [Commented] (BEAM-2993) AvroIO.write without specifying a schema Fri, 29 Sep, 08:40
Etienne Chauchot (JIRA) [jira] [Comment Edited] (BEAM-2993) AvroIO.write without specifying a schema Fri, 29 Sep, 09:27
Etienne Chauchot (JIRA) [jira] [Commented] (BEAM-2993) AvroIO.write without specifying a schema Fri, 29 Sep, 09:27
Eugene Kirpichov (JIRA) [jira] [Updated] (BEAM-2834) NullPointerException @ BigQueryServicesImpl.java:759 Fri, 01 Sep, 18:58
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2802) TextIO should allow specifying a custom delimiter Fri, 01 Sep, 19:09
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2624) File-based sinks should produce a PCollection of written filenames Fri, 01 Sep, 22:02
Eugene Kirpichov (JIRA) [jira] [Assigned] (BEAM-2750) Read whole files as one PCollection element each Sun, 03 Sep, 23:51
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2828) Create FileIO Sun, 03 Sep, 23:52
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2750) Read whole files as one PCollection element each Sun, 03 Sep, 23:52
Eugene Kirpichov (JIRA) [jira] [Assigned] (BEAM-2837) Writing To Spanner From Google Cloud DataFlow - Failure Tue, 05 Sep, 22:34
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2841) NPE in Dataflow job Tue, 05 Sep, 22:40
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2841) NPE in Dataflow job Tue, 05 Sep, 22:40
Eugene Kirpichov (JIRA) [jira] [Created] (BEAM-2844) Support implicit side inputs Wed, 06 Sep, 04:24
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2837) Writing To Spanner From Google Cloud DataFlow - Failure Wed, 06 Sep, 15:20
Eugene Kirpichov (JIRA) [jira] [Assigned] (BEAM-2706) Create JdbcIO.readAll() Wed, 06 Sep, 16:31
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2803) JdbcIO read is very slow when query return a lot of rows Wed, 06 Sep, 17:05
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2706) Create JdbcIO.readAll() Wed, 06 Sep, 17:05
Eugene Kirpichov (JIRA) [jira] [Created] (BEAM-2857) Create FileIO in Python Wed, 06 Sep, 21:31
Eugene Kirpichov (JIRA) [jira] [Created] (BEAM-2864) Support backfill deduplication in BigQueryIO.write() Thu, 07 Sep, 20:22
Eugene Kirpichov (JIRA) [jira] [Created] (BEAM-2865) Implement FileIO.write() Fri, 08 Sep, 01:38
Eugene Kirpichov (JIRA) [jira] [Updated] (BEAM-2865) Implement FileIO.write() Fri, 08 Sep, 01:38
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2860) SDF blog post discusses Match, which no longer exists Fri, 08 Sep, 17:59
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2883) Poor error message when forgetting to specify a Datastore project. Mon, 11 Sep, 21:48
Eugene Kirpichov (JIRA) [jira] [Assigned] (BEAM-2883) Poor error message when forgetting to specify a Datastore project. Mon, 11 Sep, 21:48
Eugene Kirpichov (JIRA) [jira] [Created] (BEAM-2950) Provide implicit access to State Tue, 12 Sep, 23:09
Eugene Kirpichov (JIRA) [jira] [Assigned] (BEAM-2834) NullPointerException @ BigQueryServicesImpl.java:759 Thu, 14 Sep, 23:10
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2879) Implement and use an Avro coder rather than the JSON one for intermediary files to be loaded in BigQuery Fri, 15 Sep, 23:21
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2879) Implement and use an Avro coder rather than the JSON one for intermediary files to be loaded in BigQuery Fri, 15 Sep, 23:24
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2140) Fix SplittableDoFn ValidatesRunner tests in FlinkRunner Mon, 18 Sep, 18:40
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2140) Fix SplittableDoFn ValidatesRunner tests in FlinkRunner Mon, 18 Sep, 18:41
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-407) Inconsistent synchronization in OffsetRangeTracker.copy Tue, 19 Sep, 20:54
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2837) Writing To Spanner From Google Cloud DataFlow - Failure Wed, 20 Sep, 01:20
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2826) Need to generate a single XML file when write is performed on small amount of data Wed, 20 Sep, 06:31
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2981) Unable to deserialize ProtoCoder in Dataflow, serialVersionUID mismatch Fri, 22 Sep, 18:10
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2986) Support reading avro GenericRecords with BigQueryIO Mon, 25 Sep, 15:33
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2467) KinesisIO watermark based on approximateArrivalTimestamp Mon, 25 Sep, 22:37
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2857) Create FileIO in Python Wed, 27 Sep, 00:36
Eugene Kirpichov (JIRA) [jira] [Created] (BEAM-2991) BigQueryIO.read().fromQuery() should set a TTL on the temporary tables with query results Wed, 27 Sep, 04:45
Eugene Kirpichov (JIRA) [jira] [Created] (BEAM-2992) Remove codepaths for reading unsplit BigQuery sources Wed, 27 Sep, 04:46
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2991) BigQueryIO.read().fromQuery() should set a TTL on the temporary tables with query results Wed, 27 Sep, 05:11
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2993) AvroIO.write without specifying a schema Wed, 27 Sep, 16:17
Eugene Kirpichov (JIRA) [jira] [Assigned] (BEAM-2994) Refactor TikaIO Thu, 28 Sep, 16:07
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2986) Support reading avro GenericRecords with BigQueryIO Fri, 29 Sep, 00:05
Eugene Kirpichov (JIRA) [jira] [Commented] (BEAM-2993) AvroIO.write without specifying a schema Fri, 29 Sep, 18:09
Eugene Kirpichov (JIRA) [jira] [Closed] (BEAM-2455) Backlog size retrieval for Kinesis source Sat, 30 Sep, 00:06
Guenther Grill (JIRA) [jira] [Created] (BEAM-2943) Beam Flink execution not working Tue, 12 Sep, 06:55
Guenther Grill (JIRA) [jira] [Updated] (BEAM-2943) Beam Flink execution not working Tue, 12 Sep, 06:57
Guenther Grill (JIRA) [jira] [Updated] (BEAM-2943) Beam Flink execution not working Tue, 12 Sep, 06:57
Guenther Grill (JIRA) [jira] [Updated] (BEAM-2943) Beam Flink deployment results in ClassNotFoundException Tue, 12 Sep, 06:59
Guenther Grill (JIRA) [jira] [Updated] (BEAM-2943) Beam Flink deployment results in ClassNotFoundException Tue, 12 Sep, 07:17
Guenther Grill (JIRA) [jira] [Updated] (BEAM-2943) Beam Flink deployment results in ClassNotFoundException Tue, 12 Sep, 07:17
Guenther Grill (JIRA) [jira] [Updated] (BEAM-2943) Beam Flink deployment results in ClassNotFoundException Thu, 14 Sep, 14:54
Guenther Grill (JIRA) [jira] [Commented] (BEAM-2943) Beam Flink deployment results in ClassNotFoundException Thu, 14 Sep, 14:58
Guenther Grill (JIRA) [jira] [Comment Edited] (BEAM-2943) Beam Flink deployment results in ClassNotFoundException Thu, 14 Sep, 14:58
Guillaume Balaine (JIRA) [jira] [Commented] (BEAM-793) JdbcIO can create a deadlock when parallelism is greater than 1 Wed, 20 Sep, 22:09
Guillaume Balaine (JIRA) [jira] [Commented] (BEAM-793) JdbcIO can create a deadlock when parallelism is greater than 1 Thu, 21 Sep, 07:37
Guillaume Balaine (JIRA) [jira] [Commented] (BEAM-793) JdbcIO can create a deadlock when parallelism is greater than 1 Thu, 21 Sep, 13:20
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2822) Add support for progress reporting in fn API Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-1192) Give transforms URNs, use them instead of instanceof checks Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-1348) Model the Fn Api Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2863) Add support for Side Inputs over the Fn API Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-1261) State API should allow state to be managed in different windows Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2421) Migrate Apache Beam to use impulse primitive as the only root primitive Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-1347) Basic Java harness capable of understanding process bundle tasks and sending data over the Fn Api Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-1866) FnAPI support for Metrics Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2862) Add support for User State over the Fn API Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2576) Move non-core transform payloads out of Runner API proto Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-1196) Serialize/deserialize Pipeline/TransformHierarchy to Runner API Protos Mon, 11 Sep, 15:50
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2430) Java FnApiDoFnRunner to share across runners Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2590) SparkRunner shim for Job API Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2600) Artifact for Python SDK harness that can be referenced in pipeline definition Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2597) FlinkRunner Fn API based ParDo operator Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2694) Python shim for submitting to GearpumpRunner Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2795) FlinkRunner: translate using SDK-agnostic means Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2431) Model Runner interactions in RPC layer for Runner API Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2594) Python shim for submitting to Java DirectRunner Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2598) SparkRunner Fn API based ParDo operator Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2592) Python shim for submitting to ApexRunner Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2599) ApexRunner Fn API based ParDo operator Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2371) Make Java DirectRunner demonstrate language-agnostic Runner API translation wrappers Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2588) FlinkRunner shim for serving Job API Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2593) Python shim for submitting to SparkRunner Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2333) Rehydrate Pipeline from Runner API proto Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2591) Python shim for submitting to FlinkRunner Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2589) ApexRunner shim for Job API Mon, 11 Sep, 15:54
Henning Korsholm Rohde (JIRA) [jira] [Created] (BEAM-2875) Portable SDK harness containers Mon, 11 Sep, 16:08
Henning Korsholm Rohde (JIRA) [jira] [Created] (BEAM-2876) Add provision api proto Mon, 11 Sep, 16:18
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2600) Artifact for Python SDK harness that can be referenced in pipeline definition Mon, 11 Sep, 16:25
Henning Korsholm Rohde (JIRA) [jira] [Assigned] (BEAM-2600) Artifact for Python SDK harness that can be referenced in pipeline definition Mon, 11 Sep, 16:25
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2600) Python SDK harness container Mon, 11 Sep, 16:26
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2600) Python SDK harness container Mon, 11 Sep, 16:27
Henning Korsholm Rohde (JIRA) [jira] [Updated] (BEAM-2600) Python SDK harness container Mon, 11 Sep, 16:28
Henning Korsholm Rohde (JIRA) [jira] [Created] (BEAM-2877) Java SDK harness container Mon, 11 Sep, 16:32
Henning Korsholm Rohde (JIRA) [jira] [Created] (BEAM-2878) Release process for container images Mon, 11 Sep, 16:42
Henning Korsholm Rohde (JIRA) [jira] [Created] (BEAM-2880) Artifact server proxies Mon, 11 Sep, 16:54
Henning Korsholm Rohde (JIRA) [jira] [Created] (BEAM-2881) GCS artifact server proxy Mon, 11 Sep, 16:56
Henning Korsholm Rohde (JIRA) [jira] [Created] (BEAM-2882) S3 artifact server proxy Mon, 11 Sep, 17:02
Henning Korsholm Rohde (JIRA) [jira] [Assigned] (BEAM-2882) S3 artifact server proxy Mon, 11 Sep, 17:10
Henning Korsholm Rohde (JIRA) [jira] [Created] (BEAM-2884) Dataflow runs portable pipelines Mon, 11 Sep, 17:23
Henning Korsholm Rohde (JIRA) [jira] [Created] (BEAM-2885) Support job+artifact APIs locally Mon, 11 Sep, 17:37
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · Next »Thread · Author · Date
Box list
Sep 2019212
Aug 2019351
Jul 2019387
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