flink与flink-client的版本对应
目前flink版本从0.6~1.14.0对应的flink-client版本有 无版本号,2.10,2.11,2.12这四种版本
无版本号对应flink(0.9版本和之前的版本)(一般都不会用到)
2.10对应flink(0.9以上带有hadoop版本 如:flink1.0.1-hadoop1)
2.11对应flink(0.9~1.6.4非hadoop版本 如:flink1.6.4)
2.12对应flink(1.7.0~最新版本 如:flink1.13.3)
依赖添加方法:
<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-clients -->
<properties><!--声明变量,好处:版本控制 --><flink.version>1.13.3</flink.version><flink-client.version>2.12</flink-client.version></properties><dependencies><dependency><groupId>org.apache.flink</groupId><artifactId>flink-clients_${flink-client.version}</artifactId><version>${flink.version}</version><dependency>
<dependencies>
flink与flink-client的版本对应相关推荐
- 【Flink】 Flink与Kafka版本对应关系
1.概述 转载:Flink与Kafka版本对应关系 转载这个主要是上次做flink kafka版本升级,忘记记录了. 先上干货:以下为Flink和Kafka的版本对照表 Flink版本 Kafka版本 ...
- Flink即将在1.7版本发布全新的Kafka连接器
最近我们向Flink社区贡献了一个全新的Kafka连接器(https://github.com/apache/flink/pull/6703),关联JIRA issue FLINK-9697.它包含了 ...
- https://cwiki.apache.org/confluence/display/FLINK/FLIP-24+-+SQL+Client
https://cwiki.apache.org/confluence/display/FLINK/FLIP-24+-+SQL+Client 转载于:https://www.cnblogs.com/W ...
- 【Flink】FLink 1.12 版本的 Row 类型 中的 RowKind 是干嘛的
1.概述 在[Flink]Flink 从 1.9.1 版本 升级到 1.12.4 版本的 注意事项 以及 过程 升级的时候,偶然看到row类型多了一个属性. @PublicEvolving publi ...
- flink 1.10.1 java版本sql OverWindow示例(每事件出结果)
本文的基础环境可以参考flink 1.10.1 java版本wordcount演示 (nc + socket) overwindow的处理方式是每接收到一条数据,都进行一次计算输出. 以事件时间为参考 ...
- 【Flink】Flink 1.14 版本 新特性 Barrier 在流经算子做 checkpoint Barrier跳过 unaligned checkpoint
文章目录 1.概述 2. 目前状态 2.1 无限流 2.2 有限流 3.checkpoint本身问题 M.参考 1.概述 在博客 [Flink]FLink Barrier 在流经算子 做 checkp ...
- 【Flink】Flink Flink 1.14 新特性预览
1.概述 转载:Flink 1.14 新特性预览 简介: 一文了解 Flink 1.14 版本新特性及最新进展 本文由社区志愿者陈政羽整理,内容源自阿里巴巴技术专家宋辛童 (五藏) 在 8 月 7 日 ...
- 【flink】Flink常见Checkpoint超时问题排查思路
1.概述 转载:Flink常见Checkpoint超时问题排查思路 这里仅仅是自己学习. 在日常flink应用中,相信大家经常会遇到checkpoint超时失败这类的问题,遇到这种情况的时候仅仅只会在 ...
- kafka学习_《从0到1学习Flink》—— Flink 读取 Kafka 数据写入到 RabbitMQ
前言 之前有文章 <从0到1学习Flink>-- Flink 写入数据到 Kafka 写过 Flink 将处理后的数据后发到 Kafka 消息队列中去,当然我们常用的消息队列可不止这一种, ...
- flink 写入到es_《从0到1学习Flink》—— Flink 写入数据到 Kafka
前言 之前文章 <从0到1学习Flink>-- Flink 写入数据到 ElasticSearch 写了如何将 Kafka 中的数据存储到 ElasticSearch 中,里面其实就已经用 ...
最新文章
- 用python分析了30万条微博评论,毕业生与翟天临的爱恨情仇
- vue.js 每次循环五个数据_AutoML数据增广
- linux兼容性,Atom 1.23发布:功能增强,兼容性更好
- 819 c语言程序设计,2018年大连海洋大学计算机科学与技术819高级语言程序设计(C语言)之C程序设计考研核心题库...
- linux RPM-GPG-KEY 包签名机制 简介
- java request 原理_JavaWeb-seession原理
- Python中的and和or
- android 摄像头参数,获取Android设备上的详细的摄像头信息
- JSON-JSON 百科
- linux下载gcc yarm,修改Yarn的全局安装和缓存位置
- Flash游戏开发常用函数代
- java为什么要设计包装类_Java 为什么需要包装类
- Java 任务调度,分布式定时任务XXL-JOB,elastic-job
- 如何设计一个好玩的游戏——游戏设计的艺术
- eeglab和matlab,EEGLAB for Matlab(一)--初识EEGLAB
- STM32:红外遥控接收模块
- 小米路由器显示无法连接服务器错误代码,小米路由器:路由器无法上网怎么办...
- myeclipse8.5汉化
- IOS Crash信息收集
- a += 1、a = a + 1、a++区别
热门文章
- qss样式表笔记大全(一):qss名词解析(包含相关示例)
- sscanf函数用法详解
- 【网络编程】之九、事件选择WSAEventSelect
- 非常精确的测试运行时间(比clock()更精确些)
- PHP、Node、Ruby和Python应用,漏洞修复
- 白话科普系列——双十一,竟然是一场有“预谋”的DDoS攻击?
- Flink 容错机制:Checkpoints、Savepoints
- Kafka分区分配策略(2)——RoundRobinAssignor和StickyAssignor
- 用Android Studio开发Java App (Runnable Jar)
- 搞定系统设计 03:系统设计面试的答题框架