You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by xt...@apache.org on 2022/08/02 05:50:21 UTC
[flink] branch master updated (0f77b297d37 -> 70e8d7e251c)
This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 0f77b297d37 [hotfix][runtime-web] replace loading icon with text to avoid spin animation bottleneck
add 8ff0c3f887d [FLINK-27769][sql-gateway]Adjust the RestAPIVersion and RestfulGateway to adapt a variety of endpoints
add 70e8d7e251c [FLINK-27769][sql-gateway]Introduce the REST endpoint framework
No new revisions were added by this update.
Summary of changes:
.../client/program/rest/RestClusterClientTest.java | 4 +-
.../flink/docs/rest/OpenApiSpecGenerator.java | 10 +-
.../flink/docs/rest/RestAPIDocGenerator.java | 8 +-
.../flink/docs/rest/OpenApiSpecGeneratorTest.java | 6 +-
.../flink/docs/rest/RestAPIDocGeneratorTest.java | 4 +-
.../docs/rest/data/TestEmptyMessageHeaders.java | 10 +-
.../docs/rest/data/TestExcludeMessageHeaders.java | 11 +-
.../handlers/AbstractJarPlanHeaders.java | 5 +-
.../webmonitor/handlers/JarDeleteHeaders.java | 5 +-
.../webmonitor/handlers/JarListHeaders.java | 4 +-
.../runtime/webmonitor/handlers/JarRunHeaders.java | 4 +-
.../webmonitor/handlers/JarUploadHeaders.java | 4 +-
.../rest/compatibility/RestAPIStabilityTest.java | 10 +-
.../org/apache/flink/runtime/rest/RestClient.java | 6 +-
.../flink/runtime/rest/RestServerEndpoint.java | 20 +-
.../rest/handler/RestHandlerSpecification.java | 5 +-
.../AsynchronousOperationStatusMessageHeaders.java | 4 +-
...AsynchronousOperationTriggerMessageHeaders.java | 4 +-
.../files/WebContentHandlerSpecification.java | 9 +
.../messages/ClusterConfigurationInfoHeaders.java | 3 +-
.../rest/messages/ClusterOverviewHeaders.java | 2 +-
.../messages/DashboardConfigurationHeaders.java | 2 +-
.../rest/messages/JobAccumulatorsHeaders.java | 2 +-
.../rest/messages/JobCancellationHeaders.java | 2 +-
.../runtime/rest/messages/JobConfigHeaders.java | 2 +-
.../rest/messages/JobExceptionsHeaders.java | 2 +-
.../JobIdsWithStatusesOverviewHeaders.java | 2 +-
.../messages/JobManagerEnvironmentHeaders.java | 3 +-
.../rest/messages/JobManagerLogUrlHeaders.java | 2 +-
.../runtime/rest/messages/JobPlanHeaders.java | 2 +-
.../messages/JobVertexAccumulatorsHeaders.java | 2 +-
.../messages/JobVertexBackPressureHeaders.java | 2 +-
.../rest/messages/JobVertexDetailsHeaders.java | 2 +-
.../rest/messages/JobVertexFlameGraphHeaders.java | 2 +-
.../messages/JobVertexTaskManagersHeaders.java | 2 +-
.../runtime/rest/messages/JobsOverviewHeaders.java | 3 +-
...sageHeaders.java => RuntimeMessageHeaders.java} | 44 +-
...a => RuntimeUntypedResponseMessageHeaders.java} | 38 +-
.../messages/SubtasksAllAccumulatorsHeaders.java | 2 +-
.../rest/messages/SubtasksTimesHeaders.java | 3 +-
.../rest/messages/TaskManagerLogUrlHeaders.java | 2 +-
.../messages/UntypedResponseMessageHeaders.java | 2 +-
.../messages/YarnCancelJobTerminationHeaders.java | 9 +
.../messages/YarnStopJobTerminationHeaders.java | 9 +
.../checkpoints/CheckpointConfigHeaders.java | 5 +-
.../CheckpointStatisticDetailsHeaders.java | 4 +-
.../CheckpointingStatisticsHeaders.java | 5 +-
.../TaskCheckpointStatisticsHeaders.java | 4 +-
.../cluster/JobManagerCustomLogHeaders.java | 4 +-
.../messages/cluster/JobManagerLogFileHeader.java | 4 +-
.../messages/cluster/JobManagerLogListHeaders.java | 4 +-
.../cluster/JobManagerStdoutFileHeader.java | 4 +-
.../cluster/JobManagerThreadDumpHeaders.java | 4 +-
.../rest/messages/cluster/ShutdownHeaders.java | 5 +-
.../dataset/ClusterDataSetListHeaders.java | 4 +-
.../rest/messages/job/JobDetailsHeaders.java | 4 +-
.../messages/job/JobExecutionResultHeaders.java | 3 +-
.../job/JobManagerJobConfigurationHeaders.java | 5 +-
.../job/JobManagerJobEnvironmentHeaders.java | 4 +-
.../rest/messages/job/JobStatusInfoHeaders.java | 3 +-
.../rest/messages/job/JobSubmitHeaders.java | 4 +-
.../job/SubtaskCurrentAttemptDetailsHeaders.java | 4 +-
...SubtaskExecutionAttemptAccumulatorsHeaders.java | 4 +-
.../job/SubtaskExecutionAttemptDetailsHeaders.java | 4 +-
.../coordination/ClientCoordinationHeaders.java | 4 +-
.../metrics/AbstractAggregatedMetricsHeaders.java | 3 +-
.../job/metrics/AbstractMetricsHeaders.java | 3 +-
.../job/metrics/JobVertexWatermarksHeaders.java | 3 +-
.../taskmanager/TaskManagerCustomLogHeaders.java | 4 +-
.../taskmanager/TaskManagerDetailsHeaders.java | 4 +-
.../taskmanager/TaskManagerLogFileHeaders.java | 5 +-
.../taskmanager/TaskManagerLogsHeaders.java | 5 +-
.../taskmanager/TaskManagerStdoutFileHeaders.java | 5 +-
.../taskmanager/TaskManagerThreadDumpHeaders.java | 5 +-
.../messages/taskmanager/TaskManagersHeaders.java | 5 +-
.../runtime/rest/versioning/RestAPIVersion.java | 72 +--
...tAPIVersion.java => RuntimeRestAPIVersion.java} | 53 +-
.../NonLeaderRetrievalRestfulGateway.java | 102 ++++
.../runtime/rest/MultipartUploadResource.java | 7 +-
.../apache/flink/runtime/rest/RestClientTest.java | 9 +-
.../runtime/rest/RestExternalHandlersITCase.java | 4 +-
.../runtime/rest/RestServerEndpointITCase.java | 35 +-
.../runtime/rest/handler/AbstractHandlerTest.java | 7 +
.../AbstractTaskManagerFileHandlerTest.java | 7 +
.../runtime/rest/util/TestMessageHeaders.java | 4 +-
...ionTest.java => RuntimeRestAPIVersionTest.java} | 15 +-
.../endpoint/SqlGatewayEndpointFactoryUtils.java | 25 +-
flink-table/flink-sql-gateway/pom.xml | 5 +
.../table/gateway/rest/SqlGatewayRestEndpoint.java | 60 ++
.../handler/AbstractSqlGatewayRestHandler.java | 120 ++++
.../rest/header/SqlGatewayMessageHeaders.java | 41 +-
.../rest/util/SqlGatewayRestAPIVersion.java | 65 +--
.../rest/util/SqlGatewayRestEndpointFactory.java | 99 ++++
.../gateway/rest/util/SqlGatewayRestOptions.java | 64 +++
.../org.apache.flink.table.factories.Factory | 16 +
.../gateway/rest/SqlGatewayRestEndpointITCase.java | 608 +++++++++++++++++++++
.../gateway/rest/SqlGatewayRestEndpointTest.java | 164 ++++++
.../rest/TestingSqlGatewayRestEndpoint.java | 97 ++++
.../versioning/SqlGatewayRestAPIVersionTest.java | 37 +-
.../org.apache.flink.table.factories.Factory | 16 +
100 files changed, 1726 insertions(+), 413 deletions(-)
copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{UntypedResponseMessageHeaders.java => RuntimeMessageHeaders.java} (50%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/{UntypedResponseMessageHeaders.java => RuntimeUntypedResponseMessageHeaders.java} (52%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/versioning/{RestAPIVersion.java => RuntimeRestAPIVersion.java} (57%)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/NonLeaderRetrievalRestfulGateway.java
copy flink-runtime/src/test/java/org/apache/flink/runtime/rest/versioning/{RestAPIVersionTest.java => RuntimeRestAPIVersionTest.java} (72%)
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpoint.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/AbstractSqlGatewayRestHandler.java
copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/AsynchronousOperationTriggerMessageHeaders.java => flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/SqlGatewayMessageHeaders.java (52%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/versioning/RestAPIVersion.java => flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/util/SqlGatewayRestAPIVersion.java (54%)
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/util/SqlGatewayRestEndpointFactory.java
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/util/SqlGatewayRestOptions.java
create mode 100644 flink-table/flink-sql-gateway/src/main/resources/META-INF.services/org.apache.flink.table.factories.Factory
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpointITCase.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpointTest.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/TestingSqlGatewayRestEndpoint.java
rename flink-runtime/src/test/java/org/apache/flink/runtime/rest/versioning/RestAPIVersionTest.java => flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/versioning/SqlGatewayRestAPIVersionTest.java (51%)
create mode 100644 flink-table/flink-sql-gateway/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory