阿里云开发者社区-阿里云支持与服务-问答-第38页-阿里云

1

回答

实时计算Flink如何查看VPC

已解决

阿里云服务支持 2022-12-19 264浏览量回答数 1

可以通过实时计算控制台，点击更多-->工作空间详情，就可以看到对应的信息。

阿里云服务支持赞 0 评论 0

1

回答

Flink Datastream作业开发参考示例

已解决

阿里云服务支持 2022-12-19 334浏览量回答数 1

Flink Datastream作业开发可以参考以下示例：

DataHub DataStream Connector示例：如果通过DataStream的方式读写DataHub数据，则需要使用DataHub DataStream Connector连接Flink全托管。
MaxCompute DataStream Connector示例：如果通过DataStream的方式读写MaxCompute数据，则需要使用MaxCompute DataStream Connector连接Flink全托管。
Kafka DataStream Connector示例：如果通过DataStream的方式以精确一次（Exactly-once）的语义在Kafka Topic中读写数据，则需要使用Kafka DataStream Connector连接Flink全托管。
MySQL CDC DataStream Connector示例：MySQL CDC DataStream Connector支持从全量读取到增量读取的无缝切换，保证数据不重不丢。
Hologres DataStream Connector示例：如果通过DataStream的方式读写Hologres数据，则需要使用Hologres DataStream Connector连接Flink全托管。
RocketMQ DataStream Connector示例：如果通过DataStream的方式读写RocketMQ数据，则需要使用RocketMQ DataStream Connector连接Flink全托管。
动态CEP中规则的JSON格式定义示例：介绍了CEP中规则的JSON格式相关信息。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink无法将数据写入到结果表

已解决

阿里云服务支持 2022-12-19 298浏览量回答数 1

可参考文档：如何定位Flink无法将数据写入到结果表的问题？

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错Could not execute CreateTable in path

已解决

阿里云服务支持 2022-12-19 810浏览量回答数 1

可能是报错表的with不对，可以参考对应支持的上下游存储进行检查确认。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink如何消费RDS中的数据

已解决

阿里云服务支持 2022-12-19 285浏览量回答数 1

实时计算Flink集群是计算引擎，不做数据存储，可以使用FlinkCDC作为 SourceConnector，详情参见 MySQL的CDC源表。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink结果表怎么接收json数据

已解决

阿里云服务支持 2022-12-19 364浏览量回答数 1

结果表是没有json类型的，可以定义个varchar类型，拼接成json的字符串然后接收。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错AccessKeyId invalid or expire

已解决

阿里云服务支持 2022-12-19 329浏览量回答数 1

建议检查datahub的AccessKeyId是否写错或者AK是否具有对应的权限。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink SQL默认的state时间

已解决

阿里云服务支持 2022-12-19 234浏览量回答数 1

实时计算引擎VVR4.0.12及以上版本：默认值为1.5天。实时计算引擎VVR4.0.12以下版本：默认值为空，代表State不过期。更多详情请参见设置State相关参数。

阿里云服务支持赞 0 评论 0

1

回答

Flink实时计算与批量计算的差异

已解决

阿里云服务支持 2022-12-19 276浏览量回答数 1

可参考文档：实时计算与批量计算相比存在哪些差异？

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink按量付费集群创建后没有运行作业是否会收费

已解决

阿里云服务支持 2022-12-19 512浏览量回答数 1

会收费。无论是否运行作业，只要开通了Flink全托管按量付费模式，系统就会按照计费规则收费。在不运行作业的情况下，系统也会对管控资源（固定2 CU）计费。另外，flink集群也默认开通了vpc,oss，slb，arms产品，详情参见产品计费项。

阿里云服务支持赞 0 评论 0

1

回答

Flink如何在OSS控制台上传JAR包

已解决

阿里云服务支持 2022-12-19 349浏览量回答数 1

可参考文档：如何在OSS控制台上传JAR包？

阿里云服务支持赞 0 评论 0

1

回答

如何查看当前作业实时计算Flink版本

已解决

阿里云服务支持 2022-12-19 374浏览量回答数 1

可以通过以下方式查看当前作业的Flink版本：

