本文介绍监控告警与日志问题。

Datastream作业TM日志中抛NullPointerException如果没有详细错误栈怎么办？

在作业运维页面，单击目标作业名称后，单击返回开发后，在页面右侧高级配置面板的更多Flink配置中，添加如下代码。
env.java.opts: "-XX:-OmitStackTraceInFastThrow"

如何针对单个Class设置日志级别参数？

例如，设置Kafka Connector相关的log4j.logger.org.apache.kafka.clients.consumer=trace（源表）和log4j.logger.org.apache.kafka.clients.producer=trace（结果表）参数时，需要在Log Levels中配置，不能在其他配置中配置。参数设置

如何开启Flink全托管GC日志参数？

在作业运维页面，单击目标作业名称后，单击返回开发后，在页面右侧高级配置面板的更多Flink配置中，添加如下代码。
env.java.opts: >-
-XX:+PrintGCDetails -XX:+PrintGCDateStamps -Xloggc:/flink/log/gc.log
-XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=2 -XX:GCLogFileSize=50M

Datastream作业无延迟、输出曲线，应该如何处理？

  • 问题详情

    源表有源源不断的数据进入Flink，Kafka物理表每个Partition也是有源源不断的数据的情况下，Datastream作业Kafka Source CurrentEmitEventTimeLag和CurrentFetchEventTimeLag显示作业延迟为52年。

  • 问题原因

    Datastream中Kafka Connector依赖是社区的Connector，不是Ververica内置的Connector。社区Connector是没有实现曲线汇报逻辑的，所以输入输出延迟等曲线显示异常。

  • 解决方案

    使用Ververica Connector依赖，详情请参见ververica maven仓库。

如何解决非Static方法输出不到SLS中的问题？

  • 问题详情

    由于SLS Logger Appender实现逻辑，非Static方法输出不到SLS中。

  • 解决方案

    您需要使用标准的定义方式private static final Logger LOG = LoggerFactory.getLogger(xxx.class);。