|
63 | 63 | maxNumWorkers = flag.Int64("max_num_workers", 0, "Maximum number of workers during scaling (optional).") |
64 | 64 | diskSizeGb = flag.Int64("disk_size_gb", 0, "Size of root disk for VMs, in GB (optional).") |
65 | 65 | diskType = flag.String("disk_type", "", "Type of root disk for VMs (optional).") |
66 | | - diskProvisionedIOPS = flag.Int64("disk_provisioned_iops", 0, "Provisioned IOPS for the root disk for VMs (optional).") |
67 | | - diskProvisionedThroughputMibps = flag.Int64("disk_provisioned_throughput_mibps", 0, "Provisioned throughput for the root disk for VMs (optional).") |
68 | 66 | autoscalingAlgorithm = flag.String("autoscaling_algorithm", "", "Autoscaling mode to use (optional).") |
69 | 67 | zone = flag.String("zone", "", "GCP zone (optional)") |
70 | 68 | kmsKey = flag.String("dataflow_kms_key", "", "The Cloud KMS key identifier used to encrypt data at rest (optional).") |
@@ -117,8 +115,6 @@ var flagFilter = map[string]bool{ |
117 | 115 | "max_num_workers": true, |
118 | 116 | "disk_size_gb": true, |
119 | 117 | "disk_type": true, |
120 | | - "disk_provisioned_iops": true, |
121 | | - "disk_provisioned_throughput_mibps": true, |
122 | 118 | "autoscaling_algorithm": true, |
123 | 119 | "zone": true, |
124 | 120 | "network": true, |
@@ -400,8 +396,6 @@ func getJobOptions(ctx context.Context, streaming bool) (*dataflowlib.JobOptions |
400 | 396 | WorkerHarnessThreads: *workerHarnessThreads, |
401 | 397 | DiskSizeGb: *diskSizeGb, |
402 | 398 | DiskType: *diskType, |
403 | | - DiskProvisionedIOPS: *diskProvisionedIOPS, |
404 | | - DiskProvisionedThroughputMibps: *diskProvisionedThroughputMibps, |
405 | 399 | Algorithm: *autoscalingAlgorithm, |
406 | 400 | FlexRSGoal: *flexRSGoal, |
407 | 401 | MachineType: *firstNonEmpty(workerMachineType, machineType), |
|
0 commit comments