beam-commits mailing list archives: November 2016

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 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · Next »Thread · Author · Date
Pei He (JIRA) [jira] [Created] (BEAM-1047) DataflowRunner: support regionalization. Wed, 23 Nov, 23:57
Pei He (JIRA) [jira] [Updated] (BEAM-1047) DataflowRunner: support regionalization. Wed, 23 Nov, 23:58
Pramod Immaneni (JIRA) [jira] [Commented] (BEAM-829) Apex runner: Add support for metrics and tracking of PAsserts Thu, 17 Nov, 17:11
Rafael Fernandez (JIRA) [jira] [Created] (BEAM-1024) upgrade to protobuf-3.1.0 Mon, 21 Nov, 21:17
Rafael Fernandez (JIRA) [jira] [Commented] (BEAM-1024) upgrade to protobuf-3.1.0 Mon, 21 Nov, 23:38
Raghu Angadi (JIRA) [jira] [Updated] (BEAM-591) Better handling of watermark in KafkaIO Mon, 07 Nov, 06:05
Raghu Angadi (JIRA) [jira] [Commented] (BEAM-704) KafkaIO should handle "latest offset" evenly, and persist it as part of the CheckpointMark. Tue, 08 Nov, 15:16
Raghu Angadi (JIRA) [jira] [Created] (BEAM-958) desiredNumWorkers in Dataflow is too low Thu, 10 Nov, 20:11
Raghu Angadi (JIRA) [jira] [Updated] (BEAM-958) desiredNumWorkers in Dataflow is too low Thu, 10 Nov, 20:12
Raghu Angadi (JIRA) [jira] [Commented] (BEAM-958) desiredNumWorkers in Dataflow is too low Thu, 10 Nov, 20:14
Reuven Lax (JIRA) [jira] [Created] (BEAM-974) Adds attributes support to PubsubIO Mon, 14 Nov, 05:29
Reuven Lax (JIRA) [jira] [Created] (BEAM-1022) TableNamespace should not use Java object equality when comparing windows Mon, 21 Nov, 20:30
Reuven Lax (JIRA) [jira] [Created] (BEAM-1023) Add test coverage for BigQueryIO.Write in streaming mode Mon, 21 Nov, 20:39
Reza Nouri (JIRA) [jira] [Created] (BEAM-975) Issue with MongoDBIO Mon, 14 Nov, 20:55
Reza Nouri (JIRA) [jira] [Updated] (BEAM-975) Issue with MongoDBIO Mon, 14 Nov, 20:56
Reza Nouri (JIRA) [jira] [Updated] (BEAM-975) Issue with MongoDBIO Mon, 14 Nov, 20:56
Reza Nouri (JIRA) [jira] [Commented] (BEAM-975) Issue with MongoDBIO Tue, 22 Nov, 03:16
Robert Bradshaw (JIRA) [jira] [Created] (BEAM-1002) Enable caching of side-input dependent computations Thu, 17 Nov, 18:08
Robert Bradshaw (JIRA) [jira] [Created] (BEAM-1003) Enable caching of side-input dependent computations Thu, 17 Nov, 18:09
Sam Whittle (JIRA) [jira] [Created] (BEAM-986) ReduceFnRunner doesn't batch prefetching pane firings Tue, 15 Nov, 23:22
Sandeep Deshmukh (JIRA) [jira] [Commented] (BEAM-825) Fill in the documentation/runners/apex portion of the website Tue, 15 Nov, 11:03
Sandeep Deshmukh (JIRA) [jira] [Assigned] (BEAM-980) Document how to configure the DAG created by Apex Runner Fri, 25 Nov, 02:55
Sandeep Deshmukh (JIRA) [jira] [Created] (BEAM-1053) ApexGroupByKeyOperator serialization issues Mon, 28 Nov, 15:35
Sandeep Deshmukh (JIRA) [jira] [Commented] (BEAM-1053) ApexGroupByKeyOperator serialization issues Mon, 28 Nov, 15:36
Sandeep Parikh (JIRA) [jira] [Created] (BEAM-1018) getEstimatedSizeBytes fails with large MongoDB collection sizes Mon, 21 Nov, 15:57
Sandeep Parikh (JIRA) [jira] [Updated] (BEAM-1018) getEstimatedSizeBytes fails with large MongoDB collection sizes Mon, 21 Nov, 16:01
Sandeep Parikh (JIRA) [jira] [Commented] (BEAM-1018) getEstimatedSizeBytes fails with large MongoDB collection sizes Mon, 21 Nov, 16:01
Sandeep Parikh (JIRA) [jira] [Commented] (BEAM-1018) getEstimatedSizeBytes fails with large MongoDB collection sizes Mon, 21 Nov, 16:13
Scott Wegner (JIRA) [jira] [Closed] (BEAM-767) Add DisplayData builder '.nested(..)' operation Fri, 18 Nov, 22:40
Scott Wegner (JIRA) [jira] [Commented] (BEAM-767) Add DisplayData builder '.nested(..)' operation Fri, 18 Nov, 22:40
Scott Wegner (JIRA) [jira] [Resolved] (BEAM-767) Add DisplayData builder '.nested(..)' operation Fri, 18 Nov, 22:40
Scott Wegner (JIRA) [jira] [Commented] (BEAM-795) org.apache.beam.sdk.io.ReadTest.testStreamingPrimitiveDisplayData failing in Dataflow RunnableOnService Fri, 18 Nov, 22:42
Scott Wegner (JIRA) [jira] [Commented] (BEAM-436) DirectRunner RunnableOnService tempLocation configuration insufficient Mon, 21 Nov, 16:54
Scott Wegner (JIRA) [jira] [Comment Edited] (BEAM-436) DirectRunner RunnableOnService tempLocation configuration insufficient Mon, 21 Nov, 16:57
Scott Wegner (JIRA) [jira] [Created] (BEAM-1031) Starter archetype uses OldDoFn Tue, 22 Nov, 00:30
Scott Wegner (JIRA) [jira] [Created] (BEAM-1032) Starter archetype pipeline has no runner on its classpath Tue, 22 Nov, 00:48
Sourabh Bajaj (JIRA) [jira] [Created] (BEAM-873) Support BigQuery 2.0 input format Tue, 01 Nov, 00:53
Sourabh Bajaj (JIRA) [jira] [Created] (BEAM-875) Inconsistency between time types between the inprocess and dataflow runner for BQ Tue, 01 Nov, 20:08
Sourabh Bajaj (JIRA) [jira] [Closed] (BEAM-875) Inconsistency between time types between the inprocess and dataflow runner for BQ Fri, 11 Nov, 19:20
Sourabh Bajaj (JIRA) [jira] [Resolved] (BEAM-873) Support BigQuery 2.0 input format Fri, 11 Nov, 19:24
Sourabh Bajaj (JIRA) [jira] [Created] (BEAM-964) Investing exporting BQ as Avro instead of Json for dataflow runner Fri, 11 Nov, 19:25
Sourabh Bajaj (JIRA) [jira] [Created] (BEAM-985) Retry decorator maintains state as uses an iterator Tue, 15 Nov, 22:18
Sourabh Bajaj (JIRA) [jira] [Updated] (BEAM-985) Retry decorator maintains state as uses an iterator Tue, 15 Nov, 22:49
Sourabh Bajaj (JIRA) [jira] [Created] (BEAM-994) Support for S3 file source and sink Wed, 16 Nov, 21:44
Stas Levin (JIRA) [jira] [Commented] (BEAM-891) Flake in Spark metrics library? Thu, 03 Nov, 16:30
Stas Levin (JIRA) [jira] [Commented] (BEAM-891) Flake in Spark metrics library? Wed, 09 Nov, 10:10
Stas Levin (JIRA) [jira] [Comment Edited] (BEAM-891) Flake in Spark metrics library? Wed, 09 Nov, 12:29
Stas Levin (JIRA) [jira] [Commented] (BEAM-891) Flake in Spark metrics library? Wed, 09 Nov, 12:30
Stas Levin (JIRA) [jira] [Commented] (BEAM-891) Flake in Spark metrics library? Sun, 13 Nov, 08:13
Stas Levin (JIRA) [jira] [Comment Edited] (BEAM-891) Flake in Spark metrics library? Sun, 13 Nov, 08:21
Stas Levin (JIRA) [jira] [Commented] (BEAM-891) Flake in Spark metrics library? Sun, 13 Nov, 08:22
Stas Levin (JIRA) [jira] [Issue Comment Deleted] (BEAM-891) Flake in Spark metrics library? Sun, 13 Nov, 08:22
Stas Levin (JIRA) [jira] [Commented] (BEAM-891) Flake in Spark metrics library? Sun, 13 Nov, 10:02
Stas Levin (JIRA) [jira] [Commented] (BEAM-891) Flake in Spark metrics library? Mon, 14 Nov, 09:29
Stas Levin (JIRA) [jira] [Comment Edited] (BEAM-891) Flake in Spark metrics library? Mon, 14 Nov, 09:29
Stas Levin (JIRA) [jira] [Created] (BEAM-979) ConcurrentModificationException exception after hours of running Tue, 15 Nov, 11:20
Stas Levin (JIRA) [jira] [Commented] (BEAM-979) ConcurrentModificationException exception after hours of running Tue, 15 Nov, 12:07
Stas Levin (JIRA) [jira] [Comment Edited] (BEAM-979) ConcurrentModificationException exception after hours of running Tue, 15 Nov, 12:24
Stas Levin (JIRA) [jira] [Commented] (BEAM-979) ConcurrentModificationException exception after hours of running Tue, 15 Nov, 12:35
Stas Levin (JIRA) [jira] [Comment Edited] (BEAM-979) ConcurrentModificationException exception after hours of running Tue, 15 Nov, 12:38
Stas Levin (JIRA) [jira] [Commented] (BEAM-983) runners/spark/translation/streaming/utils/TestPipelineOptions.java missing Apache license header. Tue, 15 Nov, 20:30
Stas Levin (JIRA) [jira] [Created] (BEAM-1039) Spark context is never actually re-used in tests Tue, 22 Nov, 19:10
Stas Levin (JIRA) [jira] [Assigned] (BEAM-1039) Spark context is never actually re-used in tests Tue, 22 Nov, 19:10
Stas Levin (JIRA) [jira] [Commented] (BEAM-1039) Spark context is never actually re-used in tests Tue, 22 Nov, 21:14
Stas Levin (JIRA) [jira] [Closed] (BEAM-1039) Spark context is never actually re-used in tests Tue, 22 Nov, 21:15
Stas Levin (JIRA) [jira] [Created] (BEAM-1050) PipelineResult.State is not set to FAILED in when a streaming job fails Sun, 27 Nov, 12:06
Stas Levin (JIRA) [jira] [Commented] (BEAM-1050) PipelineResult.State is not set to FAILED in when a streaming job fails Sun, 27 Nov, 12:21
Stephen Sisk (JIRA) [jira] [Created] (BEAM-1025) User guide - "How to create Beam IO Transforms" Mon, 21 Nov, 21:45
Stephen Sisk (JIRA) [jira] [Created] (BEAM-1026) User guide - "How to create Beam IO Transforms" Mon, 21 Nov, 21:46
Stephen Sisk (JIRA) [jira] [Created] (BEAM-1027) Hosting data stores to enable IO Transform testing Mon, 21 Nov, 21:53
Stephen Sisk (JIRA) [jira] [Resolved] (BEAM-1026) User guide - "How to create Beam IO Transforms" Tue, 22 Nov, 01:29
Stephen Sisk (JIRA) [jira] [Assigned] (BEAM-1027) Hosting data stores to enable IO Transform testing Tue, 22 Nov, 22:38
Stephen Sisk (JIRA) [jira] [Assigned] (BEAM-1025) User guide - "How to create Beam IO Transforms" Tue, 22 Nov, 22:39
Stephen Sisk (JIRA) [jira] [Created] (BEAM-1040) Hadoop InputFormat - IO Transform for reads Tue, 22 Nov, 23:24
Tenghuan He (JIRA) [jira] [Created] (BEAM-1020) FileBasedSink fails to remove temporary directory on Windows operating system Mon, 21 Nov, 19:10
Tenghuan He (JIRA) [jira] [Updated] (BEAM-1020) FileBasedSink fails to remove temporary directory on Windows operating system Mon, 21 Nov, 19:13
Tenghuan He (JIRA) [jira] [Updated] (BEAM-1020) FileBasedSink fails to remove temporary directory on Windows operating system Mon, 21 Nov, 19:14
Tenghuan He (JIRA) [jira] [Updated] (BEAM-1020) FileBasedSink fails to remove temporary directory on Windows operating system Mon, 21 Nov, 19:30
Tenghuan He (JIRA) [jira] [Updated] (BEAM-1020) FileBasedSink fails to remove temporary directory on Windows operating system Mon, 21 Nov, 19:47
Tenghuan He (JIRA) [jira] [Assigned] (BEAM-1041) IOChannelFactory: supports for recursively remove(). Wed, 23 Nov, 12:22
Thomas Groh (JIRA) [jira] [Created] (BEAM-885) Move PipelineOptions from Pipeline.create() to Pipeline.run() Wed, 02 Nov, 21:28
Thomas Groh (JIRA) [jira] [Updated] (BEAM-885) Move PipelineOptions from Pipeline.create() to Pipeline.run() Wed, 02 Nov, 22:31
Thomas Groh (JIRA) [jira] [Created] (BEAM-903) Flatten Timer Deliveries in WatermarkManager Thu, 03 Nov, 21:54
Thomas Groh (JIRA) [jira] [Resolved] (BEAM-903) Flatten Timer Deliveries in WatermarkManager Fri, 04 Nov, 22:34
Thomas Groh (JIRA) [jira] [Resolved] (BEAM-796) Watermarks should be updated after all other changes have been committed Fri, 04 Nov, 22:34
Thomas Groh (JIRA) [jira] [Created] (BEAM-937) The DirectRunner does not advance watermarks if reading from an empty reader Mon, 07 Nov, 21:17
Thomas Groh (JIRA) [jira] [Resolved] (BEAM-937) The DirectRunner does not advance watermarks if reading from an empty reader Tue, 08 Nov, 21:46
Thomas Groh (JIRA) [jira] [Commented] (BEAM-938) Break in direct.UnboundedReadEvaluatorFactoryTest.noElementsAvailableReaderIncludedInResidual Tue, 08 Nov, 21:46
Thomas Groh (JIRA) [jira] [Resolved] (BEAM-938) Break in direct.UnboundedReadEvaluatorFactoryTest.noElementsAvailableReaderIncludedInResidual Tue, 08 Nov, 21:46
Thomas Groh (JIRA) [jira] [Resolved] (BEAM-826) Dynamically create subscriptions if unspecified in PubSubIO Wed, 09 Nov, 21:51
Thomas Groh (JIRA) [jira] [Created] (BEAM-950) DoFn Setup and Teardown methods should have access to PipelineOptions Wed, 09 Nov, 22:50
Thomas Groh (JIRA) [jira] [Assigned] (BEAM-950) DoFn Setup and Teardown methods should have access to PipelineOptions Thu, 10 Nov, 18:25
Thomas Groh (JIRA) [jira] [Resolved] (BEAM-924) Findbugs doesn't pass in Direct Runner Sat, 12 Nov, 00:54
Thomas Groh (JIRA) [jira] [Resolved] (BEAM-957) Flake in FlattenTest under DirectRunner Wed, 16 Nov, 17:31
Thomas Groh (JIRA) [jira] [Resolved] (BEAM-839) The DirectRunner slows down significantly as the number of keys increases Wed, 16 Nov, 17:32
Thomas Groh (JIRA) [jira] [Resolved] (BEAM-833) Exercise Dynamic Splitting in the DirectRunner Wed, 16 Nov, 18:13
Thomas Groh (JIRA) [jira] [Resolved] (BEAM-999) DirectRunner flake related to splitting Mon, 21 Nov, 17:33
Thomas Groh (JIRA) [jira] [Created] (BEAM-1056) Reference beam version only once in Archetypes Mon, 28 Nov, 21:37
Thomas Weise (JIRA) [jira] [Resolved] (BEAM-858) Enable pre-commit WordCountIT/WindowedWordCountIT for ApexRunner Thu, 03 Nov, 07:29
Thomas Weise (JIRA) [jira] [Created] (BEAM-935) Pre-aggregation for group-by-key Mon, 07 Nov, 17:59
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · Next »Thread · Author · Date
Box list
Sep 2019179
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