来学技术 2022-08-03 16:53 采纳率: 0%
浏览 18

flink读取数据的方法

flink可以直接读取sqlserver中的数据吗？（怎么还要凑三十个字，怎么这么简短的问题在这里不受待见吗）

  • 写回答

1条回答 默认 最新

  • 三千烦恼丝xzh 2022-08-03 19:12
    关注

    有提供一个jdbc-connector的source，但是不支持Oracle和sqlserver这种，不过可以自己改connector源码适配sqlserver和Oracle，主要适配limit这种方言

    评论

报告相同问题？

  • flink消费kafka数据延迟 flink postgresql scala 有问必答
    2022-01-28 09:47
    回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
  • flinksql读取kafka数据报错 flink kafka
    2022-07-13 20:33
    回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
  • Flink处理乱序数据，关于侧输出流的问题 flink scala 大数据
    2022-05-27 11:19
    回答 1 已采纳 当10:14:51的数据来之前，流中最大的事件时间 >= 10:24:50(窗口结束时间) + watermark延迟时间 + 允许延迟时间 ，导致当前waterMark 的值更新为 这个最大的
  • Flink实例：将大数据写入Elasticsearch
    2023-08-30 22:48
    UIEdit的博客 接下来，我们从Kafka中读取数据流（DataStream），然后配置Elasticsearch的连接属性，并创建了一个ElasticsearchSink.Builder。首先，让我们创建一个新的Flink应用程序。在你的IDE中创建一个新的Java项目，并导入所...
  • FlinkCDC连mysql时无法获取增量数据 big data flink 大数据
    2022-10-12 21:51
    回答 1 已采纳 解决了，没有开启checkpoint导致，加上下面代码即可env.enableCheckpointing(1000, CheckpointingMode.EXACTLY_ONCE);env.getCh
  • Java-flink的sum方法输出 flink
    2022-06-05 15:31
    回答 1 已采纳 我的打印出来了，，，我代码是这样的 import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.
  • Flink连接MySQL报错，求解决方法 flink mysql 有问必答
    2022-01-11 10:12
    回答 2 已采纳 这是空指针异常，发生在读取数据那里，仔细检查一下数据是否有问题，估计是数据格式出现了问题或者路径输出了问题导致没有读取到自己想要的数据,无法被获取到，所以报了空异常
  • 10.大数据技术之Flink
    2022-07-17 08:31
    数据带你飞的博客 ​这几年大数据的飞速发展，出现了很多热门的开源社区，其中著名的有Hadoop、Storm，以及后来的Spark，他们都有着各自专注的应用场景。Spark掀开了内存计算的先河，也以内存为赌注，赢得了内存计算的飞速发展。Spark...
  • flink跑jar，需要读取csv文件 flink 大数据
    2021-12-15 18:57
    回答 1 已采纳 异常描述的很清楚，文件不存在或者flink没有读取权限
  • flink两个流join的时候怎么解决数据延迟问题 flink 有问必答
    2021-07-16 14:22
    回答 1 已采纳 OutputTag获取迟到数据，二次消费
  • Flink的Watermark flink 大数据
    2023-03-28 20:55
    回答 2 已采纳 对于时间窗口，开始时间和结束时间的计算方式如下： 滚动时间窗口：按照固定的时间长度对数据进行分组，窗口的大小和滑动步长相同，例如，5秒的滚动窗口，每5秒钟计算一次。开始时间为当前窗口大小的整数倍，结束
  • 大数据技术之Flink CDC视频教程
    2022-07-08 13:46
    Flink CDC是Flink社区开发的Flink-cdc-connector组件，是一个可以实现从MySQL、PostgreSQL等数据库直接读取全量数据和增量变更数据的source组件。通过使用Flink CDC，搭配Flink的流批一体数据计算引擎，能够实现采集...
  • flink支持对对窗口内数据过滤吗？ flink 大数据
    2021-08-03 10:23
    回答 1 已采纳 超过00:00的数据如果不需要，直接放入测流就好。不管是后续使用还是丢掉。或者本身就有时间字段，直接加filter算子过滤不参与flink计算就好。
  • flink学习总结（大数据面试）
    2021-08-16 16:36
    404个问号的博客 Apache Flink摒弃了Java原生的序列化方法，以独特的方式处理数据类型和序列化，包含自己的类型描述符，泛型类型提取和类型序列化框架。 TypeInformation 是所有类型描述符的基类。它揭示了该类型的一些基本属性，...
  • 【Flink】Flink读取数据的四种方式
    2022-02-09 23:37
    飝鱻.的博客 Flink读取数据的四种方式准备工作从集合中读取从文件中读取从Kafka中读取自定义读取方式 准备工作 Flink默认运行时是没有日志的，若想要出现日志，需要在pom文件添加 <dependency> <groupId>org....
  • 没有解决我的问题, 去提问

问题事件

  • 创建了问题 8月3日

悬赏问题

  • ¥15 求daily translation（DT）偏差订正方法的代码
  • ¥15 js调用html页面需要隐藏某个按钮
  • ¥15 ads仿真结果在圆图上是怎么读数的
  • ¥20 Cotex M3的调试和程序执行方式是什么样的？
  • ¥20 java项目连接sqlserver时报ssl相关错误
  • ¥15 一道python难题3
  • ¥15 牛顿斯科特系数表表示
  • ¥15 arduino 步进电机
  • ¥20 程序进入HardFault_Handler
  • ¥15 关于#python#的问题：自动化测试