| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-370) Remove the .named() methods from PTransforms and sub-classes |
Thu, 20 Oct, 18:02 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-354) Modify DatastoreIO to use Datastore v1beta3 API |
Thu, 20 Oct, 18:03 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-342) Change Filter#greaterThan, etc. to actually use Filter |
Thu, 20 Oct, 18:03 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-342) Change Filter#greaterThan, etc. to actually use Filter |
Thu, 20 Oct, 18:03 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-328) Provide a fallback SerializableCoder for `T extends Serializable` by default |
Thu, 20 Oct, 18:04 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Spark #1588 |
Thu, 20 Oct, 18:05 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-307) Upgrade/Test to Kafka 0.10 |
Thu, 20 Oct, 18:05 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-317) Implement PAssert without using Side Inputs |
Thu, 20 Oct, 18:05 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_MavenVerify #1588 |
Thu, 20 Oct, 18:06 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-285) Make MinLongFn and MaxLongFn mimic SumLongFn and use BinaryCombineLongFn |
Thu, 20 Oct, 18:06 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-293) StreamingOptions should not extend GcpOptions |
Thu, 20 Oct, 18:06 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-261) Apache Apex Runner |
Thu, 20 Oct, 18:08 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-256) Add lifecycle event verifiers for Beam pipelines. |
Thu, 20 Oct, 18:08 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-239) Suggest Changing RemoveDuplicates to Distinct |
Thu, 20 Oct, 18:09 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-239) Suggest Changing RemoveDuplicates to Distinct |
Thu, 20 Oct, 18:09 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-239) Suggest Changing RemoveDuplicates to Distinct |
Thu, 20 Oct, 18:09 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-239) Rename RemoveDuplicates to Distinct |
Thu, 20 Oct, 18:09 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-243) Remove DirectPipelineRunner and keep only the InProcessPipelineRunner |
Thu, 20 Oct, 18:09 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-230) Remove WindowedValue#valueInEmptyWindows |
Thu, 20 Oct, 18:10 |
| Daniel Halperin (JIRA) |
[jira] [Reopened] (BEAM-230) Remove WindowedValue#valueInEmptyWindows |
Thu, 20 Oct, 18:10 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-230) Remove WindowedValue#valueInEmptyWindows |
Thu, 20 Oct, 18:10 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-230) Remove WindowedValue#valueInEmptyWindows |
Thu, 20 Oct, 18:10 |
| fran...@apache.org |
[1/3] incubator-beam-site git commit: Add Blog Post on TestStream |
Thu, 20 Oct, 18:11 |
| fran...@apache.org |
[2/3] incubator-beam-site git commit: Regenerate html. |
Thu, 20 Oct, 18:11 |
| fran...@apache.org |
[3/3] incubator-beam-site git commit: This closes #46 |
Thu, 20 Oct, 18:11 |
| asfgit |
[GitHub] incubator-beam-site pull request #46: Add Blog Post on TestStream |
Thu, 20 Oct, 18:11 |
| Daniel Halperin (JIRA) |
[jira] [Reopened] (BEAM-215) Create should be implemented as a BoundedSource |
Thu, 20 Oct, 18:11 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-217) BoundedSource.splitAtFraction should be splitAfterFraction |
Thu, 20 Oct, 18:11 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-215) Create should be implemented as a BoundedSource |
Thu, 20 Oct, 18:12 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-215) Implement Create as a BoundedSource |
Thu, 20 Oct, 18:12 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-215) Create should be implemented as a BoundedSource |
Thu, 20 Oct, 18:12 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-202) Remove KVCoderBase, MapCoderBase |
Thu, 20 Oct, 18:13 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-202) Remove YYYCoderBase |
Thu, 20 Oct, 18:13 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-202) Remove KVCoderBase, MapCoderBase |
Thu, 20 Oct, 18:13 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-191) Remove WindowedValue.valueInEmptyWindows |
Thu, 20 Oct, 18:14 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-184) Using Merging Windows and/or Triggers without a downstream aggregation should fail |
Thu, 20 Oct, 18:15 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-170) Session windows should not be identified by their bounds |
Thu, 20 Oct, 18:18 |
| bchamb...@apache.org |
[1/3] incubator-beam git commit: Add Display Data 'path' metadata |
Thu, 20 Oct, 18:19 |
| bchamb...@apache.org |
[2/3] incubator-beam git commit: Add Display Data 'path' metadata |
Thu, 20 Oct, 18:19 |
| bchamb...@apache.org |
[3/3] incubator-beam git commit: Closes #1088 |
Thu, 20 Oct, 18:19 |
| asfgit |
[GitHub] incubator-beam pull request #1088: [BEAM-745] Add Display Data 'path' metada... |
Thu, 20 Oct, 18:19 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-745) Display Data fails on transforms with nested components of the same type |
Thu, 20 Oct, 18:20 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-135) Utilities for "batching" elements in a DoFn |
Thu, 20 Oct, 18:20 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-124) Testing -- End to End WordCount Batch and Streaming Tests |
Thu, 20 Oct, 18:20 |
| Daniel Halperin (JIRA) |
[jira] [Reopened] (BEAM-141) Remove StateSampler from Java SDK |
Thu, 20 Oct, 18:20 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-141) Remove StateSampler from Java SDK |
Thu, 20 Oct, 18:20 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-141) Remove StateSampler from Java SDK |
Thu, 20 Oct, 18:20 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-141) Remove StateSampler from Java SDK |
Thu, 20 Oct, 18:20 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-104) Capability matrix for Beam website |
Thu, 20 Oct, 18:20 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-93) Support Compute Engine Subnetworks |
Thu, 20 Oct, 18:21 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-93) Support Compute Engine Subnetworks |
Thu, 20 Oct, 18:21 |
| aaltay |
[GitHub] incubator-beam pull request #1148: [BEAM-753] Pin the version of dependencie... |
Thu, 20 Oct, 18:22 |
| Daniel Halperin (JIRA) |
[jira] [Reopened] (BEAM-81) --update PipelineOption is in the wrong interface |
Thu, 20 Oct, 18:22 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-753) Pin versions of all dependencies |
Thu, 20 Oct, 18:22 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-81) --update PipelineOption is in the wrong interface |
Thu, 20 Oct, 18:22 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-77) Reorganize Directory structure |
Thu, 20 Oct, 18:23 |
| Daniel Halperin (JIRA) |
[jira] [Reopened] (BEAM-77) Reorganize Directory structure |
Thu, 20 Oct, 18:23 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-81) Move --update PipelineOption to DataflowPipelineOptions from DataflowPipelineDebugOptions |
Thu, 20 Oct, 18:23 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-78) Rename Dataflow to Beam |
Thu, 20 Oct, 18:23 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-81) Move --update PipelineOption to DataflowPipelineOptions from DataflowPipelineDebugOptions |
Thu, 20 Oct, 18:23 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-77) Reorganize Directory structure |
Thu, 20 Oct, 18:23 |
| Daniel Halperin (JIRA) |
[jira] [Reopened] (BEAM-78) Rename Dataflow to Beam |
Thu, 20 Oct, 18:23 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-78) Rename Dataflow to Beam |
Thu, 20 Oct, 18:23 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-328) Provide a fallback SerializableCoder for `T extends Serializable` by default |
Thu, 20 Oct, 18:24 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-73) IO design pattern: Decouple Parsers and Coders |
Thu, 20 Oct, 18:24 |
| Apache Jenkins Server |
Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Spark #1589 |
Thu, 20 Oct, 18:25 |
| Apache Jenkins Server |
Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Direct Java #1589 |
Thu, 20 Oct, 18:25 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-61) DatastoreIO: unbounded sink |
Thu, 20 Oct, 18:25 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-63) DatastoreIO.Read: dynamic work rebalancing |
Thu, 20 Oct, 18:25 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-57) FileBasedSink should write intermediate output to a different folder |
Thu, 20 Oct, 18:26 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-50) BigQueryIO.Write: reimplement in Java |
Thu, 20 Oct, 18:26 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-49) BigQueryIO: support BYTES |
Thu, 20 Oct, 18:26 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_MavenVerify #1589 |
Thu, 20 Oct, 18:27 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-44) Return the input coder in NullableCoder.of() if it is a NullableCoder |
Thu, 20 Oct, 18:27 |
| Daniel Halperin (JIRA) |
[jira] [Reopened] (BEAM-38) Avoid repeated DoFn deserialization |
Thu, 20 Oct, 18:27 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-40) Replace rawtype lambda-incompatible uses of SerializableFunction with SimpleFunction (as appropriate) |
Thu, 20 Oct, 18:27 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-44) Return the input coder in NullableCoder.of() if it is a NullableCoder |
Thu, 20 Oct, 18:27 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-38) Avoid repeated DoFn deserialization |
Thu, 20 Oct, 18:27 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-38) Reuse DoFns across multiple bundles rather than deserializing per-bundle |
Thu, 20 Oct, 18:28 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-38) Reuse DoFns across multiple bundles rather than deserializing per-bundle |
Thu, 20 Oct, 18:28 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-38) Reuse DoFns across multiple bundles rather than deserializing per-bundle |
Thu, 20 Oct, 18:28 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-37) Run DoFnWithContext without conversion to vanilla DoFn |
Thu, 20 Oct, 18:29 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested |
Thu, 20 Oct, 18:30 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-32) Consider not emitting empty ON_TIME pane unless requested |
Thu, 20 Oct, 18:30 |
| Daniel Halperin (JIRA) |
[jira] [Updated] (BEAM-34) Change default output timestamp for combined values to end of window |
Thu, 20 Oct, 18:30 |
| Daniel Halperin (JIRA) |
[jira] [Closed] (BEAM-37) Run DoFnWithContext without conversion to vanilla DoFn |
Thu, 20 Oct, 18:34 |
| Daniel Halperin (JIRA) |
[jira] [Commented] (BEAM-769) Spark translation tests failing with NullPointerException |
Thu, 20 Oct, 18:48 |
| Daniel Halperin (JIRA) |
[jira] [Commented] (BEAM-787) org.apache.beam.runners.direct.SplittableDoFnTest.testPairWithIndexBasic flaking |
Thu, 20 Oct, 18:51 |
| Daniel Halperin (JIRA) |
[jira] [Created] (BEAM-787) org.apache.beam.runners.direct.SplittableDoFnTest.testPairWithIndexBasic flaking |
Thu, 20 Oct, 18:51 |
| Robert Bradshaw (JIRA) |
[jira] [Resolved] (BEAM-733) Windowed side-inputs not supported in Python |
Thu, 20 Oct, 18:54 |
| k...@apache.org |
[1/4] incubator-beam git commit: Move named DoFn classes into the tests that use them |
Thu, 20 Oct, 18:56 |
| k...@apache.org |
[2/4] incubator-beam git commit: Add analysis and validation of State parameters to DoFn.ProcessElement |
Thu, 20 Oct, 18:56 |
| k...@apache.org |
[3/4] incubator-beam git commit: Use the correct State class in DoFnSignatures |
Thu, 20 Oct, 18:56 |
| k...@apache.org |
[4/4] incubator-beam git commit: This closes #1130 |
Thu, 20 Oct, 18:56 |
| asfgit |
[GitHub] incubator-beam pull request #1130: [BEAM-25] Add parsing and validation of @... |
Thu, 20 Oct, 18:57 |
| ASF GitHub Bot (JIRA) |
[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state |
Thu, 20 Oct, 18:57 |
| Amit Sela (JIRA) |
[jira] [Commented] (BEAM-769) Spark translation tests failing with NullPointerException |
Thu, 20 Oct, 19:02 |
| Amit Sela (JIRA) |
[jira] [Updated] (BEAM-769) Spark streaming tests fail on "nothing processed" if runtime env. is slow because timeout is hit before processing is done. |
Thu, 20 Oct, 19:04 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Direct Java #1590 |
Thu, 20 Oct, 19:08 |
| Apache Jenkins Server |
Jenkins build is still unstable: beam_PostCommit_MavenVerify #1590 |
Thu, 20 Oct, 19:10 |