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

    • flink提交任务失败

      java:1071)Caused by: org.apache.flink.util.FlinkException: Failed to execute job 'Flink Streaming Job'.    at org.apache.flink.streaming.api.environment

      开发者  >  其他
      作者： stupidsky
      403
      1

    • UpdateFlinkSql 更新Flink SQL作业 - API

      该API属于DLI服务，描述: Stream SQL的语法扩展了Apache Flink SQL。接口URL: "/v1.0/{project_id}/streaming/sql-jobs/{job_id}"

      开发者 >  开发工具

    • UpdateFlinkSqlJob Updating a Flink SQL Job - API

      该API属于DLI服务，描述: This API is used to update a SQL job.接口URL: "/v1.0/{project_id}/streaming/sql-jobs/{job_id}"

      开发者 >  开发工具

    • CreateFlinkSqlJob 新建Flink SQL作业 - API

      该API属于DLI服务，描述: 通过POST方式,提交流式SQL作业,请求体为JSON格式。接口URL: "/v1.0/{project_id}/streaming/sql-jobs"

      开发者 >  开发工具

    • 华为云MRS Python3使用pyhive连接安全集群Hive

      nbsp;  下载和安装pyhive包(见附件) pip install PyHive-0.6.1.1.zip 该包已基于MRS kerberos认证进行了相应的源码修改。 修改了pyhive/hive.py文件，在文件两处增加kerberos_se

      开发者  >  博客
      作者： yugogo
      发表时间： 2021-12-01 04:39:12
      2948
      0

    • Hive基础07、Hive引入Map

      ​  点击并拖拽以移动点击并拖拽以移动​编辑 Hive基础07、Hive引入Map 1、建表语句 创建一个成绩表，记录学生的各个科目成绩： 英文关键字解析： 1、CREATE TABLE 创建一个指定名字的表，如果库中已有相同名的表，则抛出异常；用户可以使用 IF NOT

      开发者  >  博客
      作者： 红目香薰
      发表时间： 2022-07-29 02:15:21
      174
      0

    • Hive基础05、Hive引入数据

      ​  点击并拖拽以移动点击并拖拽以移动​编辑 Hive基础05、Hive引入数据 前提 Hive表中的数据不能通过insert语句插入，而是load data语句进行加载，其中加载的数据来源主要包括： 1、本地文件系统加载数据 2、HDFS文件系统加载数据 load

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

    • 《大数据技术丛书 Flink原理、实战与性能优化》—2.2　Flink项目模板

      ob.java和Streaming.java两个文件，分别对应Flink批量接口DataSet的实例代码和流式接口DataStream的实例代码。在创建好上述项目后，建议用户将项目导入到IDE进行后续开发，Flink官网推荐使用的是Intellij IDEA或者Eclipse进行

      开发者  >  博客
      作者： 华章计算机
      发表时间： 2019-06-14 16:34:24
      5526
      0

    • Hive考试练习题

      一、搭建MySQL运行环境（25分，每项5分） 1、删除MySQL依赖的libs包 2、安装MySQL的服务器与安装MySQL的客户端 3、登录MySQL并修改MySQL密码 4、给与MySQL的master权限 5、刷新MySQL权限并退出MySQL 二、搭建hive运行环境（50分，每项5分）

      开发者  >  博客
      作者： 红目香薰
      发表时间： 2022-07-29 02:19:39
      238
      0

    • Flink证券项目(二)技术架构

      采用的存储资源包含：Hbase、Mysql、Redis、HDFS等 3.采用Hadoop Yarn统一资源管理 4.计算框架采用MapReduce、Spark SQL、Flink 5.数据处理包含批处理和实时数据处理，其中批处理数仓处理采用Hive，再根据主题建立模型和业务数据分层

      开发者  >  博客
      作者： Maynor学长
      发表时间： 2022-11-24 07:47:37
      253
      0

    • 开源Hive部署指导书

      jvbb.png) # 6 部署Hive ## 6.1 安装MariaDB Hive需将元数据保存在数据库中，则在安装Hive前，需先安装数据库软件，并在hive-site.**Xml**中配置数据库相关信息。常见的数据库有Derby、MySQL、MariaDB，本文档基于MariaDB部署，其余数据库部署方式类似。

      开发者  >  其他
      作者： 真我Realme
      10278
      0

    • Flink 基本原理

      据，时延毫秒级，且兼具可靠性。Flink技术栈如图1所示。图1 Flink技术栈Flink在当前版本中重点构建如下特性，其他特性继承开源社区，不做增强，具体请参考：https://ci.apache.org/projects/flink/flink-docs-release-1.

      开发者  >  其他
      作者： 萧凡依云
      1376
      1

    • Hive快速入门系列(5) | 如何访问HiveJDBC

        此篇博文博主为大家讲解的是如何访问HiveJDBC。 目录 1. 启动hiveserver2服务2. 启动beeline(hive自带的JDBC访问的客户端)3. 连接hiveserver24. hiveserver2和beeline的区别   首先，我们先来看下Hive的bin文件夹的目录：

      开发者  >  博客
      作者： 不温卜火
      发表时间： 2020-12-02 22:47:10
      5327
      0

    • Flink的sink实战之一：初探

      究，为后续的编码实战打好基础； 从一段实例代码开始 下面是个简单的flink应用代码，红框中的print方法就是sink操作： 下图是官方给出的sink方式，都是DataStream类的API，直接调用即可实现sink，刚才代码中的print就是其中一个： 接下来看看上图

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

    • 2021年最新最全Flink系列教程_Flink原理初探和流批一体API(二.五)v2

      Kafka 连接方式 Kafka 是消息队列 需求： 通过 Flink 将数据元素写入（producer）到 Kafka 中 ~~~java   package cn.itcast.flink.sink;      import com.alibaba.fastjson

      开发者  >  博客
      作者： Maynor学长
      发表时间： 2022-07-24 03:40:39
      230
      0

    • Hive源码学习【1】——Windows WSL Hive3.x安装与调试（1）

      # 启动mysql sudo service mysql start # 测试登录，mysql5.7默认root用户初始密码为空 mysql -u root    新装MySQL登录root会存在权限问题，解决方法如此博客Hive安装与配置Hive环境变量配置export HIV

      开发者  >  博客
      作者： 想要一只猫
      发表时间： 2020-09-25 23:06:09
      6946
      0

    • Flink on Yarn三部曲之三：提交Flink任务

      现在Flink、Yarn、HDFS都就绪了，接下来实践提交Flink任务到Yarn执行； 全文链接 《Flink on Yarn三部曲之一：准备工作》 《Flink on Yarn三部曲之二：部署和设置》 《Flink on Yarn三部曲之三：提交Flink任务》

      开发者  >  博客
      作者： 程序员欣宸
      发表时间： 2022-12-03 16:01:15
      176
      0

    • Flink从入门到精通100篇（十三）-Flink的入门教学

      前言 Flink 是一种流式计算框架，为什么我会接触到 Flink 呢？因为我目前在负责的是监控平台的告警部分，负责采集到的监控数据会直接往 kafka 里塞，然后告警这边需要从 kafka topic 里面实时读取到监控数据，并将读取到的监控数据做一些

      开发者  >  博客
      作者： 格图洛书
      发表时间： 2021-11-18 15:55:06
      1038
      0

    • FLINK SQL 怎么指定嵌套json的主键

      value:{ -- "mysqlType":{"name":"char","id":"int","age":"int"}, -- "id":606, -- "es":1662693580000, -- "ts":1662693580897, -- "database":"yd_test"

      开发者  >  其他
      作者： yd_254238108
      159
      2

    • Flink Table/SQL自定义Sources和Sinks全解析（附代码）

      动态表是Flink Table和SQL API处理有界和无界数据的核心概念。 在Flink中，动态表只是逻辑概念，其本身并不存储数据，而是将表的具体数据存储在外部系统（比如说数据库、键值对存储系统、消息队列）或者文件中。 动态源和动态写可以从外部系统读写数据。在下面的描述中，动态

      开发者  >  博客
      作者： 从大数据到人工智能
      发表时间： 2022-01-20 18:08:46
      2335
      0
    总条数： 10000
    点击加载更多