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 178112376f6 [FLINK-39436][table] Address comments #2
discard ddfc55ba149 [FLINK-39436][table] Address reviewer comments
discard 57c939907b4 [FLINK-39436][table] Allow late data in PTFs
add 565dbbccf8c [FLINK-39118][docs] Add documentation for Native s3
FileSystem (#27841)
add f33b8211e8d [FLINK-39388][tests] Fix flaky
DataGeneratorSourceITCase#testGatedRateLimiter (#27883)
add 548ea5b6c64 [FLINK-39483][build] Bump dependency check maven plugin to
12.2.1
add 55d0cc6d89e [FLINK-39477][docs] Add AGENTS.md and AI disclosure to PR
template
add bab97bb7542 [FLINK-39477][docs] Add module-level AGENTS.md for table
planner and runtime
add 4997ca40a3f [FLINK-39261][table] Add FROM_CHANGELOG built-in process
table function
add d49eb629ca9 [FLINK-39264][docs] Add docs for application management
(#27818)
add c48517abba5 [FLINK-39436][table] Allow late data in PTFs
add 9ea2a72017c [FLINK-39436][table] Address reviewer comments
add 92c9bf21f7c [FLINK-39436][table] Address comments #2
add e63b9b3c008 [FLINK-39436][table] Add PTF restore test with late data
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 (178112376f6)
\
N -- N -- N
refs/heads/fhueske-FLINK-39436-Allow-late-data-in-PTFs (e63b9b3c008)
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/PULL_REQUEST_TEMPLATE.md | 21 ++
AGENTS.md | 338 +++++++++++++++++++++
.../content.zh/docs/concepts/flink-architecture.md | 2 +-
docs/content.zh/docs/concepts/glossary.md | 12 +-
.../docs/deployment/advanced/historyserver.md | 32 +-
docs/content.zh/docs/deployment/config.md | 4 +
docs/content.zh/docs/deployment/filesystems/s3.md | 275 ++++++++++++-----
docs/content.zh/docs/deployment/ha/overview.md | 29 +-
docs/content.zh/docs/deployment/overview.md | 40 ++-
.../docs/internals/application_lifecycle.md | 88 ++++++
docs/content/docs/concepts/flink-architecture.md | 6 +-
docs/content/docs/concepts/glossary.md | 19 +-
.../docs/deployment/advanced/historyserver.md | 33 +-
docs/content/docs/deployment/config.md | 4 +
docs/content/docs/deployment/filesystems/s3.md | 239 +++++++++++----
docs/content/docs/deployment/ha/overview.md | 41 ++-
docs/content/docs/deployment/overview.md | 39 ++-
.../docs/internals/application_lifecycle.md | 81 +++++
.../docs/sql/reference/queries/changelog.md | 112 ++++++-
docs/static/fig/application_status.png | Bin 0 -> 196891 bytes
.../datagen/source/DataGeneratorSourceITCase.java | 32 +-
.../pyflink/table/tests/test_table_completeness.py | 1 +
.../java/org/apache/flink/table/api/Table.java | 27 ++
.../apache/flink/table/api/internal/TableImpl.java | 5 +
.../table/functions/BuiltInFunctionDefinition.java | 28 +-
.../functions/BuiltInFunctionDefinitions.java | 27 ++
.../ChangelogModeStrategy.java} | 29 +-
.../strategies/FromChangelogTypeStrategy.java | 253 +++++++++++++++
.../strategies/SpecificInputTypeStrategies.java | 4 +
.../strategies/SpecificTypeStrategies.java | 4 +
...y.java => ValidationOnlyInputTypeStrategy.java} | 26 +-
.../FromChangelogInputTypeStrategyTest.java | 167 ++++++++++
flink-table/flink-table-planner/AGENTS.md | 117 +++++++
.../FlinkChangelogModeInferenceProgram.scala | 32 +-
...cTests.java => FromChangelogSemanticTests.java} | 22 +-
.../exec/stream/FromChangelogTestPrograms.java | 210 +++++++++++++
.../stream/ProcessTableFunctionRestoreTests.java | 3 +-
.../stream/ProcessTableFunctionTestPrograms.java | 49 +++
.../exec/stream/ProcessTableFunctionTestUtils.java | 15 +
...ToChangelogTest.java => FromChangelogTest.java} | 49 ++-
.../plan/stream/sql/ProcessTableFunctionTest.java | 14 +-
.../planner/plan/stream/sql/FromChangelogTest.xml | 57 ++++
.../plan/stream/sql/ProcessTableFunctionTest.xml | 20 ++
.../plan/process-late-events-restore.json} | 20 +-
.../savepoint/_metadata | Bin 16811 -> 15523 bytes
flink-table/flink-table-runtime/AGENTS.md | 78 +++++
.../functions/ptf/FromChangelogFunction.java | 147 +++++++++
pom.xml | 4 +-
48 files changed, 2569 insertions(+), 286 deletions(-)
create mode 100644 AGENTS.md
create mode 100644 docs/content.zh/docs/internals/application_lifecycle.md
create mode 100644 docs/content/docs/internals/application_lifecycle.md
create mode 100644 docs/static/fig/application_status.png
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/{types/inference/strategies/ForceNullableTypeStrategy.java
=> functions/ChangelogModeStrategy.java} (57%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FromChangelogTypeStrategy.java
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{CommonArrayInputTypeStrategy.java
=> ValidationOnlyInputTypeStrategy.java} (54%)
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/FromChangelogInputTypeStrategyTest.java
create mode 100644 flink-table/flink-table-planner/AGENTS.md
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{ToChangelogSemanticTests.java
=> FromChangelogSemanticTests.java} (64%)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/FromChangelogTestPrograms.java
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/stream/sql/{ToChangelogTest.java
=> FromChangelogTest.java} (55%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/FromChangelogTest.xml
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/{process-order-by-restore/plan/process-order-by-restore.json
=> process-late-events-restore/plan/process-late-events-restore.json} (91%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-process-table-function_1/{process-partitioned-named-timers-restore
=> process-late-events-restore}/savepoint/_metadata (68%)
create mode 100644 flink-table/flink-table-runtime/AGENTS.md
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/ptf/FromChangelogFunction.java
