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
Project:
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
Iss
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
Project
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-33446:
-
Summary:
SubQueryAntiJoinTest#testMultiNotExistsWithCorrelatedOnWhere_NestedCorrelation
doesn't produce the correct plan
Key: FLINK-33446
URL: https://issues.apache.org/jira/br
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-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: Sub-ta
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-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 Type
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-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
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: I
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: Flin
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 Ty
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-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-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-27766:
-
Summary: Introduce the framework of the GatewayService
Key: FLINK-27766
URL: https://issues.apache.org/jira/browse/FLINK-27766
Project: Flink
Issue Type: S
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-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 T
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 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-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: Sub-ta
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-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: Sub-ta
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 Ty
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-27931:
-
Summary: Introduce the SqlGateway to assemble all components
Key: FLINK-27931
URL: https://issues.apache.org/jira/browse/FLINK-27931
Project: Flink
Issue T
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
Co
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-28149:
-
Summary: [FLIP-223] Support HiveServer2 Endpoint
Key: FLINK-28149
URL: https://issues.apache.org/jira/browse/FLINK-28149
Project: Flink
Issue Type: New Fea
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-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-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-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-28154:
-
Summary: Introduce the E2E test for HiveServer2 Endpoint
Key: FLINK-28154
URL: https://issues.apache.org/jira/browse/FLINK-28154
Project: Flink
Issue Type:
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 T
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
Issue
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
Issue
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: Sub-ta
Shengkai Fang created FLINK-28238:
-
Summary: Fix unstable testCancelOperationAndFetchResultInParallel
Key: FLINK-28238
URL: https://issues.apache.org/jira/browse/FLINK-28238
Project: Flink
Is
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 Type
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 Typ
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 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
Projec
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-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: F
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: Sub-t
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 Type
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: Bug
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
Co
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
Iss
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: Sub
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: Su
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-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 Featu
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 Ty
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-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 Type:
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
Issu
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 Ty
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: Bug
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-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-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: F
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 Type:
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 Type:
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 Type
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-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-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-30496:
-
Summary: Introduce TableChange to represent MODIFY change
Key: FLINK-30496
URL: https://issues.apache.org/jira/browse/FLINK-30496
Project: Flink
Issue Type
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-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-30675:
-
Summary: Decompose printing logic from Executor
Key: FLINK-30675
URL: https://issues.apache.org/jira/browse/FLINK-30675
Project: Flink
Issue Type: Sub-task
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 Type:
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
Is
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: Fli
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-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
Proj
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 Ty
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-30840:
-
Summary: Fix resource leak when creating Executor
Key: FLINK-30840
URL: https://issues.apache.org/jira/browse/FLINK-30840
Project: Flink
Issue Type: Sub-ta
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
Project:
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: Improv
Shengkai Fang created FLINK-21454:
-
Summary: FLIP-163: SQL Client Improvements
Key: FLINK-21454
URL: https://issues.apache.org/jira/browse/FLINK-21454
Project: Flink
Issue Type: New Feature
Shengkai Fang created FLINK-21460:
-
Summary: Introduce option `table.planner`, `execution.runtime-mode`
Key: FLINK-21460
URL: https://issues.apache.org/jira/browse/FLINK-21460
Project: Flink
Shengkai Fang created FLINK-21462:
-
Summary: Use `table.planner`, `execution.runtime-mode` to create
TableEnvironment in sql client
Key: FLINK-21462
URL: https://issues.apache.org/jira/browse/FLINK-21462
Shengkai Fang created FLINK-21463:
-
Summary: Refactor client parser
Key: FLINK-21463
URL: https://issues.apache.org/jira/browse/FLINK-21463
Project: Flink
Issue Type: Sub-task
Compo
Shengkai Fang created FLINK-21464:
-
Summary: Support ADD JAR command in sql client
Key: FLINK-21464
URL: https://issues.apache.org/jira/browse/FLINK-21464
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-21465:
-
Summary: Extend explain syntax
Key: FLINK-21465
URL: https://issues.apache.org/jira/browse/FLINK-21465
Project: Flink
Issue Type: Sub-task
Compo
Shengkai Fang created FLINK-21466:
-
Summary: Simplify the command to start the sql client
Key: FLINK-21466
URL: https://issues.apache.org/jira/browse/FLINK-21466
Project: Flink
Issue Type: Su
Shengkai Fang created FLINK-21485:
-
Summary: Simplify the ExecutionContext
Key: FLINK-21485
URL: https://issues.apache.org/jira/browse/FLINK-21485
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-21675:
-
Summary: Push filter into the scan when watermark assigner is the
parent of the table scan
Key: FLINK-21675
URL: https://issues.apache.org/jira/browse/FLINK-21675
P
Shengkai Fang created FLINK-21701:
-
Summary: Extend the `RESET` command in the sql client
Key: FLINK-21701
URL: https://issues.apache.org/jira/browse/FLINK-21701
Project: Flink
Issue Type: Su
Shengkai Fang created FLINK-21702:
-
Summary: Support option `sql-client.verbos` to print the exception
stack
Key: FLINK-21702
URL: https://issues.apache.org/jira/browse/FLINK-21702
Project: Flink
Shengkai Fang created FLINK-21703:
-
Summary: Add option `table.dml-sync`
Key: FLINK-21703
URL: https://issues.apache.org/jira/browse/FLINK-21703
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-21836:
-
Summary: Introduce RegexOperationConverter
Key: FLINK-21836
URL: https://issues.apache.org/jira/browse/FLINK-21836
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-21847:
-
Summary: Introduce DESC grammar in sql parser
Key: FLINK-21847
URL: https://issues.apache.org/jira/browse/FLINK-21847
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-21877:
-
Summary: Add E2E test for upsert-kafka connector
Key: FLINK-21877
URL: https://issues.apache.org/jira/browse/FLINK-21877
Project: Flink
Issue Type: Test
1 - 100 of 160 matches
Mail list logo