This is an automated email from the ASF dual-hosted git repository. zhuzh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3a9bae57445274838b6f0e879758b77100dc34a0 Author: JunRuiLee <[email protected]> AuthorDate: Tue Aug 2 11:24:29 2022 +0800 [hotfix][network] Modify the log level of "Failed to read shuffle data." to DEBUG The log was DEBUG level and was changed to ERROR level by mistake. To avoid confusing users, we should change it back to DEBUG. --- .../io/network/partition/SortMergeResultPartitionReadScheduler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java index 272a8262cfa..7b04c563e0b 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionReadScheduler.java @@ -184,7 +184,7 @@ class SortMergeResultPartitionReadScheduler implements Runnable, BufferRecycler } catch (Throwable throwable) { failSubpartitionReaders(Collections.singletonList(subpartitionReader), throwable); subpartitionReader = null; - LOG.error("Failed to read shuffle data.", throwable); + LOG.debug("Failed to read shuffle data.", throwable); } subpartitionReader = addPreviousAndGetNextReader(subpartitionReader, !buffers.isEmpty());
