内容选择
    内容分类
    学堂 博客 论坛 开发服务 开发工具 直播 视频 用户
    时间
    一周 一个月 三个月
    内容选择
    全部
    内容选择
    内容分类
    • 学堂
    • 博客
    • 论坛
    • 开发服务
    • 开发工具
    • 直播
    • 视频
    • 用户
    时间
    • 一周
    • 一个月
    • 三个月
    重置 确定

    • flink问题集锦

      version: 2.11.12 org.apache.flink:flink-runtime_2.11:1.13.2 requires scala version: 2.11.12 org.apache.flink:flink-scala_2.11:1.13.2 requires

      开发者  >  博客
      作者： 橙子园
      发表时间： 2022-05-25 15:02:06
      831
      0

    • hive数据类型

      1. hive的数据类型 Hive的内置数据类型可以分为两大类：(1)、基础数据类型；(2)、复杂数据类型 2. hive基本数据类型 基础数据类型包括：TINYINT,SMALLINT,INT,BIGINT,BOOLEAN,FLOAT,DOUBLE,STRING,BINARY,TIMESTAMP

      开发者  >  博客
      作者： 百忍成金的虚竹
      发表时间： 2021-03-25 17:14:19
      1524
      0

    • Hive基础06、Hive引入数组

      ​  点击并拖拽以移动点击并拖拽以移动​编辑 Hive基础06、Hive引入数组 目录 Hive基础05、Hive引入数组 1、建表语句 2、创建【arrayInfo.txt】 3、上传到【/soft/temp/】 4、引入数组操作 1、建表语句 英文关键字解析：

      开发者  >  博客
      作者： 红目香薰
      发表时间： 2022-07-29 02:14:47
      191
      0

    • 《Flink原理、实战与性能优化》 —3.2　Flink编程接口

      3.2　Flink编程接口如图3-2所示，Flink根据数据集类型的不同将核心数据处理接口分为两大类，一类是支持批计算的接口DataSet API，另外一类是支持流计算的接口DataStream API。同时Flink将数据处理接口抽象成四层，由上向下分别为SQL API、Table

      开发者  >  博客
      作者： 华章计算机
      发表时间： 2020-02-17 14:14:00
      3033
      0

    • Flink的sink实战之一：初探

      下图来自Flink官方，红框中就是sink，可见实时数据从Source处开始，在Transformation阶段完成业务逻辑后在sink结束，因此sink可以用来处理计算结果，例如控制台输出或者保存数据库： 关于《Flink的sink实战》系列文章 本文是《Flink的sin

      开发者  >  博客
      作者： 程序员欣宸
      发表时间： 2022-04-05 11:57:35
      613
      0

    • 对比mysql和hive：mysqlzhong ,分组求不同组的前几条记录

      123456789101112131415161718192021 3、需求如下 求出不同爱好中，年龄最大的两个人(爱好，年龄，姓名) 4、实现代码 select a.* from mian61 a where (select count(*) from mian61 b

      开发者  >  博客
      作者： yd_226342373
      发表时间： 2021-05-19 18:37:10
      1253
      0

    • 2021年大数据Flink（十七）：Flink四大基石

      目录 Flink四大基石 Checkpoint State Time Window Flink四大基石 Flink之所以能这么流行，离不开它最重要的四个基石：Checkpoint、State、Time、Window。

      开发者  >  博客
      作者： Lansonli
      发表时间： 2021-09-28 14:56:29
      1096
      0

    • 【FI hd 6513】【开源flink 华为kafka】 开源flink连接华为kafka问题

      11-1.1.0) 已开启安全认证 开源flink 1.14.2 、flink-kafka-connector-1.14.2【操作步骤&问题现象】1、需要使用开源flink连接HD(6.5.1.3,x86_64)的kafka2、已经将flink kafka connector中开源

      开发者  >  其他
      作者： menghe
      798
      6

    • 2万字50张图玩转Flink面试体系

      公司怎么提交Flink实时任务的？谈谈流程 顾名思义，这里涉及Flink的部署模式内容。一般Flink部署模式除了Standalone之外，最常见的为Flink on Yarn和Flink on K8s模式，其中Flink on Yarn模式在企业中应用最广。 Flink on Yarn模式细分由可以分为Flink

      开发者  >  博客
      作者： 大数据兵工厂
      发表时间： 2022-08-03 14:04:22
      849
      0

    • 大数据Flink进阶（九）：集群基础环境搭建

      start mysqld，也可以使用service mysqld start启动msyql。 以上安装mysql的方式是直接从外网下载mysql 5.7版本安装，由于网络慢等原因导致mysql下载安装速度慢。我们也可以选择在mysql官网中找到linux版本对应的mysql版本先下载好

      开发者  >  博客
      作者： Lansonli
      发表时间： 2023-03-30 09:05:16
      161
      0

    • Flink Standalone运行模式

      另外，Fink可以将处理后的数据，输出到第三方应用系统、事件日志、数据库系统、文件系统以及键值对存储系统中。由于Flink程序主要由Java语言或Scala语言开发，另外还支持Python语言。但底层组件和Flink运行时（runtime）是运行在JVM上，因此，Flink程序可以运行

      开发者  >  博客
      作者： jackwangcumt
      发表时间： 2021-11-24 23:55:35
      2643
      0

    • Hive对接OBS

      export PATH=$HIVE_HOME/bin:$PATH 配置Hive。 重命名/opt/hive-2.3.3/conf/hive-env.sh.template为hive-env.sh。 重命名opt/hive-2.3.3/conf/hive-log4j2

      开发者 >  开发服务

    • 《Flink原理、实战与性能优化》 —1.2.4　为什么会是Flink

      数据不需要落地数据库就能直接从Flink流式应用中查询。对于实时交互式的查询业务可以直接从Flink的状态中查询最新的结果。在未来，Flink将不仅作为实时流式处理的框架，更多的可能会成为一套实时的状态存储引擎，让更多的用户从有状态计算的技术中获益。Flink的具体优势有以下几

      开发者  >  博客
      作者： 华章计算机
      发表时间： 2020-02-17 12:58:29
      3205
      0

    • flink启动HistoryServer服务

      mrs 3.1.0集群启动flink HistoryServer服务1.修改$FLINK_HOME/conf/flink-conf.yaml文件#==============================================================================#

      开发者  >  博客
      作者： 王伟康
      发表时间： 2021-12-14 09:39:15
      1513
      0

    • FusionInsight FLINK培训

      Flink产品介绍，常见现网问题解决方法分享。

      开发者  >  视频
      播放量  900

    • 【大数据】flink保证Exactly_Once的理解

      1、exactly once 要保证flink 端到端需要满足以下三点 1、flink要开启checkpoint 2、source支持数据重发 3、sink端幂等性写入、事务性写入。我们常使用事务性写入 sink 事务性写入分为两种方式 1、WAL（预写日志的方式）：先

      开发者  >  博客
      作者： 橙子园
      发表时间： 2022-05-25 16:28:40
      337
      0

    • 云原生模式部署Flink应用

      镜像捆绑在一起，因为它在集群上运行用户代码的 main() 方法。 Application Mode 确保在应用程序终止后正确清理所有 Flink 组件。 Flink 社区提供了一个基础 Docker 镜像，可用于捆绑用户代码： FROM flink RUN mkdir -p $FLINK_HOME/usrlib

      开发者  >  博客
      作者： 从大数据到人工智能
      发表时间： 2022-03-08 17:51:13
      1461
      0

    • 【HIVE】【hive对接】Kettle7.1如何对接MRS-HIVE

      【问题描述】：已通过FI客户端替换kettle中Hive相关jar，core-site.xml文件，无法连接，是否为kettle版本问题？【截图信息】：数据库连接配置：测试连接报错：

      开发者  >  其他
      作者： szh
      2365
      5

    • Flink SQL中connector的定义和实现

        'connector.url' = 'jdbc:mysql://localhost:3306/flink-test',    'connector.table' = 'jdbc_table_name',   'connector.driver' = 'com.mysql.jdbc.Driver',   'connector

      开发者  >  博客
      作者： 潇湘暮雨
      发表时间： 2020-09-28 19:52:23
      10513
      0

    • 《Flink原理、实战与性能优化》 —3.3　Flink程序结构

      径中。代码清单3-1　Streaming WordCount实例代码整个Flink程序一共分为5步，分别为设定Flink执行环境、创建和加载数据集、对数据集指定转换操作逻辑、指定计算结果输出位置、调用execute方法触发程序执行。对于所有的Flink应用程序基本都含有这5个步骤，下面将详细介绍每个步骤。1

      开发者  >  博客
      作者： 华章计算机
      发表时间： 2020-02-17 14:18:02
      3078
      0
    总条数： 10000
    点击加载更多