产品使用常见问题

Q：如何快速测试流计算作业是否有问题？
A：可通过以下步骤进行测试。

• 在IDE开发页面进行在线开发，开发完毕后，可点击“单元测试”快速进行作业测试；

• 单元测试使用线下上传的测试数据包充当数据源，支持对数据进行延迟、乱序测试，并快速生成结果；

• 单元测试无误后，可将作业发布到测试环境，进行试运行。经过数据验证后，可将该流计算作业发布至生产环境进行正式运行。

Q：流计算作业怎么更新？
A：可通过以下步骤进行测试。

• 流计算作业支持多版本，版本生成动作通过开发IDE界面的“提交”进行触发。

• 作业提交前，可以在流计算的开发IDE页面进行作业编辑。

• 作业提交后，为保障已有版本作业的稳定，以后版本不可再进行编辑操作，但可以通过生成新版本的方式替换老版本，实现流作业的更新。

Q：SavePoint有什么作用，如何创建？
A：SavePoint可以支持程序升级后，继续从升级前的那个点开始执行计算，保证数据不中断。SavePoint需要用户手动创建。

Q：是否支持自定义函数，自定义函数的作用范围多大？
A：流计算支持用户自定义函数，函数统一作用在租户级别。

Q：流计算是否支持用户自定义扩展插件？
A：流计算支持Kafka source、SQL Operator、ETL Operator、JDBC sink、HBase sink、ElasticSearch sink、Redis sink、Kafka sink 这8个插件，可灵活满足用户的各种需求。插件由平台统一维护，不支持租户自定义扩展。

Q：流计算有哪些使用限制？
A：Flink SQL不支持TopN、Emit等语法，可采用ETL实现。Kafka source多流Join，不可同时支持多个Kafka 版本。