Skip to content

Commit 611b45c

Browse files
authored
[FLINK-34259] Creating ExecutionConfig instead of mocking it in tests
1 parent 5a90eb0 commit 611b45c

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcTestBase.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -59,9 +59,13 @@ public static RuntimeContext getRuntimeContext(JobID jobId) {
5959
return context;
6060
}
6161

62-
public static ExecutionConfig getExecutionConfig(Boolean reused) {
63-
ExecutionConfig config = Mockito.mock(ExecutionConfig.class);
64-
doReturn(reused).when(config).isObjectReuseEnabled();
62+
public static ExecutionConfig getExecutionConfig(boolean reused) {
63+
ExecutionConfig config = new ExecutionConfig();
64+
if (reused) {
65+
config.enableObjectReuse();
66+
} else {
67+
config.disableObjectReuse();
68+
}
6569
return config;
6670
}
6771

0 commit comments

Comments
 (0)