You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sh...@apache.org on 2022/08/26 03:28:15 UTC
[flink] branch master updated (cdc4f4b100d -> 0fd718c03d8)
This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from cdc4f4b100d [FLINK-28177][Connectors/ElasticSearch] Fix the unstable Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey
add b1db372c1e9 [hotfix][sql-gateway]Modify url in operation related message headers
add ad68495bb64 [hotfix][sql-gateway]Modify the response format and adjust SqlGatewayRestEndpointFactory
add 221fb98daa8 [FLINK-27773][sql-gateway]Introduce the rest E2E tests for SQL Gateway
add 0fd718c03d8 fixup! [FLINK-27773][sql-gateway]Introduce the rest E2E tests for SQL Gateway
No new revisions were added by this update.
Summary of changes:
.../flink/tests/util/flink/FlinkDistribution.java | 176 +++++++++++++++++----
.../flink-sql-gateway-test/pom.xml | 6 +
.../flink/table/gateway/SqlGatewayE2ECase.java | 71 ++++++---
.../src/test/resources/gateway_e2e.sql | 2 +
.../SqlGatewayEndpointFactoryUtilsTest.java | 2 +-
.../{util => }/SqlGatewayRestEndpointFactory.java | 10 +-
.../handler/statement/FetchResultsHandler.java | 2 +-
.../header/operation/CancelOperationHeaders.java | 2 +-
.../header/operation/CloseOperationHeaders.java | 2 +-
.../operation/GetOperationStatusHeaders.java | 2 +-
.../gateway/rest/util/SqlGatewayRestOptions.java | 18 ++-
.../org.apache.flink.table.factories.Factory | 2 +-
.../gateway/rest/SqlGatewayRestEndpointTest.java | 3 +-
.../table/gateway/rest/util/RestConfigUtils.java | 4 +-
.../org.apache.flink.table.factories.Factory | 16 --
.../apache/flink/table/factories/FactoryUtil.java | 2 +-
.../apache/flink/test/util/SQLJobSubmission.java | 4 +-
17 files changed, 236 insertions(+), 88 deletions(-)
rename flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/{util => }/SqlGatewayRestEndpointFactory.java (94%)
rename flink-table/flink-sql-gateway/src/main/resources/{META-INF.services => META-INF/services}/org.apache.flink.table.factories.Factory (99%)
delete mode 100644 flink-table/flink-sql-gateway/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory