title: SocketTimeoutException when trying to run DataFlow job locally with PubSub input source
body: <p>I'm trying to test my DataFlow job locally, but keep getting timeout errors on reading from PubSub topic.</p>
  
  <pre><code>PCollection&lt;KV&lt;Integer, Tick&gt;&gt; input = pipeline.apply(PubsubIO.Read.topic(options.getPubSubTopic()).maxNumRecords(10))
  </code></pre>
  
  <p>I'm sure that topic name is correct since the DataFlow is correctly creating subscription under desired topic each time I run the job and I can see it in the browser.</p>
  
  <p>Any hints what might be the issue here?</p>