File tree Expand file tree Collapse file tree
externals/kyuubi-jdbc-engine/src
main/scala/org/apache/kyuubi/engine/jdbc/dialect
test/scala/org/apache/kyuubi/engine/jdbc/starrocks Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -85,11 +85,12 @@ abstract class JdbcDialect extends SupportServiceLoader with Logging {
8585 def cancelStatement (jdbcStatement : Statement ): Unit = {
8686 if (jdbcStatement != null ) {
8787 jdbcStatement.cancel()
88+ jdbcStatement.close()
8889 }
8990 }
9091
9192 def closeStatement (jdbcStatement : Statement ): Unit = {
92- if (jdbcStatement != null && ! jdbcStatement.isClosed ) {
93+ if (jdbcStatement != null ) {
9394 jdbcStatement.close()
9495 }
9596 }
Original file line number Diff line number Diff line change @@ -26,7 +26,7 @@ import org.apache.kyuubi.engine.jdbc.WithJdbcServerContainer
2626
2727trait WithStarRocksContainer extends WithJdbcServerContainer {
2828
29- private val starrocksDockerImage = " starrocks/allin1-ubuntu:3.1.6 "
29+ private val starrocksDockerImage = " starrocks/allin1-ubuntu:3.3.13 "
3030
3131 private val STARROCKS_FE_MYSQL_PORT = 9030
3232 private val STARROCKS_FE_HTTP_PORT = 8030
@@ -47,7 +47,7 @@ trait WithStarRocksContainer extends WithJdbcServerContainer {
4747 .withStrategy(Wait .forListeningPorts(ports : _* ))
4848 .withStrategy(forLogMessage(" .*broker service already added into FE service.*" , 1 ))
4949 .withStrategy(
50- forLogMessage(" .*Enjoy the journal to StarRocks blazing-fast lake-house engine.*" , 1 )))
50+ forLogMessage(" .*Enjoy the journey to StarRocks blazing-fast lake-house engine.*" , 1 )))
5151
5252 protected def feJdbcUrl : String = withContainers { container =>
5353 val queryServerHost : String = container.host
You can’t perform that action at this time.
0 commit comments