升个小版本，1.14.3就有AUTOMATIC
Best, TonyChen > 2022年10月28日 17:09，junjie.m...@goupwith.com 写道： > > hi,weijie: > 我使用的是flink1.14里是不支持设置execution.runtime-mode=AUTOMATIC的，会报如下错误： > org.apache.flink.table.api.TableException: Unsupported mode 'AUTOMATIC' for > 'execution.runtime-mode'. Only an explicit BATCH or STREAMING mode is > supported in Table API. > > 是后续版本已经支持execution.runtime-mode=AUTOMATIC了吗？ > > > 发件人： weijie guo > 发送时间： 2022-10-28 16:38 > 收件人： user-zh > 主题： Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 > 这种需求可以吧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信息和其有界还是无界。 >>>> >>> >>
