请问,flink Java里面多次执行executeSql会报错Cannot have more than one execute() or executeAsync() call in a single environment 怎么才能执行ddl创建表呢?
可能是因为你在多次执行executeSql命令时,没有在每次执行之前关闭与数据源的连接,导致了连接被占用。可以在每次执行之前,使用以下代码关闭数据源连接:
java Copy code // 关闭数据源连接 DataSource dataSource = env.getDataSource(tableName); dataSource.close(); 其中,tableName为要操作的表名。 如果你使用的是Datawork Cloud Platform,可以在数据库管理工具中进行数据表操作,并在操作日志中查看执行executeSql命令的详细信息。具体操作方法可以参考Datawork Cloud Platform的文档。 如果你使用的是Datawork Local,可以在应用程序中手动关闭数据源连接,可以参考以下代码示例:
java Copy code // 关闭数据源连接 DataSource dataSource = env.getDataSource(tableName); dataSource.close(); 其中,tableName为要操作的表名。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。