AI 助理
备案控制台
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC 使用jar包启动异常

IDEA可以正常运行，使用jar包启动后，就报下面的错误

2024-02-28 16:38:09.568  WARN 59419 --- [lt-dispatcher-4] .a.f.r.s.t.DefaultDelegationTokenManager : No tokens obtained so skipping notifications
2024-02-28 16:38:09.568  WARN 59419 --- [lt-dispatcher-4] .a.f.r.s.t.DefaultDelegationTokenManager : Tokens update task not started because either no tokens obtained or none of the tokens specified its renewal date
2024-02-28 16:38:09.569  INFO 59419 --- [ter-io-thread-4] o.a.f.r.h.n.e.EmbeddedLeaderService      : Received confirmation of leadership for leader pekko://flink/user/rpc/resourcemanager_1 , session=5f111541-15bc-4d44-aab7-f393c1ffdcaf
2024-02-28 16:38:09.571  INFO 59419 --- [lt-dispatcher-4] o.a.f.runtime.taskexecutor.TaskExecutor  : Connecting to ResourceManager pekko://flink/user/rpc/resourcemanager_1(aab7f393c1ffdcaf5f11154115bc4d44).
2024-02-28 16:38:09.571  INFO 59419 --- [ter-io-thread-1] o.a.f.r.h.n.e.EmbeddedLeaderService      : Received confirmation of leadership for leader pekko://flink/user/rpc/dispatcher_2 , session=b7c356f2-b9ce-4254-90a1-0d13518c6883
2024-02-28 16:38:09.601  INFO 59419 --- [lt-dispatcher-8] o.a.f.runtime.taskexecutor.TaskExecutor  : Resolved ResourceManager address, beginning registration
2024-02-28 16:38:09.608  INFO 59419 --- [lt-dispatcher-6] o.a.f.r.r.StandaloneResourceManager      : Registering TaskManager with ResourceID 9acc0233-57a4-4d8b-8c97-0e17008e0dca (pekko://flink/user/rpc/taskmanager_0) at ResourceManager
2024-02-28 16:38:09.610  INFO 59419 --- [lt-dispatcher-7] o.a.f.r.dispatcher.StandaloneDispatcher  : Received JobGraph submission 'evp job' (bbc2959a1228d4782ade6888026503f1).
2024-02-28 16:38:09.610  INFO 59419 --- [lt-dispatcher-6] o.a.f.runtime.taskexecutor.TaskExecutor  : Successful registration at resource manager pekko://flink/user/rpc/resourcemanager_1 under registration id 2e75d4e948fb7413bdd8ddaa65535673.
2024-02-28 16:38:09.611  INFO 59419 --- [lt-dispatcher-7] o.a.f.r.dispatcher.StandaloneDispatcher  : Submitting job 'evp job' (bbc2959a1228d4782ade6888026503f1).
2024-02-28 16:38:09.612  INFO 59419 --- [lt-dispatcher-4] o.a.f.r.r.s.FineGrainedSlotManager       : Registering task executor 9acc0233-57a4-4d8b-8c97-0e17008e0dca under 2e75d4e948fb7413bdd8ddaa65535673 at the slot manager.
2024-02-28 16:38:09.627  INFO 59419 --- [lt-dispatcher-7] o.a.f.r.h.n.e.EmbeddedLeaderService      : Proposing leadership to the contender that is registered under component ID 'job-bbc2959a1228d4782ade6888026503f1'.
2024-02-28 16:38:09.628  INFO 59419 --- [ter-io-thread-2] a.f.r.j.JobMasterServiceLeadershipRunner : JobMasterServiceLeadershipRunner for job bbc2959a1228d4782ade6888026503f1 was granted leadership with leader id 624ca6ad-7a55-43ed-9668-28c7ce10c3b2. Creating new JobMasterServiceProcess.
2024-02-28 16:38:09.641  INFO 59419 --- [ger-io-thread-1] o.a.f.runtime.rpc.pekko.PekkoRpcService  : Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at pekko://flink/user/rpc/jobmanager_3 .
2024-02-28 16:38:09.649  INFO 59419 --- [ger-io-thread-1] o.a.flink.runtime.jobmaster.JobMaster    : Initializing job 'evp job' (bbc2959a1228d4782ade6888026503f1).
2024-02-28 16:38:09.691  INFO 59419 --- [lt-dispatcher-7] o.a.f.r.dispatcher.StandaloneDispatcher  : Job bbc2959a1228d4782ade6888026503f1 reached terminal state FAILED.
org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
        at org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97)
        at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863)
        at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841)
        at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
        at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1773)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
        at java.base/java.lang.Thread.run(Thread.java:842)
