Skip to content

Commit

Permalink
fix sonar
Browse files Browse the repository at this point in the history
  • Loading branch information
qiaojialin committed Apr 1, 2020
1 parent 9d9a4ef commit 0a4c369
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 10 deletions.
Expand Up @@ -62,10 +62,8 @@
import org.apache.iotdb.db.engine.version.SimpleFileVersionController;
import org.apache.iotdb.db.engine.version.VersionController;
import org.apache.iotdb.db.exception.DiskSpaceInsufficientException;
import org.apache.iotdb.db.exception.LoadEmptyFileException;
import org.apache.iotdb.db.exception.LoadFileException;
import org.apache.iotdb.db.exception.MergeException;
import org.apache.iotdb.db.exception.PartitionViolationException;
import org.apache.iotdb.db.exception.StorageGroupProcessorException;
import org.apache.iotdb.db.exception.TsFileProcessorException;
import org.apache.iotdb.db.exception.WriteProcessException;
Expand Down
Expand Up @@ -24,8 +24,6 @@
import org.apache.iotdb.db.engine.modification.ModificationFile;
import org.apache.iotdb.db.engine.querycontext.ReadOnlyMemChunk;
import org.apache.iotdb.db.engine.upgrade.UpgradeTask;
import org.apache.iotdb.db.exception.LoadEmptyFileException;
import org.apache.iotdb.db.exception.LoadFileException;
import org.apache.iotdb.db.exception.PartitionViolationException;
import org.apache.iotdb.db.service.UpgradeSevice;
import org.apache.iotdb.db.utils.FilePathUtils;
Expand Down
Expand Up @@ -80,7 +80,7 @@ public class TsFileIOWriter {
protected List<ChunkGroupMetadata> chunkGroupMetadataList = new ArrayList<>();

private long markedPosition;
private String deviceId;
private String currentChunkGroupDeviceId;
private long currentChunkGroupStartOffset;
private List<Pair<Long, Long>> versionInfo = new ArrayList<>();

Expand Down Expand Up @@ -133,7 +133,7 @@ protected void startFile() throws IOException {
}

public void startChunkGroup(String deviceId) throws IOException {
this.deviceId = deviceId;
this.currentChunkGroupDeviceId = deviceId;
currentChunkGroupStartOffset = out.getPosition();
logger.debug("start chunk group:{}, file position {}", deviceId, out.getPosition());
chunkMetadataList = new ArrayList<>();
Expand All @@ -143,16 +143,16 @@ public void startChunkGroup(String deviceId) throws IOException {
* end chunk and write some log. If there is no data in the chunk group, nothing will be flushed.
*/
public void endChunkGroup() throws IOException {
if (deviceId == null || chunkMetadataList.isEmpty()) {
if (currentChunkGroupDeviceId == null || chunkMetadataList.isEmpty()) {
return;
}
long dataSize = out.getPosition() - currentChunkGroupStartOffset;
ChunkGroupFooter chunkGroupFooter = new ChunkGroupFooter(deviceId, dataSize,
ChunkGroupFooter chunkGroupFooter = new ChunkGroupFooter(currentChunkGroupDeviceId, dataSize,
chunkMetadataList.size());
chunkGroupFooter.serializeTo(out.wrapAsStream());
chunkGroupMetadataList.add(new ChunkGroupMetadata(deviceId, chunkMetadataList));
chunkGroupMetadataList.add(new ChunkGroupMetadata(currentChunkGroupDeviceId, chunkMetadataList));
logger.debug("end chunk group:{}", chunkMetadataList);
deviceId = null;
currentChunkGroupDeviceId = null;
chunkMetadataList = null;
}

Expand Down

0 comments on commit 0a4c369

Please sign in to comment.