arunpandianp commented on code in PR #33512:
URL: https://github.com/apache/beam/pull/33512#discussion_r1910206675
##########
runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto:
##########
@@ -763,6 +763,8 @@ message StreamingGetWorkRequest {
GetWorkRequest request = 1;
StreamingGetWorkRequestExtension request_extension = 2;
}
+
+ optional bool supports_multiple_work_items_in_chunk = 5 [default = false];
Review Comment:
Done
##########
runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto:
##########
@@ -763,6 +763,8 @@ message StreamingGetWorkRequest {
GetWorkRequest request = 1;
Review Comment:
done
##########
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetWorkStream.java:
##########
@@ -115,6 +120,7 @@ private void sendRequestExtension(long moreItems, long
moreBytes) {
StreamingGetWorkRequestExtension.newBuilder()
.setMaxItems(moreItems)
.setMaxBytes(moreBytes))
+
.setSupportsMultipleWorkItemsInChunk(multipleItemsInGetWorkResponse)
Review Comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
