[jira] [Created] (FLINK-26099) Table connector proctime attributes has syntax error

2022-02-13 Thread Mans Singh (Jira)
Mans Singh created FLINK-26099: -- Summary: Table connector proctime attributes has syntax error Key: FLINK-26099 URL: https://issues.apache.org/jira/browse/FLINK-26099 Project: Flink Issue Type:

[jira] [Created] (FLINK-26102) connector test by using 'flink run --python'

2022-02-13 Thread waittting (Jira)
waittting created FLINK-26102: - Summary: connector test by using 'flink run --python' Key: FLINK-26102 URL: https://issues.apache.org/jira/browse/FLINK-26102 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26106) BoundedSourceITCase failed due to JVM exits with code 239

2022-02-13 Thread Yun Gao (Jira)
Yun Gao created FLINK-26106: --- Summary: BoundedSourceITCase failed due to JVM exits with code 239 Key: FLINK-26106 URL: https://issues.apache.org/jira/browse/FLINK-26106 Project: Flink Issue Type:

[jira] [Created] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

2022-02-13 Thread Yun Gao (Jira)
Yun Gao created FLINK-26105: --- Summary: Running HA (hashmap, async) end-to-end test failed on azure Key: FLINK-26105 URL: https://issues.apache.org/jira/browse/FLINK-26105 Project: Flink Issue

[jira] [Created] (FLINK-26104) KeyError: 'type_info' in PyFlink test

2022-02-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26104: Summary: KeyError: 'type_info' in PyFlink test Key: FLINK-26104 URL: https://issues.apache.org/jira/browse/FLINK-26104 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26101) Avoid shared state registry to discard duplicate changelog state

2022-02-13 Thread Yun Tang (Jira)
Yun Tang created FLINK-26101: Summary: Avoid shared state registry to discard duplicate changelog state Key: FLINK-26101 URL: https://issues.apache.org/jira/browse/FLINK-26101 Project: Flink

[jira] [Created] (FLINK-26100) Set up Flink ML Document Website

2022-02-13 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-26100: Summary: Set up Flink ML Document Website Key: FLINK-26100 URL: https://issues.apache.org/jira/browse/FLINK-26100 Project: Flink Issue Type: New Feature

Re: [DISCUSS]Support the merge statement in FlinkSQL

2022-02-13 Thread OpenInx
I'm currently maintaining the iceberg flink modules from apache iceberg community. Currently, the spark has a great integration experience with iceberg format v2 in batch mode. In this document [1], The merge into syntax from spark sql extensions does really help a lot when people want to change

[jira] [Created] (FLINK-26103) Introduce log store

2022-02-13 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26103: Summary: Introduce log store Key: FLINK-26103 URL: https://issues.apache.org/jira/browse/FLINK-26103 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26107) CoordinatorEventsExactlyOnceITCase.test failed on azure

2022-02-13 Thread Yun Gao (Jira)
Yun Gao created FLINK-26107: --- Summary: CoordinatorEventsExactlyOnceITCase.test failed on azure Key: FLINK-26107 URL: https://issues.apache.org/jira/browse/FLINK-26107 Project: Flink Issue Type:

[jira] [Created] (FLINK-26111) ElasticsearchSinkITCase.testElasticsearchSink failed on azure

2022-02-13 Thread Yun Gao (Jira)
Yun Gao created FLINK-26111: --- Summary: ElasticsearchSinkITCase.testElasticsearchSink failed on azure Key: FLINK-26111 URL: https://issues.apache.org/jira/browse/FLINK-26111 Project: Flink Issue

[jira] [Created] (FLINK-26109) Avro Confluent Schema Registry nightly end-to-end test failed on azure

2022-02-13 Thread Yun Gao (Jira)
Yun Gao created FLINK-26109: --- Summary: Avro Confluent Schema Registry nightly end-to-end test failed on azure Key: FLINK-26109 URL: https://issues.apache.org/jira/browse/FLINK-26109 Project: Flink

[jira] [Created] (FLINK-26112) Port getEndpoint method to the specific service type subclass

2022-02-13 Thread Aitozi (Jira)
Aitozi created FLINK-26112: -- Summary: Port getEndpoint method to the specific service type subclass Key: FLINK-26112 URL: https://issues.apache.org/jira/browse/FLINK-26112 Project: Flink Issue

[jira] [Created] (FLINK-26110) AvroStreamingFileSinkITCase failed on azure

2022-02-13 Thread Yun Gao (Jira)
Yun Gao created FLINK-26110: --- Summary: AvroStreamingFileSinkITCase failed on azure Key: FLINK-26110 URL: https://issues.apache.org/jira/browse/FLINK-26110 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26108) CoordinatedSourceITCase.testEnumeratorCreationFails failed on azure

2022-02-13 Thread Yun Gao (Jira)
Yun Gao created FLINK-26108: --- Summary: CoordinatedSourceITCase.testEnumeratorCreationFails failed on azure Key: FLINK-26108 URL: https://issues.apache.org/jira/browse/FLINK-26108 Project: Flink

[jira] [Created] (FLINK-26113) (1.16) Follow up tasks and code refactoring for FLIP-147

2022-02-13 Thread Yun Gao (Jira)
Yun Gao created FLINK-26113: --- Summary: (1.16) Follow up tasks and code refactoring for FLIP-147 Key: FLINK-26113 URL: https://issues.apache.org/jira/browse/FLINK-26113 Project: Flink Issue Type: