title: PubSub streaming job is not working in Local runner
body: <p>I'm trying the following example from the <a href="https://cloud.google.com/pubsub/docs/pubsub-dataflow#java_1" rel="nofollow noreferrer">google official</a> web site.</p>
  <pre><code>import java.io.IOException;
  import org.apache.beam.examples.common.WriteOneFilePerWindow;
  import org.apache.beam.sdk.Pipeline;
  import org.apache.beam.sdk.io.gcp.pubsub.PubsubIO;
  import org.apache.beam.sdk.options.Default;
  import org.apache.beam.sdk.options.Description;
  import org.apache.beam.sdk.options.PipelineOptions;
  import org.apache.beam.sdk.options.PipelineOptionsFactory;
  import org.apache.beam.sdk.options.StreamingOptions;
  import org.apache.beam.sdk.options.Validation.Required;
  import org.apache.beam.sdk.transforms.windowing.FixedWindows;
  import org.apache.beam.sdk.transforms.windowing.Window;
  import org.joda.time.Duration;
  
  public class PubSubToGcs {
    /*
     * Define your own configuration options. Add your own arguments to be processed
     * by the command-line parser, and specify default values for them.
     */
    public interface PubSubToGcsOptions extends PipelineOptions, StreamingOptions {
      @Description(&quot;The Cloud Pub/Sub topic to read from.&quot;)
      @Required
      String getInputTopic();
  
      void setInputTopic(String value);
  
      @Description(&quot;Output file's window size in number of minutes.&quot;)
      @Default.Integer(1)
      Integer getWindowSize();
  
      void setWindowSize(Integer value);
  
      @Description(&quot;Path of the output file including its filename prefix.&quot;)
      @Required
      String getOutput();
  
      void setOutput(String value);
    }
  
    public static void main(String[] args) throws IOException {
      // The maximum number of shards when writing output.
      int numShards = 1;
  
      PubSubToGcsOptions options =
          PipelineOptionsFactory.fromArgs(args).withValidation().as(PubSubToGcsOptions.class);
  
      options.setStreaming(true);
  
      Pipeline pipeline = Pipeline.create(options);
  
      pipeline
          // 1) Read string messages from a Pub/Sub topic.
          .apply(&quot;Read PubSub Messages&quot;, PubsubIO.readStrings().fromTopic(options.getInputTopic()))
          // 2) Group the messages into fixed-sized minute intervals.
          .apply(Window.into(FixedWindows.of(Duration.standardMinutes(options.getWindowSize()))))
          // 3) Write one file to GCS for every window of messages.
          .apply(&quot;Write Files to GCS&quot;, new WriteOneFilePerWindow(options.getOutput(), numShards));
  
      // Execute the pipeline and wait until it finishes running.
      pipeline.run().waitUntilFinish();
    }
  }
  </code></pre>
  <p>This example works in DataFlowRunner works without any issues where as when I tried to run the same example in the local runner it doesn't work. The messages are read from the pubsub queue, but the data is not written the to the gcs file. I'm using apache beam 2.31.0 version.</p>