Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
67 commits
Select commit Hold shift + click to select a range
6cb13d9
feat: add support for disk provisioned IOPS and throughput options fo…
bambadiouf1 Apr 8, 2026
a1aa2dc
feat: add disk provisioned IOPS and throughput options to Dataflow wo…
bambadiouf1 Apr 13, 2026
9e6e47b
Add iops and throughput pipeline options for Go SDK
bambadiouf1 Apr 13, 2026
deefe29
Update dataflow api service versions
bambadiouf1 Apr 13, 2026
d93ac19
Update dataflow services api version to latest
bambadiouf1 Apr 13, 2026
55ab768
cast disk provisioned values to Long and reformat comments in Dataflo…
bambadiouf1 Apr 13, 2026
809c722
remove unrelated lint changes
bambadiouf1 Apr 13, 2026
1f9d868
Fix python format issues
bambadiouf1 Apr 13, 2026
e2836ab
fix format
bambadiouf1 Apr 13, 2026
9c071c9
Update runners/google-cloud-dataflow-java/src/main/java/org/apache/be…
bambadiouf1 Apr 22, 2026
27f1a6f
Adding disk iops and throughput field to job.go
bambadiouf1 Apr 22, 2026
1a02903
fix format
bambadiouf1 Apr 22, 2026
f04129d
Update runners/google-cloud-dataflow-java/src/main/java/org/apache/be…
bambadiouf1 Apr 22, 2026
58eb20b
git pull
bambadiouf1 Apr 22, 2026
8d86f5d
Merge branch 'master' into iops_throughput_pipeline_options
bambadiouf1 Apr 23, 2026
c72ed67
feat: add support for disk provisioned IOPS and throughput options fo…
bambadiouf1 Apr 8, 2026
bcc8420
feat: add disk provisioned IOPS and throughput options to Dataflow wo…
bambadiouf1 Apr 13, 2026
a19eb79
Add iops and throughput pipeline options for Go SDK
bambadiouf1 Apr 13, 2026
1a11ca1
Update dataflow api service versions
bambadiouf1 Apr 13, 2026
396f413
Update dataflow services api version to latest
bambadiouf1 Apr 13, 2026
4539bad
cast disk provisioned values to Long and reformat comments in Dataflo…
bambadiouf1 Apr 13, 2026
084b1d1
remove unrelated lint changes
bambadiouf1 Apr 13, 2026
05dc7dd
Fix python format issues
bambadiouf1 Apr 13, 2026
25be264
fix format
bambadiouf1 Apr 13, 2026
dea3af0
Update runners/google-cloud-dataflow-java/src/main/java/org/apache/be…
bambadiouf1 Apr 22, 2026
f25c3cf
Adding disk iops and throughput field to job.go
bambadiouf1 Apr 22, 2026
cf449af
fix format
bambadiouf1 Apr 22, 2026
c745824
Update runners/google-cloud-dataflow-java/src/main/java/org/apache/be…
bambadiouf1 Apr 22, 2026
3f29174
git pull
bambadiouf1 Apr 22, 2026
810fd62
Merge branch 'iops_throughput_pipeline_options' of github.com:bambadi…
bambadiouf1 Apr 23, 2026
91b0995
fix versions
bambadiouf1 Apr 23, 2026
32b8366
Apply suggestion from @gemini-code-assist[bot]
bambadiouf1 Apr 23, 2026
801c359
fix versions
bambadiouf1 Apr 23, 2026
9875d32
update gcp dependencies to latest version
bambadiouf1 Apr 23, 2026
a9f2f73
change disk provisioned IOPS and throughput types from Integer to Lon…
bambadiouf1 Apr 24, 2026
8cfd2ba
remove redundant long casting when setting disk provisioned IOPS and …
bambadiouf1 Apr 24, 2026
f3e263f
update Dataflow client credentials and regenerate v1b3 API messages
bambadiouf1 Apr 24, 2026
5307673
update FHIR search requests to pass nil instead of empty struct to ma…
bambadiouf1 Apr 24, 2026
0dc09d1
default client infos
bambadiouf1 Apr 24, 2026
425e295
restore changes
bambadiouf1 Apr 24, 2026
92db2b5
update google api versions to latest
bambadiouf1 Apr 25, 2026
2a298c5
update go.sum dependencies
bambadiouf1 Apr 25, 2026
710d249
update Go module dependencies in go.sum
bambadiouf1 Apr 25, 2026
9d3312c
update Google Cloud SDK dependencies to latest versions
bambadiouf1 Apr 25, 2026
cca8588
undo dependencies changes
bambadiouf1 Apr 25, 2026
c2d2f29
update dependencies
bambadiouf1 Apr 25, 2026
dba0adb
update dependencies in go.mod
bambadiouf1 Apr 25, 2026
ed82781
update go.sum dependencies
bambadiouf1 Apr 25, 2026
0bb4d8a
update FHIR search calls to pass nil as the request body
bambadiouf1 Apr 25, 2026
e6f4697
initialize Options map in job to prevent nil pointer exceptions
bambadiouf1 Apr 25, 2026
997c393
update disk provisioned options to use Long literals in DataflowPipel…
bambadiouf1 Apr 26, 2026
720088a
add autogenerated v1b3 client library definitions
bambadiouf1 Apr 26, 2026
c66df18
delete
bambadiouf1 Apr 26, 2026
3c75487
Merge branch 'iops_throughput_pipeline_options' of github.com:bambadi…
bambadiouf1 Apr 26, 2026
6cc6547
undo
bambadiouf1 Apr 26, 2026
785d55c
gen_client
bambadiouf1 Apr 26, 2026
3bae763
undo versions update
bambadiouf1 Apr 26, 2026
867a156
update api version
bambadiouf1 Apr 26, 2026
04e9199
update versions
bambadiouf1 Apr 26, 2026
45aeecf
update long running version
bambadiouf1 Apr 26, 2026
ca353fb
go mod tidy
bambadiouf1 Apr 26, 2026
0b42ea0
add accidentally deleted encoding fields
bambadiouf1 Apr 27, 2026
d693d6b
reset
bambadiouf1 Apr 27, 2026
d0ae4b2
git pull origin master + revert json field deletion
bambadiouf1 Apr 27, 2026
5a2fbe8
Update changes.md doc with the support for disk provisioned IOPS an…
bambadiouf1 Apr 27, 2026
1f7f981
gen_client
bambadiouf1 Apr 27, 2026
a733874
revert changes cause gen_client
bambadiouf1 Apr 27, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions CHANGES.md
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,7 @@

