{"action":"created","issue":{"url":"https://api.github.com/repos/GoogleCloudPlatform/DataflowJavaSDK/issues/80","labels_url":"https://api.github.com/repos/GoogleCloudPlatform/DataflowJavaSDK/issues/80/labels{/name}","comments_url":"https://api.github.com/repos/GoogleCloudPlatform/DataflowJavaSDK/issues/80/comments","events_url":"https://api.github.com/repos/GoogleCloudPlatform/DataflowJavaSDK/issues/80/events","html_url":"https://github.com/GoogleCloudPlatform/DataflowJavaSDK/issues/80","id":116003394,"number":80,"title":"NullPointerException in StreamingModeExecutionContext","user":{"login":"bberak","id":1929971,"avatar_url":"https://avatars.githubusercontent.com/u/1929971?v=3","gravatar_id":"","url":"https://api.github.com/users/bberak","html_url":"https://github.com/bberak","followers_url":"https://api.github.com/users/bberak/followers","following_url":"https://api.github.com/users/bberak/following{/other_user}","gists_url":"https://api.github.com/users/bberak/gists{/gist_id}","starred_url":"https://api.github.com/users/bberak/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/bberak/subscriptions","organizations_url":"https://api.github.com/users/bberak/orgs","repos_url":"https://api.github.com/users/bberak/repos","events_url":"https://api.github.com/users/bberak/events{/privacy}","received_events_url":"https://api.github.com/users/bberak/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2015-11-10T01:06:30Z","updated_at":"2015-11-14T21:03:56Z","closed_at":"2015-11-14T11:26:42Z","body":"Hi there,\r\n\r\nI've go a streaming pipeline (DataflowPipelineRunner) that polls an HTTP endpoint, performs some manipulation and stores the results in a BigQuery table. Based on some rudimentary logging I can see the data is coming down the pipeline. It then encounters the following exception:\r\n\r\n```\r\n(b359ca736e4f8d93): Exception: java.lang.NullPointerException\r\n com.google.cloud.dataflow.sdk.runners.worker.StreamingModeExecutionContext.flushState(StreamingModeExecutionContext.java:246)\r\n com.google.cloud.dataflow.sdk.runners.worker.StreamingDataflowWorker.process(StreamingDataflowWorker.java:541)\r\n com.google.cloud.dataflow.sdk.runners.worker.StreamingDataflowWorker.access$300(StreamingDataflowWorker.java:83)\r\n com.google.cloud.dataflow.sdk.runners.worker.StreamingDataflowWorker$5.run(StreamingDataflowWorker.java:435) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\r\n java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\r\n java.lang.Thread.run(Thread.java:745)\r\n```\r\n\r\nI'm using version 1.2.0 of the Dataflow Java SDK.\r\n\r\nAny help would be greatly appreciated, please let me know if I can provide more details."},"comment":{"url":"https://api.github.com/repos/GoogleCloudPlatform/DataflowJavaSDK/issues/comments/156745898","html_url":"https://github.com/GoogleCloudPlatform/DataflowJavaSDK/issues/80#issuecomment-156745898","issue_url":"https://api.github.com/repos/GoogleCloudPlatform/DataflowJavaSDK/issues/80","id":156745898,"user":{"login":"davorbonaci","id":8442684,"avatar_url":"https://avatars.githubusercontent.com/u/8442684?v=3","gravatar_id":"","url":"https://api.github.com/users/davorbonaci","html_url":"https://github.com/davorbonaci","followers_url":"https://api.github.com/users/davorbonaci/followers","following_url":"https://api.github.com/users/davorbonaci/following{/other_user}","gists_url":"https://api.github.com/users/davorbonaci/gists{/gist_id}","starred_url":"https://api.github.com/users/davorbonaci/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/davorbonaci/subscriptions","organizations_url":"https://api.github.com/users/davorbonaci/orgs","repos_url":"https://api.github.com/users/davorbonaci/repos","events_url":"https://api.github.com/users/davorbonaci/events{/privacy}","received_events_url":"https://api.github.com/users/davorbonaci/received_events","type":"User","site_admin":false},"created_at":"2015-11-14T21:03:56Z","updated_at":"2015-11-14T21:03:56Z","body":"Thanks Boris!\r\n\r\nIndeed, `getWatermark` should return a lower bound *estimate* on timestamps of future elements read by a reader, and never a `null`."}}