首页 > TAG信息列表 > flink1.13

flink-doris-connector flink1.13.1

 doris 官文: https://doris.apache.org/ecosystem/flink-doris-connector.html#how-to-use  　依赖 <!--flink-doris-connector--> <dependency> <groupId>org.apache.doris</groupId> <!--<artifactId>f

CDH6.3.x集成flink1.13

目前能下载到flink1.13的parcel包的资源确实少，有些也需要收费的，我这里采用自己编译的方法。 1、准备环境 jdk1.8 maven3.8.1 parcel制作工具   2、制作parcel 下载制作工具   git clone https://github.com/pkeropen/flink-parcel.git         修改配置文件   cd ./fli

flink1.13安装配置，flink on yarn

flink1.13安装配置 1 下载解压2 配置hadoop_classpath3 添加依赖 common-cli、hadoop…4 启动、测试 flink on yarn三种部署模式启动命令 per job # flink旧版本 ./bin/flink run -m yarn-cluster -yjm 1024 -ytm 1024 -yqu root.up ./examples/streaming/TopSpeedWindowing.

flink1.13读kafka写入hive

第一次写博客，flink自学了一下，网上查找案例，群里问大神，勉强把kafka写hive的流程走通了，在此记录一下，给后来者做个参考 ，其中有考虑不周或者错误的地方，请大家多多包涵和指正，嘻嘻。 代码 package cn.bywin import org.apache.flink.streaming.api.{CheckpointingMode, TimeCharact

flink1.13启动失败

缺少hadoop相关依赖，有的博主会下载一份2.6版本hadoop或者老版本flink，将依赖导入flink 后发现提供一个包放入$FLINK_HOME/lib下即可 flink-shaded-hadoop-2-uber-2.7.5-7.0 https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.7.5-7.0/fli