[jira] [Created] (FLINK-19760) Make the `GlobalCommitter` a standalone interface that does not extend the `Committer`

2020-10-21 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-19760: - Summary: Make the `GlobalCommitter` a standalone interface that does not extend the `Committer` Key: FLINK-19760 URL: https://issues.apache.org/jira/browse/FLINK-19760 Proj

[jira] [Created] (FLINK-19759) DeadlockBreakupTest.testSubplanReuse_AddSingletonExchange is instable

2020-10-21 Thread Dian Fu (Jira)
Dian Fu created FLINK-19759: --- Summary: DeadlockBreakupTest.testSubplanReuse_AddSingletonExchange is instable Key: FLINK-19759 URL: https://issues.apache.org/jira/browse/FLINK-19759 Project: Flink

[jira] [Created] (FLINK-19758) Implement a new unified File Sink based on the new Sink API

2020-10-21 Thread Yun Gao (Jira)
Yun Gao created FLINK-19758: --- Summary: Implement a new unified File Sink based on the new Sink API Key: FLINK-19758 URL: https://issues.apache.org/jira/browse/FLINK-19758 Project: Flink Issue Type

[jira] [Created] (FLINK-19757) TimeStampData can cause time inconsistent problem

2020-10-21 Thread xiaogang zhou (Jira)
xiaogang zhou created FLINK-19757: - Summary: TimeStampData can cause time inconsistent problem Key: FLINK-19757 URL: https://issues.apache.org/jira/browse/FLINK-19757 Project: Flink Issue Typ

[jira] [Created] (FLINK-19756) Use multi-input optimization by default

2020-10-21 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-19756: --- Summary: Use multi-input optimization by default Key: FLINK-19756 URL: https://issues.apache.org/jira/browse/FLINK-19756 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19755) flink cep

2020-10-21 Thread jackylau (Jira)
jackylau created FLINK-19755: Summary: flink cep Key: FLINK-19755 URL: https://issues.apache.org/jira/browse/FLINK-19755 Project: Flink Issue Type: Bug Components: Library / CEP Af

[jira] [Created] (FLINK-19754) Cannot have more than one execute() or executeAsync() call in a single environment.

2020-10-21 Thread little-tomato (Jira)
little-tomato created FLINK-19754: - Summary: Cannot have more than one execute() or executeAsync() call in a single environment. Key: FLINK-19754 URL: https://issues.apache.org/jira/browse/FLINK-19754

[jira] [Created] (FLINK-19753) Introduce 'STRCMP' function to compare between two string fields

2020-10-21 Thread hailong wang (Jira)
hailong wang created FLINK-19753: Summary: Introduce 'STRCMP' function to compare between two string fields Key: FLINK-19753 URL: https://issues.apache.org/jira/browse/FLINK-19753 Project: Flink

Re: [DISCUSS] FLIP-149: Introduce the KTable Connector

2020-10-21 Thread Jark Wu
Hi, IMO, if we are going to mix them in one connector, 1) either users need to set some options to a specific value explicitly, e.g. "scan.startup.mode=earliest", "sink.partitioner=hash", etc.. This makes the connector awkward to use. Users may face to fix options one by one according to the excep

[jira] [Created] (FLINK-19752) Convert BigDicimal TypeInformation to DataTypes error

2020-10-21 Thread AT-Fieldless (Jira)
AT-Fieldless created FLINK-19752: Summary: Convert BigDicimal TypeInformation to DataTypes error Key: FLINK-19752 URL: https://issues.apache.org/jira/browse/FLINK-19752 Project: Flink Issue T

[jira] [Created] (FLINK-19751) document error for GroupBy Window Aggregation

2020-10-21 Thread appleyuchi (Jira)
appleyuchi created FLINK-19751: -- Summary: document error for GroupBy Window Aggregation Key: FLINK-19751 URL: https://issues.apache.org/jira/browse/FLINK-19751 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-149: Introduce the KTable Connector

2020-10-21 Thread Konstantin Knauf
Hi Kurt, Hi Shengkai, thanks for answering my questions and the additional clarifications. I don't have a strong opinion on whether to extend the "kafka" connector or to introduce a new connector. So, from my perspective feel free to go with a separate connector. If we do introduce a new connector

[jira] [Created] (FLINK-19750) Deserializer is not opened in Kafka consumer when restoring from state

2020-10-21 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-19750: - Summary: Deserializer is not opened in Kafka consumer when restoring from state Key: FLINK-19750 URL: https://issues.apache.org/jira/browse/FLINK-19750 Project: Fli

[jira] [Created] (FLINK-19749) document error

2020-10-21 Thread appleyuchi (Jira)
appleyuchi created FLINK-19749: -- Summary: document error Key: FLINK-19749 URL: https://issues.apache.org/jira/browse/FLINK-19749 Project: Flink Issue Type: Bug Reporter: appleyuchi