commits
Thread
Date
Later messages
Messages by Date
2016/11/29
[jira] [Commented] (BEAM-1061) PreCommit test with side inputs
Luke Cwik (JIRA)
2016/11/29
[jira] [Created] (BEAM-1061) PreCommit test with side inputs
Daniel Halperin (JIRA)
2016/11/29
[2/2] incubator-beam git commit: Closes #1460
dhalperi
2016/11/29
[1/2] incubator-beam git commit: Revert "Remove WindowedValue.valueInEmptyWindows"
dhalperi
2016/11/29
[jira] [Created] (BEAM-1060) Make DoFnTester use new DoFn
Eugene Kirpichov (JIRA)
2016/11/29
[jira] [Commented] (BEAM-1060) Make DoFnTester use new DoFn
ASF GitHub Bot (JIRA)
2016/11/29
[GitHub] incubator-beam pull request #1461: [BEAM-1060] Makes DoFnTester use new DoFn...
jkff
2016/11/29
[GitHub] incubator-beam pull request #1460: Revert "Remove WindowedValue.valueInEmpty...
asfgit
2016/11/29
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1684
Apache Jenkins Server
2016/11/29
[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions
ASF GitHub Bot (JIRA)
2016/11/29
[GitHub] incubator-beam pull request #1458: Restore a private ValueInEmptyWindows to ...
kennknowles
2016/11/29
[GitHub] incubator-beam pull request #1460: Revert "Remove WindowedValue.valueInEmpty...
kennknowles
2016/11/29
[GitHub] incubator-beam pull request #1459: [BEAM-551] Changes to BigQuery validation...
sammcveety
2016/11/29
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1683
Apache Jenkins Server
2016/11/29
[1/2] incubator-beam git commit: This closes #1382
tgroh
2016/11/29
[2/2] incubator-beam git commit: Support ValidatesRunner Attribute in Python
tgroh
2016/11/29
[2/2] incubator-beam git commit: This closes #1457
tgroh
2016/11/29
[GitHub] incubator-beam pull request #1457: Remove TransformApplicationsForTesting
asfgit
2016/11/29
[1/2] incubator-beam git commit: Remove TransformApplicationsForTesting
tgroh
2016/11/29
[GitHub] incubator-beam pull request #1458: Restore a private ValueInEmptyWindows to ...
kennknowles
2016/11/29
[GitHub] incubator-beam pull request #1457: Remove TransformApplicationsForTesting
tgroh
2016/11/29
[GitHub] incubator-beam pull request #1453: Update googledatastore version
vikkyrk
2016/11/29
[2/2] incubator-beam git commit: Update googledatastore version
dhalperi
2016/11/29
[1/2] incubator-beam git commit: Closes #1453
dhalperi
2016/11/29
[GitHub] incubator-beam pull request #1456: Testing travis python issue
pabloem
2016/11/29
[GitHub] incubator-beam pull request #1455: Exploring travis issue in Python SDK's li...
pabloem
2016/11/29
[GitHub] incubator-beam pull request #1455: Exploring travis issue in Python SDK's li...
pabloem
2016/11/29
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1682
Apache Jenkins Server
2016/11/29
Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1681
Apache Jenkins Server
2016/11/29
[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions
ASF GitHub Bot (JIRA)
2016/11/29
[GitHub] incubator-beam pull request #1452: [BEAM-551] Add a test to demonstrate NVP ...
asfgit
2016/11/29
[2/2] incubator-beam git commit: Closes #1452
dhalperi
2016/11/29
[1/2] incubator-beam git commit: Add a test demonstrating how to use ValueProvider with non-serializable data
dhalperi
2016/11/29
[GitHub] incubator-beam pull request #1441: Fix double-close bug
asfgit
2016/11/29
[1/2] incubator-beam git commit: Fix double-close bug
dhalperi
2016/11/29
[2/2] incubator-beam git commit: Closes #1441
dhalperi
2016/11/29
Jenkins build is back to stable : beam_PostCommit_MavenVerify #1936
Apache Jenkins Server
2016/11/29
[1/3] incubator-beam git commit: Transmit new DoFn, not OldDoFn, in Dataflow translator
kenn
2016/11/29
[jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows
ASF GitHub Bot (JIRA)
2016/11/29
[GitHub] incubator-beam pull request #1440: [BEAM-230] Remove WindowedValue.valueInEm...
asfgit
2016/11/29
[1/2] incubator-beam git commit: This closes #1440
kenn
2016/11/29
[2/2] incubator-beam git commit: Remove WindowedValue.valueInEmptyWindows
kenn
2016/11/29
[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn
ASF GitHub Bot (JIRA)
2016/11/29
[GitHub] incubator-beam pull request #1368: [BEAM-498] Transmit new DoFn in Dataflow ...
asfgit
2016/11/29
[3/3] incubator-beam git commit: This closes #1368
kenn
2016/11/29
[2/3] incubator-beam git commit: Update Dataflow worker to beam-master-20161129
kenn
2016/11/29
Jenkins build is back to stable : beam_PostCommit_RunnableOnService_SparkLocal #261
Apache Jenkins Server
2016/11/29
Jenkins build became unstable: beam_PostCommit_MavenVerify #1935
Apache Jenkins Server
2016/11/29
Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1679
Apache Jenkins Server
2016/11/29
[GitHub] incubator-beam pull request #1454: Move datastore example to cookbook
vikkyrk
2016/11/29
[GitHub] incubator-beam pull request #1453: Update googledatastore version
vikkyrk
2016/11/29
Jenkins build became unstable: beam_PostCommit_RunnableOnService_SparkLocal #260
Apache Jenkins Server
2016/11/29
[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions
ASF GitHub Bot (JIRA)
2016/11/29
[GitHub] incubator-beam pull request #1452: [BEAM-551] Add a test to demonstrate NVP ...
sammcveety
2016/11/29
[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state
ASF GitHub Bot (JIRA)
2016/11/29
[3/3] incubator-beam git commit: Add isStateful() to DoFnSignature
kenn
2016/11/29
[1/3] incubator-beam git commit: This closes #1411
kenn
2016/11/29
[2/3] incubator-beam git commit: Reject stateful DoFn in DataflowRunner
kenn
2016/11/29
[GitHub] incubator-beam pull request #1411: [BEAM-25] Temporarily reject stateful Par...
asfgit
2016/11/29
[jira] [Commented] (BEAM-506) Fill in the documentation/runners/flink portion of the website
Maximilian Michels (JIRA)
2016/11/29
[GitHub] incubator-beam-site pull request #97: [BEAM-506] Fill in the documentation/r...
aljoscha
2016/11/29
[jira] [Commented] (BEAM-506) Fill in the documentation/runners/flink portion of the website
ASF GitHub Bot (JIRA)
2016/11/29
[jira] [Assigned] (BEAM-506) Fill in the documentation/runners/flink portion of the website
Aljoscha Krettek (JIRA)
2016/11/29
[jira] [Commented] (BEAM-1059) Create ExecIO
ASF GitHub Bot (JIRA)
2016/11/29
[GitHub] incubator-beam pull request #1451: [BEAM-1059] Create ExecIO
jbonofre
2016/11/29
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1678
Apache Jenkins Server
2016/11/29
[jira] [Created] (BEAM-1059) Create ExecIO
JIRA
2016/11/29
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1677
Apache Jenkins Server
2016/11/29
[jira] [Resolved] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used.
Amit Sela (JIRA)
2016/11/29
[jira] [Commented] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used.
ASF GitHub Bot (JIRA)
2016/11/29
[GitHub] incubator-beam pull request #1450: [BEAM-1052] Add InputDStream id to Microb...
asfgit
2016/11/29
[2/2] incubator-beam git commit: This closes #1450
amitsela
2016/11/29
[1/2] incubator-beam git commit: [BEAM-1052] Add InputDStream id to MicrobatchSource hashcode.
amitsela
2016/11/29
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1676
Apache Jenkins Server
2016/11/28
Jenkins build is back to stable : beam_PostCommit_MavenVerify #1931
Apache Jenkins Server
2016/11/28
[jira] [Commented] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used.
ASF GitHub Bot (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1450: [BEAM-1052] Add InputDStream id to Microb...
aviemzur
2016/11/28
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1675
Apache Jenkins Server
2016/11/28
[jira] [Updated] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used.
Aviem Zur (JIRA)
2016/11/28
[jira] [Updated] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used.
Aviem Zur (JIRA)
2016/11/28
[jira] [Updated] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used.
Aviem Zur (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1387: [BEAM-1006] Fixing the splitKeysToFilters...
asfgit
2016/11/28
[jira] [Resolved] (BEAM-1006) splitKeysToFilter method is creating a bad query string.
JIRA
2016/11/28
[jira] [Commented] (BEAM-1006) splitKeysToFilter method is creating a bad query string.
ASF GitHub Bot (JIRA)
2016/11/28
[2/2] incubator-beam git commit: [BEAM-1006] This closes #1387
jbonofre
2016/11/28
[1/2] incubator-beam git commit: [BEAM-1006] Fixing the MongoDbIO splitKeysToFilters, calling to string on the BSON document prefixed Document to the string, updated it to just get the value of ID
jbonofre
2016/11/28
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1674
Apache Jenkins Server
2016/11/28
Jenkins build became unstable: beam_PostCommit_MavenVerify #1930
Apache Jenkins Server
2016/11/28
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1673
Apache Jenkins Server
2016/11/28
[GitHub] incubator-beam pull request #1449: Demonstrate serializing issue
dhalperi
2016/11/28
[GitHub] incubator-beam pull request #1449: Demonstrate serializing issue
dhalperi
2016/11/28
[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions
ASF GitHub Bot (JIRA)
2016/11/28
[1/2] incubator-beam git commit: Demonstrate PubsubIO with NVP
dhalperi
2016/11/28
[GitHub] incubator-beam pull request #1230: [BEAM-551] PubsubIO with ValueProvider
asfgit
2016/11/28
[2/2] incubator-beam git commit: Closes #1230
dhalperi
2016/11/28
[GitHub] incubator-beam pull request #1156: [BEAM-551] Add method to output runtime o...
asfgit
2016/11/28
[1/2] incubator-beam git commit: Add method to output runtime options
dhalperi
2016/11/28
[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions
ASF GitHub Bot (JIRA)
2016/11/28
[2/2] incubator-beam git commit: Closes #1156
dhalperi
2016/11/28
[jira] [Resolved] (BEAM-1058) mvn clean verify is not tested
Daniel Halperin (JIRA)
2016/11/28
[jira] [Commented] (BEAM-1058) mvn clean verify is not tested
Daniel Halperin (JIRA)
2016/11/28
[jira] [Created] (BEAM-1058) mvn clean verify is not tested
Daniel Halperin (JIRA)
2016/11/28
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1672
Apache Jenkins Server
2016/11/28
[GitHub] incubator-beam pull request #1222: [Ignore, PR for discussion] Replace IOCha...
peihe
2016/11/28
[GitHub] incubator-beam pull request #1447: Remove the Experimental Annotation from t...
asfgit
2016/11/28
[2/2] incubator-beam git commit: This closes #1447
tgroh
2016/11/28
[1/2] incubator-beam git commit: Remove the Experimental Annotation from the DirectRunner
tgroh
2016/11/28
[jira] [Commented] (BEAM-1032) Starter archetype pipeline has no runner on its classpath
Davor Bonaci (JIRA)
2016/11/28
[1/2] incubator-beam git commit: Improve the speed of getting file sizes
davor
2016/11/28
[2/2] incubator-beam git commit: This closes #1404
davor
2016/11/28
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1671
Apache Jenkins Server
2016/11/28
[jira] [Commented] (BEAM-278) Add I/O section
ASF GitHub Bot (JIRA)
2016/11/28
[GitHub] incubator-beam-site pull request #96: [BEAM-278] Add I/O section to programm...
melap
2016/11/28
[jira] [Commented] (BEAM-1009) Upgrade from mockito-all 1 to mockito-core 2
ASF GitHub Bot (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1448: [BEAM-1009] Update to Mockito 2 with mock...
peihe
2016/11/28
[jira] [Commented] (BEAM-1041) IOChannelFactory: supports for recursively remove().
Daniel Halperin (JIRA)
2016/11/28
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1670
Apache Jenkins Server
2016/11/28
[jira] [Commented] (BEAM-1021) DatastoreIO for python
ASF GitHub Bot (JIRA)
2016/11/28
[2/2] incubator-beam git commit: datastoreio write/delete ptransform
dhalperi
2016/11/28
[GitHub] incubator-beam pull request #1447: Remove the Experimental Annotation from t...
tgroh
2016/11/28
[GitHub] incubator-beam pull request #1433: [BEAM-1021] python datastoreio write/dele...
vikkyrk
2016/11/28
[1/2] incubator-beam git commit: Closes #1433
dhalperi
2016/11/28
[jira] [Commented] (BEAM-1009) Upgrade from mockito-all 1 to mockito-core 2
ASF GitHub Bot (JIRA)
2016/11/28
[2/2] incubator-beam git commit: [BEAM-1009] Upgrade byte-buddy version to 1.5.5.
kenn
2016/11/28
[GitHub] incubator-beam pull request #1445: [BEAM-1009] Upgrade byte-buddy version to...
asfgit
2016/11/28
[1/2] incubator-beam git commit: This closes #1445
kenn
2016/11/28
Jenkins build is back to stable : beam_PostCommit_RunnableOnService_FlinkLocal #939
Apache Jenkins Server
2016/11/28
Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1669
Apache Jenkins Server
2016/11/28
[GitHub] incubator-beam pull request #1446: Ignore UsesStatefulParDo Tests in Flink S...
asfgit
2016/11/28
[jira] [Commented] (BEAM-1036) Support for new State API in FlinkRunner
ASF GitHub Bot (JIRA)
2016/11/28
[2/2] incubator-beam git commit: This closes #1446
kenn
2016/11/28
[1/2] incubator-beam git commit: Ignore UsesStatefulParDo Tests in Flink Streaming Runner
kenn
2016/11/28
[GitHub] incubator-beam pull request #1277: [BEAM-894] Using @Teardown to remove temp...
peihe
2016/11/28
[jira] [Commented] (BEAM-894) Using @Teardown to remove temp files from failed bundles in Write.WriteBundles
ASF GitHub Bot (JIRA)
2016/11/28
[jira] [Commented] (BEAM-1036) Support for new State API in FlinkRunner
ASF GitHub Bot (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1446: Ignore UsesStatefulParDo Tests in Flink S...
aljoscha
2016/11/28
Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1668
Apache Jenkins Server
2016/11/28
[jira] [Commented] (BEAM-1009) Upgrade from mockito-all 1 to mockito-core 2
ASF GitHub Bot (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1445: [BEAM-1009] Upgrade byte-buddy version to...
peihe
2016/11/28
[GitHub] incubator-beam pull request #1444: [BEAM-1057] Fix JDBC test derby startup i...
dkulp
2016/11/28
[jira] [Commented] (BEAM-1057) JDBC tests fail to run on slow network
ASF GitHub Bot (JIRA)
2016/11/28
[jira] [Created] (BEAM-1057) JDBC tests fail to run on slow network
Daniel Kulp (JIRA)
2016/11/28
Jenkins build became unstable: beam_PostCommit_RunnableOnService_FlinkLocal #938
Apache Jenkins Server
2016/11/28
[jira] [Created] (BEAM-1056) Reference beam version only once in Archetypes
Thomas Groh (JIRA)
2016/11/28
[jira] [Commented] (BEAM-1032) Starter archetype pipeline has no runner on its classpath
ASF GitHub Bot (JIRA)
2016/11/28
[2/2] incubator-beam git commit: Add direct runner dependency to starter archetype
tgroh
2016/11/28
[GitHub] incubator-beam pull request #1414: [BEAM-1032] Add direct runner dependency ...
asfgit
2016/11/28
[1/2] incubator-beam git commit: This closes #1414
tgroh
2016/11/28
[jira] [Closed] (BEAM-23) User-facing state and timers for ParDo(DoFn)
Kenneth Knowles (JIRA)
2016/11/28
[jira] [Updated] (BEAM-41) State for "Set" data, supporting efficient membership checks
Kenneth Knowles (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1399: [BEAM-25] Add support for stateful ParDo ...
asfgit
2016/11/28
[jira] [Updated] (BEAM-42) State for "Map" data, supporting efficient key lookup, etc.
Kenneth Knowles (JIRA)
2016/11/28
[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state
ASF GitHub Bot (JIRA)
2016/11/28
[jira] [Updated] (BEAM-25) Add user-ready API for interacting with state
Kenneth Knowles (JIRA)
2016/11/28
[jira] [Updated] (BEAM-27) Add user-ready API for interacting with timers
Kenneth Knowles (JIRA)
2016/11/28
[jira] [Updated] (BEAM-37) Run DoFnWithContext without conversion to vanilla DoFn
Kenneth Knowles (JIRA)
2016/11/28
[jira] [Updated] (BEAM-26) Model for validation of user state upon pipeline update
Kenneth Knowles (JIRA)
2016/11/28
[5/5] incubator-beam git commit: This closes #1399
kenn
2016/11/28
[3/5] incubator-beam git commit: Add State parameter support to SimpleDoFnRunner
kenn
2016/11/28
[4/5] incubator-beam git commit: Add support for Stateful ParDo in the Direct runner
kenn
2016/11/28
[2/5] incubator-beam git commit: Add simple tests for stateful ParDo
kenn
2016/11/28
[1/5] incubator-beam git commit: Remove overspecified type in ParDoEvaluator
kenn
2016/11/28
[jira] [Commented] (BEAM-1055) Display Data keys on Python are inconsistent
ASF GitHub Bot (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1443: [BEAM-1055] Display Data keys on Python a...
pabloem
2016/11/28
[jira] [Commented] (BEAM-646) Get runners out of the apply()
ASF GitHub Bot (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1442: [BEAM-646] Add Replacement Methods to Tra...
tgroh
2016/11/28
[GitHub] incubator-beam pull request #1441: Fix double-close bug
sammcveety
2016/11/28
[jira] [Commented] (BEAM-991) DatastoreIO Write should flush early for large batches
Daniel Halperin (JIRA)
2016/11/28
[jira] [Created] (BEAM-1055) Display Data keys on Python are inconsistent
Pablo Estrada (JIRA)
2016/11/28
[jira] [Created] (BEAM-1054) Language specific IO docs
Melissa Pashniak (JIRA)
2016/11/28
[jira] [Commented] (BEAM-1006) splitKeysToFilter method is creating a bad query string.
JIRA
2016/11/28
[jira] [Assigned] (BEAM-1006) splitKeysToFilter method is creating a bad query string.
JIRA
2016/11/28
[jira] [Resolved] (BEAM-795) org.apache.beam.sdk.io.ReadTest.testStreamingPrimitiveDisplayData failing in Dataflow RunnableOnService
Daniel Halperin (JIRA)
2016/11/28
[jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows
ASF GitHub Bot (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1440: [BEAM-230] Remove WindowedValue.valueInEm...
kennknowles
2016/11/28
[jira] [Reopened] (BEAM-230) Remove WindowedValue#valueInEmptyWindows
Kenneth Knowles (JIRA)
2016/11/28
[jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows
Kenneth Knowles (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1424: Add input type to TransformResult
asfgit
2016/11/28
[2/2] incubator-beam git commit: Add input type to TransformResult
tgroh
2016/11/28
[1/2] incubator-beam git commit: This closes #1424
tgroh
2016/11/28
[jira] [Commented] (BEAM-975) Issue with MongoDBIO
JIRA
2016/11/28
[jira] [Updated] (BEAM-975) Issue with MongoDBIO
JIRA
2016/11/28
[jira] [Commented] (BEAM-425) Add Elasticsearch IO
ASF GitHub Bot (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1439: [BEAM-425] Add ElasticsearchIO
echauchot
2016/11/28
[jira] [Commented] (BEAM-1053) ApexGroupByKeyOperator serialization issues
Sandeep Deshmukh (JIRA)
2016/11/28
[jira] [Created] (BEAM-1053) ApexGroupByKeyOperator serialization issues
Sandeep Deshmukh (JIRA)
2016/11/28
Jenkins build is back to stable : beam_PostCommit_MavenVerify #1918
Apache Jenkins Server
2016/11/28
incubator-beam git commit: [BEAM-1049] This closes #1437 [Forced Update!]
jbonofre
2016/11/28
[jira] [Updated] (BEAM-1050) PipelineResult.State is not set to FAILED when a streaming job fails
Amit Sela (JIRA)
2016/11/28
[jira] [Commented] (BEAM-1050) PipelineResult.State is not set to FAILED in when a streaming job fails
ASF GitHub Bot (JIRA)
2016/11/28
[GitHub] incubator-beam pull request #1438: [BEAM-1050] Fixing pipeline's result stat...
staslev
2016/11/27
Jenkins build became unstable: beam_PostCommit_MavenVerify #1917
Apache Jenkins Server
2016/11/27
[jira] [Resolved] (BEAM-1049) Upgrade default spark version to 1.6.3
JIRA
2016/11/27
[jira] [Commented] (BEAM-1049) Upgrade default spark version to 1.6.3
ASF GitHub Bot (JIRA)
2016/11/27
[GitHub] incubator-beam pull request #1437: [BEAM-1049] Update spark version to 1.6.3
asfgit
2016/11/27
[1/2] incubator-beam git commit: [BEAM-1049] Update spark version to 1.6.3
jbonofre
2016/11/27
[2/2] incubator-beam git commit: [BEAM-1049] This closes #1437
jbonofre
2016/11/27
[jira] [Created] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used.
Amit Sela (JIRA)
2016/11/27
[jira] [Assigned] (BEAM-649) Pipeline "actions" should use foreachRDD via ParDo.
JIRA
2016/11/27
[jira] [Assigned] (BEAM-648) Persist and restore Aggergator values in case of recovery from failure
JIRA
Later messages