Re:Re: ​请问是否有计划合并blink gemini到flink的计划

2022-07-13 Thread mack143
退订 在 2022-07-13 19:14:02,"Yuan Mei" 写道: >目前Gemini只用在 ververica platform 中作为 aliyun 商业化版本的 default statebackend >使用,短期还是会以提升 Gemini 更方面性能为主,后续会逐步将主要部分开源的。 > >Best >Yuan > >On Wed, Jul 13, 2022 at 6:10 PM Hangxiang Yu wrote: > >> >>

退订

2022-03-05 Thread mack143
退订

Re:flink1.14.0 temporal join hive

2022-03-05 Thread mack143
退订 在 2022-03-05 09:46:46,"guanyq" 写道: >kafka实时流关联hive的最新分区表数据时,关于缓存刷新的问题 > > >'streaming-source.monitor-interval'='12 h' >这个参数我理解是:按照启动开始时间算起,每12小时读取一下最新分区的数据是吧? >还有个问题是读取最新分区的时间间隔之间,实时流里面进入了预关联新分区的数据,那么是不是就相当于关联的还是上一次的最新分区数据吧? > >

Re:答复: 回复:如何从复杂的kafka消息体定义 table

2022-02-28 Thread mack143
退订 在 2021-07-09 10:06:19,"Chenzhiyuan(HR)" 写道: >消息体里的data是实际每行数据,columnName是字段名,rawData是值,因此我想能定义table 如下: > >CREATE TABLE MyUserTable( >APPLY_PERSON_ID VARCHAR, >UPDATE_SALARY DECIMAL, >UP_AMOUNT DECIMAL, >CURRENCY VARCHAR, >EXCHANGE_RATE DECIMAL >) with ( >'connector.type' = 'kafka',

退订

2022-02-28 Thread mack143
退订