beam-commits mailing list archives: December 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 · 30 · 31 · 32 · 33 · 34 · Next »Thread · Author · Date
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1220) Graduation items Wed, 28 Dec, 01:09
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1220) Graduation items Wed, 28 Dec, 01:10
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1163) Add signature keys to the release guide vote template Wed, 28 Dec, 01:27
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-946) Add python Code in Programming Guide. Wed, 28 Dec, 02:48
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1217) Some examples fail to run due to private / public options mismatch. Wed, 28 Dec, 06:04
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1205) Auto set "enableAbandonedNodeEnforcement" in TestPipeline Wed, 28 Dec, 13:42
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-625) Make Dataflow Python Materialized PCollection representation more efficient Wed, 28 Dec, 17:49
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1186) Migrate the remaining tests to use TestPipeline as a JUnit rule. Wed, 28 Dec, 19:41
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1221) Python E2E WordCount Test in Postcommit Wed, 28 Dec, 22:01
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1226) Use well known coder types in Python for KV, Iterable, WindowedValue, GlobalWindow, and LengthPrefix Wed, 28 Dec, 22:01
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1112) Python E2E Integration Test Framework - Batch Only Wed, 28 Dec, 22:26
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1226) Use well known coder types in Python for KV, Iterable, WindowedValue, GlobalWindow, and LengthPrefix Wed, 28 Dec, 22:28
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1227) Release 0.4.0 Wed, 28 Dec, 22:45
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1227) Release 0.4.0 Wed, 28 Dec, 22:52
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1211) Improve Coder efficiency in outer context for StandardCoder Wed, 28 Dec, 23:31
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1224) Rename options.py to pipeline_options.py Wed, 28 Dec, 23:35
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1112) Python E2E Integration Test Framework - Batch Only Thu, 29 Dec, 00:05
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1194) DataflowRunner should test a variety of valid tempLocation/stagingLocation/etc formats. Thu, 29 Dec, 00:54
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1227) Release 0.4.0 Thu, 29 Dec, 05:10
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1227) Release 0.4.0 Thu, 29 Dec, 05:44
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1227) Release 0.4.0 Thu, 29 Dec, 05:44
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1224) Rename options.py to pipeline_options.py Thu, 29 Dec, 05:48
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1224) Rename options.py to pipeline_options.py Thu, 29 Dec, 07:27
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1224) Rename options.py to pipeline_options.py Thu, 29 Dec, 07:46
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1230) Typo in the documentation of the Window class Thu, 29 Dec, 15:34
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1230) Typo in the documentation of the Window class Thu, 29 Dec, 17:45
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-545) Pipelines and their executions naming changes Thu, 29 Dec, 18:03
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions Thu, 29 Dec, 18:40
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1219) Regexp in test_default_job_name of apiclient_test.py is not general enough Thu, 29 Dec, 22:05
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1231) Use well known coder types in Java for WindowedValue, GlobalWindow, and LengthPrefix Thu, 29 Dec, 22:36
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-370) Remove the .named() methods from PTransforms and sub-classes Thu, 29 Dec, 23:45
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-147) Introduce an easy API for pipeline metrics Fri, 30 Dec, 01:41
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-501) Update website skin Fri, 30 Dec, 05:38
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1225) Add a ToString transform in Java SDK Fri, 30 Dec, 11:45
ASF GitHub Bot (JIRA) [jira] [Commented] (BEAM-1232) Fix py-sdk comments to be up-to-date and valid Fri, 30 Dec, 22:42
Ahmet Altay (JIRA) [jira] [Closed] (BEAM-1044) tests run before install fails Fri, 02 Dec, 20:16
Ahmet Altay (JIRA) [jira] [Created] (BEAM-1081) annotations should support custom messages and classes Sat, 03 Dec, 00:09
Ahmet Altay (JIRA) [jira] [Updated] (BEAM-1081) annotations should support custom messages and classes Sat, 03 Dec, 00:11
Ahmet Altay (JIRA) [jira] [Created] (BEAM-1088) submit_job_description needs job argument (Fails post commit) Mon, 05 Dec, 20:06
Ahmet Altay (JIRA) [jira] [Updated] (BEAM-886) Support new DoFn in Python SDK Tue, 06 Dec, 00:48
Ahmet Altay (JIRA) [jira] [Created] (BEAM-1100) Consider removing pylint from mvn verify Wed, 07 Dec, 01:52
Ahmet Altay (JIRA) [jira] [Assigned] (BEAM-1125) Rename one of PTransform.apply to PTransform.expand() Sat, 10 Dec, 02:32
Ahmet Altay (JIRA) [jira] [Created] (BEAM-1125) Rename one of PTransform.apply to PTransform.expand() Sat, 10 Dec, 02:32
Ahmet Altay (JIRA) [jira] [Updated] (BEAM-1125) Rename PTransform.apply to PTransform.expand Sat, 10 Dec, 02:33
Ahmet Altay (JIRA) [jira] [Assigned] (BEAM-1147) BigQuery tests do not run with DirectPipelineRunner Tue, 13 Dec, 18:50
Ahmet Altay (JIRA) [jira] [Created] (BEAM-1147) BigQuery tests do not run with DirectPipelineRunner Tue, 13 Dec, 18:50
Ahmet Altay (JIRA) [jira] [Closed] (BEAM-1125) Rename PTransform.apply to PTransform.expand Fri, 16 Dec, 03:06
Ahmet Altay (JIRA) [jira] [Created] (BEAM-1183) oauth2 client logger warning Mon, 19 Dec, 23:25
Ahmet Altay (JIRA) [jira] [Created] (BEAM-1185) Remove the word Pipeline from the name of all PipelineRunner implementations Tue, 20 Dec, 02:02
Ahmet Altay (JIRA) [jira] [Created] (BEAM-1204) beam_PostCommit_Python_Verify failing Thu, 22 Dec, 03:17
Ahmet Altay (JIRA) [jira] [Closed] (BEAM-1204) beam_PostCommit_Python_Verify failing Thu, 22 Dec, 21:25
Ahmet Altay (JIRA) [jira] [Commented] (BEAM-1204) beam_PostCommit_Python_Verify failing Thu, 22 Dec, 21:25
Ahmet Altay (JIRA) [jira] [Closed] (BEAM-1088) submit_job_description needs job argument (Fails post commit) Wed, 28 Dec, 22:22
Ahmet Altay (JIRA) [jira] [Commented] (BEAM-759) PipelineResult needs waitToFinish() and cancel() Wed, 28 Dec, 23:19
Alban Perillat-Merceroz (JIRA) [jira] [Updated] (BEAM-990) KafkaIO does not commit offsets to Kafka Thu, 01 Dec, 22:11
Alexandre Vermeerbergen (JIRA) [jira] [Commented] (BEAM-9) Storm Runner Sun, 04 Dec, 16:02
Alexey Diomin (JIRA) [jira] [Created] (BEAM-1095) Add support set config for reuse-object on flink Tue, 06 Dec, 18:11
Alexey Diomin (JIRA) [jira] [Created] (BEAM-1096) flink streaming side output optimization using SplitStream Tue, 06 Dec, 19:15
Aliaksandr Ivanou (JIRA) [jira] [Commented] (BEAM-941) Replace Xyz.INSTANCE throughout the SDK with either static methods or XyzFactory.default() Wed, 28 Dec, 13:57
Aliaksandr Ivanou (JIRA) [jira] [Commented] (BEAM-941) Replace Xyz.INSTANCE throughout the SDK with either static methods or XyzFactory.default() Thu, 29 Dec, 13:55
Aliaksandr Ivanou (JIRA) [jira] [Comment Edited] (BEAM-941) Replace Xyz.INSTANCE throughout the SDK with either static methods or XyzFactory.default() Thu, 29 Dec, 13:56
Aljoscha Krettek (JIRA) [jira] [Closed] (BEAM-506) Fill in the documentation/runners/flink portion of the website Fri, 02 Dec, 10:27
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-1092) Shade commonly used libraries (e.g. Guava) to avoid class conflicts Wed, 07 Dec, 03:11
Aljoscha Krettek (JIRA) [jira] [Issue Comment Deleted] (BEAM-1092) Shade commonly used libraries (e.g. Guava) to avoid class conflicts Wed, 07 Dec, 03:12
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-1092) Shade commonly used libraries (e.g. Guava) to avoid class conflicts Wed, 07 Dec, 03:12
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-1102) Flink Batch Runner does not populate aggregator values Wed, 07 Dec, 05:22
Aljoscha Krettek (JIRA) [jira] [Created] (BEAM-1103) Add Tests For Aggregators in Flink Runner Wed, 07 Dec, 07:21
Aljoscha Krettek (JIRA) [jira] [Closed] (BEAM-1102) Flink Batch Runner does not populate aggregator values Wed, 07 Dec, 07:31
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-1107) Display user names for steps in the Flink Web UI Wed, 07 Dec, 23:58
Aljoscha Krettek (JIRA) [jira] [Closed] (BEAM-1095) Add support set config for reuse-object on flink Thu, 08 Dec, 01:46
Aljoscha Krettek (JIRA) [jira] [Updated] (BEAM-1095) Add support set config for reuse-object on flink Thu, 08 Dec, 01:46
Aljoscha Krettek (JIRA) [jira] [Closed] (BEAM-1096) flink streaming side output optimization using SplitStream Thu, 08 Dec, 01:57
Aljoscha Krettek (JIRA) [jira] [Updated] (BEAM-1096) flink streaming side output optimization using SplitStream Thu, 08 Dec, 01:57
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-843) Use New DoFn Directly in Flink Runner Tue, 13 Dec, 14:57
Aljoscha Krettek (JIRA) [jira] [Commented] (BEAM-1148) Port PAssert away from Aggregators Wed, 14 Dec, 12:34
Amit Sela (JIRA) [jira] [Updated] (BEAM-848) Make post-read (unbounded) shuffle use coders instead of Kryo. Fri, 02 Dec, 17:04
Amit Sela (JIRA) [jira] [Created] (BEAM-1074) Set default-partitioner in SourceRDD.Unbounded. Fri, 02 Dec, 17:06
Amit Sela (JIRA) [jira] [Created] (BEAM-1075) Shuffle the input read-values to get maximum parallelism. Fri, 02 Dec, 17:07
Amit Sela (JIRA) [jira] [Updated] (BEAM-1000) Add non blocking cancel() and waitUntilFinish() for Spark batch application Sun, 04 Dec, 19:47
Amit Sela (JIRA) [jira] [Resolved] (BEAM-1000) Add non blocking cancel() and waitUntilFinish() for Spark batch application Mon, 05 Dec, 11:27
Amit Sela (JIRA) [jira] [Resolved] (BEAM-595) Support non-blocking run() in SparkRunner and cancel() and waitUntilFinish() in Spark EvaluationContext Mon, 05 Dec, 11:28
Amit Sela (JIRA) [jira] [Updated] (BEAM-595) Support non-blocking run() in SparkRunner and cancel() and waitUntilFinish() in Spark EvaluationContext Mon, 05 Dec, 11:28
Amit Sela (JIRA) [jira] [Resolved] (BEAM-1050) PipelineResult.State is not set to FAILED when a streaming job fails Mon, 05 Dec, 11:29
Amit Sela (JIRA) [jira] [Assigned] (BEAM-507) Fill in the documentation/runners/spark portion of the website Tue, 06 Dec, 20:18
Amit Sela (JIRA) [jira] [Resolved] (BEAM-1094) Spark runner should define Kafka IO dependency with test scope Wed, 07 Dec, 09:04
Amit Sela (JIRA) [jira] [Updated] (BEAM-329) Update Spark runner README. Wed, 07 Dec, 10:49
Amit Sela (JIRA) [jira] [Commented] (BEAM-507) Fill in the documentation/runners/spark portion of the website Wed, 07 Dec, 21:59
Amit Sela (JIRA) [jira] [Created] (BEAM-1111) Reject timers for ParDo in SparkRunner streaming evaluators. Thu, 08 Dec, 18:25
Amit Sela (JIRA) [jira] [Resolved] (BEAM-1111) Reject timers for ParDo in SparkRunner streaming evaluators. Thu, 08 Dec, 19:58
Amit Sela (JIRA) [jira] [Closed] (BEAM-637) Support Java serialisation (via JavaSerialiser) Sun, 11 Dec, 12:43
Amit Sela (JIRA) [jira] [Assigned] (BEAM-1130) SparkRunner ResumeFromCheckpointStreamingTest Failing Mon, 12 Dec, 09:21
Amit Sela (JIRA) [jira] [Commented] (BEAM-1130) SparkRunner ResumeFromCheckpointStreamingTest Failing Mon, 12 Dec, 09:24
Amit Sela (JIRA) [jira] [Created] (BEAM-1133) Add maxNumRecords per micro-batch for Spark runner options. Mon, 12 Dec, 10:39
Amit Sela (JIRA) [jira] [Commented] (BEAM-1130) SparkRunner ResumeFromCheckpointStreamingTest Failing Mon, 12 Dec, 10:40
Amit Sela (JIRA) [jira] [Issue Comment Deleted] (BEAM-1130) SparkRunner ResumeFromCheckpointStreamingTest Failing Mon, 12 Dec, 10:42
Amit Sela (JIRA) [jira] [Commented] (BEAM-1130) SparkRunner ResumeFromCheckpointStreamingTest Failing Mon, 12 Dec, 10:48
Amit Sela (JIRA) [jira] [Resolved] (BEAM-1130) SparkRunner ResumeFromCheckpointStreamingTest Failing Tue, 13 Dec, 07:56
Amit Sela (JIRA) [jira] [Resolved] (BEAM-1133) Add maxNumRecords per micro-batch for Spark runner options. Tue, 13 Dec, 07:56
Amit Sela (JIRA) [jira] [Commented] (BEAM-1146) Decrease spark runner startup overhead Tue, 13 Dec, 15:55
Amit Sela (JIRA) [jira] [Commented] (BEAM-1144) Spark runner fails to deserialize MicrobatchSource in cluster mode Tue, 13 Dec, 19:19
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 · 30 · 31 · 32 · 33 · 34 · Next »Thread · Author · Date
Box list
Jul 2019281
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