问答 2022-07-25 来自:开发者社区

这一段官网例子,但是用scala 写报错,是不是scala问题呢,scala是2.11的,flink

这一段官网例子,但是用scala 写报错,是不是scala问题呢,scala是2.11的,flink是1.13.5,cdc是2.20,有没有大神看看

问答 2021-12-08 来自:开发者社区

Apache Flink中的flink-table-api-scala-bridge是什么?

Apache Flink中的flink-table-api-scala-bridge是什么?

问答 2021-12-08 来自:开发者社区

flink 1.13.2 在 Java/Scala 程序中调用 Python UDF函数,通过yar

HI!     我现在使用flink 1.13.2,通过java table api开发应用,其中要使用python udf函数,最终通过yarn-application方式提交;那我需要在yarn集群的机器上都安装pyflink?还是有其他方案?*来自志愿者整理的flink邮件归档

问答 2021-12-07 来自:开发者社区

flink源码编译可以不编译scala代码吗

Hi,All: 我再尝试编译flink 1.7的源码时,遇到如下错误,本人对scala不是很了解,不知道是不是版本问题引起,另外可以去掉sacla模块编译吗: 本机scala版本:2.13.0 JDK 版本: 1.8.0_91 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.1:com....

问答 2021-12-05 来自:开发者社区

flink sql提交读取hive的批作业出现 异常“scala MatchError : MAP”

作业SQL是这样的: create view 111 as select * from table1 where event_id = '0103002' and day='2020-05-13' and hour='13'; create view view_1 as select day, a.rtime as itime, a.uid as uid, trim(BOTH a.event......

问答 2021-12-03 来自:开发者社区

flink sql 使用自定义函数 返回嵌套行,查询报错 scala.MatchError,为什么?

目前无法通过t.* 将嵌套的字段查询出来。 val schema = tEnv.executeSql( """ | SELECT t.* FROM ( | SELECT EvtParser(request) as t FROM parsed_nginx_log | ) |""".stripMargin).getTableSchema 其中自定义函数 EvtParser 定义如下。 @Data...

文章 2021-08-14 来自:开发者社区

Flink 项目Scala模板入门

     当前的很多构建工具,可以提供项目模板来让开发人员快速初始化项目文件,这对于降低学习难度,提高项目开发效率来说,起到积极的作用。Flink项目的初始化,可以借助Maven工具来构建。在之前JDK和Maven环境搭建完成,并正确设置环境变量后,即可以用mvn archetype:generate快速生成项目文件。当前支持Scala和Java两种项目模板。下面分....

Flink 项目Scala模板入门
问答 2020-08-06 来自:开发者社区

flink建议用scala还是java开发?#Flink

flink建议用scala还是java开发?#Flink

问答 2020-06-29 来自:开发者社区

请帮忙指导一下,python开发,如果想学习flink,需要具备scala还是java开#Flink

请帮忙指导一下,python开发,如果想学习flink,需要具备scala还是java开发能力?#Flink

问答 2020-06-10 来自:开发者社区

Flink SQL的Planner使用Scala写的。为啥用Scala,在这个地方实现使#Flink

Flink SQL的Planner使用Scala写的。为啥用Scala,在这个地方实现使用Scala是有什么优势吗? #Flink

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注