Skip to content

Commit

Permalink
fix conflicting ITCase
Browse files Browse the repository at this point in the history
Signed-off-by: zhongle.wang <[email protected]>
  • Loading branch information
thekingofcity committed May 14, 2021
1 parent 5566d0f commit 1734661
Showing 1 changed file with 6 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,8 @@
import org.apache.flink.table.data.RowData;
import org.apache.flink.table.data.StringData;
import org.apache.flink.util.TestLogger;
import org.junit.After;
import org.junit.Before;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.Timeout;
Expand All @@ -57,13 +57,13 @@ public class FlinkPravegaDynamicTableITCase extends TestLogger {
@Rule
public final Timeout globalTimeout = new Timeout(120, TimeUnit.SECONDS);

@Before
public void setupPravega() throws Exception {
@BeforeClass
public static void setupPravega() throws Exception {
SETUP_UTILS.startAllServices();
}

@After
public void tearDownPravega() throws Exception {
@AfterClass
public static void tearDownPravega() throws Exception {
SETUP_UTILS.stopAllServices();
}

Expand Down Expand Up @@ -105,7 +105,6 @@ public void testPravegaSourceSink() throws Exception {
" 'security.validate-hostname' = '%s',%n" +
" 'security.trust-store' = '%s',%n" +
" 'scan.execution.type' = '%s',%n" +
" 'scan.reader-group.name' = '%s',%n" +
" 'scan.streams' = '%s',%n" +
" 'sink.stream' = '%s',%n" +
" 'sink.routing-key.field.name' = 'currency',%n" +
Expand All @@ -118,7 +117,6 @@ public void testPravegaSourceSink() throws Exception {
SETUP_UTILS.isEnableHostNameValidation(),
SETUP_UTILS.getPravegaClientTrustStore(),
"streaming",
"group",
stream,
stream);

Expand Down Expand Up @@ -214,7 +212,6 @@ public void testPravegaSourceSinkWithMetadata() throws Exception {
" 'security.validate-hostname' = '%s',%n" +
" 'security.trust-store' = '%s',%n" +
" 'scan.execution.type' = '%s',%n" +
" 'scan.reader-group.name' = '%s',%n" +
" 'scan.streams' = '%s',%n" +
" 'sink.stream' = '%s',%n" +
" 'format' = 'json'%n" +
Expand All @@ -226,7 +223,6 @@ public void testPravegaSourceSinkWithMetadata() throws Exception {
SETUP_UTILS.isEnableHostNameValidation(),
SETUP_UTILS.getPravegaClientTrustStore(),
"streaming",
"group",
stream,
stream);

Expand Down

0 comments on commit 1734661

Please sign in to comment.