Skip to content

[FLINK-40001][table] Upgrade Calcite version to 1.42.0 - #28981

Draft
snuyanzin wants to merge 2 commits into
apache:masterfrom
snuyanzin:flink40001
Draft

[FLINK-40001][table] Upgrade Calcite version to 1.42.0#28981
snuyanzin wants to merge 2 commits into
apache:masterfrom
snuyanzin:flink40001

Conversation

@snuyanzin

@snuyanzin snuyanzin commented Aug 16, 2026

Copy link
Copy Markdown
Contributor

What is the purpose of the change

Bumping Calcite to 1.42.0

Brief change log

pom, NOTICE, Calcite classes

Verifying this change

Existing tests,

Does this pull request potentially affect one of the following parts:

  • Dependencies (does it add or upgrade a dependency): (yes)
  • 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 )

Was generative AI tooling used to co-author this PR?
  • Yes (please specify the tool below)

Generated-by: [Tool Name and Version]

""".stripMargin
assertThatExceptionOfType(classOf[RuntimeException])
.isThrownBy(() => util.verifyRelPlan(sqlQuery))
util.verifyRelPlan(sqlQuery)

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

A number of queries are fixed because of DHyp decorrelation algorithm implemented in Calcite

@flinkbot

flinkbot commented Aug 16, 2026

Copy link
Copy Markdown
Collaborator

CI report:

Bot commands The @flinkbot bot supports the following commands:
  • @flinkbot run azure re-run the last Azure build

@snuyanzin
snuyanzin force-pushed the flink40001 branch 10 times, most recently from cafe1aa to d637657 Compare August 17, 2026 17:11
+- Calc(select=[w0$o0 AS rk, d])
+- OverAggregate(partitionBy=[d], orderBy=[e ASC], window#0=[RANK(*) AS w0$o0 RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW], select=[d, e, w0$o0])
+- Calc(select=[rk, d])
+- OverAggregate(partitionBy=[d], orderBy=[e ASC], window#0=[RANK(*) AS rk RANGE BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW], select=[d, e, rk])

@snuyanzin snuyanzin Aug 17, 2026

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

here and in other places result of fix https://issues.apache.org/jira/browse/CALCITE-7369 (ProjectToWindowRule loses column alias when optimizing OVER window queries)

@snuyanzin
snuyanzin force-pushed the flink40001 branch 2 times, most recently from ec9999a to e394b7f Compare August 17, 2026 19:00
@snuyanzin

Copy link
Copy Markdown
Contributor Author

@flinkbot run azure

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants