This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 164d05e3d9b Revert "[debug](auto-partition) debug auto&dynamic
partition creation" (#48005)
164d05e3d9b is described below
commit 164d05e3d9bec2c5ff5ac5007b91c57641808e60
Author: zclllyybb <[email protected]>
AuthorDate: Fri Feb 21 12:08:17 2025 +0800
Revert "[debug](auto-partition) debug auto&dynamic partition creation"
(#48005)
Reverts apache/doris#40245 since it's not useful
---
.../java/org/apache/doris/service/FrontendServiceImpl.java | 12 +-----------
1 file changed, 1 insertion(+), 11 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
index 032330938f7..4af31ec8311 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
@@ -3477,7 +3477,7 @@ public class FrontendServiceImpl implements
FrontendService.Iface {
return result;
}
- OlapTable table = (OlapTable) (db.getTable(tableId).get());
+ Table table = db.getTable(tableId).get();
if (table == null) {
errorStatus.setErrorMsgs(
(Lists.newArrayList(String.format("dbId=%d tableId=%d is
not exists", dbId, tableId))));
@@ -3559,16 +3559,6 @@ public class FrontendServiceImpl implements
FrontendService.Iface {
List<TTabletLocation> tablets = Lists.newArrayList();
for (String partitionName : addPartitionClauseMap.keySet()) {
Partition partition = table.getPartition(partitionName);
- if (partition == null) {
- String partInfos = table.getAllPartitions().stream()
- .map(partitionArg -> partitionArg.getName() +
partitionArg.getId())
- .collect(Collectors.joining(", "));
-
- errorStatus.setErrorMsgs(Lists.newArrayList("get partition " +
partitionName + " failed"));
- result.setStatus(errorStatus);
- LOG.warn("send create partition error status: {}, {}", result,
partInfos);
- return result;
- }
TOlapTablePartition tPartition = new TOlapTablePartition();
tPartition.setId(partition.getId());
int partColNum = partitionInfo.getPartitionColumns().size();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
