-
Flink开启Checkpoint样例程序（Scala）
![]()
import org.apache.flink.api.java.tuple.Tuple import org.apache.flink.streaming.api.checkpoint.ListCheckpointed import org.apache.flink.streaming
来自：帮助中心 -
Jenkins依赖环境准备
![]()
Jenkins依赖环境准备 安装maven 复制文件apache-maven-3.8.1-bin.tar.gz 到 /usr/local 解压 cd /usr/local tar -zxvf apache-maven-3.8.1-bin.tar.gz 备份 cp apache-maven-3.8.1-bin
来自：帮助中心 -
使用Flink Jar写入数据到OBS开发指南
![]()
import org.apache.flink.api.common.serialization.SimpleStringEncoder; import org.apache.flink.api.java.utils.ParameterTool; import org.apache.flink
来自：帮助中心 -
有大量分区时执行drop partition操作失败
![]()
to reconnect. | org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:187) org.apache.thrift.transport.TTransportException
来自：帮助中心 -
如何在导入Hive表时指定输出的文件压缩格式？
![]()
当前Hive支持以下几种压缩格式： org.apache.hadoop.io.compress.BZip2Codec org.apache.hadoop.io.compress.Lz4Codec org.apache.hadoop.io.compress.DeflateCodec org.apache.hadoop
来自：帮助中心 -
IoTDB自定义函数（UDF）样例程序
![]()
bigdata.iotdb; import org.apache.iotdb.udf.api.UDTF; import org.apache.iotdb.udf.api.access.Row; import org.apache.iotdb.udf.api.collector.PointCollector;
来自：帮助中心 -
IoTDB自定义函数（UDF）样例程序
![]()
bigdata.iotdb; import org.apache.iotdb.udf.api.UDTF; import org.apache.iotdb.udf.api.access.Row; import org.apache.iotdb.udf.api.collector.PointCollector;
来自：帮助中心 -
消费端限流
![]()
import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.common.consumer.ConsumeFromWhere; import org.apache.rocketmq
来自：帮助中心 -
java样例代码
![]()
import org.apache.spark.SparkConf; import org.apache.spark.SparkContext; import org.apache.spark.api.java.JavaRDD; import org.apache.spark.api
来自：帮助中心 -
执行Spark Core应用，尝试收集大量数据到Driver端，当Driver端内存不足时，应用挂起不退出
![]()
am.java:371) at org.apache.spark.serializer.JavaDeserializationStream.readObject(JavaSerializer.scala:71) at org.apache.spark.serializer.JavaSerializerInstance
来自：帮助中心 -
Flink Job Pipeline样例程序（Java）
![]()
examples; import org.apache.flink.api.java.tuple.Tuple2; import org.apache.flink.configuration.Configuration; import org.apache.flink.streaming.api
来自：帮助中心 -
收发顺序消息
![]()
org.apache.rocketmq.client.exception.MQBrokerException; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq
来自：帮助中心 -
参考Hive JDBC代码用例开发的业务应用运行失败
![]()
Source) at org.apache.thrift.transport.TSaslClientTransport.handleSaslStartMessage(TSaslClientTransport.java:94) at org.apache.thrift.transport
来自：帮助中心 -
使用LZC压缩算法存储HDFS文件
![]()
org.apache.hadoop.io.compress.DefaultCodec,org.apache.hadoop.io.compress.DeflateCodec,org.apache.hadoop.io.compress.Lz4Codec,org.apache.hadoop
来自：帮助中心 -
Flink开启Checkpoint样例程序（Scala）
![]()
import org.apache.flink.api.java.tuple.Tuple import org.apache.flink.streaming.api.checkpoint.ListCheckpointed import org.apache.flink.streaming
来自：帮助中心 -
正则表达式分隔半结构化文本
![]()
Log4J日志 Log4J审计日志 Tomcat日志 Django日志 Apache server日志 Log4J日志 日志样例： 2018-01-11 08:50:59,001 INFO [org.apache.sqoop.core.SqoopConfiguration.conf
来自：帮助中心 -
正则表达式分隔半结构化文本
![]()
Log4J日志 Log4J审计日志 Tomcat日志 Django日志 Apache server日志 Log4J日志 日志样例： 2018-01-11 08:50:59,001 INFO [org.apache.sqoop.core.SqoopConfiguration.conf
来自：帮助中心 -
正则表达式分隔半结构化文本
![]()
Log4J日志 Log4J审计日志 Tomcat日志 Django日志 Apache server日志 Log4J日志 日志样例： 2018-01-11 08:50:59,001 INFO [org.apache.sqoop.core.SqoopConfiguration.conf
来自：帮助中心 -
工程结构
![]()
device.terminal; import org.apache.http.*; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.HttpRequestRetryHandler;
来自：帮助中心 -
Flink开启Checkpoint样例程序（Java）
![]()
import org.apache.flink.api.java.tuple.Tuple4; import org.apache.flink.streaming.api.checkpoint.ListCheckpointed; import org.apache.flink.streaming
来自：帮助中心 -
Flink客户端执行命令报错“Error while parsing YAML configuration file : security.kerberos.login.principal:pippo”
![]()
principal:pippo " | org.apache.flink.configuration.GlobalConfiguration (GlobalConfiguration.java:160) Exception in thread "main" org.apache.flink.configuration
来自：帮助中心
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
