flink1.17.2,使用sqlclient就可以使用,这是bug还是说是功能限制?[阿里云]
flink1.17.2,在代码中使用下面的方式注册函数时不能使用using jar,必须把jar放到任务依赖里面,一旦使用using jar语法,那么会报下面...
有没有flink写hbase的,怎么把实时数据写入hbase?[阿里云]
有没有flink写hbase的大佬,可以请教一下scala版本的flink怎么把实时数据写入hbase?
就是scala版本的flink怎么实时存入hbase,用hbase sink 怎么存?[阿里云实时计算 Flink版]
就是scala版本的flink怎么实时存入hbase,用hbase sink 怎么存?
有没有人是用scala写flink的?想问一下,怎么自定义hbase sink?[阿里云实时计算 Flink版]
有没有人是用scala写flink的?想问一下,怎么自定义hbase sink?
大数据计算MaxCompute这个对scala 和java 的版本有强要求吗?[阿里云MaxCompute]
问题1:大数据计算MaxCompute环境变量是spark 和java 的吧,这个对scala 和java 的版本有强要求吗?我这边试了还是报错,找不到datasour...
大数据计算MaxCompute能用spark3 不?[阿里云MaxCompute]
大数据计算MaxCompute能用spark3 不?本地scala 环境是2.12这里是不是缺失呀?
scala中关闭任务结束后的 Checkpoint,Flink设置的时候报异常,怎么解决?[阿里云实时计算 Flink版]
scala中关闭任务结束后的 Checkpoint,Flink设置的时候报异常,怎么解决?
flink 1.12使用state process api,keyBy 一个scala元组,在sna[阿里云实时计算 Flink版]
flink 1.12使用state process api,keyBy 一个scala元组,在snapshot时key的序列化器为ScalaCaseClassSerializer,读的时候就用kryo作为...
这一段官网例子,但是用scala 写报错,是不是scala问题呢,scala是2.11的,flink[阿里云实时计算 Flink版]
这一段官网例子,但是用scala 写报错,是不是scala问题呢,scala是2.11的,flink是1.13.5,cdc是2.20,有没有大神看看