Java:Spymemcache
import java.util.concurrent.ExecutionException;import net . spy . memcached . AddrUtil ;import net . spy . memcached . ConnectionFactoryBuilder ;import net . spy . memcached . ConnectionFactoryBuilder . Protocol ;import ...
开源SDK接入（跨云账号授权）
本文以调用Java SDK为例，介绍在RAM角色跨账号授权场景，通过开源SDK实现消息收发的操作过程，帮助您更好地理解消息收发的完整过程，其他语言或框架的SDK消息收发过程相似。前提条件 创建实例 创建Vhost 背景信息 当您需要通过RAM STS角色...
java.util.concurrent.ExecutionException
问题描述 Quick BI数据集预览报错：null:INTERNAL:java.sql.SQLException:java.util.concurrent.ExecutionException:java.sql.SQLException:execute sql[SELECT ALI_T_1_.`category_name` AS T_A1D_2_,ALI_T_1_.`sku_real_price`-ALI_T_1_....
快速开始
import java.util.concurrent.ConcurrentLinkedQueue;import java.util.concurrent.CountDownLatch;import java.util.concurrent.atomic.AtomicBoolean;import javax.sound.sampled.*;public class Main { public static void ...
快速开始
import java.util.concurrent.ConcurrentLinkedQueue;import java.util.concurrent.CountDownLatch;import java.util.concurrent.atomic.AtomicBoolean;import javax.sound.sampled.*;public class Main { public static void ...
快速使用MQTT的Java SDK收发消息（终端和云端消息收发...
本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端和云端服务的消息收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...
Java 应用接入账户同步示例
本篇文档以 Java 为例，讲解作为应用与 IDaaS 的对接。若您希望了解对接原理和调用流程，请参考 账户同步接入概述。接入账户同步可能需要处理两点：验签 解密（可选）进行完上述过程后，即可获取到该次事件的请求内容，应用自行处理即可。1...
收发延时消息
本文提供使用 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。准备环境。（可选）日志配置。背景信息 通过定时消息，在消息发送后，可以在当前时间点之后的某一个时间点，再投递到...
微消息队列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....
更新数据
本文档介绍如何使用Java、Python语言进行更新表数据，支持的更新操作有add、delete。相关依赖 Java异步<dependency><groupId>...
异步化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 ...
数据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...
步骤三：调用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....
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...
通过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 { ...
通过SDK写入时序数据
日志服务支持通过SDK写入时序数据，本文列举了Java、Golang和Python语言的SDK demo。说明 使用SDK写入时序数据时，需遵循 时序数据格式。尽可能使用Producer Library发送数据，目前支持ProducerLibrary的语言有 Java、Golang 和 C。使用...
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....
通过流引擎实现地理围栏监控
import java.util.concurrent.ExecutionException;import java.util.concurrent.Future;public class LindormStreamDemoGanos { public static void main(String[]args)throws InterruptedException,ExecutionException,JSONException { ...
常见问题
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....
常见问题
java.util.concurrent.TimeoutException at com.alipay.mychain.gl.biz.common.AbstractTransport.sendTwoWayAndSync(AbstractTransport.java:205)答：首先检查客户端所在的环境与区块链节点网络是否连通。可以从sdk.properties配置文件中...
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 ...
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 ...
并发导出数据
重要 表格存储 Java SDK从5.6.0版本开始支持并发导出数据功能。使用并发导出数据功能时，请确保获取了正确的Java SDK版本。关于Java SDK历史迭代版本的更多信息，请参见 Java SDK历史迭代版本。前提条件 已初始化OTSClient。具体操作，请...
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获取任务（Task）的执行进度。背景信息 Java SDK提供了 Instance#getTaskProgress 方法用于获取所有Stage中Worker的状态，通过Worker的状态可以计算出Task整体的大致进度。获取任务执行进度过程中会涉及到...
使用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_...
将应用从HSF架构迁移到Dubbo（Ali-Tomcat）
本文介绍如何使用Ali-Tomcat将使用HSF框架开发的应用迁移为Dubbo框架开发的应用。...优势是相对比较稳定，适合小步迭代。缺点是需要应用发布两次。...DOCTYPE web-app PUBLIC"-/Sun Microsystems,Inc./DTD Web Application 2.3/EN"...
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 ...
并发测试示例代码
本文介绍基于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 Native SDK连接并使用Lindorm时序引擎
本文介绍通过Java Native SDK连接并使用Lindorm时序引擎的方法。前提条件 已安装Java环境，要求安装JDK 1.8及以上版本。时序引擎版本为3.4.7及以上版本，如何查看或升级当前版本，请参见 时序引擎版本说明 和 升级小版本。已将客户端IP地址...
消息队列RabbitMQ版推送事件到函数计算
import java.util.concurrent.TimeoutException;import java.util.HashMap;import java.util.UUID;public class ProducerTest { public static void main(String[]args)throws IOException,TimeoutException { ConnectionFactory factory=...
并发导出数据
重要 表格存储 Java SDK从5.6.0版本开始支持并发导出数据功能。使用并发导出数据功能时，请确保获取了正确的Java SDK版本。关于Java SDK历史迭代版本的更多信息，请参见 Java SDK历史迭代版本。背景 多元索引中提供了Search接口，Search...
- 产品推荐
- 这些文档可能帮助您