Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
@herefree
herefree committed Jun 27, 2024
1 parent 5cc108a commit cfd26a1
Showing 1 changed file with 98 additions and 98 deletions.
196 changes: 98 additions & 98 deletions .../paimon-flink-common/src/test/java/org/apache/paimon/flink/action/BranchActionITCase.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -89,32 +89,32 @@ void testCreateAndDeleteBranch() throws Exception {
assertThat(branchManager.branchExists("branch_name")).isFalse();

createAction(
CreateBranchAction.class,
"create_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"branch_name",
"--tag_name",
"tag2")
CreateBranchAction.class,
"create_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"branch_name",
"--tag_name",
"tag2")
.run();
assertThat(branchManager.branchExists("branch_name")).isTrue();

createAction(
DeleteBranchAction.class,
"delete_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"branch_name")
DeleteBranchAction.class,
"delete_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"branch_name")
.run();
assertThat(branchManager.branchExists("branch_name")).isFalse();
}
Expand Down Expand Up @@ -160,32 +160,32 @@ void testCreateAndDeleteBranchWithSnapshotId() throws Exception {
assertThat(branchManager.branchExists("branch_name_with_snapshotId")).isFalse();

createAction(
CreateBranchAction.class,
"create_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"branch_name_with_snapshotId",
"--snapshot",
"2")
CreateBranchAction.class,
"create_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"branch_name_with_snapshotId",
"--snapshot",
"2")
.run();
assertThat(branchManager.branchExists("branch_name_with_snapshotId")).isTrue();

createAction(
DeleteBranchAction.class,
"delete_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"branch_name_with_snapshotId")
DeleteBranchAction.class,
"delete_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"branch_name_with_snapshotId")
.run();
assertThat(branchManager.branchExists("branch_name_with_snapshotId")).isFalse();
}
Expand Down Expand Up @@ -230,30 +230,30 @@ void testCreateAndDeleteEmptyBranch() throws Exception {
assertThat(branchManager.branchExists("empty_branch_name")).isFalse();

createAction(
CreateBranchAction.class,
"create_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"empty_branch_name")
CreateBranchAction.class,
"create_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"empty_branch_name")
.run();
assertThat(branchManager.branchExists("empty_branch_name")).isTrue();

createAction(
DeleteBranchAction.class,
"delete_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"empty_branch_name")
DeleteBranchAction.class,
"delete_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"empty_branch_name")
.run();
assertThat(branchManager.branchExists("empty_branch_name")).isFalse();
}
Expand Down Expand Up @@ -301,18 +301,18 @@ void testMergeBranch() throws Exception {
assertThat(branchManager.branchExists("merge_branch_name")).isTrue();
// Create merge_branch_name_action branch
createAction(
CreateBranchAction.class,
"create_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"merge_branch_name_action",
"--tag_name",
"tag3")
CreateBranchAction.class,
"create_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"merge_branch_name_action",
"--tag_name",
"tag3")
.run();
assertThat(branchManager.branchExists("merge_branch_name_action")).isTrue();

Expand All @@ -326,18 +326,18 @@ void testMergeBranch() throws Exception {
SnapshotManager snapshotManager = table.snapshotManager();
assertThat(snapshotManager.snapshotExists(3)).isFalse();

//Merge branch merge_branch_name_action
// Merge branch merge_branch_name_action
createAction(
MergeBranchAction.class,
"merge_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"merge_branch_name_action")
MergeBranchAction.class,
"merge_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"merge_branch_name_action")
.run();

// Check snapshot
Expand Down Expand Up @@ -384,18 +384,18 @@ void testMergeBranch() throws Exception {
expected = Arrays.asList("+I[1, Hi]", "+I[2, Hello]");
Assert.assertEquals(expected, sortedActual);

//Merge branch merge_branch_name_action again
// Merge branch merge_branch_name_action again
createAction(
MergeBranchAction.class,
"merge_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"merge_branch_name_action")
MergeBranchAction.class,
"merge_branch",
"--warehouse",
warehouse,
"--database",
database,
"--table",
tableName,
"--branch_name",
"merge_branch_name_action")
.run();

// Check main branch data
Expand Down

0 comments on commit cfd26a1

Please sign in to comment.