| 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 |