commits  

Messages by Thread

• • [jira] [Commented] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1450: [BEAM-1052] Add InputDStream id to Microb... aviemzur
  • [GitHub] incubator-beam pull request #1450: [BEAM-1052] Add InputDStream id to Microb... asfgit
• [jira] [Updated] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. Aviem Zur (JIRA)
  • [jira] [Updated] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. Aviem Zur (JIRA)
  • [jira] [Updated] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. Aviem Zur (JIRA)
• [GitHub] incubator-beam pull request #1387: [BEAM-1006] Fixing the splitKeysToFilters... asfgit
• [jira] [Resolved] (BEAM-1006) splitKeysToFilter method is creating a bad query string. JIRA
• [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
  • [2/2] incubator-beam git commit: [BEAM-1006] This closes #1387 jbonofre
• Jenkins build became unstable: beam_PostCommit_MavenVerify #1930 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_MavenVerify #1931 Apache Jenkins Server
• [GitHub] incubator-beam pull request #1449: Demonstrate serializing issue dhalperi
  • [GitHub] incubator-beam pull request #1449: Demonstrate serializing issue dhalperi
• [1/2] incubator-beam git commit: Demonstrate PubsubIO with NVP dhalperi
  • [2/2] incubator-beam git commit: Closes #1230 dhalperi
• [GitHub] incubator-beam pull request #1230: [BEAM-551] PubsubIO with ValueProvider asfgit
• [GitHub] incubator-beam pull request #1156: [BEAM-551] Add method to output runtime o... asfgit
• [1/2] incubator-beam git commit: Add method to output runtime options dhalperi
  • [2/2] incubator-beam git commit: Closes #1156 dhalperi
• [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions ASF GitHub Bot (JIRA)
• [jira] [Resolved] (BEAM-1058) mvn clean verify is not tested Daniel Halperin (JIRA)
• [jira] [Commented] (BEAM-1058) mvn clean verify is not tested Daniel Halperin (JIRA)
• [jira] [Created] (BEAM-1058) mvn clean verify is not tested Daniel Halperin (JIRA)
• [GitHub] incubator-beam pull request #1222: [Ignore, PR for discussion] Replace IOCha... peihe
• [1/2] incubator-beam git commit: Remove the Experimental Annotation from the DirectRunner tgroh
  • [2/2] incubator-beam git commit: This closes #1447 tgroh
• [1/2] incubator-beam git commit: Improve the speed of getting file sizes davor
  • [2/2] incubator-beam git commit: This closes #1404 davor
• [jira] [Commented] (BEAM-278) Add I/O section ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam-site pull request #96: [BEAM-278] Add I/O section to programm... melap
• [GitHub] incubator-beam pull request #1448: [BEAM-1009] Update to Mockito 2 with mock... peihe
• [jira] [Commented] (BEAM-1041) IOChannelFactory: supports for recursively remove(). Daniel Halperin (JIRA)
  • [jira] [Commented] (BEAM-1041) IOChannelFactory: supports for recursively remove(). Pei He (JIRA)
• [jira] [Commented] (BEAM-1021) DatastoreIO for python ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1447: Remove the Experimental Annotation from t... tgroh
  • [GitHub] incubator-beam pull request #1447: Remove the Experimental Annotation from t... asfgit
• [GitHub] incubator-beam pull request #1433: [BEAM-1021] python datastoreio write/dele... vikkyrk
• [1/2] incubator-beam git commit: Closes #1433 dhalperi
  • [2/2] incubator-beam git commit: datastoreio write/delete ptransform dhalperi
• [1/2] incubator-beam git commit: This closes #1445 kenn
  • [2/2] incubator-beam git commit: [BEAM-1009] Upgrade byte-buddy version to 1.5.5. kenn
• [1/2] incubator-beam git commit: Ignore UsesStatefulParDo Tests in Flink Streaming Runner kenn
  • [2/2] incubator-beam git commit: This closes #1446 kenn
• [GitHub] incubator-beam pull request #1277: [BEAM-894] Using @Teardown to remove temp... peihe
• [jira] [Commented] (BEAM-894) Using @Teardown to remove temp files from failed bundles in Write.WriteBundles ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-894) Using @Teardown to remove temp files from failed bundles in Write.WriteBundles Pei He (JIRA)
• [jira] [Commented] (BEAM-1036) Support for new State API in FlinkRunner ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-1036) Support for new State API in FlinkRunner ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1446: Ignore UsesStatefulParDo Tests in Flink S... aljoscha
  • [GitHub] incubator-beam pull request #1446: Ignore UsesStatefulParDo Tests in Flink S... asfgit
• Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1668 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1669 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1670 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1671 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1672 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1673 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1674 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1675 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1676 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1677 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1678 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1679 Apache Jenkins Server
• [jira] [Commented] (BEAM-1009) Upgrade from mockito-all 1 to mockito-core 2 ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-1009) Upgrade from mockito-all 1 to mockito-core 2 ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-1009) Upgrade from mockito-all 1 to mockito-core 2 ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1445: [BEAM-1009] Upgrade byte-buddy version to... peihe
  • [GitHub] incubator-beam pull request #1445: [BEAM-1009] Upgrade byte-buddy version to... asfgit
• [GitHub] incubator-beam pull request #1444: [BEAM-1057] Fix JDBC test derby startup i... dkulp
  • [GitHub] incubator-beam pull request #1444: [BEAM-1057] Fix JDBC test derby startup i... asfgit
• [jira] [Commented] (BEAM-1057) JDBC tests fail to run on slow network ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-1057) JDBC tests fail to run on slow network ASF GitHub Bot (JIRA)
• [jira] [Created] (BEAM-1057) JDBC tests fail to run on slow network Daniel Kulp (JIRA)
• Jenkins build became unstable: beam_PostCommit_RunnableOnService_FlinkLocal #938 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_RunnableOnService_FlinkLocal #939 Apache Jenkins Server
• [jira] [Created] (BEAM-1056) Reference beam version only once in Archetypes Thomas Groh (JIRA)
• [jira] [Commented] (BEAM-1032) Starter archetype pipeline has no runner on its classpath ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-1032) Starter archetype pipeline has no runner on its classpath Davor Bonaci (JIRA)
• [GitHub] incubator-beam pull request #1414: [BEAM-1032] Add direct runner dependency ... asfgit
• [1/2] incubator-beam git commit: This closes #1414 tgroh
  • [2/2] incubator-beam git commit: Add direct runner dependency to starter archetype tgroh
• [jira] [Closed] (BEAM-23) User-facing state and timers for ParDo(DoFn) Kenneth Knowles (JIRA)
• [jira] [Updated] (BEAM-41) State for "Set" data, supporting efficient membership checks Kenneth Knowles (JIRA)
• [GitHub] incubator-beam pull request #1399: [BEAM-25] Add support for stateful ParDo ... asfgit
• [jira] [Updated] (BEAM-42) State for "Map" data, supporting efficient key lookup, etc. Kenneth Knowles (JIRA)
• [jira] [Commented] (BEAM-25) Add user-ready API for interacting with state ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-25) Add user-ready API for interacting with state ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-25) Add user-ready API for interacting with state ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-25) Add user-ready API for interacting with state ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-25) Add user-ready API for interacting with state ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-25) Add user-ready API for interacting with state ASF GitHub Bot (JIRA)
• [jira] [Updated] (BEAM-25) Add user-ready API for interacting with state Kenneth Knowles (JIRA)
• [jira] [Updated] (BEAM-27) Add user-ready API for interacting with timers Kenneth Knowles (JIRA)
• [jira] [Updated] (BEAM-37) Run DoFnWithContext without conversion to vanilla DoFn Kenneth Knowles (JIRA)
• [jira] [Updated] (BEAM-26) Model for validation of user state upon pipeline update Kenneth Knowles (JIRA)
  • [jira] [Updated] (BEAM-26) Model for validation of user state upon pipeline update Kenneth Knowles (JIRA)
• [1/5] incubator-beam git commit: Remove overspecified type in ParDoEvaluator kenn
  • [2/5] incubator-beam git commit: Add simple tests for stateful ParDo kenn
  • [4/5] incubator-beam git commit: Add support for Stateful ParDo in the Direct runner kenn
  • [3/5] incubator-beam git commit: Add State parameter support to SimpleDoFnRunner kenn
  • [5/5] incubator-beam git commit: This closes #1399 kenn
• [jira] [Commented] (BEAM-1055) Display Data keys on Python are inconsistent ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-1055) Display Data keys on Python are inconsistent ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-1055) Display Data keys on Python are inconsistent ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-1055) Display Data keys on Python are inconsistent Pablo Estrada (JIRA)
  • [jira] [Commented] (BEAM-1055) Display Data keys on Python are inconsistent ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1443: [BEAM-1055] Display Data keys on Python a... pabloem
  • [GitHub] incubator-beam pull request #1443: [BEAM-1055] Display Data keys on Python a... pabloem
  • [GitHub] incubator-beam pull request #1443: [BEAM-1055] Display Data keys on Python a... pabloem
  • [GitHub] incubator-beam pull request #1443: [BEAM-1055] Display Data keys on Python a... pabloem
• [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-646) Get runners out of the apply() ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1442: [BEAM-646] Add Replacement Methods to Tra... tgroh
  • [GitHub] incubator-beam pull request #1442: [BEAM-646] Add Replacement Methods to Tra... tgroh
