Re: What is the state of Scala wrappers?

Hi all, Is there anything that the Flink community could do to raise awareness? Perhaps it would be interesting for the maintainers to write a short blog post about it, which potentially could drive traffic? Best regards, Martijn On Sun, Feb 5, 2023 at 4:39 PM Alexey Novakov via user < user@fli

Re: Unsubscribe

Hi. To unsubscribe, you should send email to user-unsubscr...@flink.apache.org with any contents or subject. Please see more in the Flink Doc[1] [1] https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list Best regards, Yuxia 发件人: "liang ji" 收件人: "User" 发送时间: 星期三, 20

Unsubscribe

Re: Unsubscribe

Hi, All. To unsubscribe, you can send email to user-unsubscr...@flink.apache.org with any contents or subject. Please see more in the Flink Doc[1] [1] https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list Best regards, Yuxia 发件人: "Ragini Manjaiah" 收件人: "Soumen Choud

Re: Unsubscribe

Hi Soumen, I want to unsubscribe from this mailing list. Thanks & Regards Ragini Manjaiah On Fri, Feb 3, 2023 at 4:07 PM Soumen Choudhury wrote: > > > -- > Regards > Soumen Choudhury > Cell : +91865316168 > mail to : sou@gmail.com >

Re: I want to subscribe users' questions

Maybe you will also be interested in joining Flink Slack, here is my invite link for joining Flink Slack: https://join.slack.com/t/apache-flink/shared_invite/zt-1obpql04h-R3o5XM8d~Siyl3KGldkl2Q Best regards, Yuxia - 原始邮件 - 发件人: "guanyuan chen" 收件人: "User" , "user-zh" 发送时间: 星期五, 2023年 2

Re: I want to subscribe users' questions

Hi, guanyuan, This document( https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list) will be helpful. welcome~ Best, Hang guanyuan chen 于2023年2月7日周二 21:37写道： > Hi, > My name is Guanyuan Chen.I am a big data development engineer, tencent > wechat department, china. I hav

Re: Kafka Sink Kafka Producer metrics?

Wow, not sure how I missed that. Thank you. On Mon, Feb 6, 2023 at 9:22 PM Mason Chen wrote: > Hi Andrew, > > I misread the docs: `register.producer.metrics` is mentioned here, but it > is not on by default. > https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kaf

Updating Scala package names while preserving state

Hi, I would like to change the package name of our Scala code from com.company.foo.something to com.company.bar.something while preserving the state. How can I make a Savepoint from an application built with com.company.foo.something and make that Savepoint compatible with new code built from

Re: EOFException when deserializing from RocksDB

If I store the Java protobuf objects in the rocksdb instead of the scala objects, I get this stacktrace: 2023-02-07 09:17:04,246 WARN org.apache.flink.runtime.taskmanager.Task [] - KeyedProcess -> (Map -> Sink: signalSink, Map -> Flat Map -> Sink: FeatureSink, Sink: logsink) (2/2)#