xuyang created FLINK-37174:
--
Summary: SqlClientTest#testPrintAllModeHelp and
#testPrintEmbeddedModeHelp failed
Key: FLINK-37174
URL: https://issues.apache.org/jira/browse/FLINK-37174
Project: Flink
xuyang created FLINK-37172:
--
Summary: Add logs in all existing async state ops to check if they
are under async state when running
Key: FLINK-37172
URL: https://issues.apache.org/jira/browse/FLINK-37172
Proj
xuyang created FLINK-37171:
--
Summary: Clear all remaining deprecated methods under public APIs
in table modules
Key: FLINK-37171
URL: https://issues.apache.org/jira/browse/FLINK-37171
Project: Flink
xuyang created FLINK-37117:
--
Summary: Add docs for async state SQL operator in 2.0
Key: FLINK-37117
URL: https://issues.apache.org/jira/browse/FLINK-37117
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-37106:
--
Summary: Consider extracting common methods in WindowJoinOperator
Key: FLINK-37106
URL: https://issues.apache.org/jira/browse/FLINK-37106
Project: Flink
Issue Type: Tech
xuyang created FLINK-37094:
--
Summary: Adapt the external Hive connector to the removal of
deprecated APIs in table module in 2.0
Key: FLINK-37094
URL: https://issues.apache.org/jira/browse/FLINK-37094
Projec
xuyang created FLINK-37079:
--
Summary: ci fails at
SqlYARNApplicationITCase.testDeployScriptViaSqlClient
Key: FLINK-37079
URL: https://issues.apache.org/jira/browse/FLINK-37079
Project: Flink
Issue
xuyang created FLINK-37001:
--
Summary: Remove all direct uses of
`TableEnvironmentInternal#registerTableSinkInternal` in table module
Key: FLINK-37001
URL: https://issues.apache.org/jira/browse/FLINK-37001
Pr
xuyang created FLINK-36998:
--
Summary: The RowKind of data about globalUpsertResult is different
in KeyedUpsertingSinkFunction while being inserted or be restored
Key: FLINK-36998
URL: https://issues.apache.org/jira/brows
xuyang created FLINK-36968:
--
Summary: The "values" lookup table used for testing does not
deduplicate data with the same key.
Key: FLINK-36968
URL: https://issues.apache.org/jira/browse/FLINK-36968
Project:
xuyang created FLINK-36927:
--
Summary: Introduce slicing & one stage Window Aggregate with Async
State API
Key: FLINK-36927
URL: https://issues.apache.org/jira/browse/FLINK-36927
Project: Flink
Issu
xuyang created FLINK-36926:
--
Summary: Introduce Window Join Operator with Async State API
Key: FLINK-36926
URL: https://issues.apache.org/jira/browse/FLINK-36926
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36849:
--
Summary: Introduce AppendOnlyFirstNFunction in Rank with Async
State API
Key: FLINK-36849
URL: https://issues.apache.org/jira/browse/FLINK-36849
Project: Flink
Issue Ty
xuyang created FLINK-36837:
--
Summary: Introduce new RowTimeDeduplicateFunction with Async State
API
Key: FLINK-36837
URL: https://issues.apache.org/jira/browse/FLINK-36837
Project: Flink
Issue Type
xuyang created FLINK-36831:
--
Summary: Introduce AppendOnlyTopNFunction in Rank with Async State
API
Key: FLINK-36831
URL: https://issues.apache.org/jira/browse/FLINK-36831
Project: Flink
Issue Type
xuyang created FLINK-36825:
--
Summary: Introduce FastTop1Function in Rank with Async State API
Key: FLINK-36825
URL: https://issues.apache.org/jira/browse/FLINK-36825
Project: Flink
Issue Type: Sub-t
xuyang created FLINK-36773:
--
Summary: Introduce new Group Agg Operator with Async State API
Key: FLINK-36773
URL: https://issues.apache.org/jira/browse/FLINK-36773
Project: Flink
Issue Type: Sub-tas
xuyang created FLINK-36675:
--
Summary: Dynamic option hints will not take effect when restoring
exec plan from json plan without setting 'table.plan.compile.catalog-objects'
to 'all'
Key: FLINK-36675
URL: https://issues.
xuyang created FLINK-36508:
--
Summary: Remove all deprecated methods in `SymbolType `
Key: FLINK-36508
URL: https://issues.apache.org/jira/browse/FLINK-36508
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36506:
--
Summary: Remove all deprecated methods in `ColumnStats`
Key: FLINK-36506
URL: https://issues.apache.org/jira/browse/FLINK-36506
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36507:
--
Summary: Remove deprecated method `LogicalTypeParser#parse`
Key: FLINK-36507
URL: https://issues.apache.org/jira/browse/FLINK-36507
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36505:
--
Summary: Remove all deprecated methods in
`ImperativeAggregateFunction`
Key: FLINK-36505
URL: https://issues.apache.org/jira/browse/FLINK-36505
Project: Flink
Issue Typ
xuyang created FLINK-36503:
--
Summary: Remove deprecated method
`FunctionDefinitionFactory#createFunctionDefinition`
Key: FLINK-36503
URL: https://issues.apache.org/jira/browse/FLINK-36503
Project: Flink
xuyang created FLINK-36504:
--
Summary: Remove all deprecated methods `ModuleFactory`
Key: FLINK-36504
URL: https://issues.apache.org/jira/browse/FLINK-36504
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36501:
--
Summary: Remove all deprecated methods in `CatalogFactory`
Key: FLINK-36501
URL: https://issues.apache.org/jira/browse/FLINK-36501
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36502:
--
Summary: Remove all deprecated methods in `FactoryUtil`
Key: FLINK-36502
URL: https://issues.apache.org/jira/browse/FLINK-36502
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36500:
--
Summary: Remove all deprecated methods in `CallExpression`
Key: FLINK-36500
URL: https://issues.apache.org/jira/browse/FLINK-36500
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36499:
--
Summary: Remove deprecated method
`SupportsProjectionPushDown#applyProjection`
Key: FLINK-36499
URL: https://issues.apache.org/jira/browse/FLINK-36499
Project: Flink
Is
xuyang created FLINK-36497:
--
Summary: Remove all deprecated methods in `CatalogTable`
Key: FLINK-36497
URL: https://issues.apache.org/jira/browse/FLINK-36497
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36498:
--
Summary: Remove deprecated method
`ResolvedCatalogBaseTable#getSchema`
Key: FLINK-36498
URL: https://issues.apache.org/jira/browse/FLINK-36498
Project: Flink
Issue Type
xuyang created FLINK-36496:
--
Summary: Remove deprecated method `CatalogFunction#isGeneric `
Key: FLINK-36496
URL: https://issues.apache.org/jira/browse/FLINK-36496
Project: Flink
Issue Type: Sub-tas
xuyang created FLINK-36495:
--
Summary: Remove deprecated method `CatalogBaseTable#getSchema`
Key: FLINK-36495
URL: https://issues.apache.org/jira/browse/FLINK-36495
Project: Flink
Issue Type: Sub-tas
xuyang created FLINK-36493:
--
Summary: Remove all deprecated methods in `MapView`
Key: FLINK-36493
URL: https://issues.apache.org/jira/browse/FLINK-36493
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36494:
--
Summary: Remove deprecated methods `Catalog#getTableFactory` and
`Catalog#supportsManagedTable`
Key: FLINK-36494
URL: https://issues.apache.org/jira/browse/FLINK-36494
Project: F
xuyang created FLINK-36492:
--
Summary: Remove all deprecated methods in `ListView`
Key: FLINK-36492
URL: https://issues.apache.org/jira/browse/FLINK-36492
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36489:
--
Summary: Remove deprecated method
`StreamTableEnvironment#toRetractStream`
Key: FLINK-36489
URL: https://issues.apache.org/jira/browse/FLINK-36489
Project: Flink
Issue
xuyang created FLINK-36491:
--
Summary: Remove deprecated method
`DataStreamSinkProvider#consumeDataStream`
Key: FLINK-36491
URL: https://issues.apache.org/jira/browse/FLINK-36491
Project: Flink
Issu
xuyang created FLINK-36490:
--
Summary: Remove deprecated method
`DataStreamScanProvider#produceDataStream`
Key: FLINK-36490
URL: https://issues.apache.org/jira/browse/FLINK-36490
Project: Flink
Issu
xuyang created FLINK-36486:
--
Summary: Remove deprecated method
`StreamTableEnvironment#registerDataStream`
Key: FLINK-36486
URL: https://issues.apache.org/jira/browse/FLINK-36486
Project: Flink
Iss
xuyang created FLINK-36488:
--
Summary: Remove deprecated method
`StreamTableEnvironment#toAppendStream`
Key: FLINK-36488
URL: https://issues.apache.org/jira/browse/FLINK-36488
Project: Flink
Issue T
xuyang created FLINK-36485:
--
Summary: Remove deprecated method
`StreamTableEnvironment#fromDataStream`
Key: FLINK-36485
URL: https://issues.apache.org/jira/browse/FLINK-36485
Project: Flink
Issue T
xuyang created FLINK-36487:
--
Summary: Remove deprecated method
`StreamTableEnvironment#createTemporaryView`
Key: FLINK-36487
URL: https://issues.apache.org/jira/browse/FLINK-36487
Project: Flink
Is
xuyang created FLINK-36484:
--
Summary: Remove deprecated method
`StreamTableEnvironment#registerFunction`
Key: FLINK-36484
URL: https://issues.apache.org/jira/browse/FLINK-36484
Project: Flink
Issue
xuyang created FLINK-36482:
--
Summary: Remove all deprecated methods in `TableEnvironment`
Key: FLINK-36482
URL: https://issues.apache.org/jira/browse/FLINK-36482
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36483:
--
Summary: Remove deprecated method `TableResult#getTableSchema`
Key: FLINK-36483
URL: https://issues.apache.org/jira/browse/FLINK-36483
Project: Flink
Issue Type: Sub-tas
xuyang created FLINK-36481:
--
Summary: Remove deprecated method `TableDescriptor#forManaged`
Key: FLINK-36481
URL: https://issues.apache.org/jira/browse/FLINK-36481
Project: Flink
Issue Type: Sub-tas
xuyang created FLINK-36480:
--
Summary: Remove all deprecated methods in `TableConfig`
Key: FLINK-36480
URL: https://issues.apache.org/jira/browse/FLINK-36480
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36479:
--
Summary: Remove deprecated methods `Table#getSchema` and `Table#as`
Key: FLINK-36479
URL: https://issues.apache.org/jira/browse/FLINK-36479
Project: Flink
Issue Type: Su
xuyang created FLINK-36478:
--
Summary: Remove deprecated methods
`EnvironmentSettings#fromConfiguration` and
`EnvironmentSettings#toConfiguration`
Key: FLINK-36478
URL: https://issues.apache.org/jira/browse/FLINK-36478
xuyang created FLINK-36477:
--
Summary: Remove deprecated method `BaseExpressions#cast` in
table-api-java
Key: FLINK-36477
URL: https://issues.apache.org/jira/browse/FLINK-36477
Project: Flink
Issue
xuyang created FLINK-36476:
--
Summary: Remove all deprecated methods under public APIs in table
modules
Key: FLINK-36476
URL: https://issues.apache.org/jira/browse/FLINK-36476
Project: Flink
Issue T
xuyang created FLINK-36436:
--
Summary: Remove legacy APIs with `legacy` package in table modules
Key: FLINK-36436
URL: https://issues.apache.org/jira/browse/FLINK-36436
Project: Flink
Issue Type: Imp
xuyang created FLINK-36396:
--
Summary: Remove dependency flink-java in all flink-table-api-xxx
module
Key: FLINK-36396
URL: https://issues.apache.org/jira/browse/FLINK-36396
Project: Flink
Issue Typ
xuyang created FLINK-36391:
--
Summary: Remove dependency flink-java in flink-table-runtime module
Key: FLINK-36391
URL: https://issues.apache.org/jira/browse/FLINK-36391
Project: Flink
Issue Type: Su
xuyang created FLINK-36387:
--
Summary: Remove dependency flink-java in flink-table-planner module
Key: FLINK-36387
URL: https://issues.apache.org/jira/browse/FLINK-36387
Project: Flink
Issue Type: Su
xuyang created FLINK-36386:
--
Summary: Remove dependency flink-java in
flink-table-planner-loader and flink-table-planner-loader-bundle module
Key: FLINK-36386
URL: https://issues.apache.org/jira/browse/FLINK-36386
xuyang created FLINK-36385:
--
Summary: Remove dependency flink-java in flink-sql-gateway module
Key: FLINK-36385
URL: https://issues.apache.org/jira/browse/FLINK-36385
Project: Flink
Issue Type: Sub-
xuyang created FLINK-36384:
--
Summary: Remove dependency flink-java in flink-sql-client module
Key: FLINK-36384
URL: https://issues.apache.org/jira/browse/FLINK-36384
Project: Flink
Issue Type: Sub-t
xuyang created FLINK-36383:
--
Summary: Remove dependency flink-java in flink-sql-jdbc-driver and
flink-sql-jdbc-driver-bundle module
Key: FLINK-36383
URL: https://issues.apache.org/jira/browse/FLINK-36383
Pro
xuyang created FLINK-36382:
--
Summary: Remove dependency flink-java in flink-table-test-utils
module
Key: FLINK-36382
URL: https://issues.apache.org/jira/browse/FLINK-36382
Project: Flink
Issue Type
xuyang created FLINK-36381:
--
Summary: Remove skip tag in python module caused by deprecating
legacy csv source
Key: FLINK-36381
URL: https://issues.apache.org/jira/browse/FLINK-36381
Project: Flink
xuyang created FLINK-36369:
--
Summary: Move deprecated user-visible classes in table modules to
the legacy package to make it easier to delete them later
Key: FLINK-36369
URL: https://issues.apache.org/jira/browse/FLINK-3
xuyang created FLINK-36363:
--
Summary: Remove references to scala-relate api in tests among
table modules
Key: FLINK-36363
URL: https://issues.apache.org/jira/browse/FLINK-36363
Project: Flink
Issue
xuyang created FLINK-36362:
--
Summary: Remove dependency about `flink-java` in table module
Key: FLINK-36362
URL: https://issues.apache.org/jira/browse/FLINK-36362
Project: Flink
Issue Type: Technica
xuyang created FLINK-36352:
--
Summary: Remove scala `Datastream` in docs
Key: FLINK-36352
URL: https://issues.apache.org/jira/browse/FLINK-36352
Project: Flink
Issue Type: Sub-task
Componen
xuyang created FLINK-36337:
--
Summary: Recursively check if the parent class is
org.apache.avro.specific.SpecificRecordBase to confirm whether it is an Avro
type
Key: FLINK-36337
URL: https://issues.apache.org/jira/brows
xuyang created FLINK-36334:
--
Summary: Remove the Disable markers from the tests in the various
TypeSerializerUpgradeTestBase subclasses that have been moved from the
flink-table-api-scala module
Key: FLINK-36334
URL: ht
xuyang created FLINK-36327:
--
Summary: Remove the dependencies of the flink-scala and
flink-streaming-scala modules from the table module.
Key: FLINK-36327
URL: https://issues.apache.org/jira/browse/FLINK-36327
xuyang created FLINK-36284:
--
Summary: StreamTableEnvironment#toDataStream(Table table, Class
targetClass) is not suitable for setting targetClass as a class generated by
Avro.
Key: FLINK-36284
URL: https://issues.apache
xuyang created FLINK-36277:
--
Summary: Remove all direct uses of
`TableEnvironmentInternal#registerTableSourceInternal`
Key: FLINK-36277
URL: https://issues.apache.org/jira/browse/FLINK-36277
Project: Flink
xuyang created FLINK-36273:
--
Summary: Remove deprecated Table/SQL configuration in 2.0
Key: FLINK-36273
URL: https://issues.apache.org/jira/browse/FLINK-36273
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36269:
--
Summary: Remove `fromTableSource` in python module
Key: FLINK-36269
URL: https://issues.apache.org/jira/browse/FLINK-36269
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36248:
--
Summary: Introduce new Join Operator with Async State API
Key: FLINK-36248
URL: https://issues.apache.org/jira/browse/FLINK-36248
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-36175:
--
Summary: Remove `register_table_source` and `register_table_sink`
in python module
Key: FLINK-36175
URL: https://issues.apache.org/jira/browse/FLINK-36175
Project: Flink
xuyang created FLINK-36171:
--
Summary: Remove APIs about ManagedTable
Key: FLINK-36171
URL: https://issues.apache.org/jira/browse/FLINK-36171
Project: Flink
Issue Type: Technical Debt
Compo
xuyang created FLINK-36157:
--
Summary: FLIP-473 Introduce New SQL Operators Based on
Asynchronous State APIs
Key: FLINK-36157
URL: https://issues.apache.org/jira/browse/FLINK-36157
Project: Flink
Is
xuyang created FLINK-36142:
--
Summary: Remove TestTableSourceWithTime and its subclasses to
prepare to remove TableEnvironmentInternal#registerTableSourceInternal
Key: FLINK-36142
URL: https://issues.apache.org/jira/brows
xuyang created FLINK-36136:
--
Summary: Remove TableSource & TableSink impl and utils, docs and
etc.
Key: FLINK-36136
URL: https://issues.apache.org/jira/browse/FLINK-36136
Project: Flink
Issue Type:
xuyang created FLINK-36135:
--
Summary: Remove the TableSource and TableSink ecosystem APIs like
TableFactory, DefinedFieldMapping, FilterableTableSource, etc.
Key: FLINK-36135
URL: https://issues.apache.org/jira/browse/FL
xuyang created FLINK-36133:
--
Summary: Remove subclass implementations of TableSource and
TableSink, along with their corresponding Factory classes.
Key: FLINK-36133
URL: https://issues.apache.org/jira/browse/FLINK-36133
xuyang created FLINK-36134:
--
Summary: Remove the classes associated with TableSource and
TableSink as part of the optimization process.
Key: FLINK-36134
URL: https://issues.apache.org/jira/browse/FLINK-36134
xuyang created FLINK-36132:
--
Summary: Remove codes that references TableSource and TableSink
directly at the API level.
Key: FLINK-36132
URL: https://issues.apache.org/jira/browse/FLINK-36132
Project: Flink
xuyang created FLINK-36122:
--
Summary: Redundant cast in outer layer when comparing Row Types
for equality
Key: FLINK-36122
URL: https://issues.apache.org/jira/browse/FLINK-36122
Project: Flink
Issu
xuyang created FLINK-35861:
--
Summary: The dependency of kafka sql connector seems wrong
Key: FLINK-35861
URL: https://issues.apache.org/jira/browse/FLINK-35861
Project: Flink
Issue Type: Bug
xuyang created FLINK-35829:
--
Summary: StreamPhysicalWindowTableFunction doesn't always require
watermark
Key: FLINK-35829
URL: https://issues.apache.org/jira/browse/FLINK-35829
Project: Flink
Issue
xuyang created FLINK-35792:
--
Summary: Sorting by proctime does not work in rank
Key: FLINK-35792
URL: https://issues.apache.org/jira/browse/FLINK-35792
Project: Flink
Issue Type: Bug
Compo
xuyang created FLINK-35271:
--
Summary: Add doc for syntax `describe job 'xxx'`
Key: FLINK-35271
URL: https://issues.apache.org/jira/browse/FLINK-35271
Project: Flink
Issue Type: Sub-task
Co
xuyang created FLINK-34381:
--
Summary: `RelDataType#getFullTypeString` should be used to print
in `RelTreeWriterImpl` if `withRowType` is true instead of `Object#toString`
Key: FLINK-34381
URL: https://issues.apache.org/j
xuyang created FLINK-34380:
--
Summary: Strange RowKind and records about intermediate output
when using minibatch join
Key: FLINK-34380
URL: https://issues.apache.org/jira/browse/FLINK-34380
Project: Flink
xuyang created FLINK-34378:
--
Summary: Minibatch join disrupted the original order of input
records
Key: FLINK-34378
URL: https://issues.apache.org/jira/browse/FLINK-34378
Project: Flink
Issue Type:
xuyang created FLINK-34375:
--
Summary: Complete work for syntax `DESCRIBE EXTENDED tableName`
Key: FLINK-34375
URL: https://issues.apache.org/jira/browse/FLINK-34375
Project: Flink
Issue Type: Sub-ta
xuyang created FLINK-34374:
--
Summary: Complete work for syntax `DESCRIBE EXTENDED DATABASE
databaseName`
Key: FLINK-34374
URL: https://issues.apache.org/jira/browse/FLINK-34374
Project: Flink
Issue
xuyang created FLINK-34373:
--
Summary: Complete work for syntax `DESCRIBE DATABASE databaseName`
Key: FLINK-34373
URL: https://issues.apache.org/jira/browse/FLINK-34373
Project: Flink
Issue Type: Sub
xuyang created FLINK-34372:
--
Summary: Complete work for syntax `DESCRIBE CATALOG catalogName`
Key: FLINK-34372
URL: https://issues.apache.org/jira/browse/FLINK-34372
Project: Flink
Issue Type: Sub-t
xuyang created FLINK-34370:
--
Summary: [Umbrella] Complete work about enhanced Flink SQL DDL
Key: FLINK-34370
URL: https://issues.apache.org/jira/browse/FLINK-34370
Project: Flink
Issue Type: Improv
xuyang created FLINK-34353:
--
Summary: A strange exception will be thrown if minibatch size is
not set while using mini-batch join
Key: FLINK-34353
URL: https://issues.apache.org/jira/browse/FLINK-34353
Proje
xuyang created FLINK-34348:
--
Summary: Release Testing: Verify FLINK-20281 Window aggregation
supports changelog stream input
Key: FLINK-34348
URL: https://issues.apache.org/jira/browse/FLINK-34348
Project: F
xuyang created FLINK-34346:
--
Summary: Release Testing: Verify FLINK-24024 Support session
Window TVF
Key: FLINK-34346
URL: https://issues.apache.org/jira/browse/FLINK-34346
Project: Flink
Issue Typ
xuyang created FLINK-34338:
--
Summary: An exception is thrown when some named params change
order when using window tvf
Key: FLINK-34338
URL: https://issues.apache.org/jira/browse/FLINK-34338
Project: Flink
xuyang created FLINK-34335:
--
Summary: Query hints in RexSubQuery could not be printed
Key: FLINK-34335
URL: https://issues.apache.org/jira/browse/FLINK-34335
Project: Flink
Issue Type: Bug
1 - 100 of 143 matches
Mail list logo
