Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5885#discussion_r184830451
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java
---
@@ -455,4 +455,5 @@ public StreamCompressionDecorator
getKeyGroupCompressionDecorator() {
@VisibleForTesting
public abstract int numStateEntries();
+
--- End diff --
revert this?---
