IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

Apr 08 03:22:45 03:22:45.450 [ERROR] org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration -- Time elapsed: 0.034 s <<< FAILURE!
Apr 08 03:22:45 org.opentest4j.AssertionFailedError: 
Apr 08 03:22:45 
Apr 08 03:22:45 expected: false
Apr 08 03:22:45  but was: true
Apr 08 03:22:45 	at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
Apr 08 03:22:45 	at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
Apr 08 03:22:45 	at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(K.java:45)
Apr 08 03:22:45 	at org.apache.flink.runtime.state.DiscardRecordedStateObject.verifyDiscard(DiscardRecordedStateObject.java:34)
Apr 08 03:22:45 	at org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration(IncrementalRemoteKeyedStateHandleTest.java:211)
Apr 08 03:22:45 	at java.lang.reflect.Method.invoke(Method.java:498)
Apr 08 03:22:45 	at java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
Apr 08 03:22:45 	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
Apr 08 03:22:45 	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
Apr 08 03:22:45 	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
Apr 08 03:22:45 	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)