Caused by: java.util.concurrent.CompletionException: java.lang.RuntimeException: java.lang.ClassNotFoundException: org.apache.flink.api.common.ExecutionConfig
        at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
        at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
        at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1770)
        ... 3 more
Caused by: java.lang.RuntimeException: java.lang.ClassNotFoundException: org.apache.flink.api.common.ExecutionConfig
        at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
        at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114)
        at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1768)
        ... 3 more
Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.ExecutionConfig
        at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
        at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
        at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520)
        at java.base/java.lang.Class.forName0(Native Method)
        at java.base/java.lang.Class.forName(Class.java:467)
        at org.apache.flink.util.InstantiationUtil$ClassLoaderObjectInputStream.resolveClass(InstantiationUtil.java:78)
        at java.base/java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:2045)
        at java.base/java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1909)
        at java.base/java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2235)
        at java.base/java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1744)
        at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:514)
        at java.base/java.io.ObjectInputStream.readObject(ObjectInputStream.java:472)
        at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:539)
        at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:527)
        at org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:67)
        at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:101)
        at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:122)
        at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:379)
        at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:356)
        at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:128)
        at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:100)
        at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
        ... 4 more
2024-02-28 16:38:09.695  INFO 59419 --- [ter-io-thread-3] o.a.f.r.dispatcher.StandaloneDispatcher  : Job bbc2959a1228d4782ade6888026503f1 has been registered for cleanup in the JobResultStore after reaching a terminal state.
2024-02-28 16:38:09.796  INFO 59419 --- [onPool-worker-2] o.a.f.runtime.minicluster.MiniCluster    : Shutting down Flink Mini Cluster
2024-02-28 16:38:09.801  INFO 59419 --- [lt-dispatcher-6] o.a.f.runtime.taskexecutor.TaskExecutor  : Stopping TaskExecutor pekko://flink/user/rpc/taskmanager_0.
2024-02-28 16:38:09.802  INFO 59419 --- [lt-dispatcher-6] o.a.f.runtime.taskexecutor.TaskExecutor  : Close ResourceManager connection 7f55f62128eada4a14d21fb554184f7a.
2024-02-28 16:38:09.803  INFO 59419 --- [lt-dispatcher-7] o.a.f.r.r.StandaloneResourceManager      : Closing TaskExecutor connection 9acc0233-57a4-4d8b-8c97-0e17008e0dca because: The TaskExecutor is shutting down.
2024-02-28 16:38:09.803  INFO 59419 --- [lt-dispatcher-7] o.a.f.r.r.s.FineGrainedSlotManager       : Unregistering task executor 2e75d4e948fb7413bdd8ddaa65535673 from the slot manager.
2024-02-28 16:38:09.804  INFO 59419 --- [lt-dispatcher-6] askExecutorStateChangelogStoragesManager : Shutting down TaskExecutorStateChangelogStoragesManager.
2024-02-28 16:38:09.804  INFO 59419 --- [lt-dispatcher-6] ecutorChannelStateExecutorFactoryManager : Shutting down TaskExecutorChannelStateExecutorFactoryManager.
2024-02-28 16:38:09.807  INFO 59419 --- [onPool-worker-2] o.a.f.r.d.DispatcherRestEndpoint         : Shutting down rest endpoint.
2024-02-28 16:38:09.813  INFO 59419 --- [lt-dispatcher-6] o.a.f.r.t.DefaultJobLeaderService        : Stop job leader service.
2024-02-28 16:38:09.814  INFO 59419 --- [lt-dispatcher-6] .r.s.TaskExecutorLocalStateStoresManager : Shutting down TaskExecutorLocalStateStoresManager.
2024-02-28 16:38:09.818  INFO 59419 --- [lt-dispatcher-6] o.a.f.r.io.disk.FileChannelManagerImpl   : FileChannelManager removed spill file directory /home/evuser3/tmp/flink-io-c0cdff82-d2b4-4706-80db-dd401f5c90e3
2024-02-28 16:38:09.819  INFO 59419 --- [lt-dispatcher-6] o.a.f.r.i.n.NettyShuffleEnvironment      : Shutting down the network environment and its components.
2024-02-28 16:38:09.823  INFO 59419 --- [lt-dispatcher-6] o.a.f.r.io.disk.FileChannelManagerImpl   : FileChannelManager removed spill file directory /home/evuser3/tmp/flink-netty-shuffle-729f4439-d93a-4e70-bbf7-742fdd082feb
2024-02-28 16:38:09.823  INFO 59419 --- [lt-dispatcher-6] o.a.f.r.taskexecutor.KvStateService      : Shutting down the kvState service and its components.
2024-02-28 16:38:09.823  INFO 59419 --- [lt-dispatcher-6] o.a.f.r.t.DefaultJobLeaderService        : Stop job leader service.
2024-02-28 16:38:09.824  INFO 59419 --- [lt-dispatcher-6] o.a.flink.runtime.filecache.FileCache    : removed file cache directory /home/evuser3/tmp/flink-dist-cache-101fc1d5-3b33-4859-b815-78e0f97146c7
2024-02-28 16:38:09.826  INFO 59419 --- [lt-dispatcher-6] o.a.f.runtime.taskexecutor.TaskExecutor  : Stopped TaskExecutor pekko://flink/user/rpc/taskmanager_0.
2024-02-28 16:38:09.828  INFO 59419 --- [onPool-worker-7] o.a.f.r.d.DispatcherRestEndpoint         : Removing cache directory /home/evuser3/tmp/flink-web-ui
2024-02-28 16:38:09.829  INFO 59419 --- [onPool-worker-7] o.a.f.r.d.DispatcherRestEndpoint         : http://localhost:34096 lost leadership
2024-02-28 16:38:09.830  INFO 59419 --- [onPool-worker-7] o.a.f.r.d.DispatcherRestEndpoint         : Shut down complete.
2024-02-28 16:38:09.831  INFO 59419 --- [lt-dispatcher-6] o.a.f.r.r.StandaloneResourceManager      : Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
2024-02-28 16:38:09.832  INFO 59419 --- [lt-dispatcher-7] r.e.c.DispatcherResourceManagerComponent : Closing components.
2024-02-28 16:38:09.833  INFO 59419 --- [lt-dispatcher-7] a.f.r.d.r.SessionDispatcherLeaderProcess : Stopping SessionDispatcherLeaderProcess.
org.apache.flink.util.FlinkException: Failed to execute job 'evp job'.
2024-02-28 16:38:09.833  INFO 59419 --- [lt-dispatcher-6] o.a.f.r.dispatcher.StandaloneDispatcher  : Stopping dispatcher pekko://flink/user/rpc/dispatcher_2.
        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2253)
        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2125)
        at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:68)
