commits  

Messages by Date

• 2016/12/02 [2/4] incubator-beam git commit: Supports window parameter in DoFnTester kenn
• 2016/12/02 [4/4] incubator-beam git commit: Makes DoFnTester use new DoFn internally. kenn
• 2016/12/02 [3/4] incubator-beam git commit: Removes DoFnTester.of(OldDoFn) kenn
• 2016/12/02 [jira] [Resolved] (BEAM-239) Rename RemoveDuplicates to Distinct Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-879) Renaming DeDupExample to DistinctExample Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-879) Renaming DeDupExample to DistinctExample ASF GitHub Bot (JIRA)
• 2016/12/02 [1/2] incubator-beam git commit: BEAM-879: Changing DeDupExample to DistinctExample dhalperi
• 2016/12/02 [GitHub] incubator-beam pull request #1489: [BEAM-879]: Renaming DeDupExample to Dist... asfgit
• 2016/12/02 [2/2] incubator-beam git commit: Closes #1489 dhalperi
• 2016/12/02 [GitHub] incubator-beam pull request #1496: Add labels to lambdas in write finalizati... charlesccychen
• 2016/12/02 [jira] [Commented] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample may be flaky Stas Levin (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1495: [BEAM-646] Add DirectTestUtils tgroh
• 2016/12/02 [jira] [Commented] (BEAM-485) Can't set Flink runner in code Emanuele Cesena (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1494: Fix auth related unit test failures vikkyrk
• 2016/12/02 [jira] [Created] (BEAM-1080) python sdk apiclient needs proper unit tests Vikas Kedigehalli (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-1079) Validation speed for really large number of files Sourabh Bajaj (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-986) ReduceFnRunner doesn't batch prefetching pane firings ASF GitHub Bot (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1493: [BEAM-986] Deprecate TimerCallback and In... scwhittle
• 2016/12/02 [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1487: [BEAM-646] Stop using Maps of Transforms ... asfgit
• 2016/12/02 [1/3] incubator-beam git commit: Stop using Maps of Transforms in the DirectRunner tgroh
• 2016/12/02 [3/3] incubator-beam git commit: This closes #1487 tgroh
• 2016/12/02 [2/3] incubator-beam git commit: Rename ConsumerTrackingPipelineVisitor to DirectGraphVisitor tgroh
• 2016/12/02 [jira] [Commented] (BEAM-1077) @ValidatesRunner test in Python postcommit ASF GitHub Bot (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1492: [BEAM-1077] @ValidatesRunner Test in Pyth... markflyhigh
• 2016/12/02 [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1490: [BEAM-646] Explicitly Throw in TransformE... asfgit
• 2016/12/02 [1/2] incubator-beam git commit: Explicitly Throw in TransformExecutorTest tgroh
• 2016/12/02 [2/2] incubator-beam git commit: This closes #1490 tgroh
• 2016/12/02 [GitHub] incubator-beam pull request #1491: [BEAM-1070] Call from_p12_keyfile() with ... aaltay
• 2016/12/02 [jira] [Commented] (BEAM-1070) Service Account Based Authentication Broken ASF GitHub Bot (JIRA)
• 2016/12/02 [1/3] incubator-beam-site git commit: Simplify Flink Runner instructions for running on cluster davor
• 2016/12/02 [2/3] incubator-beam-site git commit: Regenerate website davor
• 2016/12/02 [GitHub] incubator-beam-site pull request #99: Simplify Flink Runner instructions for... asfgit
• 2016/12/02 [3/3] incubator-beam-site git commit: This closes #99 davor
• 2016/12/02 [jira] [Created] (BEAM-1079) Validation speed for really large number of files Sourabh Bajaj (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers ASF GitHub Bot (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1477: [BEAM-27] Add timerId to TimerData asfgit
• 2016/12/02 [2/2] incubator-beam git commit: Add timerId to TimerData kenn
• 2016/12/02 [1/2] incubator-beam git commit: This closes #1477 kenn
• 2016/12/02 [GitHub] incubator-beam pull request #1260: Reduces exposure of WindowedValue in the ... asfgit
• 2016/12/02 [2/3] incubator-beam git commit: Move Towards removing WindowedValue from SDK tgroh
• 2016/12/02 [1/3] incubator-beam git commit: Move Towards removing WindowedValue from SDK tgroh
• 2016/12/02 [3/3] incubator-beam git commit: This closes #1260 tgroh
• 2016/12/02 [jira] [Assigned] (BEAM-1078) Modifying the links in JavaDocs to point to the Beam github repo rather than GCP Neelesh Srinivas Salian (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #871: [BEAM-580] Datastore delete example vikkyrk
• 2016/12/02 [jira] [Commented] (BEAM-580) Add a Datastore delete example ASF GitHub Bot (JIRA)
• 2016/12/02 [jira] [Created] (BEAM-1078) Modifying the links in JavaDocs to point to the Beam github repo rather than GCP Neelesh Srinivas Salian (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1482: [BEAM-246] travis.yml: disable skipping t... asfgit
• 2016/12/02 [jira] [Commented] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample may be flaky Thomas Weise (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-246) Streamline default Maven profile for user efficiency ASF GitHub Bot (JIRA)
• 2016/12/02 [2/2] incubator-beam git commit: Closes #1482 dhalperi
• 2016/12/02 [1/2] incubator-beam git commit: travis.yml: disable skipping things that no longer run dhalperi
• 2016/12/02 [jira] [Updated] (BEAM-641) Need to test the generated archetypes projects Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-682) Invoker Class should be created in Thread Context Classloader Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-555) Documentation in BiqQueryIO.java has awkward cut-and-paste error. Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-555) Documentation in BiqQueryIO.java has awkward cut-and-paste error. Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-551) Support Dynamic PipelineOptions Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-1031) Starter archetype uses OldDoFn Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-939) New credentials code broke Dataflow runner Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-857) Add documentation for configuring Checkstyle-IDEA Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-857) Add documentation for configuring Checkstyle-IDEA Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-857) Beam's checkstyle.xml broken for Checkstyle-IDEA Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-351) Add DisplayData to KafkaIO Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-351) Add DisplayData to KafkaIO Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-246) Streamline default Maven profile for user efficiency Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Closed] (BEAM-1044) tests run before install fails Ahmet Altay (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-993) Python SDK build broken due to datastore dependency Vikas Kedigehalli (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-1044) tests run before install fails Vikas Kedigehalli (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-246) Do not build source jar, javadoc, in default Maven profile. Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-246) Do not build source jar, javadoc, in default Maven profile. Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-480) Use BigQueryServices abstraction in BigQueryIO Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-580) Add a Datastore delete example Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-989) GcsUtil batch remove() and copy() need tests. Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Comment Edited] (BEAM-989) GcsUtil batch remove() and copy() need tests. Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample may be flaky Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample may be flaky Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-223) KafkaIO: don't use SerializableCoder Daniel Halperin (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1481: snippet for datastoreio vikkyrk
• 2016/12/02 [GitHub] incubator-beam pull request #1476: auth: add application default credentials... vikkyrk
• 2016/12/02 [jira] [Resolved] (BEAM-747) Text checksum verifier is not resilient to eventually consistent filesystems Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-252) Make Regex Transform Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-926) Findbugs doesn't pass in Microbenchmarks Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-1043) Dependency problems found in runner-apex Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-810) Beam's uses of archetypes are problematic Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-475) High-quality javadoc for Beam Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-635) Release 0.2.0-incubating - Support Flink Release Version 1.1.2 Daniel Halperin (JIRA)
• 2016/12/02 [GitHub] incubator-beam-site pull request #100: Website: minor typographical correcti... asfgit
• 2016/12/02 [jira] [Updated] (BEAM-874) sdks/java/microbenchmarks instructions incorrect since benchmarks no longer run Daniel Halperin (JIRA)
• 2016/12/02 [2/3] incubator-beam-site git commit: Regenerate website davor
• 2016/12/02 [3/3] incubator-beam-site git commit: This closes #100 davor
• 2016/12/02 [jira] [Resolved] (BEAM-874) sdks/java/microbenchmarks instructions incorrect since benchmarks no longer run Daniel Halperin (JIRA)
• 2016/12/02 [1/3] incubator-beam-site git commit: Website: minor typographical corrections davor
• 2016/12/02 [jira] [Resolved] (BEAM-268) Suppress Jekyll timestamp clobbering Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-748) Issues with local processes in MongoDbIO and JdbcIO Daniel Halperin (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1490: Explicitly Throw in TransformExecutorTest tgroh
• 2016/12/02 [jira] [Updated] (BEAM-76) FileBasedSource should take a list of files/globs Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-60) FileBasedSource/IOChannelFactory: Custom glob expansion Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-485) Can't set Flink runner in code Daniel Halperin (JIRA)
• 2016/12/02 [2/2] incubator-beam git commit: Closes #1481 robertwb
• 2016/12/02 [1/2] incubator-beam git commit: Add snippet for datastoreio robertwb
• 2016/12/02 [jira] [Commented] (BEAM-485) Can't set Flink runner in code Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-512) Fill in the contribute/testing section of the website Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-160) Port 'NexMark Queries' to Beam for use as integration test Daniel Halperin (JIRA)
• 2016/12/02 [1/2] incubator-beam git commit: auth: add application default credentials as fallback robertwb
• 2016/12/02 [jira] [Resolved] (BEAM-431) Examples dependencies on runners are a bit much and not enough Daniel Halperin (JIRA)
• 2016/12/02 [2/2] incubator-beam git commit: Closes #1476 robertwb
• 2016/12/02 [jira] [Updated] (BEAM-318) AvroCoder may be affected by AVRO-607 Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Created] (BEAM-1077) @ValidatesRunner test in Python postcommit Mark Liu (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-787) org.apache.beam.runners.direct.SplittableDoFnTest.testPairWithIndexBasic flaking Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Updated] (BEAM-945) Expose BigQueryIO.parseTableSpec as a public utility Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-945) BigQueryIO.parseTableSpec is package-private Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Created] (BEAM-1076) Datastore Delete template Vikas Kedigehalli (JIRA)
• 2016/12/02 [GitHub] incubator-beam-site pull request #100: Website: minor typographical correcti... dhalperi
• 2016/12/02 [jira] [Closed] (BEAM-901) Fill in Pipeline Fundamentals docs Hadar Hod (JIRA)
• 2016/12/02 [jira] [Resolved] (BEAM-1072) Dataflow should reject unset versions Daniel Halperin (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-1072) Dataflow should reject unset versions ASF GitHub Bot (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1483: [BEAM-1072] DataflowRunner: reject job su... asfgit
• 2016/12/02 [1/2] incubator-beam git commit: Closes #1483 dhalperi
• 2016/12/02 [2/2] incubator-beam git commit: DataflowRunner: reject job submission when the version has not been properly set dhalperi
• 2016/12/02 [jira] [Commented] (BEAM-1074) Set default-partitioner in SourceRDD.Unbounded. JIRA
• 2016/12/02 [jira] [Created] (BEAM-1075) Shuffle the input read-values to get maximum parallelism. Amit Sela (JIRA)
• 2016/12/02 [jira] [Created] (BEAM-1074) Set default-partitioner in SourceRDD.Unbounded. Amit Sela (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-881) Provide a PTransform in IOs providing a "standard" Avro IndexedRecord JIRA
• 2016/12/02 [jira] [Updated] (BEAM-848) Make post-read (unbounded) shuffle use coders instead of Kryo. Amit Sela (JIRA)
• 2016/12/02 [jira] [Closed] (BEAM-506) Fill in the documentation/runners/flink portion of the website Aljoscha Krettek (JIRA)
• 2016/12/02 [jira] [Commented] (BEAM-879) Renaming DeDupExample to DistinctExample ASF GitHub Bot (JIRA)
• 2016/12/02 [GitHub] incubator-beam pull request #1489: [BEAM-879]: Renaming DeDupExample to Dist... nssalian
• 2016/12/02 [jira] [Commented] (BEAM-994) Support for S3 file source and sink JIRA
• 2016/12/02 Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #1707 Apache Jenkins Server
• 2016/12/02 Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #1707 Apache Jenkins Server
• 2016/12/02 Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Flink #978 Apache Jenkins Server
• 2016/12/02 Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Flink #978 Apache Jenkins Server
• 2016/12/02 Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #290 Apache Jenkins Server
• 2016/12/02 Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #290 Apache Jenkins Server
• 2016/12/01 [jira] [Commented] (BEAM-995) Apache Pig DSL JIRA
• 2016/12/01 [jira] [Assigned] (BEAM-995) Apache Pig DSL JIRA
• 2016/12/01 Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1706 Apache Jenkins Server
• 2016/12/01 Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1706 Apache Jenkins Server
• 2016/12/01 [2/2] incubator-beam git commit: Closes #1488 dhalperi
• 2016/12/01 [GitHub] incubator-beam pull request #1488: Fix pom syntax for excludedGroups for Spl... asfgit
• 2016/12/01 [1/2] incubator-beam git commit: Fix pom syntax for excludedGroups for SplittableParDo dhalperi
• 2016/12/01 Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #289 Apache Jenkins Server
• 2016/12/01 Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #289 Apache Jenkins Server
• 2016/12/01 Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #977 Apache Jenkins Server
• 2016/12/01 Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #977 Apache Jenkins Server
• 2016/12/01 Re: Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1705 Kenneth Knowles
• 2016/12/01 [GitHub] incubator-beam pull request #1488: Fix pom syntax for excludedGroups for Spl... kennknowles
• 2016/12/01 Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1705 Apache Jenkins Server
• 2016/12/01 Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1705 Apache Jenkins Server
• 2016/12/01 Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #1967 Apache Jenkins Server
• 2016/12/01 Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #1967 Apache Jenkins Server
• 2016/12/01 [jira] [Commented] (BEAM-995) Apache Pig DSL Neelesh Srinivas Salian (JIRA)
• 2016/12/01 Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #288 Apache Jenkins Server
• 2016/12/01 [jira] [Updated] (BEAM-1070) Service Account Based Authentication Broken Frances Perry (JIRA)
• 2016/12/01 [jira] [Updated] (BEAM-1068) Service Account Credentials File Specified via Pipeline Option Ignored Frances Perry (JIRA)
• 2016/12/01 Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #288 Apache Jenkins Server
• 2016/12/01 Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Flink #976 Apache Jenkins Server
• 2016/12/01 Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Flink #976 Apache Jenkins Server
• 2016/12/01 [2/2] incubator-beam git commit: Category for tests using splittable DoFn kenn
• 2016/12/01 [GitHub] incubator-beam pull request #1486: Adds a category for tests using splittabl... asfgit
• 2016/12/01 [1/2] incubator-beam git commit: This closes #1486 kenn
• 2016/12/01 [GitHub] incubator-beam pull request #1487: Stop using Maps of Transforms in the Dire... tgroh
• 2016/12/01 [GitHub] incubator-beam pull request #1486: Adds a category for tests using splittabl... jkff
• 2016/12/01 Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #1965 Apache Jenkins Server
• 2016/12/01 Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #1965 Apache Jenkins Server
• 2016/12/01 [jira] [Resolved] (BEAM-801) SplittableParDo must be a pseudo-primitive, not ParDo(OldDoFn) Daniel Halperin (JIRA)
• 2016/12/01 [GitHub] incubator-beam pull request #1485: WIP - Beam test main session pickle sb2nov
• 2016/12/01 [jira] [Commented] (BEAM-801) SplittableParDo must be a pseudo-primitive, not ParDo(OldDoFn) Eugene Kirpichov (JIRA)
• 2016/12/01 [jira] [Updated] (BEAM-1073) Staged websites have extra whitespace around links Daniel Halperin (JIRA)
• 2016/12/01 [jira] [Created] (BEAM-1073) Staged websites have extra whitespace around links Daniel Halperin (JIRA)
• 2016/12/01 [1/3] incubator-beam git commit: This closes #1484 tgroh
• 2016/12/01 [3/3] incubator-beam git commit: Migrate TransformTreeNode to an Inner Class tgroh
• 2016/12/01 [2/3] incubator-beam git commit: Reduce the visibility of TransformHierarchy Node Mutators tgroh
• 2016/12/01 [GitHub] incubator-beam pull request #1484: Migrate TransformTreeNode to an Inner Cla... asfgit
• 2016/12/01 [jira] [Commented] (BEAM-506) Fill in the documentation/runners/flink portion of the website ASF GitHub Bot (JIRA)
• 2016/12/01 [GitHub] incubator-beam-site pull request #97: [BEAM-506] Fill in the documentation/r... asfgit
• 2016/12/01 [2/3] incubator-beam-site git commit: [BEAM-506] Fill in the documentation/runners/flink portion of the website dhalperi
• 2016/12/01 [1/3] incubator-beam-site git commit: Closes #97 dhalperi
• 2016/12/01 [3/3] incubator-beam-site git commit: Regenerate website dhalperi
• 2016/12/01 [jira] [Commented] (BEAM-801) SplittableParDo must be a pseudo-primitive, not ParDo(OldDoFn) ASF GitHub Bot (JIRA)
• 2016/12/01 [GitHub] incubator-beam pull request #1261: [BEAM-801, BEAM-787] Improvements to Spli... asfgit
• 2016/12/01 [1/2] incubator-beam git commit: Improve Splittable DoFn tgroh
• 2016/12/01 [2/2] incubator-beam git commit: This closes #1261 tgroh
• 2016/12/01 [jira] [Closed] (BEAM-895) Transport.newStorageClient requires credentials Daniel Halperin (JIRA)
• 2016/12/01 [jira] [Commented] (BEAM-894) Using @Teardown to remove temp files from failed bundles in Write.WriteBundles Pei He (JIRA)
• 2016/12/01 [jira] [Closed] (BEAM-894) Using @Teardown to remove temp files from failed bundles in Write.WriteBundles Pei He (JIRA)
• 2016/12/01 [jira] [Closed] (BEAM-952) Dynamically load and register IOChannelFactory Pei He (JIRA)
• 2016/12/01 [jira] [Updated] (BEAM-990) KafkaIO does not commit offsets to Kafka Alban Perillat-Merceroz (JIRA)
• 2016/12/01 [jira] [Closed] (BEAM-962) Fix games example pipeline options default values conflicts. Pei He (JIRA)
• 2016/12/01 [jira] [Closed] (BEAM-443) PipelineResult needs waitUntilFinish() and cancel() Pei He (JIRA)
• 2016/12/01 [jira] [Assigned] (BEAM-719) Run WindowedWordCount Integration Test in Spark Mark Liu (JIRA)
• 2016/12/01 [jira] [Closed] (BEAM-444) Promote isBlockOnRun() to PipelineOptions. Pei He (JIRA)
• 2016/12/01 [jira] [Updated] (BEAM-719) Run WindowedWordCount Integration Test in Spark Daniel Halperin (JIRA)
• 2016/12/01 [jira] [Updated] (BEAM-443) PipelineResult needs waitUntilFinish() and cancel() Daniel Halperin (JIRA)
• 2016/12/01 [jira] [Updated] (BEAM-580) Add a Datastore delete example Daniel Halperin (JIRA)
• 2016/12/01 [jira] [Updated] (BEAM-765) TriggerStateMachine does not need to be separate from OnceTriggerStateMachine Daniel Halperin (JIRA)
• 2016/12/01 [jira] [Updated] (BEAM-792) In WC Walkthrough: Document how logging works on Apache Spark Daniel Halperin (JIRA)
• 2016/12/01 [jira] [Updated] (BEAM-444) Promote isBlockOnRun() to PipelineOptions. Daniel Halperin (JIRA)

• Earlier messages
• Later messages