[jira] [Created] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

2021-12-04 Thread Lsw_aka_laplace (Jira)
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

[jira] [Created] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist

2021-04-11 Thread Lsw_aka_laplace (Jira)
Lsw_aka_laplace created FLINK-22196: --- Summary: FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist Key: FLINK-22196 URL:

[jira] [Created] (FLINK-21532) Make CatalogTableImpl#toProperties and CatalogTableImpl#fromProperties case sensitive

2021-02-28 Thread Lsw_aka_laplace (Jira)
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

[jira] [Created] (FLINK-19937) Support sink parallelism for all connectors

2020-11-02 Thread Lsw_aka_laplace (Jira)
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

[jira] [Created] (FLINK-19706) Introduce `Repeated Partition Commit Check` in `org.apache.flink.table.filesystem.PartitionCommitPolicy`

2020-10-19 Thread Lsw_aka_laplace (Jira)
Lsw_aka_laplace created FLINK-19706: --- Summary: Introduce `Repeated Partition Commit Check` in `org.apache.flink.table.filesystem.PartitionCommitPolicy` Key: FLINK-19706 URL:

[jira] [Created] (FLINK-19630) Sink data in [ORC] format into Hive By using Legacy Table API caused unexpected Exception

2020-10-13 Thread Lsw_aka_laplace (Jira)
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

[jira] [Created] (FLINK-15573) Let Flink SQL PlannerExpressionParserImpl#FieldRefrence use Unicode as its default charset

2020-01-13 Thread Lsw_aka_laplace (Jira)
Lsw_aka_laplace created FLINK-15573: --- Summary: Let Flink SQL PlannerExpressionParserImpl#FieldRefrence use Unicode as its default charset Key: FLINK-15573 URL:

[jira] [Created] (FLINK-14268) YARN AM endless restarts when using wrong checkpoint path or wrong checkpoint

2019-09-28 Thread Lsw_aka_laplace (Jira)
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