flink
flink copied to clipboard
[FLINK-34446][table] Apply workaround to allow parsing of cross join with lateral
What is the purpose of the change
The PR applies WA to fix CALCITE-6266
It applieas similar fix as for CALCITE-6266
However since there is no way to override generated methods then the whole Parser.jj (based on version from https://github.com/apache/calcite/releases/tag/calcite-1.32.0) is replaced.
It should be removed together with Calcite upgrade which will bring the fix for CALCITE-6266
Verifying this change
There is a test flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/CorrelateITCase.scala
Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): ( no)
- The public API, i.e., is any changed class annotated with
@Public(Evolving): ( no) - The serializers: ( no)
- The runtime per-record code paths (performance sensitive): ( no)
- Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: ( no)
- The S3 file system connector: ( no )
Documentation
- Does this pull request introduce a new feature? ( no)
- If yes, how is the feature documented? (not applicable)
CI report:
- f02315eeef4de8060d743a3073a7753575f49f95 Azure: SUCCESS
Bot commands
The @flinkbot bot supports the following commands:@flinkbot run azurere-run the last Azure build
Thanks for taking a look