We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent af23563 commit f99ee47Copy full SHA for f99ee47
1 file changed
paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java
@@ -162,11 +162,11 @@ private void spill() throws IOException {
162
: segment.size();
163
channelWriterOutputView.write(segment, 0, bufferSize);
164
}
165
+ channelWriterOutputView.close();
166
LOG.info(
167
"here spill the reset buffer data with {} records {} bytes",
168
inMemoryBuffer.size(),
169
channelWriterOutputView.getWriteBytes());
- channelWriterOutputView.close();
170
} catch (IOException e) {
171
channelWriterOutputView.closeAndDelete();
172
throw e;
0 commit comments