收发延时消息
本文提供使用 TCP 协议下的 Java SDK 收发延时消息的示例代码供您参考。前提条件 您已完成以下操作：下载 Java SDK。准备环境。（可选）日志配置。背景信息 延时消息用于指定消息发送到消息队列的服务端后，延时一段时间才被投递到客户端...
统计数据
本文档介绍如何使用Java、Python语言获取表的统计数据。相关依赖 Java异步<dependency><groupId>com.aliyun</groupId> <artifactId>aliyun-sdk-ha3engine-async</artifactId> <version>1.0.0</version> </dependency>Java<dependency>...
收发定时消息
本文将引导您如何使用 TCP 协议下的 Java SDK 进行定时消息的收发。前置条件 需要确保您已完成以下操作：下载 Java SDK。准备环境。（可选）日志配置。背景信息 通过定时消息，在消息发送后，可以在当前时间点之后的某一个时间点，再投递到...
异步化IO多线程上传示例
import java.util.concurrent.*;import java.util.concurrent.atomic.AtomicBoolean;import com.aliyun.odps.Column;import com.aliyun.odps.Odps;import com.aliyun.odps.PartitionSpec;import com.aliyun.odps.TableSchema;import ...
Quick BI使用MaxCompute数据源创建SQL数据集时报错
问题描述 使用MaxCompute创建SQL数据集时报错，报错信息如下：报错：null:INTERNAL:java.util.concurrent.ExecutionException:java.lang.RuntimeException:java.sql.SQLException:execute sql[SELECT ALL_T_1_.`business_serial_number` AS...
更新数据
本文档介绍如何使用Java、Python语言进行更新表数据，支持的更新操作有add、delete。相关依赖 Java异步<dependency><groupId>...
微消息队列MQTT版推送事件到函数计算
步骤四：发布事件 import java.util.concurrent.ExecutorService;import java.util.concurrent.LinkedBlockingQueue;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;import org.eclipse.paho....
数据AMQP方式推送
import java.util.concurrent.LinkedBlockingQueue;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;import javax.crypto.Mac;import javax.crypto.spec.SecretKeySpec;import javax.jms.Connection...
将时空数据写入宽表引擎
import java.util.concurrent.ExecutionException;import java.util.concurrent.Future;public class LindormStreamDemoGanos { public static void main(String[]args)throws InterruptedException,ExecutionException,JSONException { ...
步骤三：调用SDK收发消息
本文以Java SDK为例，说明如何将开源SDK客户端接入 云消息队列 RabbitMQ 版 服务端，并完成消息收发。前提条件 创建资源 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA Ultimate为例。安装JDK 安装Maven 安装Java依赖...
通过OpenTelemetry上报Java应用数据
参考文档：*1.https://opentelemetry.io/docs/java/manual_instrumentation/ */RestController@RequestMapping("/user")public class UserController {@Autowired private UserService userService;private ExecutorService es=Executors....
通过SDK写入时序数据
日志服务支持通过SDK写入时序数据，本文列举了Java、Golang和Python语言的SDK demo。说明 使用SDK写入时序数据时，需遵循 时序数据格式。尽可能使用Producer Library发送数据，目前支持ProducerLibrary的语言有 Java、Golang 和 C。使用...
通过OpenTelemetry上报Java应用数据
参考文档：*1.https://opentelemetry.io/docs/java/manual_instrumentation/ */RestController@RequestMapping("/user")public class UserController {@Autowired private UserService userService;private ExecutorService es=Executors....
通过流引擎实现地理围栏监控
import java.util.concurrent.ExecutionException;import java.util.concurrent.Future;public class LindormStreamDemoGanos { public static void main(String[]args)throws InterruptedException,ExecutionException,JSONException { ...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
import java.util.concurrent.LinkedBlockingQueue;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;import org.eclipse.paho.client....
常见问题
java.util.concurrent.TimeoutException at com.alipay.mychain.gl.biz.common.AbstractTransport.sendTwoWayAndSync(AbstractTransport.java:205)答：首先检查客户端所在的环境与区块链节点网络是否连通。可以从sdk.properties配置文件中...
常见问题
354)at java.lang.ClassLoader.loadClass(ClassLoader.java:425)at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)at java.lang.ClassLoader.loadClass(ClassLoader.java:358).3 more 或 Exception in thread"main"java....
Headers Exchange绑定
import java.util.concurrent.TimeoutException;import com.rabbitmq.client.AMQP.BasicProperties;import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;import ...
CDC问题
try restarting transaction 报错：Cause by：java.lang.ArrayIndexOutOfBoundsException 报错：Caused by:io.debezium.DebeziumException:Received DML 'xxx' for processing,binlog probably contains events generated with statement ...
快速开始
import java.util.concurrent.Semaphore;import com.alibaba.dashscope.common.ResultCallback;import com.alibaba.dashscope.embeddings.TextEmbedding;import com.alibaba.dashscope.embeddings.TextEmbeddingParam;import ...
并发导出数据
重要 表格存储 Java SDK从5.6.0版本开始支持并发导出数据功能。使用并发导出数据功能时，请确保获取了正确的Java SDK版本。关于Java SDK历史迭代版本的更多信息，请参见 Java SDK历史迭代版本。前提条件 已初始化OTSClient。具体操作，请...
获取任务执行进度示例
本文为您介绍如何使用Java SDK获取任务（Task）的执行进度。背景信息 Java SDK提供了 Instance#getTaskProgress 方法用于获取所有Stage中Worker的状态，通过Worker的状态可以计算出Task整体的大致进度。获取任务执行进度过程中会涉及到...
Oracle2PolarDB：Polardb-O兼容性之fetchsize
2020-10-27T19:06:08.935:PRS select ID,INFO,test_time(ID)t from test Exception in thread"main"java.lang.OutOfMemoryError:Java heap space at java.lang.Class.newReflectionData(Class.java:2511)at java.lang.Class.reflectionData...
查询数据
本文档介绍如何使用Java异步、Java、Python语言进行向量检索、预测检索、以及包含过滤条件的检索。相关依赖 Java异步<dependency><groupId>...
使用Java SDK管理Shard
import java.util.concurrent.TimeUnit;public class SplitShard { public static void main(String[]args)throws LogException {/本示例从环境变量中获取AccessKey ID和AccessKey Secret。String accessId=System.getenv("ALIBABA_CLOUD_...
RPC 常见问题
方法一：在 config/java_opts 文件中加入以下启动参数，并重新打包发布。verbose:gc-XX:+PrintGCDetails-XX:+PrintGCDateStamps-Xloggc:/home/admin/logs/gc.log 方法二：用 kill-15 命令结束服务端进程。手动启动 RPC 服务。运行 su admin...
SQL常见问题
报错：exceeded quota:resourcequota 报错：Exceeded checkpoint tolerable failure threshold 报错：Flink version null is not configured for sql 报错：java.util.concurrent.CompletionException:java.lang.IllegalArgumentException ...
将应用从HSF架构迁移到Dubbo（Ali-Tomcat）
本文介绍如何使用Ali-Tomcat将使用HSF框架开发的应用迁移为Dubbo框架开发的应用。...优势是相对比较稳定，适合小步迭代。缺点是需要应用发布两次。...DOCTYPE web-app PUBLIC"-/Sun Microsystems,Inc./DTD Web Application 2.3/EN"...
并发测试示例代码
本文介绍基于Java SDK提供的队列消息发送以及消费的并发测试用例。在并发测试中，您可以：指定并发度、运行时间。通过发送总请求数除以运行时间计算得到QPS。步骤一：初始化 在运行目录创建 perf_test_config.properties 文件，按照如下...
开通与计费常见问题
at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)~?1.8.0_302].3 more 报错原因 工作空间购买的CU数已经使用完。解决方案 对工作空间的CU进行扩容或减少作业请求的资源，详情请参见 资源调整。Flink...
开通与计费常见问题
at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)~?1.8.0_302].3 more 报错原因 工作空间购买的CU数已经使用完。解决方案 对工作空间的CU进行扩容或减少作业请求的资源，详情请参见 资源调整。Flink...
默认接入点收发消息
本文以Java SDK为例介绍如何在VPC环境下使用SDK接入 云消息队列 Kafka 版 的默认接入点并收发消息。前提条件 步骤三：创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装编译工具。本文以 IntelliJ IDEA Ultimate 为例。安装Java...
并发导出数据
重要 表格存储 Java SDK从5.6.0版本开始支持并发导出数据功能。使用并发导出数据功能时，请确保获取了正确的Java SDK版本。关于Java SDK历史迭代版本的更多信息，请参见 Java SDK历史迭代版本。背景 多元索引中提供了Search接口，Search...
Java SDK快速入门
本文介绍如何快速使用日志服务Java SDK完成常见操作，包括创建项目（Project）、创建日志库（Logstore）、写入日志和查询日志等。前提条件 已创建RAM用户并完成授权。具体操作，请参见 创建RAM用户并完成授权。已配置环境变量 ALIBABA_...
SSL接入点PLAIN机制收发消息
本文以Java SDK为例介绍如何在公网环境下使用SDK接入 云消息队列 Kafka 版 的SSL接入点并使用PLAIN机制收发消息。前提条件 步骤三：创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装Java依赖库 在 pom.xml 中添加以下依赖。...
常见问题
处理方法：可以使用 head 和 tail 命令结合日志中生成的时间戳信息，来判断是否由于Java Logging APIs生成的日志导致存储空间占用过大。通常情况下，这些依赖库产生的都是INFO级别日志，不影响组件正常功能使用，但为了避免数据盘存储空间...
通过流引擎实现交易数据实时统计
import java.util.concurrent.Future;public class KafkaToLindormStreamDemo { public static void main(String[]args){ Properties props=new Properties();设置Lindorm Stream Kafka地址 props.put(ProducerConfig.BOOTSTRAP_SERVERS_...
协同消费
import java.nio.charset.StandardCharsets;import java.util.ArrayList;import java.util.List;import org.slf4j.Logger;import org.slf4j.LoggerFactory;public class SimpleProducer { private static final Logger LOGGER=...
快速开始
import java.util.concurrent.Semaphore;import com.alibaba.dashscope.common.ResultCallback;import com.alibaba.dashscope.embeddings.TextEmbedding;import com.alibaba.dashscope.embeddings.TextEmbeddingParam;import ...
接入方式
本文介绍Linkedmall分销消息在多种SDK下的接入方式 JAVA SDK 环境准备 安装1.8或以上版本JDK。具体操作。请参见 安装JDK。安装2.5或以上版本Maven。具体操作，请参见 安装Maven。安装编译工具。安装依赖库 在pom.xml中添加如下依赖...
- 产品推荐
- 这些文档可能帮助您