Lsw_aka_laplace created FLINK-25167:
---
Summary: Support user-defined `StreamOperatorFactory` in
`ConnectedStreams`#transform
Key: FLINK-25167
URL: https://issues.apache.org/jira/browse/FLINK-25167
Pr
Lsw_aka_laplace created FLINK-22196:
---
Summary: FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out
the column indices which the does not exist
Key: FLINK-22196
URL: https://issues.apache.org/jira/browse/F
Lsw_aka_laplace created FLINK-21532:
---
Summary: Make CatalogTableImpl#toProperties and
CatalogTableImpl#fromProperties case sensitive
Key: FLINK-21532
URL: https://issues.apache.org/jira/browse/FLINK-21532
Lsw_aka_laplace created FLINK-19937:
---
Summary: Support sink parallelism for all connectors
Key: FLINK-19937
URL: https://issues.apache.org/jira/browse/FLINK-19937
Project: Flink
Issue Type:
Lsw_aka_laplace created FLINK-19706:
---
Summary: Introduce `Repeated Partition Commit Check` in
`org.apache.flink.table.filesystem.PartitionCommitPolicy`
Key: FLINK-19706
URL: https://issues.apache.org/jira/brows
Lsw_aka_laplace created FLINK-19630:
---
Summary: Sink data in [ORC] format into Hive By using Legacy Table
API caused unexpected Exception
Key: FLINK-19630
URL: https://issues.apache.org/jira/browse/FLINK-19630
Lsw_aka_laplace created FLINK-15573:
---
Summary: Let Flink SQL PlannerExpressionParserImpl#FieldRefrence
use Unicode as its default charset
Key: FLINK-15573
URL: https://issues.apache.org/jira/browse/FLINK-1557
Lsw_aka_laplace created FLINK-14268:
---
Summary: YARN AM endless restarts when using wrong checkpoint path
or wrong checkpoint
Key: FLINK-14268
URL: https://issues.apache.org/jira/browse/FLINK-14268
P