在sqlserver2014上创建一张空表“test_1”用于存储SparkSQL数据。执行以下语句： create table test_1 (id int, name text, value text); 配置“Spark输入”算子，生成三个字段A、B和C： 设置了数据连接器后，单击“自动识别”，

查看更多 →

MRS Spark 功能 通过MRS Spark节点实现在MRS中执行预先定义的Spark作业。 参数 用户可参考表1，表2和表3配置MRS Spark节点的参数。 表1 属性参数 参数 是否必选 说明 节点名称 是 节点名称，可以包含中文、英文字母、数字、“_”、“-”、“/”

查看更多 →

Spark Core 日志聚合下如何查看Spark已完成应用日志 Driver返回码和RM WebUI上应用状态显示不一致 为什么Driver进程不能退出 网络连接超时导致FetchFailedException 当事件队列溢出时如何配置事件队列的大小 Spark应用执行过程中，

查看更多 →

概述 SParkPack ERP系统需要与泛微OA系统进行集成，完成数据的同步以及单据的审批，现通过 集成工作台 实现同步逻辑，实现功能的同时注重通用性，让实现的功能通过配置可以应用于同类场景不同单据。现以泛微OA Ecology系统与B1系统的集成开发流程为例，介绍利用集成工作台进行开发的思路与实现方式。

查看更多 →

Spark Core 日志聚合下，如何查看Spark已完成应用日志 Driver返回码和RM WebUI上应用状态显示不一致 为什么Driver进程不能退出 网络连接超时导致FetchFailedException 当事件队列溢出时如何配置事件队列的大小 Spark应用执行过程中

查看更多 →

DLI Spark 功能 通过DLI Spark节点执行一个预先定义的Spark作业。 DLI Spark节点的具体使用教程，请参见开发一个DLI Spark作业。 参数 用户可参考表1，表2和表3配置DLI Spark节点的参数。 表1 属性参数 参数 是否必选 说明 节点名称

查看更多 →

使用Spark 运行Spark应用时修改split值报错 提交Spark任务时提示参数格式错误 磁盘容量不足导致Spark、Hive和Yarn服务不可用 引入jar包不正确导致Spark任务无法运行 Spark任务由于内存不够或提交作业时未添加Jar包，作业卡住 提交Spark任务

查看更多 →

、RC和PARQUET）。 说明： PARQUET格式是一种列式存储格式，PARQUET要求Loader的输出字段名和SparkSQL表中的字段名保持一致。 Hive 1.2.0版本之后，Hive使用字段名称替代字段序号对ORC文件进行解析，因此，Loader的输出字段名和SparkSQL表中的字段名需要保持一致。

查看更多 →

在sqlserver2014上创建一张空表“test_1”用于存储SparkSQL数据。执行以下语句： create table test_1 (id int, name text, value text); 配置“Spark输入”算子，生成三个字段A、B和C： 设置了数据连接器后，单击“自动识别”，

查看更多 →

Streaming支持微批模式和连续模式。微批模式不能保证对数据的低延迟处理，但是在相同时间下有更大的吞吐量；连续模式适合毫秒级的数据处理延迟，当前暂时还属于实验特性。 在当前版本中，若需要使用流流Join功能，则output模式只能选择append模式。 图6 微批模式运行过程简图

查看更多 →

sparkpackERP环境问题导致失败 等待sparkpackERP环境恢复后，选择总流程的流 找到运行失败的记录，点击重试（企业微信回调失败后会重试两次，选择一个重试即可） 父主题： 企业微信审批回调结果同步失败处理方式

查看更多 →

JDK版本不匹配导致启动spark-sql和spark-shell失败 问题背景与现象 JDK版本不匹配导致客户端启动spark-sql、spark-shell失败。 原因分析 在Driver端打印异常如下： Exception Occurs: BadPadding 16/02/22

查看更多 →

上传Jar包到OBS和DLI OBS控制台 DLI控制台 将生成的Spark Jar包文件上传到OBS目录下和DLI程序包中。 7 创建Spark Jar作业 DLI控制台 在DLI控制台创建Spark Jar作业并提交运行作业。 8 查看作业运行结果 DLI控制台 查看作业运行状态和作业运行日志。

查看更多 →

SparkPack(B1)和条码集成 应用场景分析 集成方案设计 依赖接口清单描述 父主题： SparkPack 企业ERP条码集成指南

查看更多 →

、RC和PARQUET）。 说明： PARQUET格式是一种列式存储格式，PARQUET要求Loader的输出字段名和SparkSQL表中的字段名保持一致。 Hive 1.2.0版本之后，Hive使用字段名称替代字段序号对ORC文件进行解析，因此，Loader的输出字段名和SparkSQL表中的字段名需要保持一致。

查看更多 →

t，可前往地区和终端节点查询。 cp ~/spark-obs/conf/spark-defaults.conf.template ~/spark-obs/conf/spark-defaults.conf cat >> ~/spark-obs/conf/spark-defaults

查看更多 →

使用Spark/Spark2x Spark使用说明 Spark用户权限管理 Spark客户端使用实践 访问Spark WebUI界面 使用代理用户提交Spark作业 配置Spark读取HBase表数据 配置Spark任务不获取HBase Token信息 Spark Core企业级能力增强

查看更多 →

Streaming支持微批模式和连续模式。微批模式不能保证对数据的低延迟处理，但是在相同时间下有更大的吞吐量；连续模式适合毫秒级的数据处理延迟，当前暂时还属于实验特性。 在当前版本中，若需要使用流流Join功能，则output模式只能选择append模式。 图6 微批模式运行过程简图

查看更多 →

创建“企业微信标准单据审批回调_23-11-0”流 如果有多个标准单据（审批人一致，且不需要更新其它自定义字段），直接到我的流，找到"企业微信回调处理总流程_23-11-0",点击编辑（标准单据审批回调流想要更新自定义字段参考步骤7-步骤14） 滑到左下方，点击添加分支，点击新添

查看更多 →

创建企业微信连接 集成工作台-连接器-我的连接器-创建我的连接 集成工作台-连接器-连接-创建连接-选择连接器 其中corpid与corpsecret在企业微信开发者后台的应用信息处获取，参考术语说明-corpid与术语说明-secret 父主题： 创建到SparkPackERP和OA集成链路

查看更多 →

应用场景介绍 SparkPack(SparkPackERP Business One)和企业微信OA系统需要互通的场景主要为销售、采购、库存领域的单据审批场景，以某个项目为例，需要对接的场景分别为库存收货、库存发货、采购报价单的审批。具体场景描述参考如下。 应用场景 应用场景描述

查看更多 →