MapReduce常见问题

如果是Map-Only作业,需要显式指定Reducer数量为0,即 job.setNumReduceTasks(0)。Mapper中输入表中的每条Record数据,是否可以按列名读取?可以。输入表中的每条Record数据不仅可以按序号 record.get(i)读取,还可以按照列名来获取Record...

Tunnel常见错误码

本文您介绍使用Tunnel过程中的常见错误码,帮助您了解错误码产生原因,并提供解决措施。Tunnel常见错误码如下:报信息:ErrorCode=NoSuchPartition,ErrorMessage=The specified partition does not exist.报信息:ErrorCode=...

函数实例生命周期回调方法

944bca62-b209-47a1-9e48-2723647bce0a 示例程序 函数计算 您提供了使用Initializer回调和PreStop回调的MySQL示例程序。在本示例中,Initializer回调函数用于从环境变量中获取MySQL数据库配置,创建MySQL连接并测试连通性,PreStop回调...

函数实例生命周期回调方法

944bca62-b209-47a1-9e48-2723647bce0a 示例程序 函数计算 您提供了使用Initializer回调和PreStop回调的MySQL示例程序。在本示例中,Initializer回调函数用于从环境变量中获取MySQL数据库配置,创建MySQL连接并测试连通性,PreStop回调...

函数实例生命周期回调方法

944bca62-b209-47a1-9e48-2723647bce0a 示例程序 函数计算 您提供了使用Initializer回调和PreStop回调的MySQL示例程序。在本示例中,Initializer回调函数用于从环境变量中获取MySQL数据库配置,创建MySQL连接并测试连通性,PreStop回调...

函数实例生命周期回调

index.preStop 2023-09-06 11:08:102023-09-06 11:08:10 944bca62-b209-47a1-9e48-2723647bce0a[verbose]preStop 2023-09-06 11:08:10FC PreStop End RequestId:944bca62-b209-47a1-9e48-2723647bce0a 示例程序 函数计算 您提供了...

快速创建函数

如果您的函数在执行时报"Unable to import module 'index'",需要先确认请求处理程序(函数入口)配置是否错误,然后确认依赖是否安装,具体请参见 函数安装第三方依赖。函数计算提供通过Serverless Devs工具构建应用、调试应用和部署...

请求处理程序(Handler)

命名空间和类 命名空间 Example,类名 Hello,方法名 StreamHandler,假设程序集名称 HelloFcApp,则请求处理程序的配置 HelloFcApp:Example.Hello:StreamHandler。参数 Stream input 处理程序的输入,该示例的输入类型Stream...

快速创建函数

相关文档 如果您的函数在执行时报"Unable to import module 'index'",需要先确认请求处理程序(函数入口)配置是否错误,然后确认依赖是否安装,具体请参见 函数安装第三方依赖。函数计算提供通过Serverless Devs工具构建应用、调试...

代码模板

累积窗口聚合 如果您需要提早看到窗口的计算结果,例如每分钟看到最新的窗口结果,则可以使用累积窗口。说明 累积窗口聚合不支持CDC,使用CDC后语法校验会报 org.apache.flink.table.api.TableException:Not supported window type:...

DAG作业快速开始

如果您还开通批量计算服务,请先开通。命令行工具安装和配置 命令行工具安装和配置 作业准备 本作业的目的是求和,将 input.txt 中的数字全部加起来,求和后写入 output.txt。由于计算比较简单本作业只需 1 个任务。本例将 OSS 的目录...

请求处理程序(Handler)

您可以使用Python请求处理程序响应接收到的事件并执行相应的业务逻辑。本文介绍Python请求处理程序的相关概念、结构特点和示例。什么是请求处理程序 FC 函数的请求处理程序,是函数代码中处理请求的方法。当您的 FC 函数被调用时,函数计算...

普通模式和Hive兼容模式下SQL的差异

计算结果溢出 Hive兼容模式 set odps.sql.hive.compatible=true;set odps.function.strictmode=true;select(100L+a)from values(9223372036854775807L)t(a);计算结果溢出,但是不会报错 Hive select(100L+9223372036854775807L);返回...

设置实例自定义健康检查

