This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch FLINK-39256
in repository https://gitbox.apache.org/repos/asf/flink.git
discard ddb93ca3e85 Remove single partition ORDER BY
discard e38f5fc0baf Fix spotless
discard 67c8ae16744 Feedback addressed
discard bb83b36917f [FLINK-39256][table] Support ORDER BY clause in Process
Table Functions
add d8010df8795 [FLINK-39394][web] Fix job overview metrics broken when a
vertex is finished
add e4280d4f168 [FLINK-38893][runtime/rest] Introduce the
/jobs/:jobid/rescales/overview endpoint in the REST API
add 5ba9166f729 [FLINK-38898][runtime-web] Introduce the Rescales/Overview
sub-page for streaming jobs with the adaptive scheduler enabled
add 096f031b950 [FLINK-38898][runtime-web] Refactor Rescale Details
related parts into templates for reusing in Rescales/Overview and
Rescales/History
add 983e76fa087 Update version to 2.4-SNAPSHOT
add 27688329838 [FLINK-39446] Add version 2.4 and update nightly build
action
add 27328b89f8a [FLINK-39443][release] Build docs for release-2.3 branch
add 496f8a87ed1 [FLINK-39457][docs/tests] Upgrade version tag from
'2.3-SNAPSHOT' to '2.4-SNAPSHOT' in REST-API related doc files to fix CI
failure (#27938)
add d5cfc67d0dc [FLINK-39256][table] Support ORDER BY clause in Process
Table Functions
add b4fee373bdc Feedback addressed
add 8b590186a93 Fix spotless
add 7be1f01a119 Remove single partition ORDER BY
add 69959fdb802 Fix arch checks
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ddb93ca3e85)
\
N -- N -- N refs/heads/FLINK-39256 (69959fdb802)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/docs.yml | 1 +
.github/workflows/nightly-trigger.yml | 2 +-
docs/config.toml | 4 +-
.../shortcodes/generated/rest_v1_dispatcher.html | 227 ++++++++
docs/static/generated/rest_v1_dispatcher.yml | 51 +-
docs/static/generated/rest_v1_sql_gateway.yml | 2 +-
docs/static/generated/rest_v2_sql_gateway.yml | 2 +-
docs/static/generated/rest_v3_sql_gateway.yml | 2 +-
docs/static/generated/rest_v4_sql_gateway.yml | 2 +-
flink-annotations/pom.xml | 2 +-
.../main/java/org/apache/flink/FlinkVersion.java | 3 +-
.../flink-architecture-tests-base/pom.xml | 2 +-
.../flink-architecture-tests-production/pom.xml | 2 +-
.../flink-architecture-tests-test/pom.xml | 2 +-
flink-architecture-tests/pom.xml | 2 +-
flink-clients/pom.xml | 2 +-
flink-connectors/flink-connector-base/pom.xml | 2 +-
.../flink-connector-datagen-test/pom.xml | 2 +-
flink-connectors/flink-connector-datagen/pom.xml | 2 +-
flink-connectors/flink-connector-files/pom.xml | 2 +-
flink-connectors/flink-file-sink-common/pom.xml | 2 +-
.../flink-hadoop-compatibility/pom.xml | 2 +-
flink-connectors/pom.xml | 2 +-
flink-container/pom.xml | 2 +-
flink-core-api/pom.xml | 2 +-
flink-core/pom.xml | 2 +-
flink-datastream-api/pom.xml | 2 +-
flink-datastream/pom.xml | 2 +-
flink-dist-scala/pom.xml | 2 +-
flink-dist/pom.xml | 2 +-
flink-docs/pom.xml | 2 +-
flink-dstl/flink-dstl-dfs/pom.xml | 2 +-
flink-dstl/pom.xml | 2 +-
.../flink-batch-sql-test/pom.xml | 2 +-
flink-end-to-end-tests/flink-cli-test/pom.xml | 2 +-
.../flink-confluent-schema-registry/pom.xml | 2 +-
.../flink-datastream-allround-test/pom.xml | 2 +-
.../flink-distributed-cache-via-blob-test/pom.xml | 4 +-
.../flink-end-to-end-tests-common/pom.xml | 2 +-
.../flink-end-to-end-tests-jdbc-driver/pom.xml | 2 +-
.../flink-end-to-end-tests-restclient/pom.xml | 2 +-
.../flink-end-to-end-tests-scala/pom.xml | 2 +-
.../flink-end-to-end-tests-sql/pom.xml | 2 +-
.../flink-end-to-end-tests-table-api/pom.xml | 2 +-
.../flink-failure-enricher-test/pom.xml | 2 +-
.../flink-file-sink-test/pom.xml | 2 +-
.../flink-heavy-deployment-stress-test/pom.xml | 2 +-
.../pom.xml | 2 +-
.../flink-metrics-availability-test/pom.xml | 2 +-
.../flink-metrics-reporter-prometheus-test/pom.xml | 2 +-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
.../flink-plugins-test/another-dummy-fs/pom.xml | 2 +-
.../flink-plugins-test/dummy-fs/pom.xml | 2 +-
flink-end-to-end-tests/flink-plugins-test/pom.xml | 2 +-
flink-end-to-end-tests/flink-python-test/pom.xml | 2 +-
.../flink-queryable-state-test/pom.xml | 2 +-
.../flink-quickstart-test-dummy-dependency/pom.xml | 2 +-
.../flink-quickstart-test/pom.xml | 2 +-
.../pom.xml | 2 +-
.../flink-sql-client-test/pom.xml | 2 +-
.../flink-state-evolution-test/pom.xml | 2 +-
.../flink-stream-sql-test/pom.xml | 2 +-
.../flink-stream-state-ttl-test/pom.xml | 2 +-
.../flink-stream-stateful-job-upgrade-test/pom.xml | 2 +-
flink-end-to-end-tests/flink-tpcds-test/pom.xml | 2 +-
flink-end-to-end-tests/flink-tpch-test/pom.xml | 2 +-
flink-end-to-end-tests/pom.xml | 2 +-
.../flink-examples-streaming-state-machine/pom.xml | 2 +-
flink-examples/flink-examples-build-helper/pom.xml | 2 +-
flink-examples/flink-examples-streaming/pom.xml | 2 +-
flink-examples/flink-examples-table/pom.xml | 2 +-
flink-examples/pom.xml | 2 +-
.../flink-external-resource-gpu/pom.xml | 2 +-
flink-external-resources/pom.xml | 2 +-
flink-filesystems/flink-azure-fs-hadoop/pom.xml | 2 +-
flink-filesystems/flink-fs-hadoop-shaded/pom.xml | 2 +-
flink-filesystems/flink-gs-fs-hadoop/pom.xml | 2 +-
flink-filesystems/flink-hadoop-fs/pom.xml | 2 +-
flink-filesystems/flink-oss-fs-hadoop/pom.xml | 2 +-
flink-filesystems/flink-s3-fs-base/pom.xml | 2 +-
flink-filesystems/flink-s3-fs-hadoop/pom.xml | 2 +-
flink-filesystems/flink-s3-fs-native/pom.xml | 2 +-
flink-filesystems/flink-s3-fs-presto/pom.xml | 2 +-
flink-filesystems/pom.xml | 2 +-
.../flink-avro-confluent-registry/pom.xml | 2 +-
flink-formats/flink-avro/pom.xml | 2 +-
flink-formats/flink-compress/pom.xml | 2 +-
flink-formats/flink-csv/pom.xml | 2 +-
flink-formats/flink-format-common/pom.xml | 2 +-
flink-formats/flink-hadoop-bulk/pom.xml | 2 +-
flink-formats/flink-json/pom.xml | 2 +-
flink-formats/flink-orc-nohive/pom.xml | 2 +-
flink-formats/flink-orc/pom.xml | 2 +-
flink-formats/flink-parquet/pom.xml | 2 +-
flink-formats/flink-protobuf/pom.xml | 2 +-
flink-formats/flink-sequence-file/pom.xml | 2 +-
.../flink-sql-avro-confluent-registry/pom.xml | 2 +-
flink-formats/flink-sql-avro/pom.xml | 2 +-
flink-formats/flink-sql-csv/pom.xml | 2 +-
flink-formats/flink-sql-json/pom.xml | 2 +-
flink-formats/flink-sql-orc/pom.xml | 2 +-
flink-formats/flink-sql-parquet/pom.xml | 2 +-
flink-formats/flink-sql-protobuf/pom.xml | 2 +-
flink-formats/pom.xml | 2 +-
flink-fs-tests/pom.xml | 2 +-
flink-kubernetes/pom.xml | 2 +-
flink-libraries/flink-cep/pom.xml | 2 +-
flink-libraries/flink-state-processing-api/pom.xml | 2 +-
flink-libraries/pom.xml | 2 +-
flink-metrics/flink-metrics-core/pom.xml | 2 +-
flink-metrics/flink-metrics-datadog/pom.xml | 2 +-
flink-metrics/flink-metrics-dropwizard/pom.xml | 2 +-
flink-metrics/flink-metrics-graphite/pom.xml | 2 +-
flink-metrics/flink-metrics-influxdb/pom.xml | 2 +-
flink-metrics/flink-metrics-jmx/pom.xml | 2 +-
flink-metrics/flink-metrics-otel/pom.xml | 2 +-
flink-metrics/flink-metrics-prometheus/pom.xml | 2 +-
flink-metrics/flink-metrics-slf4j/pom.xml | 2 +-
flink-metrics/flink-metrics-statsd/pom.xml | 2 +-
flink-metrics/pom.xml | 2 +-
flink-models/flink-model-openai/pom.xml | 2 +-
flink-models/flink-model-triton/pom.xml | 2 +-
flink-models/pom.xml | 2 +-
flink-python/pom.xml | 2 +-
flink-python/pyflink/version.py | 2 +-
.../flink-queryable-state-client-java/pom.xml | 2 +-
.../flink-queryable-state-runtime/pom.xml | 2 +-
flink-queryable-state/pom.xml | 2 +-
flink-quickstart/flink-quickstart-java/pom.xml | 2 +-
flink-quickstart/pom.xml | 2 +-
flink-rpc/flink-rpc-akka-loader/pom.xml | 2 +-
flink-rpc/flink-rpc-akka/pom.xml | 2 +-
flink-rpc/flink-rpc-core/pom.xml | 2 +-
flink-rpc/pom.xml | 2 +-
flink-runtime-web/pom.xml | 2 +-
.../src/test/resources/rest_api_v1.snapshot | 203 +++++++
.../src/app/interfaces/job-rescales.ts | 18 +
.../pages/job/overview/job-overview.component.ts | 16 +-
.../pages/job/rescales/job-rescales.component.html | 583 ++++++++++++---------
.../pages/job/rescales/job-rescales.component.less | 52 +-
.../pages/job/rescales/job-rescales.component.ts | 49 +-
.../web-dashboard/src/app/services/job.service.ts | 5 +
flink-runtime/pom.xml | 2 +-
...andler.java => JobRescalesOverviewHandler.java} | 35 +-
.../messages/job/rescales/JobRescalesOverview.java | 246 +++++++++
...eaders.java => JobRescalesOverviewHeaders.java} | 24 +-
.../runtime/webmonitor/WebMonitorEndpoint.java | 15 +
...st.java => JobRescalesOverviewHandlerTest.java} | 128 ++---
.../flink-statebackend-changelog/pom.xml | 2 +-
.../flink-statebackend-common/pom.xml | 2 +-
.../flink-statebackend-forst/pom.xml | 2 +-
.../flink-statebackend-heap-spillable/pom.xml | 2 +-
.../flink-statebackend-rocksdb/pom.xml | 2 +-
flink-state-backends/pom.xml | 2 +-
flink-streaming-java/pom.xml | 2 +-
flink-table/flink-sql-client/pom.xml | 2 +-
flink-table/flink-sql-gateway-api/pom.xml | 2 +-
flink-table/flink-sql-gateway/pom.xml | 2 +-
flink-table/flink-sql-jdbc-driver-bundle/pom.xml | 2 +-
flink-table/flink-sql-jdbc-driver/pom.xml | 2 +-
flink-table/flink-sql-parser/pom.xml | 2 +-
flink-table/flink-table-api-bridge-base/pom.xml | 2 +-
flink-table/flink-table-api-java-bridge/pom.xml | 2 +-
flink-table/flink-table-api-java-uber/pom.xml | 2 +-
flink-table/flink-table-api-java/pom.xml | 2 +-
flink-table/flink-table-api-scala-bridge/pom.xml | 2 +-
flink-table/flink-table-api-scala/pom.xml | 2 +-
flink-table/flink-table-calcite-bridge/pom.xml | 2 +-
flink-table/flink-table-code-splitter/pom.xml | 2 +-
flink-table/flink-table-common/pom.xml | 2 +-
.../flink/table/functions/TableSemantics.java | 3 +-
.../flink-table-planner-loader-bundle/pom.xml | 2 +-
flink-table/flink-table-planner-loader/pom.xml | 2 +-
flink-table/flink-table-planner/pom.xml | 2 +-
flink-table/flink-table-runtime/pom.xml | 2 +-
flink-table/flink-table-test-utils/pom.xml | 2 +-
flink-table/pom.xml | 2 +-
.../flink-clients-test-utils/pom.xml | 2 +-
.../flink-connector-test-utils/pom.xml | 2 +-
.../flink-migration-test-utils/pom.xml | 2 +-
.../flink-table-filesystem-test-utils/pom.xml | 2 +-
.../flink-test-utils-connector/pom.xml | 2 +-
.../flink-test-utils-junit/pom.xml | 2 +-
flink-test-utils-parent/flink-test-utils/pom.xml | 2 +-
flink-test-utils-parent/pom.xml | 2 +-
flink-tests-java17/pom.xml | 2 +-
flink-tests/pom.xml | 2 +-
.../flink-walkthrough-common/pom.xml | 2 +-
.../flink-walkthrough-datastream-java/pom.xml | 2 +-
.../flink-walkthrough-table-java/pom.xml | 2 +-
flink-walkthroughs/pom.xml | 2 +-
flink-yarn-tests/pom.xml | 2 +-
flink-yarn/pom.xml | 2 +-
pom.xml | 2 +-
tools/ci/flink-ci-tools/pom.xml | 4 +-
197 files changed, 1475 insertions(+), 550 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/rescales/{JobRescalesHistoryHandler.java
=> JobRescalesOverviewHandler.java} (80%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/rescales/JobRescalesOverview.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/rescales/{JobRescalesHistoryHeaders.java
=> JobRescalesOverviewHeaders.java} (74%)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/rescales/{JobRescalesHistoryHandlerTest.java
=> JobRescalesOverviewHandlerTest.java} (58%)
