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

查看更多 →

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

查看更多 →

配置微信通知规则 前提条件 NetEco用户已具备“远程通知”的操作权限。 微信通知 服务器 已启用。 微信通知用户已创建。 已获取公众号中设置的告警通知模板id。 操作步骤 选择“系统 > 系统设置 > 远程通知”。 在左侧导航区域中，单击“三方APP通知设置 > 通知规则”。 在“通知规则”页面中，单击“新增”。

查看更多 →

创建“企业微信自定义单据审批回调_23-11-0”流 有其它的自定义单据，在我的流中找到"企业微信自定义单据审批回调_23-11-0",点击复制，输入名称，点击确定（自定义单据审批回调流需要修改自定义字段的可参考步骤4-步骤9，不需要可跳过） 选择刚刚复制的流，点击更多-配置管理

查看更多 →

SparkRTC支持接入微信小程序吗？ SparkRTC不支持微信小程序端SDK。 父主题： 产品咨询

查看更多 →

集成实施最佳实践 前期准备 创建servicelayer连接器 封装servicelayer执行动作 创建泛微OA连接器 封装泛微OA执行动作 创建业务流 父主题： SparkPack 企业ERP泛微OA集成指南

查看更多 →

点击扩展配置，点击更新 选择"企业微信自定义单据审批回调_23-11-0"，点击更多-配置管理 点击下一步，输入单据唯一标识，点击下一步，点击更新 再选择"企业微信回调处理总流程_23-11-0"，点击编辑 复制URL地址到企业微信管理后台的URL，再滑到最左下方，将对应的企业微信表单模板ID填入

查看更多 →

“获取审批详情”，参数如图所示： 添加执行动作，选择连接器为创建的SparkPackERP连接器，执行动作为“微信-SparkPackERP数据转换”，参数如图所示（此步骤使用函数将企业微信数据结构转换成SparkPackERP数据结构，也可以封装一些有关审批信息的需要的字段）：

查看更多 →

适用场景 本文主要指导实施顾问如何实施SparkPackERP与企业微信的集成，当前支持的OA场景如下： 表1 基础场景 涉及单据 数据流向 草稿单据同步 采购申请（实施参考5.4.3.3.1） SparkPackERP->OA 草稿单据审批 采购申请（实施参考5.4.3.3.2与5

查看更多 →

箱就更好了。其他像163、QQ等免费邮箱服务不稳定，不一定可以发送邮件成功的。 公众号绑定成功（认证服务号），在微信群发时显示“用户查询错误”？ 您需要在管理后台的“微信管理>用户管理”中，单击“用户同步”，然后再群发信息。 当客户在留言板块留言时，如何设置可以通过邮件提醒网站所有者？

查看更多 →

标准单据场景流创建 创建“SparkPackERP标准单据同步至企业微信_23-11-0”流 创建“企业微信回调处理总流程_23-11-0”流 创建“企业微信标准单据审批回调_23-11-0”流 父主题： 基于复制的流模板部署流

查看更多 →

如何使用PySpark连接 MRS Spark？ 问： 如何在E CS 服务器上用PySpark连接内网开启Kerberos认证的MRS Spark集群？ 答： 将Spark的“spark-defaults.conf”文件中“spark.yarn.security.credentials

查看更多 →

自定义单据场景流创建 创建“SparkPackERP自定义单据同步企业微信_23-11-0”流 创建“企业微信回调处理总流程_23-11-0”流 创建“企业微信自定义单据审批回调_23-11-0”流 父主题： 基于复制的流模板部署流

查看更多 →

SparkPack 企业ERP和钉钉集成 修订记录 应用场景介绍 集成方案设计 依赖接口清单描述 集成实施最佳实践 SQL版本审批流部署流程

查看更多 →

batchJob.asyncSubmit(); SparkJobStatus sparkJobStatus=batchJob.getStatus(); System.out.println(sparkJobStatus); } 查询批处理作业日志 DL

查看更多 →

开发Spark应用 Spark Core样例程序 Spark SQL样例程序 通过JDBC访问Spark SQL样例程序 Spark读取HBase表样例程序 Spark从HBase读取数据再写入HBase样例程序 Spark从Hive读取数据再写入HBase样例程序 Spark S

查看更多 →

开发Spark应用 Spark Core样例程序 Spark SQL样例程序 通过JDBC访问Spark SQL样例程序 Spark读取HBase表样例程序 Spark从HBase读取数据再写入HBase样例程序 Spark从Hive读取数据再写入HBase样例程序 Spark S

查看更多 →

多保留20个文件，压缩存储。 日志大小和压缩文件保留个数可以在 FusionInsight Manager界面中配置。 表1 Spark2x日志列表 日志类型 日志文件名 描述 SparkResource2x日志 spark.log Spark2x服务初始化日志。 prestart

查看更多 →

Spark Streaming Streaming任务打印两次相同DAG日志 Spark Streaming任务一直阻塞 运行Spark Streaming任务参数调优的注意事项 为什么提交Spark Streaming应用超过token有效期，应用失败 为什么Spark Str

查看更多 →

将集群角色spark-role和上一步创建服务账号绑定，并指定default命名空间授予edit的clusterrole权限 kubectl create clusterrolebinding spark-role --clusterrole=edit --serviceaccount=default:spark

查看更多 →

Spark对接OpenTSDB 创建表关联OpenTSDB 插入数据至OpenTSDB表 查询OpenTSDB表 默认配置修改 父主题： 使用Spark（MRS 3.x之前版本）

查看更多 →