Indhumathi27 commented on code in PR #4261:
URL: https://github.com/apache/carbondata/pull/4261#discussion_r878309090
##########
core/src/main/java/org/apache/carbondata/core/metadata/SegmentFileStore.java:
##########
@@ -629,17 +630,19 @@ public static boolean updateTableStatusFile(CarbonTable
carbonTable, String segm
*/
public static boolean updateTableStatusFile(CarbonTable carbonTable, String
segmentId,
String segmentFile, String tableId, SegmentFileStore segmentFileStore,
- SegmentStatus segmentStatus) throws IOException {
+ SegmentStatus segmentStatus, String tblStatusVersion) throws IOException
{
boolean status = false;
String tablePath = carbonTable.getTablePath();
- String tableStatusPath = CarbonTablePath.getTableStatusFilePath(tablePath);
+ String tableStatusPath =
+ CarbonTablePath.getTableStatusFilePath(tablePath, tblStatusVersion);
if (!FileFactory.isFileExist(tableStatusPath)) {
return status;
}
String metadataPath = CarbonTablePath.getMetadataPath(tablePath);
AbsoluteTableIdentifier absoluteTableIdentifier =
AbsoluteTableIdentifier.from(tablePath, null, null, tableId);
- SegmentStatusManager segmentStatusManager = new
SegmentStatusManager(absoluteTableIdentifier);
+ SegmentStatusManager segmentStatusManager =
+ new SegmentStatusManager(absoluteTableIdentifier,
carbonTable.getTableStatusVersion());
Review Comment:
carbonTable.getTableStatusVersion() is the read version and tblStatusVersion
is the new version for writing
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
