Mysql Data to Doris by streamload 导出mysql数据到csv文件 1mysql -e "select tracking_number,order_created_time from datamart.t_wide_table_waybill where waybill_submit_time >= '2021-04-01' and waybill_submit_time < '2 2022-05-27 Doris #Doris
Doris-Unique模型标记删除 指定sequence_type类型目前只支持bigint和date两种 1ALTER TABLE ods.ods_esc_system_oct_buyer_one_sale_goods ENABLE FEATURE "SEQUENCE_LOAD" WITH PROPERTIES ("function_column.sequence_type" = 2022-05-27 Doris #Doris
Flink作业从checkpoint恢复启动 Flink作业故障重启flink是高可用大数据计算框架,在程序中断后支持断点续传 这里人为kill掉程序,测试断点续传 kill部署 在yarn上的Flink作业代码如下: 1234567891011121314151617181920212223242526#!/bin/bash# 需要传入applicationidyarn application --list | grep $1 > / 2022-05-27 Flink #Flink
Doris副本数修改 修改历史的分区副本1234567891011ALTER TABLE ods.order_purchase_orderMODIFY PARTITION (p2021_05,p_2020_12,p2022_18,p2022_19,p2022_20,p2022_21,p2022_22,p2022_23)SET("replication_num"="3"); 历史 2022-05-27 Doris #Doris
Doris表创建动态分区 Doris创建动态分区表动态分区仅仅支持range分区 DDL建表语句如下: 12345678910111213141516171819202122232425262728293031323334353637CREATE TABLE dwd.`dwd_cdc_t_fin_trade_record_detail` ( `trade_id` varchar(200) NULL COMMENT &quo 2022-05-27 Doris #Doris
MySQL错误Illegal mix of collations (utf8mb4_unicode_ci,IMPLICIT) and (utf8mb4_general_ci,IMPLICIT)解决方法 现象描述在执行SQL语句中有比较两个表的字段时,出现Illegal mix of collations (utf8_unicode_ci,IMPLICIT) and (utf8_general_ci,IMPLICIT)错误。意思是遇到的编码错误。 表a是utf8_unicode_ci,而表b是utf8_general_ci。同样是uft-8编码,不知道这样细分的意义。我的两张表是用Navicat分 2022-05-27 #MySQL
记一次Flinkcdc调参 场景描述:利用Flinkcdc从mysql中抓取数据到kafka,再写到doris数据库里 mysql表结构如下: 123456789101112131415161718192021222324252627CREATE TABLE `goods_aspects_relation_detail` ( `id` varchar(32) NOT NULL, `GOODS_UID` varchar(3 2022-05-26 Flink #Flink
Flink作业调度参数详解 本篇文章介绍Flink作业调度命令,以及调度参数的解释 flink yarn-cluster 模式是否使用分离模式1234567891011121314151617-m,–jobmanager 指定提交的jobmanager-yat,–yarnapplicationType 设置yarn应用的类型-yD <property=value> 使用给定属性的值-yd,–yarndetache 2022-05-26 Flink #Flink