diff --git a/flink-core/src/main/java/org/apache/flink/api/common/accumulators/AccumulatorHelper.java b/flink-core/src/main/java/org/apache/flink/api/common/accumulators/AccumulatorHelper.java index 1533b3d717723..e2414aae99771 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/accumulators/AccumulatorHelper.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/accumulators/AccumulatorHelper.java @@ -145,7 +145,7 @@ private static OptionalFailure wrapUnchecked(String name, Supplier sup try { return supplier.get(); } catch (RuntimeException ex) { - LOG.error("Unexpected error while handling accumulator [" + name + "]", ex); + LOG.error("Unexpected error while handling accumulator [{}]", name, ex); throw new FlinkException(ex); } });