Re:Re: flink1.16 sql gateway hive2

2023-03-26 文章 guanyq
感谢两位老师 在 2023-03-27 09:58:24,"Shengkai Fang" 写道: >方勇老师说的没错。我们在文档里面也加了如何配置 hiveserver2 endpoint 的文档[1] > >[1] >https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/hive-compatibility/hiveserver2/#setting-up > >Shammon FY 于2023年3月27日周一 08:41写道: > >> Hi >> >> >> 如果要启动hiveserve

Re: flink1.16 sql gateway hive2

2023-03-26 文章 Shengkai Fang
方勇老师说的没错。我们在文档里面也加了如何配置 hiveserver2 endpoint 的文档[1] [1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/hive-compatibility/hiveserver2/#setting-up Shammon FY 于2023年3月27日周一 08:41写道: > Hi > > > 如果要启动hiveserver2协议的gateway,需要将jar包flink-connector-hive_${scala.binary.version}放入到ga

Re: flink1.16 sql gateway hive2

2023-03-26 文章 Shammon FY
Hi 如果要启动hiveserver2协议的gateway,需要将jar包flink-connector-hive_${scala.binary.version}放入到gateway的lib目录 Best, Shammon FY On Sun, Mar 26, 2023 at 12:07 PM guanyq wrote: > 本地启动了flink及hive在启动sql gateway时有以下异常,请问还需要其他什么操作么 > ./bin/sql-gateway.sh start-foreground > -Dsql-gateway.endpoint.type=hiveserver

Re: flink watermark 乱序数据问题

2023-03-26 文章 Shammon FY
Hi 使用withTimestampAssigner只是定义了生成watermark消息的策略,不会影响数据流。超出指定时间的数据是否处理,可以在定义window的时候使用allowedLateness定义最晚的late event,超出这个时间的窗口数据会直接丢弃 Best, Shammon FY On Sat, Mar 25, 2023 at 12:28 AM crazy <2463829...@qq.com.invalid> wrote: > 大佬好,如下程序,flink在生成watermark策略中,forBoundedOutOfOrderness > 这个乱序时长的指定会不