Skip to content

Commit 6b10812

Browse files
authored
Update StatisticExecutor.java
Signed-off-by: stdpain <34912776+stdpain@users.noreply.github.com>
1 parent f9ce663 commit 6b10812

1 file changed

Lines changed: 0 additions & 10 deletions

File tree

fe/fe-core/src/main/java/com/starrocks/statistic/StatisticExecutor.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,7 @@
2020
import com.starrocks.catalog.Database;
2121
import com.starrocks.catalog.InternalCatalog;
2222
import com.starrocks.catalog.OlapTable;
23-
<<<<<<< HEAD
24-
import com.starrocks.catalog.Partition;
25-
=======
2623
import com.starrocks.catalog.PhysicalPartition;
27-
>>>>>>> e533a34694 ([BugFix] fix dict version of random distribution table (#61933))
2824
import com.starrocks.catalog.Table;
2925
import com.starrocks.common.Pair;
3026
import com.starrocks.common.Status;
@@ -159,14 +155,8 @@ public static Pair<List<TStatisticData>, Status> queryDictSync(Long dbId, Long t
159155
}
160156

161157
OlapTable olapTable = (OlapTable) table;
162-
<<<<<<< HEAD
163-
long version = olapTable.getPartitions().stream().map(Partition::getVisibleVersionTime)
164-
.max(Long::compareTo).orElse(0L);
165-
=======
166158
long version = table.getPartitions().stream().flatMap(p -> p.getSubPartitions().stream()).map(
167159
PhysicalPartition::getVisibleVersionTime).max(Long::compareTo).orElse(0L);
168-
String columnName = MetaUtils.getColumnNameByColumnId(dbId, tableId, columnId);
169-
>>>>>>> e533a34694 ([BugFix] fix dict version of random distribution table (#61933))
170160
String catalogName = InternalCatalog.DEFAULT_INTERNAL_CATALOG_NAME;
171161
String sql = "select cast(" + StatsConstants.STATISTIC_DICT_VERSION + " as Int), " +
172162
"cast(" + version + " as bigint), " +

0 commit comments

Comments
 (0)