flinkcdc 2.3.0jar包冲突
时间: 2023-10-01 19:05:24 浏览: 95
根据引用内容,flink-cdc-connectors 2.3.0版本引用了flink 1.16.0,这个版本的flink使用了flink-shaded-guava:30.1.1-jre-15.0版本。而flink 1.13.0使用的是flink-shaded-guava:18.0-13.0版本。因此,由于两个版本的shaded package不一样,可能会引起flinkcdc 2.3.0 jar包冲突。为了解决这个问题,可以在cdc中再次shaded一下,让cdc里面引用到的guava30变为guava18。具体操作方法是,基于tag release-2.3.0创建一个分支,修改flink-cdc-connectors的pom.xml文件,引入cdc后排除guava依赖。最后,通过编译基于已经release的tag来解决冲突。
相关问题
flinkcdc2.3.0版本sqlserver
Flink CDC(Change Data Capture)是 Flink 的一项重要功能,用于捕获和处理数据源中的变化(新增、更新、删除等)。而 SQL Server 是微软公司推出的一款关系型数据库管理系统。
Flink CDC 2.3.0 版本支持 SQL Server 数据库,可以实时地捕获 SQL Server 数据库中的变化,并将变化数据流传输到 Flink 中进行实时计算和分析。在 Flink 中,我们可以使用 SQL 或者 Table API 来定义数据转换、过滤以及聚合等操作,方便进行实时数据处理和计算。
通过 Flink CDC,我们可以轻松将 SQL Server 中的数据变化同步到 Flink 中,以实时地处理和分析数据。无论是从 SQL Server 数据库中获取数据变化,还是将变化数据流传输到下游的数据处理流程中,都可以实现高效、准确的数据同步和实时计算。
在使用 Flink CDC 2.3.0 版本与 SQL Server 进行集成时,需要配置相应的连接信息和表名,确保能够成功连接到 SQL Server 数据库,并正确地捕获数据变化。通过配置 Flink 的 SQL 作业或 Table API,我们可以实现对 SQL Server 数据库的实时计算和分析。
总之,Flink CDC 2.3.0 版本支持 SQL Server 数据库,可以帮助我们实时捕获和处理 SQL Server 数据库中的数据变化,为我们的实时计算和分析提供可靠的数据源。
阅读全文