TongruiLi commented on code in PR #38532:
URL: https://github.com/apache/beam/pull/38532#discussion_r3306494833
##########
sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py:
##########
@@ -6764,9 +6764,9 @@ class StreamingConfigTask(_messages.Message):
format version for streaming engine jobs.
userStepToStateFamilyNameMap: Map from user step names to state families.
userWorkerRunnerV1Settings: Binary encoded proto to control runtime
- behavior of the java runner v1 user worker.
+ behavior of the Streaming Java Runner user worker.
Review Comment:
reverted change
##########
sdks/python/apache_beam/examples/kafkataxi/README.md:
##########
@@ -67,7 +67,7 @@ Perform Beam runner specific setup.
ℹ️ Note that cross-language transforms require
portable implementations of Spark/Flink/Direct runners. Dataflow requires
-[runner
V2](https://cloud.google.com/dataflow/docs/guides/deploying-a-pipeline#dataflow-runner-v2).
+[Portable
Runner](https://cloud.google.com/dataflow/docs/guides/deploying-a-pipeline#dataflow-runner-v2).
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]
