Google Git
Sign in
apache / beam / HEAD
  1. def1ea6 Merge pull request #14655 from ibzib/enable-calc-splitting by Kyle Weaver · 3 years ago
  2. eca1426 [BEAM-12045] Install google cloud profiler agent in java sdk container image by Yichi Zhang · 3 years, 1 month ago
  3. 2020555 [BEAM-12227] Implement ExternalWorkerService#stopWorker to support LOOPBACK by Ke Wu · 3 years ago
  4. c046d7f [BEAM-12009] Enable Calc splitting rule by default. by Kyle Weaver · 3 years ago
  5. 33fe359 Merge pull request #14489: [BEAM-11994] Refactor BigQueryTornadoes to make more options parameterizable by Chamikara Jayalath · 3 years ago
  6. 331ac5d [BEAM-12229] StreamingModeExecutionContext invalidated WindmillStateCache keys by Sam Whittle · 3 years ago
  7. 8532acb Merge pull request #14632 from y1chi/sampler by Yichi Zhang · 3 years ago
  8. 7e59751 Use try-with-resources in ZipFiles by Brian Hulette · 3 years ago
  9. d284d07 Enable dual job submission for Dataflow by Kenneth Knowles · 3 years ago
  10. 72fc94d Merge #14641: [BEAM-12222] Use portable side input expansion always by Kenn Knowles · 3 years ago
  11. 4774c1c [BEAM-12232] Expose public factory methods in SparkJobServerDriver (#14652) by ajo thomas · 3 years ago
  12. a2230e0 Merge pull request #14651: [BEAM-12231] Update Dataflow container to adjust for API changes by Kenn Knowles · 3 years ago
  13. 46b704a Clarify when to use `@DefaultCoder` (#14326) by Udi Meiri · 3 years ago
  14. da03439 Remove WindowFn.getOutputTime by Kenneth Knowles · 3 years ago
  15. 422db52 [BEAM-12231] Update Dataflow container to adjust for API changes by Kenneth Knowles · 3 years ago
  16. 4492fa3 Resolve beam_fn_api experiment for side inputs, using portable expansion always by Kenneth Knowles · 3 years, 7 months ago
  17. 1c2b9bc Temporarily disable FnApiDoFnRunnerTest.testUsingMetrics by Kenneth Knowles · 3 years ago
  18. d152c9c Merge pull request #14646: [BEAM-12226] JdbcIO DefaultRetryStrategy: retry on PostgreSQL-specific 40P01 error code by Alexey Romanenko · 3 years ago
  19. 93fe942 [BEAM-12226] JdbcIO DefaultRetryStrategy: retry on PostgreSQL-specific 40P01 error code by Sylvain Veyrié · 3 years ago
  20. 9505f4e Merge pull request #14631: [BEAM-12220] Close ZipOutputStream to avoid native memory leak by Ismaël Mejía · 3 years ago
  21. e13e548 [BEAM-10029] Adds Grafana config for Spanner IO Perf Metrics (#14643) by Shoaib Zafar · 3 years ago
  22. 38e879b [BEAM-3713] Moving integration tests from nose to pytest (#14481) by Benjamin Gonzalez · 3 years ago
  23. e1ed8ec Merge pull request #14625: [BEAM-11418][BEAM-9920] Fix Go universal runner x-lang artifact staging. by Daniel Oliveira · 3 years ago
  24. 200752d [BEAM-9582] Bump grpcio-tools to the latest version (#14576) by Brian Hulette · 3 years ago
  25. bdee3bd Merge pull request #14630 from ibzib/BEAM-12219 by Kyle Weaver · 3 years ago
  26. 9ea3884 Merge pull request #14579: [BEAM-8019] 'sdk_harness_container_image_overrides' works when there are multiple overrides by Chamikara Jayalath · 3 years ago
  27. 6f6715e [BEAM-12188] Bump snakeyaml to 1.28 by masahitojp · 3 years ago
  28. f61d100 Merge pull request #14627: [BEAM-12216] MqttIO.create() with clientId constructor removed as it is deprecated since Beam 2.13.0 by Ismaël Mejía · 3 years ago
  29. 85a5560 [BEAM-12216] MqttIO.create() with clientId constructor removed because it was deprecated since Beam 2.13.0 by Alexey Romanenko · 3 years ago
  30. 618b060 Merge pull request #14626: [BEAM-12214] RedisIO.readAll() was removed since it is deprecated since Beam 2.13.0 by Alexey Romanenko · 3 years ago
  31. 73d644c [BEAM-12214] RedisIO.readAll() was removed since it was deprecated since Beam 2.13.0 by Alexey Romanenko · 3 years ago
  32. 325471d Merge pull request #14636: [BEAM-7237] Refine SparkRunner exception management to fix ViewTest.testNonSingletonSideInput by Alexey Romanenko · 3 years ago
  33. 729129e Add View.toList pipeline to translator tests by Kenneth Knowles · 3 years ago
  34. 62b9c0f [BEAM-9283] Disable caching ValidatesRunner tests tasks by Ismaël Mejía · 3 years ago
  35. ecc3bc5 Fix not-fully-expanded values in pipeline override code by Kenneth Knowles · 3 years, 6 months ago
  36. 9b1081d [BEAM-7237] Refine SparkRunner exception management to fix ViewTest.testNonSingletonSideInput by Ismaël Mejía · 3 years ago
  37. 7b51b51 [BEAM-7372] cleanup following codes from apache_beam/runners/dataflow and apache_beam/runners/interactive by yoshiki.obata · 3 years, 2 months ago
  38. ed8dad4 Merge pull request #14614: [BEAM-12213] Dataflow dual job submission by Kenn Knowles · 3 years ago
  39. 805f818 Merge pull request #14591: [BEAM-10277][BEAM-12198] Dataflow update support for schemas by reuvenlax · 3 years ago
  40. 2aab1b0 [BEAM-7372] cleanup py2 codepaths in apache_beam/runners/direct, job, portability and test #14565 by tvalentyn · 3 years ago
  41. de5d75e 'sdk_harness_container_image_overrides' works when there are multiple overrides by Chamikara Jayalath · 3 years, 1 month ago
  42. 3981686 [BEAM-12221] Add experimental pipeline option to control the execution state sampling period. by Yichi Zhang · 3 years ago
  43. 455dd10 Merge pull request #14580 from [BEAM-12192] Have WatchKafkaTopicPartitionDoFn respects topics given by KafkaIO by Boyuan Zhang · 3 years ago
  44. 6558ce3 [BEAM-10937] Tour of Beam use FileSystems for I/O (#14431) by David Cavazos · 3 years ago
  45. 247915c Merge pull request #14624 from Fixing Cloud Healthcare counter names #14233 by Pablo · 3 years ago
  46. 8b7f0b9 Merge pull request #14622 from [BEAM-8357] Upgrading auto-value to 1.8.1 from 1.8 by Pablo · 3 years ago
  47. 2f3b188 [BEAM-12192] Have WatchKafkaTopicPartitionDoFn respects topics given by KafkaIO by Boyuan Zhang · 3 years, 1 month ago
  48. 18b2e5b Merge pull request #14597 [BEAM-12199] Run pack_combiners phase by default in DataflowRunner. by Robert Bradshaw · 3 years ago
  49. 487fdb1 Merge pull request #14593 [BEAM-11787] Update annotations in ValidateRunner tests for pack_combiners by Robert Bradshaw · 3 years ago
  50. ef654f6 Close ZipOutputStream by Brian Hulette · 3 years ago
  51. c3025ec [BEAM-12204] Allow unboundedly large side inputs in portable Java. (#14604) by Robert Bradshaw · 3 years ago
  52. d3a4d52 [BEAM-12219] Enable SUBSTRING function. by Kyle Weaver · 3 years ago
  53. baa106e Merge pull request #14570 from [BEAM-12193] Add user metrics to show founded TopicPartition by Boyuan Zhang · 3 years ago
  54. 8d220ce Remove runner V2 overrides from V1 codepath by Kenneth Knowles · 3 years, 2 months ago
  55. 47cfbcb [BEAM-12127] More optimizations for PCollectionConsumerRegistry: cache monitoring container, avoid randomInt for sampling if resevoir is empty (#14601) by scwhittle · 3 years ago
  56. dc636be [BEAM-12209] Fix thread safety of DirectStreamObserver by using atomic for message counting (#14617) by scwhittle · 3 years ago
  57. 9209c75 Merge pull request #14628: [BEAM-12217] MongoDbIO: Read.withFilter() and Read.withProjection() are removed since they are deprecated since Beam 2.12.0 by Ismaël Mejía · 3 years ago
  58. bf17110 [BEAM-12217] MongoDbIO: Read.withFilter() and Read.withProjection() are removed by Alexey Romanenko · 3 years ago
  59. ada287a [BEAM-11907] Full function SqsIO Consumer'' by dennisylyung · 3 years, 2 months ago
  60. bb6a660 [BEAM-11418] Fix Go universal runner x-lang artifact staging. by Daniel Oliveira · 3 years ago
  61. 018f5e7 Merge pull request #14575 from [BEAM-12212] Adds --sdkContainerImage as new Java Dataflow PipelineOption by Boyuan Zhang · 3 years ago
  62. 4c5ecbd Fixing counter names from PR https://github.com/apache/beam/pull/14233 by Mackenzie Clark · 3 years, 1 month ago
  63. c4cea56 Merge pull request #14609 from ibzib/BEAM-12194 by Kyle Weaver · 3 years, 1 month ago
  64. d4650dd Plumb worker pool from properties to capabilities in Dataflow java worker (#14535) by Eric Roshan-Eisner · 3 years, 1 month ago
  65. 1c1e371 Merge pull request #14618: [BEAM-8684] Upgrading google-api-services Java libraries by Kenn Knowles · 3 years, 1 month ago
  66. 8905851 [BEAM-8753] Upgrading com.google.apis:google-api-services-pubsub by Tomo Suzuki · 3 years, 1 month ago
  67. 93996a7 [BEAM-10349] Upgrading com.google.apis:google-api-services-healthcare by Tomo Suzuki · 3 years, 1 month ago
  68. 41dd973 [BEAM-8752] Upgrading com.google.apis:google-api-services-dataflow by Tomo Suzuki · 3 years, 1 month ago
  69. 6b89768 [BEAM-8751] Upgrading com.google.apis:google-api-services-cloudresourcemanager by Tomo Suzuki · 3 years, 1 month ago
  70. 05c851a [BEAM-8750] Upgrading com.google.apis:google-api-services-clouddebugger by Tomo Suzuki · 3 years, 1 month ago
  71. e19fa64 [BEAM-8684] Upgrading com.google.apis:google-api-services-bigquery by Tomo Suzuki · 3 years, 1 month ago
  72. 3246690 Merge pull request #14620: [BEAM-12210] Use formatting string for checkArgument to avoid excess … by Ismaël Mejía · 3 years, 1 month ago
  73. 9c66c70 [BEAM-8357] Upgrading auto-value to 1.8.1 from 1.8 by Tomo Suzuki · 3 years, 1 month ago
  74. 2300f45 add sdkContainerImage to Java WorkerPool PipelineOptions by Emily Ye · 3 years, 1 month ago
  75. f15294a [BEAM-8691] Upgrading bigtable-client-core to 1.19.1 by Tomo Suzuki · 3 years, 1 month ago
  76. 8821163 [BEAM-11994] Refactor BigQueryTornadoes to make more options parameterizable. by Alex Amato · 3 years, 1 month ago
  77. fc45ad4 Fix spotless by Daniel Kulp · 3 years, 1 month ago
  78. 62e0f38 [BEAM-12210] Use formatting string for checkArgument to avoid excess String appends by Daniel Kulp · 3 years, 1 month ago
  79. e300068 Merge pull request #14603: [BEAM-12203] Remove LinkedBlockingQueue overhead from BeamFnControlClient by Kenn Knowles · 3 years, 1 month ago
  80. 51541a5 [BEAM-7372] cleanup py2 codepath from apache_beam/runners/direct, job, portability and test by yoshiki.obata · 3 years, 1 month ago
  81. 93ecc1d Merge pull request #14616: [BEAM-12207] Remove log messages about files to stage. by Ismaël Mejía · 3 years, 1 month ago
  82. 2e9ee8c [BEAM-2085] Fixups for Python resource hints. (#14605) by tvalentyn · 3 years, 1 month ago
  83. 28020ef [BEAM-7372] cleanup codes for py2 from apache_beam/transforms (#14544) by yoshiki.obata · 3 years, 1 month ago
  84. c4bd6f0 [BEAM-7372] fix wrong usage of with_traceback (#14566) by yoshiki.obata · 3 years, 1 month ago
  85. c963660 [BEAM-12191] Add a test for python template generation with upload_graph (#14600) by Yunqing Zhou · 3 years, 1 month ago
  86. 4e3decb [BEAM-12207] Enable nullness check on SparkPipelineRunner.java. by Kyle Weaver · 3 years, 1 month ago
  87. 7b2c67b Lint by Yifan Mai · 3 years, 1 month ago
  88. 689b83c Lint by Yifan Mai · 3 years, 1 month ago
  89. 8e0ee41 [BEAM-12207] Remove log messages about files to stage. by Kyle Weaver · 3 years, 1 month ago
  90. fb1d769 Merge pull request #14578: [BEAM-11010] Upgrading google-cloud-pubsublite to 0.13.2 by Tomo Suzuki · 3 years, 1 month ago
  91. 76ba334 Fix tests by Yifan Mai · 3 years, 1 month ago
  92. 9eb6eb5 Make sdk/worker_harness_container_image fully backwards compatible (#14599) by emily · 3 years, 1 month ago
  93. 9f6a8c6 Update run_rc_validation.sh to pull RC tag by Kenneth Knowles · 3 years, 1 month ago
  94. 9182d8d Merge pull request #14590 from [BEAM-11772, BEAM-11408] Add a BQ option for configuring buffering duration when auto-sharding is used by Pablo · 3 years, 1 month ago
  95. 4439170 Merge pull request #14608 from [BEAM-12114] Dataflow should apply KAFKA_READ_OVERRIDE when it's not with runner_v2 by Boyuan Zhang · 3 years, 1 month ago
  96. 9d603fe [BEAM-12203] Reduce thread switches and queuing for BeamFnControlClient by Sam Whittle · 3 years, 1 month ago
  97. 8c8c330 [BEAM-12194] Implement CREATE AGGREGATE FUNCTION. by Kyle Weaver · 3 years, 1 month ago
  98. 1fdfef5 [BEAM-12114] Dataflow should apply KAFKA_READ_OVERRIDE when it's not with runner_v2 by Boyuan Zhang · 3 years, 1 month ago
  99. c0c95b5 Merge pull request #14588 from ibzib/BEAM-12194 by Kyle Weaver · 3 years, 1 month ago
  100. d6a3256 [BEAM-12194] Code style changes from review. by Kyle Weaver · 3 years, 1 month ago