Skip to content

Commit 5d85539

Browse files
committed
fix
1 parent fa8db4f commit 5d85539

File tree

2 files changed

+4
-17
lines changed

2 files changed

+4
-17
lines changed

paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,6 @@
5555
import org.apache.paimon.rest.responses.AlterDatabaseResponse;
5656
import org.apache.paimon.rest.responses.CommitTableResponse;
5757
import org.apache.paimon.rest.responses.ConfigResponse;
58-
import org.apache.paimon.rest.responses.CreateDatabaseResponse;
5958
import org.apache.paimon.rest.responses.ErrorResponseResourceType;
6059
import org.apache.paimon.rest.responses.GetDatabaseResponse;
6160
import org.apache.paimon.rest.responses.GetTableResponse;
@@ -207,11 +206,7 @@ public void createDatabase(String name, boolean ignoreIfExists, Map<String, Stri
207206
checkNotSystemDatabase(name);
208207
CreateDatabaseRequest request = new CreateDatabaseRequest(name, properties);
209208
try {
210-
client.post(
211-
resourcePaths.databases(),
212-
request,
213-
CreateDatabaseResponse.class,
214-
restAuthFunction);
209+
client.post(resourcePaths.databases(), request, restAuthFunction);
215210
} catch (AlreadyExistsException e) {
216211
if (!ignoreIfExists) {
217212
throw new DatabaseAlreadyExistException(name);

paimon-open-api/src/main/java/org/apache/paimon/open/api/RESTCatalogController.java

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@
3232
import org.apache.paimon.rest.responses.AlterDatabaseResponse;
3333
import org.apache.paimon.rest.responses.CommitTableResponse;
3434
import org.apache.paimon.rest.responses.ConfigResponse;
35-
import org.apache.paimon.rest.responses.CreateDatabaseResponse;
3635
import org.apache.paimon.rest.responses.ErrorResponse;
3736
import org.apache.paimon.rest.responses.GetDatabaseResponse;
3837
import org.apache.paimon.rest.responses.GetTableResponse;
@@ -125,11 +124,7 @@ public ListDatabasesResponse listDatabases(
125124
summary = "Create Databases",
126125
tags = {"database"})
127126
@ApiResponses({
128-
@ApiResponse(
129-
responseCode = "200",
130-
content = {
131-
@Content(schema = @Schema(implementation = CreateDatabaseResponse.class))
132-
}),
127+
@ApiResponse(responseCode = "200", description = "Success, no content"),
133128
@ApiResponse(
134129
responseCode = "409",
135130
description = "Resource has exist",
@@ -139,11 +134,8 @@ public ListDatabasesResponse listDatabases(
139134
content = {@Content(schema = @Schema())})
140135
})
141136
@PostMapping("/v1/{prefix}/databases")
142-
public CreateDatabaseResponse createDatabases(
143-
@PathVariable String prefix, @RequestBody CreateDatabaseRequest request) {
144-
Map<String, String> properties = new HashMap<>();
145-
return new CreateDatabaseResponse("name", properties);
146-
}
137+
public void createDatabases(
138+
@PathVariable String prefix, @RequestBody CreateDatabaseRequest request) {}
147139

148140
@Operation(
149141
summary = "Get Database",

0 commit comments

Comments
 (0)