步骤一的代码示例,函数实例健康检查正常,返回结果为OK。修改代码中的健康检查部分为下面的代码,然后单击 部署代码,代码部署成功后,再次单击 测试函数,查看函数运行结果。修改后的代码内容如下。app.get('/readyz',(req,res)=>{ ...

事件请求处理程序(Event Handler)

在以下Node.js Express示例中,POST方法和/initialize 路径会在函数实例初始化时被 函数计算 调用,POST方法和/invoke 路径 函数计算 被调用时的Handler,通过 req.headers 以及 req.body 获取 context 和 event 并将函数返回结果通过...

请求处理程序(Handler)

您可以通过 函数计算控制台 配置 请求处理程序,对于Java语言的函数,您的请求处理程序需配置[包名].[类名]:[方法名]。例如,您的包名example,类型HelloFC,方法名handleRequest,则请求处理程序可配置 example.HelloFC:...

日志服务SLS

本文您介绍如何使用日志服务SLS连接器。背景信息 日志服务 是针对日志类数据的一站式服务。日志服务可以帮助您快捷地完成数据采集、消费、投递以及查询分析,提升运维和运营效率,建立海量日志处理能力。SLS连接器支持的信息如下。类别 ...

HTTP请求处理程序(HTTP Handler)

不设置 x-fc-status:函数计算 默认本次调用是成功执行的,但是您的函数可能有异常,没有向 函数计算 汇报,函数计算 会认为这次函数执行没有报,在业务逻辑上可能没有影响,但是在监控可观测性上会有影响。如下图所示:设置 x-fc-status...

消费-计量计费日志

计量程序每隔固定时间消费LogHub中步长数据,在内存中计算生成计费数据结果。(附加)对明细数据查询需求,可以将计量日志配置索引查询。(附加)将计量日志推送至OSS、MaxCompute 进行离线存储,进行T+1等对账与统计。实时计量程序内部...

配置HTTP触发器并使用WebSocket触发

如下图所示,一个函数的并发度设置2,第一个请求到达的时间T1,结束时间T3,第二个请求到达时间T2,结束时间T4,计费时间T4-T1,其中T2到T3这段时间只会被计费一次,不会被重复计费。更多示例 Custom Runtime Custom Container...

OSS挂载

比如\127.0.0.1\ossdata\bucket\dir 是 OSS 上已经存在的一个文件夹,应用程序挂载后又在 dir 文件夹里创建了一个文件 file,那么 \127.0.0.1\ossdata\bucket\dir\file 文件是办法删除和重命名的。但是如果在 \127.0.0.1\ossdata\bucket\...

使用限制

split_size 默认为64 MB,您可自行设置,范围为0≤(9223372036854775807>>20)。MaxCompute Graph程序中的GraphLoader、Vertex、Aggregator等在集群运行时,受到Java沙箱的限制(Graph作业的主程序则不受此限制),具体限制请参见 Java...

HTTP触发器概述

此时,您可以在代码中添加HTTP请求头 x-fc-async-delay,其取值范围0,3600),单位为秒。函数计算 将从您触发执行开始计算,延迟 x-fc-async-delay 设置的时间后触发函数调用。更多信息,请参见 延迟调用。认证鉴权 函数计算支持对HTTP...

PyODPS常见问题

In[42]:df from_x from_y to_x to_y 0 0.393094 0.427736 0.463035 0.105007 1 0.629571 0.364047 0.972390 0.081533 2 0.460626 0.530383 0.443177 0.706774 3 0.647776 0.192169 0.244621 0.447979 4 0.846044 0.153819 0.873813 0....

Python SDK常见问题

In[42]:df from_x from_y to_x to_y 0 0.393094 0.427736 0.463035 0.105007 1 0.629571 0.364047 0.972390 0.081533 2 0.460626 0.530383 0.443177 0.706774 3 0.647776 0.192169 0.244621 0.447979 4 0.846044 0.153819 0.873813 0....

配置HTTP触发器并使用gRPC触发

如下图所示,一个函数的并发度设置2,第一个请求到达的时间T1,结束时间T3,第二个请求到达时间T2,结束时间T4,计费时间T4-T1,其中T2到T3这段时间只会被计费一次,不会被重复计费。客户端流式、服务端流式和双向流式请求:...

产品优势

结果可视 E-HPC提供可视化服务功能,您可以通过可视化服务功能将计算结果转换可读的图形化数据。例如您可以直接观看渲染后的动画效果,或者直接查看天气变化的动态图。E-HPC与传统计算集群对比的优势 对比项 E-HPC 传统计算集群 部署 ...

云数据库RDS MySQL版

在Flink计算引擎VVR 4.0.0~4.0.6版本,该参数默认值为0。在Flink计算引擎VVR 3.x版本及以下版本,该参数默认值为1000。在默认值为0的版本中,如果不配置该参数,可能导致少量数据永远无法写出到结果表。建议您采用更高版本的Flink。...

Flink Python作业快速入门

批作业结果为ext文件,下载后可以用记事本或者Microsoft Office Word打开查看结果,计算结果如下图所示。(可选)步骤六:停止作业 如果您对作业进行了修改且希望修改生效,则需要将 运行中 或 已完成 的作业停止再启动。另外,如果作业...

开发部署扩展程序:函数计算方式

本文您介绍如何通过函数计算方式开发部署扩展程序。权限说明 开放平台管理员 和 租户管理员 拥有 开发者后台 的读写权限,其他租户级角色、空间级角色仅拥有开发者后台的只读权限。详情请参见 全局级模块权限控制。仅支持阿里云主账号...

数据正确性

将节点拆分,然后观察每个节点的Bytes Received(输入)和Bytes Sent(输出),确定数据在哪个节点被过滤,如果某个节点输出为0,输入不为0,说明数据被这个节点过滤了。常见的导致数据无输出的算子包括join、window或where。检查下游是否...

聚合函数

示例四-由于聚合函数的参数中携带了DISTINCT关键字,此时wm_concat函数中bigint类型的入参sal会被隐式转换string类型,-为了与wm_concat函数的入参类型保持一致,则order by sal中需要使用cast将sal转换string类型,否则会导致报。...

Flink JAR作业快速入门

流作业示例的计算结果 在TaskManager中以.out 结尾的日志文件中,搜索shakespeare查看Flink计算结果。批作业示例的计算结果 登录 OSS管理控制台,在您配置的数据输出文件存放目录查看结果。本示例中的数据输出文件目录 oss:/flink-test-...

事件请求处理程序(Event Handler)

命名空间和类 命名空间 Example,类名 Hello,方法名 StreamHandler,假设程序集名称 HelloFcApp,则请求处理程序的配置 HelloFcApp:Example.Hello:StreamHandler。参数 Stream input 处理程序的输入,该示例的输入类型Stream...

概述

例如,假设上图中Worker数是2,则v0、v2会被分配到Worker0,因为ID对2取模结果为0。而v1、v3、v5将被分配到Worker1,ID对2取模结果为1。迭代计算 一次迭代为一个超步(SuperStep),遍历所有非结束状态(Halted值为False)的点或者收到消息...

Sequence

print(iris['sepallength'].head(5))返回结果 sepallength 0 4.9 1 4.7 2 4.6 3 5.0 4 5.4 列类型 DataFrame拥有自己的类型系统,进行表初始化时,MaxCompute的类型会被转换成对应的DataFrame类型,以便支持更多类型的计算后端。...

管理函数

函数计算 的资源调度与运行以函数单位。一个服务下可以创建多个函数,这些函数彼此相互独立,互不影响,但这些函数可以共享一些相同的设置,例如服务授权和日志配置等。您可以通过 函数计算 控制台创建函数、更新函数及获取函数ARN等。...

管理函数

函数计算 的资源调度与运行以函数单位。不同函数彼此相互独立,互不影响。您可以通过 函数计算 控制台创建函数、更新函数及获取函数ARN等。创建函数 登录 函数计算控制台,在左侧导航栏,单击 函数。在顶部菜单栏,选择地域,然后在 函数...

STDDEV_SAMP

窗口仅包含1条 expr 值非NULL的数据时,结果为0。示例数据 为便于理解各函数的使用方法,本文为您提供源数据,基于源数据提供函数相关示例。创建表emp,并添加数据,命令示例如下:create table if not exists emp(empno bigint,ename ...

HTTP触发器调用函数

text/*application/json application/ld+json application/xhtml+xml application/xml application/atom+xml application/javascript 响应结构体 响应结构体格式 当函数返回响应时,函数计算会解析响应并将其转换HTTP响应。解析后的响应...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云数据库 RDS 数据库备份 轻量应用服务器 云服务器 ECS 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用