开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink如何设置表级别的超时时间呢?

Flink中sql里边社区全局超时时间是table.exec.state.ttl,如何设置表级别的超时时间呢?

展开
收起
真的很搞笑 2024-03-11 16:37:37 59 0
3 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    在Flink SQL中,要设置表级别的超时时间,可以使用TTL PROPERTIES子句来为表定义超时属性。通过这种方式,您可以为特定的表设置超时时间,而不是全局的超时时间。

    以下是设置表级别超时时间的示例代码:

    CREATE TABLE my_table (
      ... -- 表的定义
    ) WITH (
      ... -- 其他属性
      TTL PROPERTIES (
        ttl = '1 HOUR', -- 设置超时时间为1小时
        ... -- 其他TTL属性
      )
    );
    

    上述代码创建了一个名为my_table的表,并使用TTL PROPERTIES子句设置了超时时间为1小时。您可以根据需要调整ttl的值来设置不同的超时时间。

    2024-03-12 13:41:01
    赞同 展开评论 打赏
  • 是个只会写bug的程序媛啊!!!

    表级别是什么意思?我知道设置秒级别的超时时间,可以在flink-conf.yaml文件中添加下面的配置:

    table.exec.execution-timeout: 30000
    

    也可以在执行任务时通过命令行参数进行设置。

    ./bin/flink run -m yarn-cluster -yn 2 -yjm 1024m -ytm 1024m -ys 2 -yt /path/to/task.jar -sql "SELECT * FROM my_table" -Dtable.exec.execution-timeout=30000
    

    这样设置的最大超时时间为60秒

    2024-03-11 16:48:21
    赞同 展开评论 打赏
  • flink 1.18才支持image.png
    ,此回答整理自钉群“【③群】Apache Flink China社区”

    2024-03-11 16:48:01
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载