## New Features / Improvements

* Added support for setting disk provisioned IOPS and throughput in Dataflow runner via `--diskProvisionedIops` and `--diskProvisionedThroughputMibps` pipeline options (Java/Python/Go) ([#37377](https://github.com/apache/beam/issues/37377)).
Comment thread
damccorm marked this conversation as resolved.
* X feature added (Java/Python) ([#X](https://github.com/apache/beam/issues/X)).
* TriggerStateMachineRunner changes from BitSetCoder to SentinelBitSetCoder to
encode finished bitset. SentinelBitSetCoder and BitSetCoder are state
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -740,7 +740,7 @@ class BeamModulePlugin implements Plugin<Project> {
google_api_common : "com.google.api:api-common", // google_cloud_platform_libraries_bom sets version
google_api_services_bigquery : "com.google.apis:google-api-services-bigquery:v2-rev20251012-2.0.0", // [bomupgrader] sets version
google_api_services_cloudresourcemanager : "com.google.apis:google-api-services-cloudresourcemanager:v1-rev20250606-2.0.0", // [bomupgrader] sets version
google_api_services_dataflow : "com.google.apis:google-api-services-dataflow:v1b3-rev20260118-$google_clients_version",
google_api_services_dataflow : "com.google.apis:google-api-services-dataflow:v1b3-rev20260405-$google_clients_version",
google_api_services_healthcare : "com.google.apis:google-api-services-healthcare:v1-rev20240130-$google_clients_version",
google_api_services_pubsub : "com.google.apis:google-api-services-pubsub:v1-rev20220904-$google_clients_version",
google_api_services_storage : "com.google.apis:google-api-services-storage:v1-rev20260204-2.0.0", // [bomupgrader] sets version
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -489,6 +489,13 @@ public Job translate(List<DataflowPackage> packages) {
if (options.getDiskSizeGb() > 0) {
workerPool.setDiskSizeGb(options.getDiskSizeGb());
}
if (options.getDiskProvisionedIops() != null && options.getDiskProvisionedIops() > 0) {
workerPool.setDiskProvisionedIops(options.getDiskProvisionedIops());
}
if (options.getDiskProvisionedThroughputMibps() != null
&& options.getDiskProvisionedThroughputMibps() > 0) {
workerPool.setDiskProvisionedThroughputMibps(options.getDiskProvisionedThroughputMibps());
}
Comment thread
bambadiouf1 marked this conversation as resolved.
AutoscalingSettings settings = new AutoscalingSettings();
if (options.getAutoscalingAlgorithm() != null) {
settings.setAlgorithm(options.getAutoscalingAlgorithm().getAlgorithm());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -193,6 +193,20 @@ public String getAlgorithm() {

void setWorkerDiskType(String value);

/** Provisioned IOPS for the worker disk. */
@Description("Provisioned IOPS for the worker disk.")
@Nullable
Long getDiskProvisionedIops();

void setDiskProvisionedIops(Long value);

/** Provisioned throughput in MiB/s for the worker disk. */
@Description("Provisioned throughput in MiB/s for the worker disk.")
@Nullable
Long getDiskProvisionedThroughputMibps();

void setDiskProvisionedThroughputMibps(Long value);

/**
* Specifies whether worker pools should be started with public IP addresses.
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -322,4 +322,13 @@ public void destroy() {
TimeoutException.class, () -> DefaultGcpRegionFactory.getRegionFromGcloudCli(1L));
}
}

@Test
public void testDiskProvisionedIopsAndThroughput() {
DataflowPipelineOptions options = PipelineOptionsFactory.as(DataflowPipelineOptions.class);
options.setDiskProvisionedIops(1000L);
options.setDiskProvisionedThroughputMibps(100L);
assertEquals(Long.valueOf(1000), options.getDiskProvisionedIops());
assertEquals(Long.valueOf(100), options.getDiskProvisionedThroughputMibps());
}
}
28 changes: 14 additions & 14 deletions sdks/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,12 @@ go 1.26.0
toolchain go1.26.2

require (
cloud.google.com/go/bigquery v1.72.0
cloud.google.com/go/bigtable v1.41.0
cloud.google.com/go/datastore v1.21.0
cloud.google.com/go/bigquery v1.74.0
cloud.google.com/go/bigtable v1.42.0
cloud.google.com/go/datastore v1.22.0
cloud.google.com/go/profiler v0.4.3
cloud.google.com/go/pubsub v1.50.1
cloud.google.com/go/spanner v1.87.0
cloud.google.com/go/spanner v1.88.0
cloud.google.com/go/storage v1.59.2
github.com/aws/aws-sdk-go-v2 v1.41.1
github.com/aws/aws-sdk-go-v2/config v1.32.7
Expand All @@ -56,12 +56,12 @@ require (
github.com/xitongsys/parquet-go-source v0.0.0-20241021075129-b732d2ac9c9b
go.mongodb.org/mongo-driver v1.17.9
golang.org/x/net v0.52.0
golang.org/x/oauth2 v0.35.0
golang.org/x/oauth2 v0.36.0
golang.org/x/sync v0.20.0
golang.org/x/sys v0.42.0
golang.org/x/text v0.35.0
google.golang.org/api v0.257.0
google.golang.org/genproto v0.0.0-20250922171735-9219d122eba9
google.golang.org/api v0.276.0
google.golang.org/genproto v0.0.0-20260319201613-d00831a3d3e7
google.golang.org/grpc v1.80.0
google.golang.org/protobuf v1.36.11
gopkg.in/yaml.v2 v2.4.0
Expand All @@ -77,13 +77,13 @@ require (

require (
cel.dev/expr v0.25.1 // indirect
cloud.google.com/go/auth v0.17.0 // indirect
cloud.google.com/go/auth v0.20.0 // indirect
cloud.google.com/go/auth/oauth2adapt v0.2.8 // indirect
cloud.google.com/go/monitoring v1.24.3 // indirect
cloud.google.com/go/pubsub/v2 v2.0.0 // indirect
dario.cat/mergo v1.0.2 // indirect
filippo.io/edwards25519 v1.1.1 // indirect
github.com/GoogleCloudPlatform/grpc-gcp-go/grpcgcp v1.5.3 // indirect
github.com/GoogleCloudPlatform/grpc-gcp-go/grpcgcp v1.6.0 // indirect
github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.31.0 // indirect
github.com/GoogleCloudPlatform/opentelemetry-operations-go/exporter/metric v0.54.0 // indirect
github.com/GoogleCloudPlatform/opentelemetry-operations-go/internal/resourcemapping v0.54.0 // indirect
Expand Down Expand Up @@ -124,8 +124,8 @@ require (
go.einride.tech/aip v0.73.0 // indirect
go.opentelemetry.io/auto/sdk v1.2.1 // indirect
go.opentelemetry.io/contrib/detectors/gcp v1.39.0 // indirect
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.63.0 // indirect
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.61.0 // indirect
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.67.0 // indirect
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.67.0 // indirect
go.opentelemetry.io/otel v1.43.0 // indirect
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.43.0 // indirect
go.opentelemetry.io/otel/metric v1.43.0 // indirect
Expand All @@ -141,7 +141,7 @@ require (
cloud.google.com/go v0.123.0 // indirect
cloud.google.com/go/compute/metadata v0.9.0 // indirect
cloud.google.com/go/iam v1.5.3 // indirect
cloud.google.com/go/longrunning v0.7.0 // indirect
cloud.google.com/go/longrunning v0.8.0 // indirect
github.com/Azure/go-ansiterm v0.0.0-20250102033503-faa5f7b0171c // indirect
github.com/Microsoft/go-winio v0.6.2 // indirect
github.com/apache/arrow/go/arrow v0.0.0-20211112161151-bc219186db40 // indirect
Expand Down Expand Up @@ -175,8 +175,8 @@ require (
github.com/google/pprof v0.0.0-20250602020802-c6617b811d0e // indirect
github.com/google/renameio/v2 v2.0.0 // indirect
github.com/google/s2a-go v0.1.9 // indirect
github.com/googleapis/enterprise-certificate-proxy v0.3.7 // indirect
github.com/googleapis/gax-go/v2 v2.15.0 // indirect
github.com/googleapis/enterprise-certificate-proxy v0.3.14 // indirect
github.com/googleapis/gax-go/v2 v2.21.0 // indirect
github.com/gorilla/handlers v1.5.2 // indirect
github.com/gorilla/mux v1.8.1 // indirect
github.com/inconshreveable/mousetrap v1.1.0 // indirect
Expand Down
Loading
Loading