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
omit e63b9b3c008 [FLINK-39436][table] Add PTF restore test with late data
omit 92c9bf21f7c [FLINK-39436][table] Address comments #2
omit 9ea2a72017c [FLINK-39436][table] Address reviewer comments
omit c48517abba5 [FLINK-39436][table] Allow late data in PTFs
add 837b01e99f8 [FLINK-37599][table] Support column expansion for PTF
on_time columns
add 7373dc9e2a3 [FLINK-39226][python] Fix embedded PyIterator class cast
after recovery (#27849)
add fe8507c1eea [FLINK-38900][runtime-web] Introduce the Rescales/Summary
sub-page for streaming jobs with the adaptive scheduler enabled
add 0e899fdb352 [FLINK-39482][filesystem] Support configurable
maxConnections in S3ClientProvider
add 9edb0f5bc43 [FLINK-39479][python] Add fromChangelog() to Python Table
API
add f01d2fdd722 [FLINK-39436][table] Allow late data in PTFs
add 7410d183758 [FLINK-39436][table] Address reviewer comments
add dd8d9ff0d16 [FLINK-39436][table] Address comments #2
add 521b0177abf [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 (e63b9b3c008)
\
N -- N -- N
refs/heads/fhueske-FLINK-39436-Allow-late-data-in-PTFs (521b0177abf)
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:
.../flink/fs/s3native/NativeS3BulkCopyHelper.java | 101 +++++++-
.../flink/fs/s3native/NativeS3FileSystem.java | 6 +
.../fs/s3native/NativeS3FileSystemFactory.java | 26 +-
.../apache/flink/fs/s3native/S3ClientProvider.java | 4 +-
.../fs/s3native/NativeS3BulkCopyHelperTest.java | 53 +++-
.../fs/s3native/NativeS3FileSystemFactoryTest.java | 84 +++++++
flink-python/pyflink/table/table.py | 42 +++-
.../pyflink/table/tests/test_table_completeness.py | 1 -
...ractOneInputEmbeddedPythonFunctionOperator.java | 16 +-
...ractTwoInputEmbeddedPythonFunctionOperator.java | 31 ++-
.../python/embedded/EmbeddedPythonIterator.java | 73 ++++++
.../EmbeddedPythonKeyedCoProcessOperator.java | 17 +-
.../EmbeddedPythonKeyedProcessOperator.java | 17 +-
.../embedded/EmbeddedPythonWindowOperator.java | 17 +-
.../table/EmbeddedPythonTableFunctionOperator.java | 35 ++-
.../embedded/EmbeddedPythonIteratorTest.java | 109 ++++++++
.../embedded/ForeignClassLoaderIterator.java | 34 +--
.../src/app/interfaces/job-rescales.ts | 25 ++
.../pages/job/rescales/job-rescales.component.html | 280 +++++++++++++++++++++
.../pages/job/rescales/job-rescales.component.ts | 22 +-
.../web-dashboard/src/app/services/job.service.ts | 5 +
.../java/org/apache/flink/table/api/Table.java | 36 ++-
.../planner/calcite/FlinkCalciteSqlValidator.java | 184 +++++++++-----
.../flink/table/planner/utils/ShortcutUtils.java | 13 +
.../plan/stream/sql/ColumnExpansionTest.java | 89 ++++++-
25 files changed, 1128 insertions(+), 192 deletions(-)
create mode 100644
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/embedded/EmbeddedPythonIterator.java
create mode 100644
flink-python/src/test/java/org/apache/flink/streaming/api/operators/python/embedded/EmbeddedPythonIteratorTest.java
copy
flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/utils/CollectionResultIterator.java
=>
flink-python/src/test/java/org/apache/flink/streaming/api/operators/python/embedded/ForeignClassLoaderIterator.java
(60%)
