beam

beam copied to clipboard

Use default Python 3 interpreter, when precise minor version is not specified to gradle.

4

tvalentyn

Add Backlog Metrics to Kafka Splittable DoFn Implementation

4

**Please** add a meaningful description for your change here ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ]...

Naireen

This reverts commit 49056fd7ed111c4c9ebb9236ab447d39f0aa86f3. **Please** add a meaningful description for your change here ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and...

kennknowles

Break out work processing logic from StreamingDataflowWorker

2

Break up the processing logic from StreamingDataflowWorker#process still in progress ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [...

m-trieu

Add a test for sql dialect.

1

------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Mention the appropriate issue in your description (for example:...

robertwb

ATM this PR is in the phase of scoping what's not working #29149 ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and...

tvalentyn

### What would you like to happen? In a few scenarios beam has failed to interpret the data type, these include: 1. a source coming from BigQuery table, the unique...

ewanzhang-google

**Please** add a meaningful description for your change here ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ]...

chamikaramj

### What would you like to happen? FileIO supports https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/FileIO.Write.html#withAutoSharding, which usually works well to split large bundles to smaller ones and then write the shards to files. However, in...

liferoad

[Feature Request][Go SDK]: Allow setting Log Level for pipelines.

3

### What would you like to happen? The SDK isn't able to specific log levels to filter down into at the present time (noted by Dataflow documentation https://cloud.google.com/dataflow/docs/guides/logging#SettingLevels at least)....

lostluck