Shengkai Fang created FLINK-35735:
-
Summary: Don't list catalogs when closing session
Key: FLINK-35735
URL: https://issues.apache.org/jira/browse/FLINK-35735
Project: Flink
Issue Type:
Shengkai Fang created FLINK-33490:
-
Summary: Validate the name conflicts when creating view
Key: FLINK-33490
URL: https://issues.apache.org/jira/browse/FLINK-33490
Project: Flink
Issue Type:
Shengkai Fang created FLINK-33446:
-
Summary:
SubQueryAntiJoinTest#testMultiNotExistsWithCorrelatedOnWhere_NestedCorrelation
doesn't produce the correct plan
Key: FLINK-33446
URL:
Shengkai Fang created FLINK-33226:
-
Summary: Forbid to drop current database
Key: FLINK-33226
URL: https://issues.apache.org/jira/browse/FLINK-33226
Project: Flink
Issue Type: Improvement
Shengkai Fang created FLINK-32618:
-
Summary: Remove the dependency of the flink-core in the
flink-sql-jdbc-driver-bundle
Key: FLINK-32618
URL: https://issues.apache.org/jira/browse/FLINK-32618
Shengkai Fang created FLINK-32617:
-
Summary: FlinkResultSetMetaData throw exception for most methods
Key: FLINK-32617
URL: https://issues.apache.org/jira/browse/FLINK-32617
Project: Flink
Shengkai Fang created FLINK-32616:
-
Summary: FlinkStatement#executeQuery resource leaks when the input
sql is not query
Key: FLINK-32616
URL: https://issues.apache.org/jira/browse/FLINK-32616
Shengkai Fang created FLINK-32299:
-
Summary: Upload python jar when sql contains python udf jar
Key: FLINK-32299
URL: https://issues.apache.org/jira/browse/FLINK-32299
Project: Flink
Issue
Shengkai Fang created FLINK-31403:
-
Summary: CliClientITCase print unexpected border when printing
explain results
Key: FLINK-31403
URL: https://issues.apache.org/jira/browse/FLINK-31403
Project:
Shengkai Fang created FLINK-31175:
-
Summary: Fix link doesn't work in hive_reaad_write doc
Key: FLINK-31175
URL: https://issues.apache.org/jira/browse/FLINK-31175
Project: Flink
Issue Type:
Shengkai Fang created FLINK-31137:
-
Summary: SQL Client doesn't print results for SHOW CREATE
TABLE/DESC in hive dialect
Key: FLINK-31137
URL: https://issues.apache.org/jira/browse/FLINK-31137
Shengkai Fang created FLINK-31136:
-
Summary: SQL Client Gateway mode should not read read execution
config
Key: FLINK-31136
URL: https://issues.apache.org/jira/browse/FLINK-31136
Project: Flink
Shengkai Fang created FLINK-31132:
-
Summary: Set sink.parallelism doesn't work for Hive table
Key: FLINK-31132
URL: https://issues.apache.org/jira/browse/FLINK-31132
Project: Flink
Issue
Shengkai Fang created FLINK-30970:
-
Summary: Fix SQL Client doc still uses old style output
Key: FLINK-30970
URL: https://issues.apache.org/jira/browse/FLINK-30970
Project: Flink
Issue Type:
Shengkai Fang created FLINK-30925:
-
Summary: Add docs for the SQL Client gateway mode
Key: FLINK-30925
URL: https://issues.apache.org/jira/browse/FLINK-30925
Project: Flink
Issue Type:
Shengkai Fang created FLINK-30868:
-
Summary: Revert to use LongSerializer for seralization in the
TimeIndicatorTypeInfo
Key: FLINK-30868
URL: https://issues.apache.org/jira/browse/FLINK-30868
Shengkai Fang created FLINK-30840:
-
Summary: Fix resource leak when creating Executor
Key: FLINK-30840
URL: https://issues.apache.org/jira/browse/FLINK-30840
Project: Flink
Issue Type:
Shengkai Fang created FLINK-30827:
-
Summary: Improve the SQL Client code structure
Key: FLINK-30827
URL: https://issues.apache.org/jira/browse/FLINK-30827
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-30819:
-
Summary: Fix history file records incomplete statement sets
Key: FLINK-30819
URL: https://issues.apache.org/jira/browse/FLINK-30819
Project: Flink
Issue
Shengkai Fang created FLINK-30816:
-
Summary: Fix Sql Client always uses the packaged highests version
to connect to gateway
Key: FLINK-30816
URL: https://issues.apache.org/jira/browse/FLINK-30816
Shengkai Fang created FLINK-30811:
-
Summary: Fix sql gateway can not stop job correctly
Key: FLINK-30811
URL: https://issues.apache.org/jira/browse/FLINK-30811
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-30810:
-
Summary: Rework the CliClientITCase to extend
AbstractSqlGatewayStatementITCase
Key: FLINK-30810
URL: https://issues.apache.org/jira/browse/FLINK-30810
Project:
Shengkai Fang created FLINK-30692:
-
Summary: Introduce embedded session manager to support REMOVE JAR
Key: FLINK-30692
URL: https://issues.apache.org/jira/browse/FLINK-30692
Project: Flink
Shengkai Fang created FLINK-30691:
-
Summary: Sql Client supports to specify endpoint address
Key: FLINK-30691
URL: https://issues.apache.org/jira/browse/FLINK-30691
Project: Flink
Issue
Shengkai Fang created FLINK-30675:
-
Summary: Decompose printing logic from Executor
Key: FLINK-30675
URL: https://issues.apache.org/jira/browse/FLINK-30675
Project: Flink
Issue Type:
Shengkai Fang created FLINK-30554:
-
Summary: Remove useless session id in the Sql Client Executor
Key: FLINK-30554
URL: https://issues.apache.org/jira/browse/FLINK-30554
Project: Flink
Issue
Shengkai Fang created FLINK-30497:
-
Summary: Introduce TableChange to represent DROP change
Key: FLINK-30497
URL: https://issues.apache.org/jira/browse/FLINK-30497
Project: Flink
Issue Type:
Shengkai Fang created FLINK-30496:
-
Summary: Introduce TableChange to represent MODIFY change
Key: FLINK-30496
URL: https://issues.apache.org/jira/browse/FLINK-30496
Project: Flink
Issue
Shengkai Fang created FLINK-30495:
-
Summary: Introduce TableChange to represents ADD change
Key: FLINK-30495
URL: https://issues.apache.org/jira/browse/FLINK-30495
Project: Flink
Issue Type:
Shengkai Fang created FLINK-30494:
-
Summary: Introduce TableChange to represents table option
modification
Key: FLINK-30494
URL: https://issues.apache.org/jira/browse/FLINK-30494
Project: Flink
Shengkai Fang created FLINK-30493:
-
Summary: FLIP 273: Improve the Catalog API to Support ALTER TABLE
syntax
Key: FLINK-30493
URL: https://issues.apache.org/jira/browse/FLINK-30493
Project: Flink
Shengkai Fang created FLINK-30416:
-
Summary: Add configureSession REST API in the SQL Gateway
Key: FLINK-30416
URL: https://issues.apache.org/jira/browse/FLINK-30416
Project: Flink
Issue
Shengkai Fang created FLINK-29875:
-
Summary: Can not find JobConf when using Hive Connector
Key: FLINK-29875
URL: https://issues.apache.org/jira/browse/FLINK-29875
Project: Flink
Issue
Shengkai Fang created FLINK-29734:
-
Summary: Support authentication in the Flink SQL Gateway
Key: FLINK-29734
URL: https://issues.apache.org/jira/browse/FLINK-29734
Project: Flink
Issue
Shengkai Fang created FLINK-29229:
-
Summary: Fix HiveServer2 Endpoint doesn't support execute
statements in sync mode
Key: FLINK-29229
URL: https://issues.apache.org/jira/browse/FLINK-29229
Project:
Shengkai Fang created FLINK-29228:
-
Summary: Align the schema of the HiveServer2 getMetadata with JDBC
Key: FLINK-29228
URL: https://issues.apache.org/jira/browse/FLINK-29228
Project: Flink
Shengkai Fang created FLINK-29188:
-
Summary: The option
`sql-gateway.endpint.hiveserver2.catalog.hive-conf-dir` should be requried
Key: FLINK-29188
URL: https://issues.apache.org/jira/browse/FLINK-29188
Shengkai Fang created FLINK-29185:
-
Summary: Failed to execute USING JAR in Hive Dialect
Key: FLINK-29185
URL: https://issues.apache.org/jira/browse/FLINK-29185
Project: Flink
Issue Type:
Shengkai Fang created FLINK-29184:
-
Summary: SQL Gateway should remove the downloaded resources
Key: FLINK-29184
URL: https://issues.apache.org/jira/browse/FLINK-29184
Project: Flink
Issue
Shengkai Fang created FLINK-29152:
-
Summary: Describe statement resutls is different from the Hive
Key: FLINK-29152
URL: https://issues.apache.org/jira/browse/FLINK-29152
Project: Flink
Shengkai Fang created FLINK-29151:
-
Summary: SHOW CREATE TABLE doesn't work for Hive dialect
Key: FLINK-29151
URL: https://issues.apache.org/jira/browse/FLINK-29151
Project: Flink
Issue
Shengkai Fang created FLINK-29148:
-
Summary: Add docs for SQL Gateway
Key: FLINK-29148
URL: https://issues.apache.org/jira/browse/FLINK-29148
Project: Flink
Issue Type: Improvement
Shengkai Fang created FLINK-29118:
-
Summary: Remove default_catalog in the HiveServer2 Endpoint
Key: FLINK-29118
URL: https://issues.apache.org/jira/browse/FLINK-29118
Project: Flink
Issue
Shengkai Fang created FLINK-29073:
-
Summary: [FLIP-91] Support SQL Gateway(Part 2)
Key: FLINK-29073
URL: https://issues.apache.org/jira/browse/FLINK-29073
Project: Flink
Issue Type: New
Shengkai Fang created FLINK-29000:
-
Summary: Support python UDF in the SQL Gateway
Key: FLINK-29000
URL: https://issues.apache.org/jira/browse/FLINK-29000
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-28954:
-
Summary: Release Testing: Verify HiveServer2 Endpoint
Key: FLINK-28954
URL: https://issues.apache.org/jira/browse/FLINK-28954
Project: Flink
Issue Type:
Shengkai Fang created FLINK-28953:
-
Summary: Release Testing: Verify FLIP-91 SQL Gateway
Key: FLINK-28953
URL: https://issues.apache.org/jira/browse/FLINK-28953
Project: Flink
Issue Type:
Shengkai Fang created FLINK-28938:
-
Summary: Fix HiveServer2 Endpoint can not set variable correctly
Key: FLINK-28938
URL: https://issues.apache.org/jira/browse/FLINK-28938
Project: Flink
Shengkai Fang created FLINK-28937:
-
Summary: Add doc for SqlGateway
Key: FLINK-28937
URL: https://issues.apache.org/jira/browse/FLINK-28937
Project: Flink
Issue Type: Improvement
Shengkai Fang created FLINK-28936:
-
Summary: Fix RSET endpoint can not serialize CHAR(0)
Key: FLINK-28936
URL: https://issues.apache.org/jira/browse/FLINK-28936
Project: Flink
Issue Type:
Shengkai Fang created FLINK-28851:
-
Summary: Allow to GetTypeInfo in the HiveServer2 Endpoint
Key: FLINK-28851
URL: https://issues.apache.org/jira/browse/FLINK-28851
Project: Flink
Issue
Shengkai Fang created FLINK-28793:
-
Summary: Allow to GetInfo for HiveServer2 Endpoint
Key: FLINK-28793
URL: https://issues.apache.org/jira/browse/FLINK-28793
Project: Flink
Issue Type:
Shengkai Fang created FLINK-28723:
-
Summary: Support json format to serialize the MapData when its key
is not STRING
Key: FLINK-28723
URL: https://issues.apache.org/jira/browse/FLINK-28723
Project:
Shengkai Fang created FLINK-28633:
-
Summary: Allow to GetTables in the HiveServer2 Endpoint
Key: FLINK-28633
URL: https://issues.apache.org/jira/browse/FLINK-28633
Project: Flink
Issue Type:
Shengkai Fang created FLINK-28632:
-
Summary: Allow to GetColumns/GetTableTypes/GetPrimaryKeys in the
HiveServer2 Endpoint
Key: FLINK-28632
URL: https://issues.apache.org/jira/browse/FLINK-28632
Shengkai Fang created FLINK-28630:
-
Summary: Allow to GetSchemas in the HiveServer2 Endpoint
Key: FLINK-28630
URL: https://issues.apache.org/jira/browse/FLINK-28630
Project: Flink
Issue
Shengkai Fang created FLINK-28631:
-
Summary: Allow to GetFunctions in the HiveServer2 Endpoint
Key: FLINK-28631
URL: https://issues.apache.org/jira/browse/FLINK-28631
Project: Flink
Issue
Shengkai Fang created FLINK-28629:
-
Summary: Allow to getCatalogs in the HiveServer2 Endpoint
Key: FLINK-28629
URL: https://issues.apache.org/jira/browse/FLINK-28629
Project: Flink
Issue
Shengkai Fang created FLINK-28238:
-
Summary: Fix unstable testCancelOperationAndFetchResultInParallel
Key: FLINK-28238
URL: https://issues.apache.org/jira/browse/FLINK-28238
Project: Flink
Shengkai Fang created FLINK-28164:
-
Summary: Introduce utilities API for REST endpint
Key: FLINK-28164
URL: https://issues.apache.org/jira/browse/FLINK-28164
Project: Flink
Issue Type:
Shengkai Fang created FLINK-28163:
-
Summary: Introduce the statement related API for REST endpoint
Key: FLINK-28163
URL: https://issues.apache.org/jira/browse/FLINK-28163
Project: Flink
Shengkai Fang created FLINK-28162:
-
Summary: Introduce the operation-related API for REST endpoint
Key: FLINK-28162
URL: https://issues.apache.org/jira/browse/FLINK-28162
Project: Flink
Shengkai Fang created FLINK-28161:
-
Summary: Introduce the session related API for REST endpoint
Key: FLINK-28161
URL: https://issues.apache.org/jira/browse/FLINK-28161
Project: Flink
Issue
Shengkai Fang created FLINK-28154:
-
Summary: Introduce the E2E test for HiveServer2 Endpoint
Key: FLINK-28154
URL: https://issues.apache.org/jira/browse/FLINK-28154
Project: Flink
Issue
Shengkai Fang created FLINK-28153:
-
Summary: Introduce the catalog-related API for HiveServer2 Endpoint
Key: FLINK-28153
URL: https://issues.apache.org/jira/browse/FLINK-28153
Project: Flink
Shengkai Fang created FLINK-28152:
-
Summary: Introduce the statement-related API for HiveServer2
Endpoint
Key: FLINK-28152
URL: https://issues.apache.org/jira/browse/FLINK-28152
Project: Flink
Shengkai Fang created FLINK-28151:
-
Summary: Introduce the session-related API for HiveServer2 Endpoint
Key: FLINK-28151
URL: https://issues.apache.org/jira/browse/FLINK-28151
Project: Flink
Shengkai Fang created FLINK-28150:
-
Summary: Introduce the hiveserver2 endpoint and factory
Key: FLINK-28150
URL: https://issues.apache.org/jira/browse/FLINK-28150
Project: Flink
Issue Type:
Shengkai Fang created FLINK-28149:
-
Summary: [FLIP-223] Support HiveServer2 Endpoint
Key: FLINK-28149
URL: https://issues.apache.org/jira/browse/FLINK-28149
Project: Flink
Issue Type: New
Shengkai Fang created FLINK-28053:
-
Summary: Introduce queue to execute request in sequence
Key: FLINK-28053
URL: https://issues.apache.org/jira/browse/FLINK-28053
Project: Flink
Issue Type:
Shengkai Fang created FLINK-27995:
-
Summary: Upgrade Janio version
Key: FLINK-27995
URL: https://issues.apache.org/jira/browse/FLINK-27995
Project: Flink
Issue Type: Improvement
Shengkai Fang created FLINK-27931:
-
Summary: Introduce the SqlGateway to assemble all components
Key: FLINK-27931
URL: https://issues.apache.org/jira/browse/FLINK-27931
Project: Flink
Issue
Shengkai Fang created FLINK-27874:
-
Summary: KeyedStateCheckpointingITCase Timeout
Key: FLINK-27874
URL: https://issues.apache.org/jira/browse/FLINK-27874
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-27838:
-
Summary: Support timeout mechansim for executeStatement API
Key: FLINK-27838
URL: https://issues.apache.org/jira/browse/FLINK-27838
Project: Flink
Issue
Shengkai Fang created FLINK-27837:
-
Summary: Support statement set in the SQL Gateway
Key: FLINK-27837
URL: https://issues.apache.org/jira/browse/FLINK-27837
Project: Flink
Issue Type:
Shengkai Fang created FLINK-27768:
-
Summary: Allow to execute sql for the SqlGatewayService
Key: FLINK-27768
URL: https://issues.apache.org/jira/browse/FLINK-27768
Project: Flink
Issue Type:
Shengkai Fang created FLINK-27773:
-
Summary: Introduce the E2E tests for SQL Gateway
Key: FLINK-27773
URL: https://issues.apache.org/jira/browse/FLINK-27773
Project: Flink
Issue Type:
Shengkai Fang created FLINK-27772:
-
Summary: Expose Operation-level logs in the SqlGatewayService
Key: FLINK-27772
URL: https://issues.apache.org/jira/browse/FLINK-27772
Project: Flink
Issue
Shengkai Fang created FLINK-27771:
-
Summary: Introduce the listAPIs in the SqlGatewayService
Key: FLINK-27771
URL: https://issues.apache.org/jira/browse/FLINK-27771
Project: Flink
Issue
Shengkai Fang created FLINK-27770:
-
Summary: Introduce the script to start/stop/stop-all gateway
Key: FLINK-27770
URL: https://issues.apache.org/jira/browse/FLINK-27770
Project: Flink
Issue
Shengkai Fang created FLINK-27769:
-
Summary: Introduce the REST endpoint framework
Key: FLINK-27769
URL: https://issues.apache.org/jira/browse/FLINK-27769
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-27766:
-
Summary: Introduce the framework of the GatewayService
Key: FLINK-27766
URL: https://issues.apache.org/jira/browse/FLINK-27766
Project: Flink
Issue Type:
Shengkai Fang created FLINK-27767:
-
Summary: Introduce Endpoint API and utils
Key: FLINK-27767
URL: https://issues.apache.org/jira/browse/FLINK-27767
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-27263:
-
Summary: Rename the metadata column to the user specified name in
DDL
Key: FLINK-27263
URL: https://issues.apache.org/jira/browse/FLINK-27263
Project: Flink
Shengkai Fang created FLINK-27212:
-
Summary: Failed to CAST('abcde', VARBINARY)
Key: FLINK-27212
URL: https://issues.apache.org/jira/browse/FLINK-27212
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-24930:
-
Summary: Print Sink should also print the table identifier when
output data
Key: FLINK-24930
URL: https://issues.apache.org/jira/browse/FLINK-24930
Project: Flink
Shengkai Fang created FLINK-23825:
-
Summary: Test SQL Client manually
Key: FLINK-23825
URL: https://issues.apache.org/jira/browse/FLINK-23825
Project: Flink
Issue Type: Improvement
Shengkai Fang created FLINK-23671:
-
Summary: Failed to inference type in correlate
Key: FLINK-23671
URL: https://issues.apache.org/jira/browse/FLINK-23671
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-23623:
-
Summary: Over expression should allow to order by any fields in
batch mode
Key: FLINK-23623
URL: https://issues.apache.org/jira/browse/FLINK-23623
Project: Flink
Shengkai Fang created FLINK-23467:
-
Summary: Remove the usage of the yaml file in pyflink e2e test
Key: FLINK-23467
URL: https://issues.apache.org/jira/browse/FLINK-23467
Project: Flink
Shengkai Fang created FLINK-23455:
-
Summary: Remove the usage of the yaml file in SQLJobSubmission
Key: FLINK-23455
URL: https://issues.apache.org/jira/browse/FLINK-23455
Project: Flink
Shengkai Fang created FLINK-23446:
-
Summary: Refactor SQL Client end to end tests
Key: FLINK-23446
URL: https://issues.apache.org/jira/browse/FLINK-23446
Project: Flink
Issue Type:
Shengkai Fang created FLINK-22969:
-
Summary: Validate the topic is not null or empty string when
create kafka source/sink function
Key: FLINK-22969
URL: https://issues.apache.org/jira/browse/FLINK-22969
Shengkai Fang created FLINK-22787:
-
Summary: Fix parse error when input statement has inline comments
Key: FLINK-22787
URL: https://issues.apache.org/jira/browse/FLINK-22787
Project: Flink
Shengkai Fang created FLINK-22694:
-
Summary: Refactor TPCH end to end tests
Key: FLINK-22694
URL: https://issues.apache.org/jira/browse/FLINK-22694
Project: Flink
Issue Type: Improvement
Shengkai Fang created FLINK-22673:
-
Summary: Add document about add jar related commands
Key: FLINK-22673
URL: https://issues.apache.org/jira/browse/FLINK-22673
Project: Flink
Issue Type:
Shengkai Fang created FLINK-22486:
-
Summary: Wrong results of the IN operator
Key: FLINK-22486
URL: https://issues.apache.org/jira/browse/FLINK-22486
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-22454:
-
Summary: Ignore CAST condition in temporal join
Key: FLINK-22454
URL: https://issues.apache.org/jira/browse/FLINK-22454
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-22338:
-
Summary: Clear watermark output when test finished for
FromElementSourceFunctionWithWatermark
Key: FLINK-22338
URL: https://issues.apache.org/jira/browse/FLINK-22338
Shengkai Fang created FLINK-22334:
-
Summary: Fail to translate the hive-sql in STREAMING mode
Key: FLINK-22334
URL: https://issues.apache.org/jira/browse/FLINK-22334
Project: Flink
Issue
1 - 100 of 160 matches
Mail list logo
