Re: How to clean up resources in a UDF?

2020-10-02 Thread Aljoscha Krettek
Unfortunately, there is no such hook right now. However, we're working on this in the context of FLIP-134 [1] and FLIP-143 [2]. Best, Aljoscha [1] https://cwiki.apache.org/confluence/x/4i94CQ [2] https://cwiki.apache.org/confluence/x/KEJ4CQ On 01.10.20 20:35, Boyuan Zhang wrote: Thanks, Aljos

[jira] [Created] (FLINK-19490) Document SOMAXCONN OS limit on blob server backlog

2020-10-02 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-19490: Summary: Document SOMAXCONN OS limit on blob server backlog Key: FLINK-19490 URL: https://issues.apache.org/jira/browse/FLINK-19490 Project: Flink Is

Re: [VOTE] FLIP-144: Native Kubernetes HA for Flink

2020-10-02 Thread Till Rohrmann
+1 (binding) Cheers, Till On Fri, Oct 2, 2020 at 3:13 AM Yang Wang wrote: > Hi, all > > > After the discussion in [1], I would like to open a voting thread for > FLIP-144 [2], > which proposes to add a new native Kubernetes HA service. > > > The vote will be open until October 6th (72h + weeke

[jira] [Created] (FLINK-19491) AvroSerializerSnapshot cannot handle large schema

2020-10-02 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-19491: --- Summary: AvroSerializerSnapshot cannot handle large schema Key: FLINK-19491 URL: https://issues.apache.org/jira/browse/FLINK-19491 Project: Flink Issue Type: B

[jira] [Created] (FLINK-19492) Consolidate Source Events between Source API and Split Reader API

2020-10-02 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-19492: Summary: Consolidate Source Events between Source API and Split Reader API Key: FLINK-19492 URL: https://issues.apache.org/jira/browse/FLINK-19492 Project: Flink

[jira] [Created] (FLINK-19493) In CliFrontend, make flow of Configuration more obvious

2020-10-02 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-19493: Summary: In CliFrontend, make flow of Configuration more obvious Key: FLINK-19493 URL: https://issues.apache.org/jira/browse/FLINK-19493 Project: Flink

[jira] [Created] (FLINK-19494) Adjust "StreamExecutionEnvironment.generateSequence()" to new API Sources

2020-10-02 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-19494: Summary: Adjust "StreamExecutionEnvironment.generateSequence()" to new API Sources Key: FLINK-19494 URL: https://issues.apache.org/jira/browse/FLINK-19494 Project: Fl

[jira] [Created] (FLINK-19495) Add documentation for avro-confluent format

2020-10-02 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-19495: Summary: Add documentation for avro-confluent format Key: FLINK-19495 URL: https://issues.apache.org/jira/browse/FLINK-19495 Project: Flink Issue Typ

[jira] [Created] (FLINK-19496) DataGen source DECIMAL always returns null

2020-10-02 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19496: Summary: DataGen source DECIMAL always returns null Key: FLINK-19496 URL: https://issues.apache.org/jira/browse/FLINK-19496 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19497) Implement mutator methods for FlinkCounterWrapper

2020-10-02 Thread Richard Moorhead (Jira)
Richard Moorhead created FLINK-19497: Summary: Implement mutator methods for FlinkCounterWrapper Key: FLINK-19497 URL: https://issues.apache.org/jira/browse/FLINK-19497 Project: Flink Iss