• [GitHub] incubator-beam pull request #1441: Fix double-close bug sammcveety
  • [GitHub] incubator-beam pull request #1441: Fix double-close bug asfgit
• [jira] [Commented] (BEAM-991) DatastoreIO Write should flush early for large batches Daniel Halperin (JIRA)
  • [jira] [Commented] (BEAM-991) DatastoreIO Write should flush early for large batches Joshua Fox (JIRA)
• [jira] [Created] (BEAM-1055) Display Data keys on Python are inconsistent Pablo Estrada (JIRA)
• [jira] [Created] (BEAM-1054) Language specific IO docs Melissa Pashniak (JIRA)
• [jira] [Commented] (BEAM-1006) splitKeysToFilter method is creating a bad query string. JIRA
  • [jira] [Commented] (BEAM-1006) splitKeysToFilter method is creating a bad query string. ASF GitHub Bot (JIRA)
• [jira] [Assigned] (BEAM-1006) splitKeysToFilter method is creating a bad query string. JIRA
• [jira] [Resolved] (BEAM-795) org.apache.beam.sdk.io.ReadTest.testStreamingPrimitiveDisplayData failing in Dataflow RunnableOnService Daniel Halperin (JIRA)
• [GitHub] incubator-beam pull request #1440: [BEAM-230] Remove WindowedValue.valueInEm... kennknowles
  • [GitHub] incubator-beam pull request #1440: [BEAM-230] Remove WindowedValue.valueInEm... asfgit
• [jira] [Reopened] (BEAM-230) Remove WindowedValue#valueInEmptyWindows Kenneth Knowles (JIRA)
• [jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows Kenneth Knowles (JIRA)
  • [jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1424: Add input type to TransformResult asfgit
• [1/2] incubator-beam git commit: This closes #1424 tgroh
  • [2/2] incubator-beam git commit: Add input type to TransformResult tgroh
• [jira] [Commented] (BEAM-975) Issue with MongoDBIO JIRA
  • [jira] [Commented] (BEAM-975) Issue with MongoDBIO JIRA
  • [jira] [Commented] (BEAM-975) Issue with MongoDBIO Reza Nouri (JIRA)
  • [jira] [Commented] (BEAM-975) Issue with MongoDBIO JIRA
  • [jira] [Commented] (BEAM-975) Issue with MongoDBIO JIRA
  • [jira] [Commented] (BEAM-975) Issue with MongoDBIO Reza Nouri (JIRA)
  • [jira] [Commented] (BEAM-975) Issue with MongoDBIO Reza Nouri (JIRA)
• [jira] [Updated] (BEAM-975) Issue with MongoDBIO JIRA
  • [jira] [Updated] (BEAM-975) Issue with MongoDBIO Davor Bonaci (JIRA)
• [jira] [Commented] (BEAM-425) Add Elasticsearch IO ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1439: [BEAM-425] Add ElasticsearchIO echauchot
• [jira] [Commented] (BEAM-1053) ApexGroupByKeyOperator serialization issues Sandeep Deshmukh (JIRA)
• [jira] [Created] (BEAM-1053) ApexGroupByKeyOperator serialization issues Sandeep Deshmukh (JIRA)
• incubator-beam git commit: [BEAM-1049] This closes #1437 [Forced Update!] jbonofre
• [jira] [Updated] (BEAM-1050) PipelineResult.State is not set to FAILED when a streaming job fails Amit Sela (JIRA)
• [jira] [Commented] (BEAM-1050) PipelineResult.State is not set to FAILED in when a streaming job fails ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1438: [BEAM-1050] Fixing pipeline's result stat... staslev
  • [GitHub] incubator-beam pull request #1438: [BEAM-1050] Fixing pipeline's result stat... staslev
• Jenkins build became unstable: beam_PostCommit_MavenVerify #1917 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_MavenVerify #1918 Apache Jenkins Server
• [jira] [Resolved] (BEAM-1049) Upgrade default spark version to 1.6.3 JIRA
• [jira] [Commented] (BEAM-1049) Upgrade default spark version to 1.6.3 ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1437: [BEAM-1049] Update spark version to 1.6.3 asfgit
• [1/2] incubator-beam git commit: [BEAM-1049] Update spark version to 1.6.3 jbonofre
  • [2/2] incubator-beam git commit: [BEAM-1049] This closes #1437 jbonofre
• [jira] [Created] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used. Amit Sela (JIRA)
• [jira] [Assigned] (BEAM-649) Pipeline "actions" should use foreachRDD via ParDo. JIRA
• [jira] [Assigned] (BEAM-648) Persist and restore Aggergator values in case of recovery from failure JIRA

• Later messages