Re: Questions around MemoryStateBackend size limits

Hi + user mail list The limit max state size is because we would send the checkpointed data as a byte array and send it back to jobmanager. If the checkpointed byte stream is too large, the job manager would meet the risk of out-of-memory-error. If you want to use heap-based state-backend, you

[jira] [Created] (FLINK-18059) Can not execute create/drop catalog statement in sql client

godfrey he created FLINK-18059: -- Summary: Can not execute create/drop catalog statement in sql client Key: FLINK-18059 URL: https://issues.apache.org/jira/browse/FLINK-18059 Project: Flink Issu

[jira] [Created] (FLINK-18058) MesosResourceManagerTest.testWorkerStarted:656 » NullPointer

Robert Metzger created FLINK-18058: -- Summary: MesosResourceManagerTest.testWorkerStarted:656 » NullPointer Key: FLINK-18058 URL: https://issues.apache.org/jira/browse/FLINK-18058 Project: Flink

[jira] [Created] (FLINK-18057) SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2>

Robert Metzger created FLINK-18057: -- Summary: SingleInputGateTest.testConcurrentReadStateAndProcessAndClose: expected:<3> but was:<2> Key: FLINK-18057 URL: https://issues.apache.org/jira/browse/FLINK-18057

[jira] [Created] (FLINK-18056) Hive file sink throws exception when the target in-progress file exists.

Yun Gao created FLINK-18056: --- Summary: Hive file sink throws exception when the target in-progress file exists. Key: FLINK-18056 URL: https://issues.apache.org/jira/browse/FLINK-18056 Project: Flink

[jira] [Created] (FLINK-18055) Catalog does not exist in SQL Client

godfrey he created FLINK-18055: -- Summary: Catalog does not exist in SQL Client Key: FLINK-18055 URL: https://issues.apache.org/jira/browse/FLINK-18055 Project: Flink Issue Type: Bug Co

[jira] [Created] (FLINK-18054) Environment should provide API to resume from savepoint

Sergii Mikhtoniuk created FLINK-18054: - Summary: Environment should provide API to resume from savepoint Key: FLINK-18054 URL: https://issues.apache.org/jira/browse/FLINK-18054 Project: Flink

[jira] [Created] (FLINK-18053) Savepoints do not preserve watermarks

Sergii Mikhtoniuk created FLINK-18053: - Summary: Savepoints do not preserve watermarks Key: FLINK-18053 URL: https://issues.apache.org/jira/browse/FLINK-18053 Project: Flink Issue Type: B

[jira] [Created] (FLINK-18052) Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey fails with NPE

Robert Metzger created FLINK-18052: -- Summary: Elasticsearch7DynamicSinkITCase.testWritingDocumentsNoPrimaryKey fails with NPE Key: FLINK-18052 URL: https://issues.apache.org/jira/browse/FLINK-18052 P

[jira] [Created] (FLINK-18051) Fail Maven setup on AZP if download fails

Robert Metzger created FLINK-18051: -- Summary: Fail Maven setup on AZP if download fails Key: FLINK-18051 URL: https://issues.apache.org/jira/browse/FLINK-18051 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18050) Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch

Zhijiang created FLINK-18050: Summary: Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch Key: FLINK-18050 URL: https://issues.apache.org/jira/browse/FLINK-18050

[jira] [Created] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

Zheng Hu created FLINK-18049: Summary: The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema Key: FLINK-18049 URL: https://issues.apache.org/jira/browse/FLINK-18049

[ANNOUNCE] Weekly Community Update 2020/22

Dear community, happy to share this week's community update with an update on the upcoming Apache Flink releases: Flink 1.11 and Flink Stateful Functions 2.1. With the community focused on release testing the dev@ mailing list remains relatively quiet. Flink Development == * [releas

[jira] [Created] (FLINK-18048) "--host" option could not take effect for standalone application cluster

Yang Wang created FLINK-18048: - Summary: "--host" option could not take effect for standalone application cluster Key: FLINK-18048 URL: https://issues.apache.org/jira/browse/FLINK-18048 Project: Flink

Re: I want to contribute to Apache Flink

Hi Pony, Welcome to the community! Currently, there are no special permissions required to contribute to Flink. Just ping a committer if you want to work on some JIRA ticket and someone will assign the ticket to you. Here is some information about how to contribute to Flink [1]. [1] https://flin

I want to contribute to Apache Flink

Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is pony712.

[jira] [Created] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

pengnengsong created FLINK-18047: Summary: [DDL] ExecutotionEnvironment set the parallelism did not take effect Key: FLINK-18047 URL: https://issues.apache.org/jira/browse/FLINK-18047 Project: Flink

[VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1

Hi everyone, Please review and vote on the *release candidate #1* for the version 2.1.0 of Apache Flink Stateful Functions, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) ***Testing Guideline*** You can find here [1] a page in the pr

[jira] [Created] (FLINK-18046) Decimal column stats not supported for Hive table

Rui Li created FLINK-18046: -- Summary: Decimal column stats not supported for Hive table Key: FLINK-18046 URL: https://issues.apache.org/jira/browse/FLINK-18046 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18045) Newest version reintroduced a bug causing not working on secured MapR

Bartosz Krasiński created FLINK-18045: - Summary: Newest version reintroduced a bug causing not working on secured MapR Key: FLINK-18045 URL: https://issues.apache.org/jira/browse/FLINK-18045 Proje