2024-02-28 16:38:09.834  INFO 59419 --- [lt-dispatcher-6] o.a.f.r.dispatcher.StandaloneDispatcher  : Stopping all currently running jobs of dispatcher pekko://flink/user/rpc/dispatcher_2.
2024-02-28 16:38:09.834  INFO 59419 --- [lt-dispatcher-7] o.a.f.r.r.ResourceManagerServiceImpl     : Stopping resource manager service.
        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:2099)
        at com.modi.evp.biz.job.EvpJob.mainJob(EvpJob.java:40)

展开
收起
su3vdt5cfb72g 2024-02-28 17:52:10 494 0
5 条回答
写回答
取消 提交回答
  • 游客ws4pv3njscl72

    我发现使用最新版本的flink-CDC3.1.1,3.2.0版本就也这个问题，我把CDC换成2.4，flink版本退回到1.15，打包这个问题就不存在了，希望对各位有帮助。 如果有新版本的解决方法，也希望有人在这边留言。

    2024-11-06 18:39:50
    赞同 展开评论 打赏
  • 游客toux7xuvawxzq

    同样的问题，请问怎么解决的呀

    2024-07-15 17:36:42
    赞同 1 展开评论 打赏
  • 游客g2sgnzkuiwomu

    请问最后怎么解决的呀？我也遇到了这样的问题

    2024-05-25 19:29:20
    赞同 展开评论 打赏
  • mrq4nk6ni2neg

    使用jar包启动Flink CDC作业时遇到异常，以下是一些可能的原因及对应的解决方法：

    1. 依赖冲突：确保打包时所有需要的依赖都已经包含在jar包中。如果某些依赖与Flink框架的核心包存在冲突，可能会导致类加载问题。检查并解决这些冲突，确保没有重复或不兼容的依赖。
    2. 数据库配置：检查MySQL的配置文件my.cnf，确保已经开启了binlog，并且设置了正确的server-id。这是Flink CDC正常运作的前提。对于MySQL 5.6版本，虽然官方建议使用5.7以上版本，但在5.6上运行1.4版本的Flink CDC通常没有问题。不过，如果是生产环境，请仔细测试。
    3. 反压问题：如果Flink作业存在反压，CDC Source中使用的Binlog Client可能会因为反压而无法继续读取数据。这可能导致连接被MySQL切断，从而引发异常。考虑优化作业以减少反压的发生。
    4. 驱动程序问题：如果在启动时出现类似“No suitable driver found”的错误，可能是因为缺少相应的JDBC驱动。确保在打包时包含了正确版本的JDBC驱动，并且在代码中正确地注册了驱动。
    5. 环境差异：IDEA运行不报错而jar包运行报错可能是因为IDEA运行时使用的类路径和打包后的类路径不同。检查IDEA的配置和打包脚本，确保它们是一致的。
    6. 类加载器问题：如果使用的是自定义的类加载器，确保它能够正确地加载到Flink CDC所需的类。有时候，类加载器的设置可能会导致在IDE中运行正常，而在独立运行时出现问题。

    综上所述，使用jar包启动Flink CDC作业时遇到异常可能是由依赖冲突、数据库配置以及反压等因素导致的。为了解决这个问题，您可以检查并解决依赖冲突、确认数据库配置是否正确、优化作业以减少反压、包含正确版本的JDBC驱动、确保环境一致性以及正确配置类加载器。

    2024-02-29 22:52:33
    赞同 展开评论 打赏
  • 请看我回答~
    阿里云大降价~

    这个问题可能是由于在打包时，某些依赖没有被正确地包含在jar包中。你可以尝试以下方法来解决这个问题：

    1. 确保你的项目中包含了所有必要的依赖。你可以在pom.xml文件中检查这些依赖，确保它们都被正确地声明和引用。

    2. 使用Maven的maven-assembly-plugin插件来创建一个包含所有依赖的可执行jar文件。在你的pom.xml文件中添加以下配置：

    <build>
    <plugins>
        <plugin>
            <artifactId>maven-assembly-plugin</artifactId>
            <configuration>
                <archive>
                    <manifest>
                        <mainClass>你的主类全名，例如：com.example.Main</mainClass>
                    </manifest>
                </archive>
                <descriptorRefs>
                    <descriptorRef>jar-with-dependencies</descriptorRef>
                </descriptorRefs>
            </configuration>
            <executions>
                <execution>
                    <id>make-assembly</id>
                    <phase>package</phase>
                    <goals>
                        <goal>single</goal>
                    </goals>
                </execution>
            </executions>
        </plugin>
    </plugins>
