This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch master
in repository

The following commit(s) were added to refs/heads/master by this push:
     new 3ce24e7  Minor FnAPI proto cleanups.
     new 561b221  Merge pull request #10806 from robertwb/cleanup-protos2
3ce24e7 is described below

commit 3ce24e73c4d6d39c29dcb376514373414c307b31
Author: Robert Bradshaw <>
AuthorDate: Fri Feb 7 17:51:27 2020 -0800

    Minor FnAPI proto cleanups.
    * Don't require is_bounded on BundleApplication, as the default
      is the same as unknown.
    * Remove monitoring_infos from BundleApplication, as sizing information
      is now encoded in the element value.
    * Update the note on the UserState flag to indicate it applies to all
      user state.
 model/fn-execution/src/main/proto/beam_fn_api.proto | 12 ++----------
 1 file changed, 2 insertions(+), 10 deletions(-)

diff --git a/model/fn-execution/src/main/proto/beam_fn_api.proto 
index 9678966..4bf1a39 100644
--- a/model/fn-execution/src/main/proto/beam_fn_api.proto
+++ b/model/fn-execution/src/main/proto/beam_fn_api.proto
@@ -189,18 +189,10 @@ message BundleApplication {
   // use MIN_TIMESTAMP by default.
   map<string, google.protobuf.Timestamp> output_watermarks = 4;
-  // (Required) Whether this application potentially produces an unbounded
+  // Whether this application potentially produces an unbounded
   // amount of data. Note that this should only be set to BOUNDED if and
   // only if the application is known to produce a finite amount of output.
   org.apache.beam.model.pipeline.v1.IsBounded.Enum is_bounded = 5;
-  // Contains additional monitoring information related to this application.
-  //
-  // Each application is able to report information that some runners
-  // will use when providing a UI or for making scaling and performance
-  // decisions. See for
-  // details about what types of signals may be useful to report.
-  repeated org.apache.beam.model.pipeline.v1.MonitoringInfo monitoring_infos = 
 // An Application should be scheduled for execution after a delay.
@@ -227,7 +219,7 @@ message ProcessBundleRequest {
   // of cached elements which have a cache token associated.
   message CacheToken {
-    // A flag to indicate a cache token is valid for user state.
+    // A flag to indicate a cache token is valid for all user state.
     message UserState {}
     // A flag to indicate a cache token is valid for a side input.

Reply via email to