[GH] (streampark/dev): Workflow run "Unit-Test" is working again!

[GitBox <gi...@apache.org>]

The GitHub Actions job "Unit-Test" on streampark.git/dev has succeeded.
Run started by GitHub user wolfboys (triggered by wolfboys).

Head commit for run:
7d7d71aa1f80f5b9062bf54f0e1f35456efd30f7 / Assert <42...@users.noreply.github.com>
[Build] Remove Scala overall regression test and post-migration cleanup (#4471)

* [Build] Drop Scala build toolchain from Flink and Console modules

Flink modules are fully Java after #4467; remove the common-scala-bridge
dependency, enumeratum/scalatest test deps, and scala-maven-plugin from
Flink parent, sqlclient, udf, and console-service. Bridge module is
retained for Spark until #4453.

* [Test][Common][Flink] Add migration regression tests and small cleanups

Add unit tests for AutoCloseUtils, ClientBeanUtils, SubmitRequest, and
ExitSecurityManager. Remove unused FlinkVersion.flinkLibs Scala bridge,
drop unused LoggerSupport from FlinkClient, and minor SubmitRequest tidy.


* [Common][Flink] Sonar-oriented fixes and expand migration regression tests

Replace printStackTrace and generic RuntimeException wraps with specific
exceptions, null-safe SubmitRequest accessors, FlinkShimsProxy URL helper,
and TrackId validation cleanup. Add ParameterCliTest, TrackIdTest, and
more SqlClient/SubmitRequest coverage.

* [Test] Keep unit-test-only coverage; revert production Sonar edits

Restore production code from the prior commit and retain focused unit
tests for ParameterCli, TrackId, SqlClient, and SubmitRequest. Complex
deploy-mode and cluster scenarios are deferred to E2E.


* [Common][Flink] Re-apply Sonar Java quality fixes with unit test sync

Restore production Sonar improvements (specific exceptions, null-safe
accessors, toUrl helper, lambda cleanup) while keeping unit tests focused
on pure logic; complex deploy scenarios remain deferred to E2E.

* [Flink] Fix shims Sonar issues in code and remove migration Sonar configs

Remove @SuppressWarnings and shims-specific sonar-project/.sonarcloud
properties added during Scala-to-Java migration; address deprecations
and unchecked casts directly in shims source instead.

* [Flink] Remove unused imports after TableContext refactor

Spotless check requires dropping stale Utils imports from TableContext.

* [Flink] Drop invalid @Override on FlinkStreamTableTrait.execute

execute(String) is not part of StreamTableEnvironment in all Flink
versions; keep the method public without @Override for compatibility.

* [Flink] Address Sonar new-code findings in shims-base

Fix unused parameters, replace generic exceptions, reduce cognitive
complexity, return empty collections, simplify regex matching, and
deduplicate TableExt conversion helpers per SonarCloud dev analysis.

* [Flink] Continue Sonar cleanup for shims, client, and SQL splitter

Refactor SqlSplitter with QueryExtractor, fix generic type names,
ParameterCli stdout emission, SubmitRequest exceptions, and remaining
Sonar findings from the dev new-code report.

* [Flink] Hoist shared Table API to traits and slim version shims contexts

Move common TableEnvironment delegates into FlinkTableTrait and
FlinkStreamTableTrait so version-specific TableContext and
StreamTableContext only retain legacy or version-gated APIs.
Refactor FlinkSqlValidator validation flow for lower complexity.

* [Flink] Hoist stream-table bridge APIs and collapse version contexts

Move Schema-based stream-table conversions and version-gated Table API
delegates into FlinkStreamTableTrait and FlinkTableTrait. Reduce
1.15–1.20 context classes to constructors plus version-specific legacy
overrides only where older Flink APIs require them.

* [Flink] Remove unchecked proxy casts and tighten error handling

Use Class.cast in FlinkShimsProxy.getObject and typed FlinkClient
invocations to drop @SuppressWarnings. Fix SqlClient unzip validation,
SubmitRequest exception handling, and FlinkSqlValidator caused-by parsing.

* [Flink] Clean up packer and kubernetes Sonar findings

Replace unchecked casts with Class.cast or typed YAML helpers, use
IllegalStateException for operational failures, and document enum constants
to remove @SuppressWarnings suppressions.

* [Flink] Replace RuntimeException in Yarn client deploy paths

* [Console] Replace Flink RuntimeException usages with typed failures

Use IllegalStateException with causes for Yarn/K8s deploy and watcher
paths, fix FlinkSql rollback error chaining, and remove unchecked JSON
casts in FlinkApplication via TypeReference.

* [Common] Replace RuntimeException with typed failures in shared utilities

Use IllegalStateException/IllegalArgumentException with context across common
util classes, refactor StringCastUtils with Class.cast, and align Console
shared infrastructure (Shiro, build task, Throws) for Sonar compliance.

* [Flink] Fix Sonar duplication and code smell findings for PR #4471

Extract shared Yarn jar upload and K8s Docker build helpers to reduce new-code
duplication below the 3% quality gate, rename pipeline enum constants to
UPPER_CASE, and address SqlSplitter/StringCastUtils Sonar issues.

* [Flink] Extract shared Yarn/K8s build pipeline steps to fix Sonar duplication

Hoist Yarn SQL build steps into BuildPipeline, K8s docker/pod-template steps
into AbstractK8sApplicationBuildPipeline, and AppControl factory to bring
new-code duplication below the 3% quality gate threshold.


* [Console] Extract shared application and build pipeline helpers to fix Sonar duplication

Consolidate duplicated logic between Flink/Spark entities and build pipeline services so PR #4471 can pass the new-code duplication quality gate.


* [Console] Further deduplicate entities, build pipelines, and watchers for Sonar

Move shared entity defaults to ApplicationEntitySupport, extract release outcome
and watcher init helpers to bring PR #4471 new-code duplication below 3%.

* [Common] Fix StringCastUtils generic cast and restore Flink build log level

Accept Class<?> in cast() so common_2.12 compiles with ConfigOption callers, and keep Flink dependency-merge failures logged at error while Spark stays at warn.

Report URL: https://github.com/apache/streampark/actions/runs/30794373468

With regards,
GitHub Actions via GitBox