Hi Jiazhi,
Try ctx.timerService().currentProcessingTime()
Best,
Mike
On Sun, Aug 16, 2020 at 4:48 AM ゞ野蠻遊戲χ wrote:
> Hi all
>
> When I get the processingTime in the processElement method of the
> KeyedProcessFunction,
> like ctx.timestamp(), which returns null, how do I get the
> p
I was able to get generic types to work when I used GenericTypeInfo and
made sure to wrap the generic in some concrete type. In my case I used
scala.Some as the wrapper. It looks something like this (in Scala):
import org.apache.flink.api.java.typeutils.GenericTypeInfo
val descriptor = new ListSta
does not support jdk9; we only fixed some of
> the issues, not all of them.
>
> On 06.12.2018 07:13, Mike Mintz wrote:
>
> Hi Flink developers,
>
> We're running some new DataStream jobs on Flink 1.7.0 using the shaded
> Hadoop S3 file system, and running into frequent error
Hi Flink developers,
We're running some new DataStream jobs on Flink 1.7.0 using the shaded
Hadoop S3 file system, and running into frequent errors saving checkpoints
and savepoints to S3. I'm not sure what the underlying reason for the error
is, but we often fail with the following stack trace, w
