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

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 1a4eb09  [hotfix][docs] Fix NullPointerException
1a4eb09 is described below

commit 1a4eb097a9454db7cc5972fda43e0b15084371bd
Author: intsmaze <979222...@qq.com>
AuthorDate: Fri Jan 11 19:01:55 2019 +0800

    [hotfix][docs] Fix NullPointerException
    
    Offset is Long type, the default value is null, and executing offset+=1 in 
Java 1.8.x will throw a NullPointerException
---
 docs/dev/stream/state/state.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/dev/stream/state/state.md b/docs/dev/stream/state/state.md
index a3109f2..8fe2981 100644
--- a/docs/dev/stream/state/state.md
+++ b/docs/dev/stream/state/state.md
@@ -640,7 +640,7 @@ public static class CounterSource
         implements ListCheckpointed<Long> {
 
     /**  current offset for exactly once semantics */
-    private Long offset;
+    private Long offset = 0L;
 
     /** flag for job cancellation */
     private volatile boolean isRunning = true;

Reply via email to