commits  

Messages by Thread

• • Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1706 Apache Jenkins Server
  • Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1705 Apache Jenkins Server
  • Re: Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #1705 Kenneth Knowles
• [jira] [Commented] (BEAM-995) Apache Pig DSL Neelesh Srinivas Salian (JIRA)
  • [jira] [Commented] (BEAM-995) Apache Pig DSL JIRA
• [jira] [Updated] (BEAM-1070) Service Account Based Authentication Broken Frances Perry (JIRA)
• Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #288 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #289 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #290 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #290 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Spark #289 Apache Jenkins Server
  • Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #288 Apache Jenkins Server
• Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Flink #976 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #977 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Flink #978 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Flink #978 Apache Jenkins Server
  • Jenkins build is still unstable: beam_PostCommit_Java_RunnableOnService_Flink #977 Apache Jenkins Server
  • Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Flink #976 Apache Jenkins Server
• [1/2] incubator-beam git commit: This closes #1486 kenn
  • [2/2] incubator-beam git commit: Category for tests using splittable DoFn kenn
• [GitHub] incubator-beam pull request #1487: Stop using Maps of Transforms in the Dire... tgroh
  • [GitHub] incubator-beam pull request #1487: [BEAM-646] Stop using Maps of Transforms ... asfgit
• [GitHub] incubator-beam pull request #1486: Adds a category for tests using splittabl... jkff
  • [GitHub] incubator-beam pull request #1486: Adds a category for tests using splittabl... asfgit
• Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #1965 Apache Jenkins Server
  • Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #1965 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #1967 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #1967 Apache Jenkins Server
• [jira] [Resolved] (BEAM-801) SplittableParDo must be a pseudo-primitive, not ParDo(OldDoFn) Daniel Halperin (JIRA)
• [GitHub] incubator-beam pull request #1485: WIP - Beam test main session pickle sb2nov
  • [GitHub] incubator-beam pull request #1485: [BEAM-1087] Fix inconsistent pickle from ... sb2nov
• [jira] [Updated] (BEAM-1073) Staged websites have extra whitespace around links Daniel Halperin (JIRA)
• [jira] [Created] (BEAM-1073) Staged websites have extra whitespace around links Daniel Halperin (JIRA)
• [1/3] incubator-beam git commit: This closes #1484 tgroh
  • [2/3] incubator-beam git commit: Reduce the visibility of TransformHierarchy Node Mutators tgroh
  • [3/3] incubator-beam git commit: Migrate TransformTreeNode to an Inner Class tgroh
• [1/3] incubator-beam-site git commit: Closes #97 dhalperi
  • [3/3] incubator-beam-site git commit: Regenerate website dhalperi
  • [2/3] incubator-beam-site git commit: [BEAM-506] Fill in the documentation/runners/flink portion of the website dhalperi
• [jira] [Commented] (BEAM-801) SplittableParDo must be a pseudo-primitive, not ParDo(OldDoFn) ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-801) SplittableParDo must be a pseudo-primitive, not ParDo(OldDoFn) Eugene Kirpichov (JIRA)
• [GitHub] incubator-beam pull request #1261: [BEAM-801, BEAM-787] Improvements to Spli... asfgit
• [1/2] incubator-beam git commit: Improve Splittable DoFn tgroh
  • [2/2] incubator-beam git commit: This closes #1261 tgroh
• [jira] [Closed] (BEAM-895) Transport.newStorageClient requires credentials Daniel Halperin (JIRA)
• [jira] [Closed] (BEAM-894) Using @Teardown to remove temp files from failed bundles in Write.WriteBundles Pei He (JIRA)
• [jira] [Closed] (BEAM-952) Dynamically load and register IOChannelFactory Pei He (JIRA)
• [jira] [Closed] (BEAM-962) Fix games example pipeline options default values conflicts. Pei He (JIRA)
• [jira] [Closed] (BEAM-443) PipelineResult needs waitUntilFinish() and cancel() Pei He (JIRA)
• [jira] [Assigned] (BEAM-719) Run WindowedWordCount Integration Test in Spark Mark Liu (JIRA)
• [jira] [Closed] (BEAM-444) Promote isBlockOnRun() to PipelineOptions. Pei He (JIRA)
• [jira] [Updated] (BEAM-719) Run WindowedWordCount Integration Test in Spark Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-443) PipelineResult needs waitUntilFinish() and cancel() Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-580) Add a Datastore delete example Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-765) TriggerStateMachine does not need to be separate from OnceTriggerStateMachine Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-792) In WC Walkthrough: Document how logging works on Apache Spark Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-444) Promote isBlockOnRun() to PipelineOptions. Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-599) Return KafkaIO getWatermark log in debug mode Daniel Halperin (JIRA)
  • [jira] [Updated] (BEAM-599) Return KafkaIO getWatermark log in debug mode Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-511) Fill in the contribute/technical-vision section of the website Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-494) All E2E Tests Run Against All Runners In Postcommit Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-683) Make BZIP compressed files splittable Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-521) Execute some bounded source reads via composite transform Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-546) Aggregator Verifier and Integrate to E2E Test Framework Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-537) Create Apache Bigtop Beam packages Daniel Halperin (JIRA)
