This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 4904d919e9 [core] Fix invalidate tables with same tableNames in other
db issue (#4895)
add c1d4616ab1 [core] Add a http-report action to reporting partition done
to remote servers. (#4862)
No new revisions were added by this update.
Summary of changes:
docs/content/flink/sql-write.md | 30 ++-
.../shortcodes/generated/core_configuration.html | 20 +-
.../main/java/org/apache/paimon/CoreOptions.java | 65 +++++-
.../actions/HttpReportMarkDoneAction.java | 230 +++++++++++++++++++++
.../actions/HttpReportMarkDoneException.java} | 13 +-
.../partition/actions/PartitionMarkDoneAction.java | 15 +-
.../java/org/apache/paimon/rest/HttpClient.java | 21 +-
.../org/apache/paimon/rest/HttpClientTest.java | 51 ++---
.../org/apache/paimon/rest/TestHttpWebServer.java | 98 +++++++++
paimon-flink/paimon-flink-common/pom.xml | 8 +
.../action/MarkPartitionDoneActionITCase.java | 107 +++++++++-
.../CustomPartitionMarkDoneActionTest.java | 2 +-
.../partition/HttpReportMarkDoneActionTest.java | 188 +++++++++++++++++
13 files changed, 786 insertions(+), 62 deletions(-)
create mode 100644
paimon-core/src/main/java/org/apache/paimon/partition/actions/HttpReportMarkDoneAction.java
copy
paimon-core/src/main/java/org/apache/paimon/{table/source/OutOfRangeException.java
=> partition/actions/HttpReportMarkDoneException.java} (73%)
create mode 100644
paimon-core/src/test/java/org/apache/paimon/rest/TestHttpWebServer.java
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/partition/HttpReportMarkDoneActionTest.java