在作业开发页面右侧，单击高级配置，选择常规配置 > 引擎版本。
如果作业已经上线可以在作业运维页面，单击目标作业名称，在配置信息页签下，单击Artifact 配置，即可看到版本信息。

阿里云服务支持赞 0 评论 0

1

回答

Flink的Prometheus监控服务是否可以直接关闭

已解决

阿里云服务支持 2022-12-19 474浏览量回答数 1

Prometheus不支持直接关闭。但是可以卸载Prometheus监控插件，详情参见卸载Prometheus监控插件。

需要注意的是该监控插件一旦被卸载，VVP将不再显示数据曲线。如果作业出现异常现象，将无法定位初始异常时间，并且无法上报监控告警，请谨慎操作。

阿里云服务支持赞 0 评论 0

1

回答

Flink作业在本地能够运行但在集群上报错如何解决

已解决

阿里云服务支持 2022-12-19 264浏览量回答数 1

可以检查使用的connector版本是否和Flink集群版本一致。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink如何消费Kafka

已解决

阿里云服务支持 2022-12-19 312浏览量回答数 1

使用实时计算Flink产品消费Kafka，可以通过raw方式进行解析，详情请点击消息队列Kafka源表。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink和MySQL的类型映射

已解决

阿里云服务支持 2022-12-19 294浏览量回答数 1

实时计算Flink全托管产品支持MySQL源表、MySQL结果表，具体的类型映射可以参考对应的官方文档。更多信息参见 MySQL的CDC源表、结果表类型映射。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink提示Only INSERT and DELETE record are suppo

已解决

阿里云服务支持 2022-12-19 486浏览量回答数 1

需要在Flink ADB的DDL中定义主键，主键同物理表保持一致。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink版SQL是否能自动同步更新的字段到MySQL Catalog源表

已解决

阿里云服务支持 2022-12-19 319浏览量回答数 1

是的，详情可以参考 MySQL的CDC源表。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink进行数据新增时若不同字段的主键相同如何操作

已解决

阿里云服务支持 2022-12-19 258浏览量回答数 1

这个要看结果表是什么类型，如果设置了主键会根据主键进行插入和更新。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink读取Mysql如何授权

已解决

阿里云服务支持 2022-12-19 284浏览量回答数 1

可参考文档：配置MySQL

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink使用Maxcompute维表不会重新加载

已解决

阿里云服务支持 2022-12-19 244浏览量回答数 1

可能是维表语法写错了，识别成了源表。维表写法可以云数据库RDS MySQL维表。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink消费connector存储ddl字段是否需要按物理表字段名/顺序/类型进行定义

已解决

阿里云服务支持 2022-12-19 263浏览量回答数 1

Flink读取connector字段ddl是需要按照物理表的字段名、顺序、类型来定义的。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错SubscriptionSessionInvalidException

已解决

阿里云服务支持 2022-12-19 433浏览量回答数 1

该报错请检查datahub表subid参数是否有填写，或者是否填写有误。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink跨可用区是否能购买

已解决

阿里云服务支持 2022-12-19 264浏览量回答数 1

实时计算Flink产品默认只能访问相同region相同vpc下的存储，对可用区限制不大，可以跨可用区使用。不必担心延时问题，跨地域或同地域跨可用区访问是没有问题的，可用区间延迟和同城可用区之间是10毫秒，临近区域是数十毫秒（与地域距离有关）。

阿里云服务支持赞 0 评论 0

2

回答

虚拟主机如何登录到FTP

已解决

阿里云服务支持 2022-12-19 293浏览量回答数 2

可以通过FileZilla等第三方软件登录到虚拟主机的FTP中，具体操作请看FileZilla使用手册。

阿里云服务支持赞 0 评论 0

1

回答

Flink全托管相同资源配置性能下为什么不及Blink

已解决

阿里云服务支持 2022-12-16 356浏览量回答数 1

Blink是所有作业放到一个整个集群的资源池里，计费、资源管理维度是yarn集群，yarn上资源控制没那么好，所以才可以超用，但是超用的都是用户集群资源池子里，这个已经提前付费了。

Flink是on k8s的，k8s资源管理更完善，可以按每个作业进行的资源管理、独立计费，但是需要每个作业的资源配置比较更合理，避免资源不足，才能保持健康的作业运行状态。只要每个作业配置合理，从Blink迁移到Flink可以更加节省资源。

