Re: [DISCUSS] Releasing Flink 1.10.1

Hi All, Here is the status update of issues in 1.10.1 watch list: * Blockers (7) - [Under Discussion] FLINK-16018 Improve error reporting when submitting batch job (instead of AskTimeoutException) - [Under Discussion] FLINK-16142 Memory Leak causes Metaspace OOM error on repeated job submis

Re: [DISCUSS] Introduce TableFactory for StatefulSequenceSource

+1. I would suggest to take a step even further and see what users really need to test/try/play with table API and Flink SQL. Besides this one, here're some more sources and sinks that I have developed or used previously to facilitate building Flink table/SQL pipelines. 1. random input data s

[jira] [Created] (FLINK-16703) AkkaRpcActor state machine does record transition to terminating state.

Dmitri Chmelev created FLINK-16703: -- Summary: AkkaRpcActor state machine does record transition to terminating state. Key: FLINK-16703 URL: https://issues.apache.org/jira/browse/FLINK-16703 Project:

[jira] [Created] (FLINK-16702) develop JDBCCatalogFactory for service discovery

Bowen Li created FLINK-16702: Summary: develop JDBCCatalogFactory for service discovery Key: FLINK-16702 URL: https://issues.apache.org/jira/browse/FLINK-16702 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16701) Elasticsearch sink support alias for indices.

Leonard Xu created FLINK-16701: -- Summary: Elasticsearch sink support alias for indices. Key: FLINK-16701 URL: https://issues.apache.org/jira/browse/FLINK-16701 Project: Flink Issue Type: Improve

Re: [DISCUSS] JMX remote monitoring integration with Flink

Hi Rong Rong, you are right that it JMX is quite hard to use in production due to the mentioned problems with discovering the port. There is actually already a JIRA ticket [1] discussing this problem. It just never gained enough traction to be tackled. In general, I agree that it would be nice to

[jira] [Created] (FLINK-16700) Document Kinesis I/O Module

Seth Wiesman created FLINK-16700: Summary: Document Kinesis I/O Module Key: FLINK-16700 URL: https://issues.apache.org/jira/browse/FLINK-16700 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Link Stateful Functions from the Flink Website

+1 for the list of proposed changes - What is "Stateful Functions"? link - Documentation -> Stateful Functions Docs - StateFun on GitHub Cheers, Till On Thu, Mar 12, 2020 at 12:22 PM Stephan Ewen wrote: > Thank you all, for chiming in! > > I like the ideas suggested to update the website,

Re: Flink YARN app terminated before the client receives the result

Yes you are right that `thenAcceptAsync` only breaks the control flow but it does not guarantee that the `RestServer` has actually sent the response to the client. Maybe we also need something similar to FLINK-10309 [1]. The problem I see with this approach is that it makes all RestHandlers statefu

Re: Flink YARN app terminated before the client receives the result

Hi Tison & Till, Changing *thenAccept *into *thenAcceptAsync *in the MiniDispatcher#cancelJob does not help to solve the problem in my environment. However, I have found that adding a* Thread.sleep(2000) *before the return of JobCancellationHandler#handleRequest solved the problem (at least the sy

[jira] [Created] (FLINK-16699) Support accessing secured services via K8s secrets

Canbin Zheng created FLINK-16699: Summary: Support accessing secured services via K8s secrets Key: FLINK-16699 URL: https://issues.apache.org/jira/browse/FLINK-16699 Project: Flink Issue Type

[jira] [Created] (FLINK-16698) fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things

jackylau created FLINK-16698: Summary: fllink need catalog listener to do such as preCreate/PreDrop* afterCreate/AfterDrop* things Key: FLINK-16698 URL: https://issues.apache.org/jira/browse/FLINK-16698 P

[jira] [Created] (FLINK-16697) Disable JMX rebinding

Colm O hEigeartaigh created FLINK-16697: --- Summary: Disable JMX rebinding Key: FLINK-16697 URL: https://issues.apache.org/jira/browse/FLINK-16697 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16696) Incomplete REST API docs

Roman Khachatryan created FLINK-16696: - Summary: Incomplete REST API docs Key: FLINK-16696 URL: https://issues.apache.org/jira/browse/FLINK-16696 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16695) PrometheusReporterEndToEndITCase failed on travis

Piotr Nowojski created FLINK-16695: -- Summary: PrometheusReporterEndToEndITCase failed on travis Key: FLINK-16695 URL: https://issues.apache.org/jira/browse/FLINK-16695 Project: Flink Issue T

[jira] [Created] (FLINK-16694) Resuming Externalized Checkpoint end-to-end test failed on travis

Piotr Nowojski created FLINK-16694: -- Summary: Resuming Externalized Checkpoint end-to-end test failed on travis Key: FLINK-16694 URL: https://issues.apache.org/jira/browse/FLINK-16694 Project: Flink

[jira] [Created] (FLINK-16693) Legacy planner incompatible with Timestamp backed by LocalDateTime

Paul Lin created FLINK-16693: Summary: Legacy planner incompatible with Timestamp backed by LocalDateTime Key: FLINK-16693 URL: https://issues.apache.org/jira/browse/FLINK-16693 Project: Flink I

[jira] [Created] (FLINK-16692) flink joblistener can register from config

jackylau created FLINK-16692: Summary: flink joblistener can register from config Key: FLINK-16692 URL: https://issues.apache.org/jira/browse/FLINK-16692 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16691) Adjust Python UDF document to remind users to install PyFlink on the cluster

Huang Xingbo created FLINK-16691: Summary: Adjust Python UDF document to remind users to install PyFlink on the cluster Key: FLINK-16691 URL: https://issues.apache.org/jira/browse/FLINK-16691 Project:

[jira] [Created] (FLINK-16690) Refactor StreamTaskTest to reuse TestTaskBuilder and MockStreamTaskBuilder

Zhijiang created FLINK-16690: Summary: Refactor StreamTaskTest to reuse TestTaskBuilder and MockStreamTaskBuilder Key: FLINK-16690 URL: https://issues.apache.org/jira/browse/FLINK-16690 Project: Flink