• [jira] [Resolved] (BEAM-636) Add Char, Byte to TypeDescriptors Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-655) Rename @RunnableOnService to something more descriptive Daniel Halperin (JIRA)
  • [jira] [Updated] (BEAM-655) Rename @RunnableOnService to something more descriptive Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-730) Remove Reshuffle transform in favor of Redistribute.byKey() Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-614) File compression/decompression should support auto detection Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-877) Allow disabling flattening of results when using BigQuery source Sourabh Bajaj (JIRA)
• [jira] [Updated] (BEAM-636) Add Char, Byte to TypeDescriptors Daniel Halperin (JIRA)
• [jira] [Closed] (BEAM-985) Retry decorator maintains state as uses an iterator Sourabh Bajaj (JIRA)
• [jira] [Updated] (BEAM-852) Validate sources when they are created Sourabh Bajaj (JIRA)
• [jira] [Updated] (BEAM-750) Remove StateTag Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-766) Trigger AST should use @AutoValue Daniel Halperin (JIRA)
• [jira] [Closed] (BEAM-754) WordCountIT Flake -- Incorrect checksum Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-850) Add Display Data to the Python Transforms, Sinks, Sources, etc. Daniel Halperin (JIRA)
• [jira] [Resolved] (BEAM-803) Maven configuration that easily launches examples IT tests on one specific runner Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-804) Python Pipeline Option save_main_session non-functional Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-824) Misleading error message when sdk_location is missing in python Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-884) Add Display Data to the Python SDK's PipelineOptions, Avro io and other transforms Daniel Halperin (JIRA)
• [jira] [Resolved] (BEAM-860) Move Apache RAT license check out of release profile Daniel Halperin (JIRA)
• [jira] [Resolved] (BEAM-905) Archetype pom needs to generalize dependencies Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-909) Starter archetype's pom doesn't include the right dependencies Daniel Halperin (JIRA)
  • [jira] [Updated] (BEAM-909) Starter archetype's pom doesn't include the right dependencies Davor Bonaci (JIRA)
  • [jira] [Updated] (BEAM-909) Starter archetype's pom doesn't include the right dependencies Davor Bonaci (JIRA)
  • [jira] [Updated] (BEAM-909) Starter archetype's pom doesn't include the right dependencies Davor Bonaci (JIRA)
• [jira] [Updated] (BEAM-987) TestStream.advanceWatermarkToInfinity should perhaps also advance processing time Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-985) Retry decorator maintains state as uses an iterator Daniel Halperin (JIRA)
  • [jira] [Updated] (BEAM-985) Retry decorator maintains state as uses an iterator Sourabh Bajaj (JIRA)
• [jira] [Updated] (BEAM-994) Support for S3 file source and sink Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-964) Investing exporting BQ as Avro instead of Json for dataflow runner Daniel Halperin (JIRA)
  • [jira] [Updated] (BEAM-964) Investing exporting BQ as Avro instead of Json for dataflow runner Sourabh Bajaj (JIRA)
• [jira] [Updated] (BEAM-988) Support for testing how soon output is emitted Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-990) KafkaIO does not commit offsets to Kafka Daniel Halperin (JIRA)
  • [jira] [Updated] (BEAM-990) KafkaIO does not commit offsets to Kafka Alban Perillat-Merceroz (JIRA)
