Junbo Wang
Junbo Wang
Only Spark 3.5 supports `JobArtifactState`. I need to use reflection to solve the compatibility problem, but I don’t know how to use reflection to call `def withActiveJobArtifactState[T](state: JobArtifactState)(block: => T):...
@pan3793 cc, and need some help, thank you.
Looks like what I worked for before #5384 , please assign to me if possible.
@lvyanquan cc, thanks. Paimon 0.8.0 use dynamic bucket as default, and FLINK-35394 prepare to support dynamic bucket. For bump paimon to 0.8.0, we can set unit test paimon table bucket...
PS: An error will be reported during local testing with a lower version of jdk (like jdk 1.8.0). Does it need to be fixed? ``` [ERROR] Error: VM option 'UseG1GC'...
> Does this error only affect local testing and does not affect running with jar? If it does not affect the operation after packaging, it can be ignored. OK, just...
> @beryllw Would you like to bump paimon version to 8.0.2? done(paimon 0.8.2)
Exception in MySQL CDC test. ``` 2024-07-16T10:37:08.5104004Z 52150 [debezium-reader-1] INFO org.apache.flink.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask - For split 'date_convert_test_370b26.date_convert_test:0' of table date_convert_test_370b26.date_convert_test using select statement: 'SELECT * FROM `date_convert_test_370b26`.`date_convert_test`' 2024-07-16T10:37:08.5109144Z 52153 [debezium-reader-1] ERROR io.debezium.relational.TableSchemaBuilder...
@leonardBang It seems that the failure of unit ci has nothing to do with Paimon's changes.
Waiting for k8s application mode pr: #3093