This is an automated email from the ASF dual-hosted git repository.
fhueske pushed a change to branch fhueske-FLINK-39436-Allow-late-data-in-PTFs
in repository https://gitbox.apache.org/repos/asf/flink.git
discard 857e77c4ce7 [FLINK-39436] Allow late data in PTFs
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 e7c0d17074d [FLINK-39424][table] Setting LIKE does not support default
escape characters
add 15c5dc2ffa8 [FLINK-39436][table] Allow late data in PTFs
add a08f39344ba [FLINK-39436][table] Address reviewer comments
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 (857e77c4ce7)
\
N -- N -- N
refs/heads/fhueske-FLINK-39436-Allow-late-data-in-PTFs (a08f39344ba)
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 +-
docs/content/docs/dev/table/functions/ptfs.md | 11 +
docs/data/sql_functions.yml | 4 +-
docs/data/sql_functions_zh.yml | 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/table/expression.py | 6 +-
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/api/internal/BaseExpressions.java | 4 +-
.../apache/flink/table/functions/SqlLikeUtils.java | 14 +-
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 +-
.../table/functions/ProcessTableFunction.java | 25 +
.../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 +-
.../table/planner/codegen/calls/LikeCallGen.scala | 3 +
.../planner/calcite/FlinkSqlLikeUtilsTest.java | 12 +-
.../planner/functions/LikeFunctionITCase.java | 6 +-
.../stream/ProcessTableFunctionTestPrograms.java | 2 +-
.../planner/expressions/ScalarFunctionsTest.scala | 14 +-
flink-table/flink-table-runtime/pom.xml | 2 +-
.../process/AbstractProcessTableOperator.java | 5 +-
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 +-
209 files changed, 1560 insertions(+), 572 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%)
