加载中
starrcoks中的明细表 (DUPLICATE KEY), DUPLICATE KEY(visitorid, sessionid) 区别

starrcoks中的明细表 (DUPLICATE KEY), DUPLICATE KEY(visitorid, sessionid) 指定两个字段,和 指定一个字段 DUPLICATE KEY(visitorid) 有什么区别?......

starrocks 表类型

优化性能 本文介绍如何优化 StarRocks 性能。 通过建表优化性能 您可以在建表阶段通过以下方式优化 StarRocks 性能。 选择表类型 StarRocks 支持四种表类型:主键表 (PRIMARY KEY),聚合表 ...

spark 读取数据问题疑问记录

%spark_delivery_report import org.apache.spark.sql.SparkSession import org.apache.spark.sql.functions._ import org.apache.spark.sql.expressions.Window import java.sql.{Connectio...

flink task manager内存问题

场景: 目前正在跑的任务为:mysql-prod-archive_to_starrocks-prod 当启动 mysql-dev-archive_to_starrocks-dev 任务时出现异常 问题排查: 查看控制台,此时的Task Managers为0 查看Task ...

Git 修改已提交 commit 的信息

修改最后一次提交 commit 的信息 # 修改最近提交的 commit 信息 $ git commit --amend --message="modify message by daodaotest" --author="jiangliheng <jiang_liheng@163.com>" # 仅修改 ...

spark 写starrock 记录

/** 该写发插入很慢,要一条一条插入 dfFinal.write .format("jdbc") .mode("overwrite") // or "append" .option("driver", "com.mysql.cj.jdbc.Driver") .option("url", "jdbc:mysql:loadb...

spark 写starrock 记录

/** 该写发插入很慢,要一条一条插入 dfFinal.write .format("jdbc") .mode("overwrite") // or "append" .option("driver", "com.mysql.cj.jdbc.Driver") .option("url", "jdbc:mysql:loadb...

springboot kafka topic匹配

import org.apache.kafka.clients.consumer.ConsumerRecord; import org.springframework.kafka.annotation.KafkaListener; import org.springframework.kafka.support.Acknowledgment; impo...

05/23 17:01
79
kafka 监控

https://blog.csdn.net/weixin_44411039/article/details/135396051 启动脚本添加 @REM cmak launcher script @REM @REM Environment: @REM JAVA_HOME - location of a JDK home dir (option...

kafka按照测试命令

https://blog.csdn.net/xyajia/article/details/122774159 cd C:\mq\kafka_2.13-3.6.0 .\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties .\bin\windows\kafka-serve...

业务并发死锁-分布式锁方案

场景: 我想以分布式锁来解决这个问题,比如一个流转业务牵扯到 a b c d e 表 ,另外一个流程业务牵扯到 a c d表, 假设 a b c d e 表 先执行,那么这些表先加锁,等执行完后释放锁。另外一个...

java 流式导出

@RequestMapping(value = "/aa", method = RequestMethod.GET) public void aa(HttpServletResponse response, @ApiParam PeRuleCouponDetailQueryBean queryBe......

flink内存溢出

2025-03-26 10:44:14,063 WARN org.apache.pekko.remote.transport.netty.NettyTransport [] - Remote connection to [null] failed with java.net.ConnectException: Connection refused: l...

mybatis puls 异常场景

mybatis puls 异常场景: 1. 在mapper 里面执行ddl 创建表 2. 往新创建的表insert 3. 往新创建的表update 步骤3的时候会有异常: error updating database. cause: java.sql.sqlexception: t...

flink cdc 同步数据的几种方式比较

Flink CDC(Change Data Capture)是用于从数据库中捕获变更数据的工具,在使用 Flink CDC 同步数据时,常见的方式有 YAML 配置、Flink SQL 和 API 编程,下面为你详细比较这几种方式: 1. Y...

flink cdc 同步任务 数据格式调整

默认是csv格式,这种格式一些特殊字符可能有问题,可以调整为json格式。 如以下异常: Caused by: org.apache.flink.util.SerializedThrowable: com.starrocks.data.load.stream.exception.S...

flinkcdc 同步源数据sqlserver

https://nightlies.apache.org/flink/flink-cdc-docs-release-3.1/docs/connectors/flink-sources/sqlserver-cdc/ package com.aaa.app; import java.time.Duration; import org.apache.flin...

flink cdc 资源不够的问题

java.util.concurrent.CompletionException: java.util.concurrent.CompletionException: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not acquire...

mybatis 支持多个表的insert sql 批量插入吗?

这种情况JdbcTemplate 笔比较合适 这样写是支持的: <!-- Insert User 必须 jdbc url 添加参数 allowMultiQueries=true--> <insert id="insertBatch" useGeneratedKeys="true" keyProperty="...

Spring Boot 集成 RocketMQ 二次封装

<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.2.2</version> </dependency> 配置类: import org.apache.rock...

02/11 10:32
135

没有更多内容

加载失败,请刷新页面

返回顶部
顶部