Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -202,9 +202,6 @@ log.write.flush_chunk_groups = start to flush chunk groups, memory space occupy:
# TsFileWriter / AbstractTableModelTsFileWriter — close file (2 files, 1 key)
log.write.close_file = start close file

# AbstractTableModelTsFileWriter — close file exception (1 site)
log.write.close_file_exception = Meet exception when close file writer.

# TsFileWriter / AbstractTableModelTsFileWriter — page size vs chunk group size warn (2 files, 1 key)
log.write.page_size_warn = TsFile's page size {} is greater than chunk group size {}, please enlarge the chunk group size or decrease page size.

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -202,9 +202,6 @@ log.write.flush_chunk_groups = 开始刷新 chunk groups,占用内存空间: {
# TsFileWriter / AbstractTableModelTsFileWriter — close file (2 files, 1 key)
log.write.close_file = 开始关闭文件

# AbstractTableModelTsFileWriter — close file exception (1 site)
log.write.close_file_exception = 关闭文件 writer 时发生异常。

# TsFileWriter / AbstractTableModelTsFileWriter — page size vs chunk group size warn (2 files, 1 key)
log.write.page_size_warn = TsFile 的 page size {} 大于 chunk group size {},请增大 chunk group size 或减小 page size。

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -271,13 +271,9 @@ public void addTsFileProperty(String key, byte[] value) {
*/
@Override
@TsFileApi
public void close() {
public void close() throws IOException {
LOG.info(Messages.get("log.write.close_file"));
try {
flush();
fileWriter.endFile();
} catch (IOException e) {
LOG.warn(Messages.get("log.write.close_file_exception"), e);
}
flush();
fileWriter.endFile();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ public interface ITsFileWriter extends AutoCloseable {
void write(Tablet tablet) throws IOException, WriteProcessException;

@TsFileApi
void close();
void close() throws IOException;

@TsFileApi
void write(TSRecord record) throws IOException, WriteProcessException;
Expand Down
Loading