碰到這么個代碼:

import com.alibaba.fastjson.JSON;import org.apache.flink.streaming.api.functions.ProcessFunction; import org.apache.flink.util.Collector;import java.time.LocalDateTime; import java.time.OffsetDateTime; import java.time.ZoneOffset; import java.time.format.DateTimeFormatter;/*** 解析Kafka數(shù)據(jù)*/public class BrowseKafkaProcessFunction extends ProcessFunction<String, UserBrowseLog> {@Overridepublic void processElement(String value, Context ctx, Collector<UserBrowseLog> out) throws Exception {try {UserBrowseLog log = JSON.parseObject(value, UserBrowseLog.class);// 增加一個long類型的時間戳// 指定eventTime為yyyy-MM-dd HH:mm:ss格式的北京時間DateTimeFormatter format = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");OffsetDateTime eventTime = LocalDateTime.parse(log.getEventTime(), format).atOffset(ZoneOffset.of("+08:00"));// 轉換成毫秒時間戳long eventTimeTimestamp = eventTime.toInstant().toEpochMilli();log.setEventTimeTimestamp(eventTimeTimestamp);out.collect(log);}catch (Exception ex){log.error("解析Kafka數(shù)據(jù)異常...",ex);}} }

log.error反復報告cannot resolve symbol 'log'

蒙蔽了好久

解決方案:

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class BrowseKafkaProcessFunction extends ProcessFunction<String, UserBrowseLog> {
...

...

}

總結

以上是生活随笔為你收集整理的cannot resolve symbol ‘log‘问题解决的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內容還不錯，歡迎將生活随笔推薦給好友。