• [jira] [Updated] (BEAM-989) GcsUtil batch remove() and copy() need tests. Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1016) Use Content-Type and Content-Encoding (as opposed to overriding Content-Type) for compressed files Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1009) Upgrade from mockito-all 1 to mockito-core 2 Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1023) Add test coverage for BigQueryIO.Write in streaming mode Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1021) DatastoreIO for python Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1025) User guide - "How to create Beam IO Transforms" Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1019) Shade bytebuddy dependency Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1027) Hosting data stores to enable IO Transform testing Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1040) Hadoop InputFormat - IO Transform for reads Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1042) Clean build fails on Windows in Starter archetype Daniel Halperin (JIRA)
• [jira] [Commented] (BEAM-1024) upgrade to protobuf-3.1.0 Daniel Halperin (JIRA)
• [GitHub] incubator-beam pull request #1395: Fixing error with PipelineOptions Display... pabloem
• [jira] [Updated] (BEAM-1064) Convert Jenkins jobs to DSL Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1024) upgrade to protobuf-3.1.0 Daniel Halperin (JIRA)
  • [jira] [Updated] (BEAM-1024) upgrade to protobuf-3.1.0 Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1055) Display Data keys on Python are inconsistent Daniel Halperin (JIRA)
• [jira] [Updated] (BEAM-1060) Make DoFnTester use new DoFn Daniel Halperin (JIRA)
  • [jira] [Updated] (BEAM-1060) Make DoFnTester use new DoFn Kenneth Knowles (JIRA)
  • [jira] [Updated] (BEAM-1060) Make DoFnTester use new DoFn Kenneth Knowles (JIRA)
• [jira] [Updated] (BEAM-1071) Support pre-existing tables with streaming BigQueryIO Daniel Halperin (JIRA)
• [GitHub] incubator-beam pull request #1484: Migrate TransformTreeNode to an Inner Cla... tgroh
  • [GitHub] incubator-beam pull request #1484: Migrate TransformTreeNode to an Inner Cla... asfgit
• [jira] [Commented] (BEAM-1072) Dataflow should reject unset versions ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-1072) Dataflow should reject unset versions ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1483: [BEAM-1072] DataflowRunner: reject job su... dhalperi
  • [GitHub] incubator-beam pull request #1483: [BEAM-1072] DataflowRunner: reject job su... asfgit
• [jira] [Created] (BEAM-1072) Dataflow should reject unset versions Daniel Halperin (JIRA)
• [jira] [Closed] (BEAM-1066) Add test coverage for ReleaseInfo Daniel Halperin (JIRA)
• [1/3] incubator-beam git commit: Add a test of ReleaseInfo dhalperi
  • [3/3] incubator-beam git commit: Closes #1480 dhalperi
  • [2/3] incubator-beam git commit: Revert "Move resource filtering later to avoid spurious rebuilds" dhalperi
• [1/2] incubator-beam git commit: Move TransformHierarchy Maintenance into it tgroh
  • [2/2] incubator-beam git commit: This closes #1469 tgroh
• [GitHub] incubator-beam-site pull request #99: Simplify Flink Runner instructions for... aljoscha
  • [GitHub] incubator-beam-site pull request #99: Simplify Flink Runner instructions for... asfgit
• [jira] [Created] (BEAM-1071) Support pre-existing tables with streaming BigQueryIO Sam McVeety (JIRA)
• [jira] [Created] (BEAM-1070) Service Account Based Authentication Broken Stephen Reichling (JIRA)
• [jira] [Updated] (BEAM-1068) Service Account Credentials File Specified via Pipeline Option Ignored Stephen Reichling (JIRA)
  • [jira] [Updated] (BEAM-1068) Service Account Credentials File Specified via Pipeline Option Ignored Frances Perry (JIRA)
• [GitHub] incubator-beam pull request #1482: travis.yml: disable skipping things that ... dhalperi
  • [GitHub] incubator-beam pull request #1482: [BEAM-246] travis.yml: disable skipping t... asfgit
• [jira] [Commented] (BEAM-1042) Clean build fails on Windows in Starter archetype Thomas Weise (JIRA)
• [jira] [Created] (BEAM-1069) Add CountingInput Transform to python sdk Vikas Kedigehalli (JIRA)
• [jira] [Created] (BEAM-1068) Service Account Credentials File Specified via Pipeline Option Ignored Stephen Reichling (JIRA)
• [jira] [Commented] (BEAM-1046) Travis (Linux) failing for python sdk Pablo Estrada (JIRA)
  • [jira] [Commented] (BEAM-1046) Travis (Linux) failing for python sdk ASF GitHub Bot (JIRA)