</build>
    1. 使用命令行运行以下命令来构建项目并生成可执行jar文件：
    mvn clean package
    1. 运行生成的jar文件：
    java -jar target/your-project-name-version-jar-with-dependencies.jar

    这样应该可以解决你的问题。如果问题仍然存在，请检查日志以获取更多详细信息，并确保你的环境配置正确。

    2024-02-29 13:55:47
    赞同 展开评论 打赏
问答分类：
Java 流计算 Apache API 网络架构 实时计算 Flink版
问答标签：
实时计算 Flink版CDC flink jar 实时计算 Flink版jar 实时计算 Flink版异常 实时计算 Flink版jar包
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答
相关产品：
实时计算 Flink版

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

相关问答
实时计算 Flink版
在Flink CDC中， 我把flink lib下面的所有jar包放上去也是报这个错误？
54
0
0
在Flink CDC中，启动flink使用application模式 依赖jar用cdc2.4.2？
37
0
0
在Flink CDC中，要看项目用的是flink-cdc哪个jar包？
33
1
0
如何避免用户作业包中包含Flink的core包？
33
1
0
在Flink CDC中，去掉dbz-core试试，在咨询一下，这些包是不是胖包都有，可以不需要？
44
1
0
在Flink CDC中，flink 1.19 升级到 1.19.1 替换flink lib下的包吗？
85
1
0
本地能跑阿里云版本的 flink jar包吗？
52
1
0
在Flink CDC中s想重启flink以使lib的jar包生效，导致之前的容器不可用 怎么办？
47
1
0
在Flink CDC中可以写好同步代码 打包jar包 然后上传到flink web界面的吗？
44
0
0
Flink任务的jar包打的是最小包，如何指定这个本地磁盘lib目录，能有效加载这些依赖包呢？
79
1
0
大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

