Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3198#discussion_r97553270
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -773,12 +783,13 @@ private void restoreKVStateData() throws IOException,
RocksDBException {
* we don't restore the individual k/v states, just the global RocksDB
data base and the
* list of column families. When a k/v state is first requested we
check here whether we
* already have a column family for that and return it or create a new
one if it doesn't exist.
- *
+ * <p>
--- End diff --
superfluous `<p>`
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
