[jira] [Created] (FLINK-21753) Cycle references between memory manager and gc cleaner action

Kezhu Wang created FLINK-21753: -- Summary: Cycle references between memory manager and gc cleaner action Key: FLINK-21753 URL: https://issues.apache.org/jira/browse/FLINK-21753 Project: Flink Is

[jira] [Created] (FLINK-21752) NullPointerException on restore in PojoSerializer

Roman Khachatryan created FLINK-21752: - Summary: NullPointerException on restore in PojoSerializer Key: FLINK-21752 URL: https://issues.apache.org/jira/browse/FLINK-21752 Project: Flink I

Re: [DISCUSS] Apache Flink Jira Process

Hi Leonard, Thank you for your feedback. Re Notifications: The bot would write a comment that would notify assignee, reporter and watchers. Probably, we could change the notifications not to notify watchers on comments, but this would also affect regular comments. Generally, I'd argue that if you

[jira] [Created] (FLINK-21751) Improve handling of freed slots if final requirement message is in flight

Chesnay Schepler created FLINK-21751: Summary: Improve handling of freed slots if final requirement message is in flight Key: FLINK-21751 URL: https://issues.apache.org/jira/browse/FLINK-21751 Pro

Re: [Parquet support]

Hi Jingsong, I just submitted a cherry-pick PR https://github.com/apache/flink/pull/15172 of (1) to release-.1.12 branch [1] https://github.com/apache/flink/pull/14961 Etienne On 12/03/2021 14:55, Etienne Chauchot wrote: Hi Jingsong, No problem for the delay. Thanks for merging the first p

[jira] [Created] (FLINK-21750) Support StreamExecWatermarkAssigner json serialization/deserialization

godfrey he created FLINK-21750: -- Summary: Support StreamExecWatermarkAssigner json serialization/deserialization Key: FLINK-21750 URL: https://issues.apache.org/jira/browse/FLINK-21750 Project: Flink

Re: [Parquet support]

Hi Jingsong, No problem for the delay. Thanks for merging the first parquet PR. I'll submit the 2 PRs to 1.12 when they're all merged to master. For that, I just have to submit a PR against this branch: https://github.com/apache/flink/tree/release-1.12 ? Best, Etienne On 12/03/2021 03:56,

[jira] [Created] (FLINK-21749) unable to use scala Shell

Bhagi created FLINK-21749: - Summary: unable to use scala Shell Key: FLINK-21749 URL: https://issues.apache.org/jira/browse/FLINK-21749 Project: Flink Issue Type: Bug Components: Deployment

Re: [DISCUSS] Move Flink ML pipeline API and library code to a separate repository named flink-ml

Thanks for raising the discussion, Dong. +1 on moving the Flink ML to a separate repository. Machine learning is a big area which deserves a separate project so the development can be decoupled from Flink core. In the meantime, it gives us the flexibility of evolving Flink without breaking the exi

[jira] [Created] (FLINK-21748) LocalExecutorITCase.testBatchQueryExecutionMultipleTimes[Planner: old] fails

Dawid Wysakowicz created FLINK-21748: Summary: LocalExecutorITCase.testBatchQueryExecutionMultipleTimes[Planner: old] fails Key: FLINK-21748 URL: https://issues.apache.org/jira/browse/FLINK-21748

[jira] [Created] (FLINK-21747) Encounter an exception that contains "max key length exceeded ..." when reporting metrics to influxdb

tim yu created FLINK-21747: -- Summary: Encounter an exception that contains "max key length exceeded ..." when reporting metrics to influxdb Key: FLINK-21747 URL: https://issues.apache.org/jira/browse/FLINK-21747

[jira] [Created] (FLINK-21746) flink sql fields in row access error about scalarfunction

Peihui He created FLINK-21746: - Summary: flink sql fields in row access error about scalarfunction Key: FLINK-21746 URL: https://issues.apache.org/jira/browse/FLINK-21746 Project: Flink Issue Typ

[jira] [Created] (FLINK-21745) JobMasterTest.testReconnectionAfterDisconnect hangs on azure

Dawid Wysakowicz created FLINK-21745: Summary: JobMasterTest.testReconnectionAfterDisconnect hangs on azure Key: FLINK-21745 URL: https://issues.apache.org/jira/browse/FLINK-21745 Project: Flink

[DISCUSS] Move Flink ML pipeline API and library code to a separate repository named flink-ml

Hi everyone, I am opening this thread to discuss the idea of moving Flink ML pipeline API and library code to a separate repository in Flink (similar to what we did for flink-statefun ). The Flink ML pipeline API was proposed by FLIP-39: Flink ML pipeline

[jira] [Created] (FLINK-21744) Support StreamExecDeduplicate json serialization/deserialization

Terry Wang created FLINK-21744: -- Summary: Support StreamExecDeduplicate json serialization/deserialization Key: FLINK-21744 URL: https://issues.apache.org/jira/browse/FLINK-21744 Project: Flink

[jira] [Created] (FLINK-21743) JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx

Wei Hao created FLINK-21743: --- Summary: JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx Key: FLINK-21743 URL: https://issues.apache.org/jira/browse/FLINK-21743 Project: Flink

Re: JIRA Username

Hi, Welcome to the community! You don't need a contributor permission to contribute to Apache Flink. Simply find a JIRA ticket you'd like to work on and ask a committer to assign you to the ticket. You may find more details in the contribution guidelines [1]. [1] https://flink.apache.org/contribu