MAx parallelism

How to set the max parallelism , if I set it to 200 or 2000 ,the performance will be the same? 

the new state serializer can not be incompatible

Hi team : restore.from savepoint i meet: the new state serializer can not be incompatible Who can help me? Thanks in advance Kobe24

Invalid AMRMToken from appattempy

Caused by :org.apache.hadoop.ipc.RemoteException：Invalid AMRMToken from appattempy_162**_1178_1 at org.apache.hadoop.ipc.Client.getRpcResponse（Client.java:1563） … Flink 1.10 on yarn Thanks in advance 湘晗刚

flink14 sql sink kafka error

UnknownServerException :The server experienced an unexpected error when processing the reqiest. Thanks Kobe24

flink14 batch mode can read.iceberg table but stream mode can not

flink14 batch mode can read iceberg table but stream mode can not ,why? Thanks in advance Kobe24

flink integrate redis

Flink write data to redis,how to assure data accuracy  ,for example  i wang to save several months data every user,,if use state,first save to the state, then just set to redis,but if user  data is too large ,i will need much memory ,is there better way?  Thanks in advance Kobe24

(无主题)

Hi all  Linux system rngd.service ,entropy_avail is small cause flink task back pressure  high,how to solve other than restart rngd.service every time Thanks in advance Tian

(无主题)

Flink 1.10.0 checkpoint to hdfs failed: Caused by:org.apache.flink.util.SerializedThrowable: The directory item limit of .../shared is  Exceeded:limit=1048576 items=1048576