相关产品

  • 实时计算 Flink版
    文档详情 产品详情

    • 热门讨论

    热门文章

  • Flink sql将数组炸开，实现hive的explode函数的效果，还有什么其他好的方式？
    1800
  • Flink如何配置Task Manager？
    940
  • 各位老师，请教个问题，flink 会在本地 /tmp 目录下产生大量flink-临时文件，目前看好？
    1990
  • Flink这个未授权访问漏洞有什么解决方案吗？
    1571
  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
    3867
  • flinksql 可以 设置自增id 吗？
    8518
  • Flink CDC中SQL server CDC这种报错有什么解决方式嘛？
    1071
  • 我们在使用阿里云flinksql 往clickhouse写数据的时候发现会丢数据或重复数据，怎么办？
    1029
  • Flink 集群重启后，所有的Jobs任务全都没有了。如果快速恢复所有的任务
    1475
  • Apache Flink未授权访问上传导致的RCE漏洞，这个漏洞目前方案解决吗？
    771
    • 展开全部
  • OPPO数据中台之基石：基于Flink SQL构建实数据仓库
    22005
  • Flink SQL 功能解密系列 —— 流式 TopN 挑战与实现
    16678
  • Flink Checkpoint 问题排查实用指南
    13293
  • 广告场景下的实时计算
    11098
  • 史上超强阵容！大数据及人工智能领域顶级盛会，Flink Forward Asia 2019 不容错过！
    9435
  • Apache Flink 漫谈系列(15) - DataStream Connectors之Kafka
    8916
  • Apache Flink 进阶（五）：数据类型和序列化
    8305
  • 咱们从头到尾讲一次 Flink 网络流控和反压剖析
    6094
  • 开篇 | 揭秘 Flink 1.9 新架构，Blink Planner 你会用了吗？
    7246
  • Apache Flink 漫谈系列(06) - 流表对偶(duality)性
    9724
    • 展开全部

    相关课程

    更多
  • 大数据Flink实时旅游平台环境篇 2020版
    611
    29
    去学习
  • Apache Flink 入门到实战 - Flink开源社区出品
    1652
    16
    去学习
  • 实时计算 Flink 版产品入门与实操
    4035
    10
    去学习
  • 开源 Flink 极速上手教程
    1878
    7
    去学习
  • 大数据实时计算框架Spark快速入门
    1030
    93
    去学习
  • Apache Flink 入门
    5145
    9
    去学习

    • 相关文章

  • Lambda表达式与函数式工具应用详解
  • 【Azure Event Hub】Kafka消息发送失败(Timeout Exception)
  • Java mysql根据很长的富文本如何自动获取简介
  • 在C程序中实现类似Redis的SCAN机制的LevelDB大规模key分批扫描
  • 《鸿蒙HarmonyOS应用开发从入门到精通（第2版）》学习笔记——HarmonyOS纯血鸿蒙新特性

    • 相关电子书

    更多
    • Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载

    相关实验场景

    更多
  • 基于Hologres+Flink搭建GitHub实时数据大屏
    203
    1.0小时
    去实验
  • 基于Flink+Tair搭建实时监控大屏
    215
    1.0小时
    去实验
  • 5分钟上手Flink MySQL连接器
    498
    1.0小时
    去实验
  • 使用Flink实时发现最热Github项目
    1184
    1.0小时
    去实验