You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/02/05 23:17:38 UTC
[flink] 03/03: [hotfix][runtime] Small improvements in log messages
for Task and RocksDB Backend
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9d74eb270ef4f51d9578c20f85085eb9b4984921
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Wed Feb 5 15:26:18 2020 +0100
[hotfix][runtime] Small improvements in log messages for Task and RocksDB Backend
---
.../main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java | 2 +-
.../flink/contrib/streaming/state/RocksDBKeyedStateBackend.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
index 6de6747..67acbd8 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
@@ -1451,7 +1451,7 @@ public class TaskExecutor extends RpcEndpoint implements TaskExecutorGateway {
}
log.info("Un-registering task and sending final execution state {} to JobManager for task {} {}.",
- task.getExecutionState(), task.getTaskInfo().getTaskName(), task.getExecutionId());
+ task.getExecutionState(), task.getTaskInfo().getTaskNameWithSubtasks(), task.getExecutionId());
AccumulatorSnapshot accumulatorSnapshot = task.getAccumulatorRegistry().getSnapshot();
diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
index 6f27f11..2ddb79b 100644
--- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
+++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
@@ -381,12 +381,12 @@ public class RocksDBKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> {
}
private void cleanInstanceBasePath() {
- LOG.info("Deleting existing instance base directory {}.", instanceBasePath);
+ LOG.info("Closed RocksDB State Backend. Cleaning up RocksDB working directory {}.", instanceBasePath);
try {
FileUtils.deleteDirectory(instanceBasePath);
} catch (IOException ex) {
- LOG.warn("Could not delete instance base path for RocksDB: " + instanceBasePath, ex);
+ LOG.warn("Could not delete RocksDB working directory: {}", instanceBasePath, ex);
}
}