Skip to content

Commit

Permalink
fix conflict (#54455)
Browse files Browse the repository at this point in the history
Signed-off-by: xiangguangyxg <[email protected]>
  • Loading branch information
xiangguangyxg authored Dec 27, 2024
1 parent 366efb3 commit 0b1bb66
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 20 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -84,11 +84,7 @@ public enum RecoverySource {
private boolean createSchemaFile = true;
private boolean enableTabletCreationOptimization = false;
private final TTabletSchema tabletSchema;
<<<<<<< HEAD
=======
private long gtid = 0;
private long timeoutMs = -1;
>>>>>>> f977337f8 ([Feature] Support restoring from a cluster snapshot for shared-data mode (part 3, introduce gtid for tablet metadata) (#54326))

private CreateReplicaTask(Builder builder) {
super(null, builder.getNodeId(), TTaskType.CREATE, builder.getDbId(), builder.getTableId(),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -124,14 +124,7 @@ public static void buildPartitionsConcurrently(long dbId, OlapTable table, List<
int numIndexes = partitions.stream().mapToInt(
partition -> partition.getMaterializedIndices(MaterializedIndex.IndexExtState.VISIBLE).size()).sum();
int maxTimeout = numIndexes * Config.max_create_table_timeout_second;
<<<<<<< HEAD
boolean enableTabletCreationOptimization = table.isCloudNativeTableOrMaterializedView()
&& Config.lake_enable_tablet_creation_optimization;
if (enableTabletCreationOptimization) {
=======
long maxWaitTimeSeconds = Math.min(timeout, maxTimeout);
if (option.isEnableTabletCreationOptimization()) {
>>>>>>> f977337f8 ([Feature] Support restoring from a cluster snapshot for shared-data mode (part 3, introduce gtid for tablet metadata) (#54326))
numReplicas = numIndexes;
}
MarkedCountDownLatch<Long, Long> countDownLatch = new MarkedCountDownLatch<>(numReplicas);
Expand Down
4 changes: 0 additions & 4 deletions gensrc/proto/lake_types.proto
Original file line number Diff line number Diff line change
Expand Up @@ -234,10 +234,6 @@ message TxnInfoPB {
optional bool combined_txn_log = 3;
optional TxnTypePB txn_type = 4;
optional bool force_publish = 5; // only used for compaction
<<<<<<< HEAD
=======
optional bool rebuild_pindex = 6;
optional int64 gtid = 7 [default=0];
>>>>>>> f977337f8 ([Feature] Support restoring from a cluster snapshot for shared-data mode (part 3, introduce gtid for tablet metadata) (#54326))
};

5 changes: 0 additions & 5 deletions gensrc/thrift/AgentService.thrift
Original file line number Diff line number Diff line change
Expand Up @@ -118,13 +118,8 @@ struct TCreateTabletReq {
21: optional i32 compression_level = -1;
// Whether or not use shared tablet initial metadata.
22: optional bool enable_tablet_creation_optimization = false;
<<<<<<< HEAD
=======
// The timeout FE will wait for the tablet to be created.
23: optional i64 timeout_ms = -1;
// Global transaction id
24: optional i64 gtid = 0;
>>>>>>> f977337f8 ([Feature] Support restoring from a cluster snapshot for shared-data mode (part 3, introduce gtid for tablet metadata) (#54326))
}

struct TDropTabletReq {
Expand Down

0 comments on commit 0b1bb66

Please sign in to comment.