nicodeme 2021-05-25 14:24 采纳率: 0%
浏览 9

flink的相关问题

1、Standlone 模式下flink中运行作业,怎么获取保证单个作业生成自己得日志文件?或者获取单个作业的日志?

2、flink中的数据类型与数据库中的数据类型有没有什么匹配的好办法?或者对照表?

  • 写回答

1条回答 默认 最新

  • 憧憬blog 2023-03-14 22:03
    关注

    1、在 Standalone 模式下,可以通过配置 flink-conf.yaml 文件来设置日志文件的路径和名称。具体的设置如下:

    # 配置日志文件路径和名称,以 jobmanager、taskmanager 和 taskexecutor 为例
    log.file: weblogs/flink/jobmanager.log
    log.file.taskmanager: weblogs/flink/taskmanager.log
    log.file.taskexecutor: weblogs/flink/taskexecutor.log
    

    然后,在运行作业时,可以通过通过命令行参数:-Dlog.file=<path/to/custom.log> 来设置日志文件路径和名称,这个设置会覆盖配置文件中的设置。

    如果想要获取单个作业的日志,可以直接进入日志文件所在目录,找到相应的日志文件。如果想要通过 Flink Web UI 来查看作业日志,可以在作业详情页上点击「Show Log」按钮来查看作业的日志。

    2、Flink 中的数据类型与数据库中的数据类型并没有直接的匹配对照表,因为不同的数据库使用的数据类型可能略有不同。但是,对于基本的数据类型,比如整型、浮点型、字符串等,Flink 中的数据类型应该能够和大多数数据库中的数据类型相对应。同时,Flink 还支持对自定义的数据类型进行处理,可以通过实现 Flink 的 SerializedValue 接口来进行序列化和反序列化操作。如果需要将 Flink 中的数据类型与特定数据库中的数据类型匹配,可以参考相关数据库的文档或者咨询专业的数据库技术人员。

    评论

报告相同问题?

悬赏问题

  • ¥15 爬取招聘网站数据信息
  • ¥15 安装完tensorflow,import tensorflow as tf后报错,如何解决?
  • ¥15 ultralytics库导出onnx模型,模型失去预测能力
  • ¥15 linux下点对点协议连接2个USB串口的硬件流量控制问题
  • ¥15 SQL数据自动生成问题
  • ¥15 设密码后无法访问他人的共享文件
  • ¥15 浏览器打不开学校网页
  • ¥100 android开发打不开相册,不弹出授权信息,请问怎么解决?
  • ¥15 我想通过python处理sybase IQ库的一些数据,但是不知道sybase IQ库怎么连接,之前连接都是用linux上的 dbisql
  • ¥15 安装llama-cpp-python==0.1.83失败