Hi Guowei,
Thanks for pointing that out! It helps me resolve the issue.
Just a small correction: `static` identifier is not available in Scala. Its
Scala alternative is `object`.
```scala
object BaseJob {
final val LOG = LoggerFactory.getLogger(getClass)
}
```
Then referencing the LOG objec
Hi, Yik San
You need to change the following line:
protected final val LOG = LoggerFactory.getLogger(getClass)
protected *static* final val LOG = LoggerFactory.getLogger(getClass)
Best,
Guowei
On Mon, May 24, 2021 at 2:41 PM Yik San Chan
wrote:
> Hi community,
>
> I have a job that cons
Hi community,
I have a job that consumes data from a datagen source, tries to log
something in `map` operators, and sinks the result to a DiscardingSink. The
full example can be found in [the repo](
https://github.com/YikSanChan/log-in-flink-operator).
The `Job` extends `BaseJob` where `preproces