• [jira] [Created] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample may be flaky Stas Levin (JIRA)
• [jira] [Updated] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample may be flaky Stas Levin (JIRA)
  • [jira] [Updated] (BEAM-1067) apex.examples.WordCountTest.testWordCountExample may be flaky Daniel Halperin (JIRA)
• [GitHub] incubator-beam pull request #1481: snippet for datastoreio vikkyrk
  • [GitHub] incubator-beam pull request #1481: snippet for datastoreio vikkyrk
• [1/2] incubator-beam git commit: Add snippet for standard sql robertwb
  • [2/2] incubator-beam git commit: Closes #1472 robertwb
• [jira] [Commented] (BEAM-1066) Add test coverage for ReleaseInfo ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-1066) Add test coverage for ReleaseInfo ASF GitHub Bot (JIRA)
• [jira] [Created] (BEAM-1066) Add test coverage for ReleaseInfo Daniel Halperin (JIRA)
• [GitHub] incubator-beam pull request #1480: [BEAM-1066] Add a test of ReleaseInfo dhalperi
  • [GitHub] incubator-beam pull request #1480: [BEAM-1066] Add a test of ReleaseInfo asfgit
• [1/2] incubator-beam git commit: Closes #1467 robertwb
  • [2/2] incubator-beam git commit: Improve size estimation speed for file samples robertwb
• [1/2] incubator-beam git commit: Parse table schema from JSON robertwb
  • [2/2] incubator-beam git commit: Closes #1468 robertwb
• [jira] [Commented] (BEAM-1065) FileBasedSource: replace SeekableByteChannel with open(spec, startingPosition) Daniel Halperin (JIRA)
  • [jira] [Commented] (BEAM-1065) FileBasedSource: replace SeekableByteChannel with open(spec, startingPosition) Daniel Halperin (JIRA)
  • [jira] [Commented] (BEAM-1065) FileBasedSource: replace SeekableByteChannel with open(spec, startingPosition) ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam-site pull request #98: [BEAM-825] Fill in the documentation/r... sandeepdeshmukh
• [jira] [Commented] (BEAM-825) Fill in the documentation/runners/apex portion of the website ASF GitHub Bot (JIRA)
• [jira] [Resolved] (BEAM-918) Let users set STORAGE_LEVEL via SparkPipelineOptions. JIRA
• [GitHub] incubator-beam pull request #1370: [BEAM-918] Allow users to define the stor... asfgit
• [jira] [Commented] (BEAM-918) Let users set STORAGE_LEVEL via SparkPipelineOptions. ASF GitHub Bot (JIRA)
• [1/2] incubator-beam git commit: [BEAM-918] Allow users to define the storage level via pipeline options jbonofre
  • [2/2] incubator-beam git commit: [BEAM-918] This closes #1370 jbonofre
• Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #280 Apache Jenkins Server
  • Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Spark #280 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #281 Apache Jenkins Server
  • Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Spark #281 Apache Jenkins Server
• [jira] [Comment Edited] (BEAM-991) DatastoreIO Write should flush early for large batches Joshua Fox (JIRA)
• [jira] [Commented] (BEAM-1033) WindowedWordCountIT is flaky ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1479: [BEAM-1033] Bigquery Verifier Retry When ... markflyhigh
  • [GitHub] incubator-beam pull request #1479: [BEAM-1033] Bigquery Verifier Retry When ... asfgit
• [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-362) Move shared runner functionality out of SDK and into runners/core-java ASF GitHub Bot (JIRA)
• [GitHub] incubator-beam pull request #1478: [BEAM-362] Moved KeyedWorkItem and relate... kennknowles
  • [GitHub] incubator-beam pull request #1478: [BEAM-362] Moved KeyedWorkItem and relate... asfgit
• [GitHub] incubator-beam pull request #1477: [BEAM-27] Add timerId to TimerData kennknowles
  • [GitHub] incubator-beam pull request #1477: [BEAM-27] Add timerId to TimerData asfgit
• [jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers ASF GitHub Bot (JIRA)
  • [jira] [Commented] (BEAM-27) Add user-ready API for interacting with timers ASF GitHub Bot (JIRA)

• Earlier messages
• Later messages