Re: StateFun examples in scala

;> I am pulling in Gordon who will be able to help you with your question. >> >> Personally, I am not aware of any limitations which prohibit the usage of >> Scala. >> >> Cheers, >> Till >> >> On Tue, Mar 30, 2021 at 11:55 AM jose farfan wrote: >

StateFun examples in scala

Hi I am trying to find some examples written in scala of StateFun. But, I cannot find nothing. My questions is: 1. is there any problem to use statefun with Scala 2. is there any place with examples written in scala. BR Jose

Re: When I use flink 1.9.1 and produce data to Kafka 1.1.1, The streamTask checkpoint error .

Hi I have the same issue. BR Jose On Thu, 9 Jan 2020 at 10:28, ouywl wrote: > Hi all: > When I use flink 1.9.1 and produce data to Kafka 1.1.1. the error was > happen as* log-1,code is::* > > input.addSink( > new FlinkKafkaProducer( > parameterTool.getRequired("bootstra

Re: Orc Sink Table

r questions if the description is not enough for > you. > > Regards, > Timo > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/connect.html#further-tablesources-and-tablesinks > > > Am 13.09.18 um 11:50 schrieb jose farfan: > &

Orc Sink Table

Hi I am checking the documentation https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/common.html#register-a-tablesink Register a TableSink A registered TableSink can be used t

Re: Create a file in parquet format

rmats/parquet/avro/ParquetStreamingFileSinkITCase.java#L58 > > Best, > Gary > > On Tue, Sep 11, 2018 at 11:59 AM, jose farfan wrote: > >> Hi >> >> I am working in a task. The purpose is to create a sink in Parquet >> format. >> Then, I am using the "Streaming Flink Sink"

Create a file in parquet format

Hi I am working in a task. The purpose is to create a sink in Parquet format. Then, I am using the "Streaming Flink Sink", but I cannot complete the task. Do you know any example in github, blog, that I can use to complete the task. Many Thx BR Jose