这种需求可以吧execution.runtime-mode设置成AUTOMATIC, 这种模式就是你的需求，如果所有的Source都是有界的，则使用Batch执行模式，否则使用Streaming
Best regards, Weijie junjie.m...@goupwith.com <junjie.m...@goupwith.com> 于2022年10月28日周五 15:56写道： > hi, Weijie: > > 由于我没有发现如何判断管道是有界还是无界的方法，特别是对于Table&SQL需要手动指定execution.runtime-mode=BATCH或STREAMING。 > > 我想通过得到所有的source的有界/无界来判断整个管道是有界/无界的，如果所有scnSource都是有界的则管道必定是有界管道，否则管道就是无界管道。 > > > 发件人： weijie guo > 发送时间： 2022-10-28 15:44 > 收件人： user-zh > 主题： Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 > Hi, junjie: > > 我想先了解一下你的目的是什么，为什么需要在Table API中判断Source的Boundness，这些信息对你的场景的帮助是什么？ > > Best regards, > > Weijie > > > junjie.m...@goupwith.com <junjie.m...@goupwith.com> 于2022年10月28日周五 > 15:36写道： > > > public static DynamicTableSource FactoryUtil.createTableSource(@Nullable > > Catalog catalog,ObjectIdentifier objectIdentifier, ResolvedCatalogTable > > catalogTable, ReadableConfig configuration, ClassLoader classLoader, > > boolean isTemporary)可以得到但是需要传入的参数太多了，这些参数不知道如何获取 > > > > 发件人： junjie.m...@goupwith.com > > 发送时间： 2022-10-28 15:33 > > 收件人： user-zh > > 主题： Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 > > 问题是如何拿到ScanTableSource呢？目前我没发现哪里可以得到 > > > > > > 发件人： TonyChen > > 发送时间： 2022-10-28 15:21 > > 收件人： user-zh > > 主题： Re: 关于如何得到管道中哪些源是有界和无界的问题 > > 是不是可以看下这个 > > > > > https://github.com/apache/flink/blob/master/flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/ScanTableSource.java#L94 > > Best, > > TonyChen > > > 2022年10月28日 15:12，junjie.m...@goupwith.com 写道： > > > > > > 大家好： > > > 有个问题判断Table是有界还是无界，或者通过TableEnv如何能得到source table信息和其有界还是无界。 > > > > > >