阿里云服务支持赞 0 评论 0

2

回答

Flink可用区资源不足如何解决

已解决

阿里云服务支持 2022-12-16 372浏览量回答数 2

由于机房整体机位已满，已经无法进行扩容了，建议将作业迁移至相同地域的其他可用区，并对访问外部资源的白名单进行重新配置。

不必担心延时问题，跨地域或同地域跨可用区访问是没有问题的，跨地域或同地域跨可用区访问是没有问题的。

同城可用区之间是10ms，临近区域是数十ms（视地域距离）。

阿里云服务支持赞 0 评论 0

1

回答

Flink购买时创建的SLB是如何收费的

已解决

阿里云服务支持 2022-12-16 322浏览量回答数 1

按量收费分按使用量收费和按规格收费，Flink自动创建的SLB默认是按规格收费的，规格默认使用最小的c型号。

阿里云服务支持赞 1 评论 0

1

回答

实时计算Flink如何访问RDS PostgreSQL

已解决

阿里云服务支持 2022-12-16 290浏览量回答数 1

可参考文档：Postgres的CDC源表

阿里云服务支持赞 0 评论 0

2

回答

Flink SQL如何解析嵌套json

已解决

阿里云服务支持 2022-12-16 725浏览量回答数 2

嵌套json想要获取指定字段，只需要在DDL中row去取对应字段的key就可以，前提是这个对应字段的key在数据中一定存在如果对于那种某些数据中有这个key，某些数据中没有key，这种情况作业运行会报错的，这个需要自行编写udf来解析获取。

更多详情请参见 Flink如何获取JSON数据。例如JSON格式的数据，直接用JSON format解析，会被解析成一个 ARRAY<ROW< cola VARCHAR, colb VARCHAR>> 字段，就是一个 Row类型的数组，其中这个Row类型包含两个VARCHAR字段，然后通过UDTF解析。

{

"data":[

    {

        "cola":"test1",

        "colb":"test2"

    },

    {

        "cola":"test1",

        "colb":"test2"

    },

    {

        "cola":"test1",

        "colb":"test2"

    },

    {

        "cola":"test1",

        "colb":"test2"

    },

    {

        "cola":"test1",

        "colb":"test2"

    }

]

}

阿里云服务支持赞 0 评论 0

3

回答

Flink作业调试介绍

已解决

阿里云服务支持 2022-12-16 235浏览量回答数 3

作业调试功能模拟作业运行、检查输出结果，验证SELECT或INSERT业务逻辑的正确性，提升开发效率，降低数据质量风险。详情参考帮助文档。

阿里云服务支持赞 0 评论 0

1

回答

Flink源表物理表数据删除有什么影响

已解决

阿里云服务支持 2022-12-16 563浏览量回答数 1

源表物理表数据被删除后，是不会对任务的正常运行造成影响的，这个需要看任务的下游sink是否支持更新撤回，当不支持更新撤回的时候，上游删除数据，下游是不会生效的，如果支持更新撤回，下游也会将同一条数据给撤回掉。

阿里云服务支持赞 0 评论 0

1

回答

Flink主键与自增主键的区别

已解决

阿里云服务支持 2022-12-16 314浏览量回答数 1

自增主键不能被算作主键，有些场景下自增主键是可以不需要被声明的，如果一个表是必须要有主键的时候需要声明主键，但不能使用自增主键来代替这个主键（自增主键包含在主键范围内）。

阿里云服务支持赞 0 评论 0

1

回答

Flink暂停恢复与停止重启的作业状态及对应恢复方式

已解决

阿里云服务支持 2022-12-16 761浏览量回答数 1

目前平台将暂停取消掉了，实现了停止后启动可以从状态恢复（当作业停止后状态是会被保留的，如果10天内未对作业进行操作，状态将会被清除），停止前可以手动savepoint，或者自动sp（savepoint）后停止作业，启动作业的时候可以选择从sp恢复或者选择从cp（checkpoint）恢复，作业failover重启是会自动选择从最近一次的cp恢复的。

阿里云服务支持赞 0 评论 0

1

回答