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-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-19282:
-
Summary: Support watermark push down with WatermarkStrategy
Key: FLINK-19282
URL: https://issues.apache.org/jira/browse/FLINK-19282
Project: Flink
Issue Ty
Shengkai Fang created FLINK-19639:
-
Summary: Support SupportsNestedProjectionPushDown in planner
Key: FLINK-19639
URL: https://issues.apache.org/jira/browse/FLINK-19639
Project: Flink
Issue T
Shengkai Fang created FLINK-19647:
-
Summary: Support limit push down for hbase connector
Key: FLINK-19647
URL: https://issues.apache.org/jira/browse/FLINK-19647
Project: Flink
Issue Type: New
Shengkai Fang created FLINK-19648:
-
Summary: Support nested projection push down for hbase connector
Key: FLINK-19648
URL: https://issues.apache.org/jira/browse/FLINK-19648
Project: Flink
Iss
Shengkai Fang created FLINK-19650:
-
Summary: Support the limit push down for the Jdbc connector
Key: FLINK-19650
URL: https://issues.apache.org/jira/browse/FLINK-19650
Project: Flink
Issue Ty
Shengkai Fang created FLINK-19651:
-
Summary: Support filter push down for the Jdbc connector
Key: FLINK-19651
URL: https://issues.apache.org/jira/browse/FLINK-19651
Project: Flink
Issue Type:
Shengkai Fang created FLINK-20029:
-
Summary: Define the computed column on the metadata column
Key: FLINK-20029
URL: https://issues.apache.org/jira/browse/FLINK-20029
Project: Flink
Issue Typ
Shengkai Fang created FLINK-20041:
-
Summary: Support Watermark push down for kafka connector
Key: FLINK-20041
URL: https://issues.apache.org/jira/browse/FLINK-20041
Project: Flink
Issue Type:
Shengkai Fang created FLINK-20058:
-
Summary: Improve kafka per-partition-watermark tests
Key: FLINK-20058
URL: https://issues.apache.org/jira/browse/FLINK-20058
Project: Flink
Issue Type: Imp
Shengkai Fang created FLINK-20084:
-
Summary: Fix NPE when generating watermark for record whose
rowtime field is null after watermark push down
Key: FLINK-20084
URL: https://issues.apache.org/jira/browse/FLINK-200
Shengkai Fang created FLINK-20191:
-
Summary: Add document for per-partition-watermark kafka in table
api
Key: FLINK-20191
URL: https://issues.apache.org/jira/browse/FLINK-20191
Project: Flink
Shengkai Fang created FLINK-20271:
-
Summary: ArrayIndexOutOfBounds When using Rank
Key: FLINK-20271
URL: https://issues.apache.org/jira/browse/FLINK-20271
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-20272:
-
Summary: Wrong result of Rank Function
Key: FLINK-20272
URL: https://issues.apache.org/jira/browse/FLINK-20272
Project: Flink
Issue Type: Bug
Com
Shengkai Fang created FLINK-20273:
-
Summary: Fix Table api Kafka connector Sink Partitioner Document
Error
Key: FLINK-20273
URL: https://issues.apache.org/jira/browse/FLINK-20273
Project: Flink
Shengkai Fang created FLINK-20321:
-
Summary: Get NPE when using AvroDeserializationSchema to
deserialize null input
Key: FLINK-20321
URL: https://issues.apache.org/jira/browse/FLINK-20321
Project: Fli
Shengkai Fang created FLINK-20760:
-
Summary: Broken doc link in Apache Flink Code Style and Quality
Guide
Key: FLINK-20760
URL: https://issues.apache.org/jira/browse/FLINK-20760
Project: Flink
Shengkai Fang created FLINK-20825:
-
Summary: Upsert-kafka should throw a better exception when the key
of the record is NULL
Key: FLINK-20825
URL: https://issues.apache.org/jira/browse/FLINK-20825
Pro
Shengkai Fang created FLINK-20831:
-
Summary: Introduce the in memory topN buffer
Key: FLINK-20831
URL: https://issues.apache.org/jira/browse/FLINK-20831
Project: Flink
Issue Type: New Feature
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-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-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-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
Shengkai Fang created FLINK-21886:
-
Summary: Loosen argument of
TableEnvironmentInternal#executeInternal from QueryOperation to Operation
Key: FLINK-21886
URL: https://issues.apache.org/jira/browse/FLINK-21886
Shengkai Fang created FLINK-21887:
-
Summary: Add show views test in CliClientITCase
Key: FLINK-21887
URL: https://issues.apache.org/jira/browse/FLINK-21887
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-21968:
-
Summary: Calcite parser doesn't support to parse "-- test"
Key: FLINK-21968
URL: https://issues.apache.org/jira/browse/FLINK-21968
Project: Flink
Issue Typ
Shengkai Fang created FLINK-21974:
-
Summary: Don't match pattern `SET key= ' '` in
SetOperationParseStrategy
Key: FLINK-21974
URL: https://issues.apache.org/jira/browse/FLINK-21974
Project: Flink
Shengkai Fang created FLINK-21985:
-
Summary: Support Explain Query/Modifcation syntax in Calcite Parser
Key: FLINK-21985
URL: https://issues.apache.org/jira/browse/FLINK-21985
Project: Flink
Shengkai Fang created FLINK-22064:
-
Summary: Don't submit statement set when no insert is added in
the sql client
Key: FLINK-22064
URL: https://issues.apache.org/jira/browse/FLINK-22064
Project: Flin
Shengkai Fang created FLINK-22065:
-
Summary: Beautify the parse error exception when input invalid
command in the sql client
Key: FLINK-22065
URL: https://issues.apache.org/jira/browse/FLINK-22065
Pro
Shengkai Fang created FLINK-22078:
-
Summary: Introduce a Printer interface to rederict the output to
the desired stream
Key: FLINK-22078
URL: https://issues.apache.org/jira/browse/FLINK-22078
Project:
Shengkai Fang created FLINK-22118:
-
Summary: Always apply projection push down in blink planner
Key: FLINK-22118
URL: https://issues.apache.org/jira/browse/FLINK-22118
Project: Flink
Issue Ty
Shengkai Fang created FLINK-22155:
-
Summary: Fix EXPLAIN implementation
Key: FLINK-22155
URL: https://issues.apache.org/jira/browse/FLINK-22155
Project: Flink
Issue Type: Bug
Compon
Shengkai Fang created FLINK-22169:
-
Summary: Beautify the CliTableauResultView when print
Key: FLINK-22169
URL: https://issues.apache.org/jira/browse/FLINK-22169
Project: Flink
Issue Type: Bu
Shengkai Fang created FLINK-22171:
-
Summary: Update the doc about SQL Client
Key: FLINK-22171
URL: https://issues.apache.org/jira/browse/FLINK-22171
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-22176:
-
Summary: Test SQL Client manually
Key: FLINK-22176
URL: https://issues.apache.org/jira/browse/FLINK-22176
Project: Flink
Issue Type: Bug
Componen
Shengkai Fang created FLINK-22245:
-
Summary: Reuse PrintUtils.MAX_COLUMN_WIDTH in
CliChangelogResultView and CliTableResultView
Key: FLINK-22245
URL: https://issues.apache.org/jira/browse/FLINK-22245
Shengkai Fang created FLINK-22308:
-
Summary: Fix CliTableauResultView print results after cancel in
STREAMING mode
Key: FLINK-22308
URL: https://issues.apache.org/jira/browse/FLINK-22308
Project: Flin
Shengkai Fang created FLINK-22309:
-
Summary: Reduce response time when using SQL Client submit
query(SELECT)
Key: FLINK-22309
URL: https://issues.apache.org/jira/browse/FLINK-22309
Project: Flink
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 Type
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-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-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
1 - 100 of 170 matches
Mail list logo