[Bug] Using flink datagen to create complex nested type data sink fail
- Dominant language
- Java
- Stars
- 3.4k
- Forks
- 1.4k
- Avg merge
- 1d 11h
- Merged PRs (30d)
- 396
Description
### Search before asking
- [X] I searched in the [issues](https://github.com/apache/incubator-paimon/issues) and found nothing similar.
### Paimon version
0.5.0
### Compute Engine
flink 1.17.1
### Minimal reproduce step
[create.txt](https://github.com/apache/incubator-paimon/files/13172347/create.txt)
### What doesn't meet your expectations?
### Anything else?
_No response_
### Are you willing to submit a PR?
- [ ] I'm willing to submit a PR!
Contributor guide
No contributing guide indexed for this repository
Research direction
Start by reproducing the failure from the attached create.txt with Paimon 0.5.0 and Flink 1.17.1, then compare the sink error and output with the screenshots. Trace the nested-type handling in the Flink sink and add a regression test once the failing path is identified; done means complex nested datagen records sink successfully.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- data-engineering
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100