Re: Looking for online live training courses

Thanks Jing, I really appreciate your sharing. 多谢老铁！:) Best, *Xia(Nate) Qu* On Thu, Jun 10, 2021 at 10:07 PM JING ZHANG wrote: > Hi XiaQu, > Welcome to Flink community! > I don't know if there are online interactive training courses yet, I would > add it to the email later after I consult o

Re: Looking for online live training courses

Hi BB, Thanks for your suggestion, I will take a look. I was hoping there are customized training services for flink like Kafka or Spark since out team had some video courses already and would like to dive into some specific topics and ask some questions. Best, *Xia(Nate) Qu* On Fri, Jun 11

Re: Flink PrometheusReporter support for HTTPS

Hi Ashutosh, How are you deploying your Flink apps? Would running a reverse proxy like Nginx or Envoy that handles the HTTPS connection work for you? Best, Austin On Sat, Jun 12, 2021 at 1:11 PM Ashutosh Uttam wrote: > Hi All, > > Does PrometheusReporter provide support for HTTPS?. I couldn't

Re: Error with extracted type from custom partitioner key

Hi Timo, Thanks, I’ll give the ResultTypeQueryable interface a try - my previous experience registering custom Kryo serializers wasn’t so positive. Though I’m still curious as to whether java.lang.ClassCastException I got was representative of a bug in Flink, or my doing something wrong. But w

should i expect POJO serialization warnings when dealing w/ kryo protobuf serialization?

i'm currently using protobufs, and registering the serializers using kryo protobuf using the following snippet of code: static void optionalRegisterProtobufSerializer(ExecutionConfig config, Class clazz) { if (clazz != null) { config.registerTypeWithKryoSerializer(clazz,

Flink PrometheusReporter support for HTTPS

Hi All, Does PrometheusReporter provide support for HTTPS?. I couldn't find any information in flink documentation. Is there any way we can achieve the same? Thanks & Regards, Ashutosh

Re: NPE when aggregate window.

Hi, I meet the same exception, and find your suggestion here. I'm confused about the word 'grouping key', is that refers to the key of the accumulating hash map, or the key that separate the stream by some information? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabbl

Web UI shows my AssignTImestamp is in high back pressure but in/outPoolUsage are both 0.

Hi, I have a job like 'Source -> assignmentTimestamp -> flatmap -> Window -> Sink' and I get back pressure from 'Source' to the 'FlatMap' operators form the 'BackPressure' tab in the Web UI. When trying to find which operator is the source of back pressure, I use metrics provided by the Web UI, sp