[hotfix][rocksdb] Fix exception message

tongcheng-elong · Apr 15, 2020 · 5d21fbe · 5d21fbe
1 parent 893ae56
commit 5d21fbe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateUploader.java b/...-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateUploader.java
@@ -81,7 +81,7 @@ public Map<StateHandleID, StreamStateHandle> uploadFilesToCheckpointFs(
  if (throwable instanceof IOException) {
  throw (IOException) throwable;
  } else {
- throw new FlinkRuntimeException("Failed to download data for state handles.", e);
+ throw new FlinkRuntimeException("Failed to upload data for state handles.", e);
  }
  }