Thanks David and others.
Our DAG has multiple sources which are not connected to each other. If one
of them fails, I believe Flink can restart a single region for
defaultscheduler. but it is not the same case for adaptive scheduler. Do
you think somehow the adaptive scheduler supports region pipel
退订
--
发自新浪邮箱客户端
Hi community,
I am pretty new to the Flink ecosystem and I am trying to create a Flink
consumer that consumes messages from an Azure Event Hub for Apache Kafka.
My flink job runs on an ubuntu vm.
When I run my job via the mvn -exec command the consumer brings messages.
Following a different proc
Hi, igyu,
It seems like the state in the join sql can not be recovered rightly. Do
you change the columns in the join sql? If so, I think this may cause
failing to recover from the checkpoint.
Best,
Hang
igyu 于2023年4月14日周五 16:13写道：
> I have a flink-SQL task. (enable savepoint)
> I want change
Hi, Kirti,
I think you need a custom convertor for your csv files. The convertors
provided by Flink only define how to translate the data into a Flink type.
Best,
Hang
Kirti Dhar Upadhyay K via user 于2023年4月14日周五
15:27写道：
> Hi Community,
>
>
>
> I am reading CSV data using data stream file sour
Hi, Anuj,
I searched the jira and found the related issue[1]. But this issue is still
open now.
Best,
Hang
[1] https://issues.apache.org/jira/browse/FLINK-6185
Anuj Jain 于2023年4月14日周五 14:58写道：
> Hi Community,
>
> Does Flink File Sink support compression of output files, to reduce the
> file s
My job read data from mysql and write to doris. It will crash after 20 mins
~ 1 hour after start.
org.apache.flink.runtime.JobException: Recovery is suppressed by
FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=10,
backoffTimeMS=1)
at org.apache.flink.runtime.executiongraph.failo
I have a flink-SQL task. (enable savepoint)
I want change it , so I stop itsink and source add a cloumn in oracle tableand modify SQL in flinkwhen I commit it I get a errororg.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStra
Hi Community,
I am reading CSV data using data stream file source connector and need to
convert them into AVRO generated specific objects.
I am using CsvReaderFormat with CSVSchema but this supports only primitive
types of AVRO (that also except null and bytes).
Is there any support provided f
