Re: [DISCUSS] Releasing Stateful Functions 2.1.0 soon?

+1 from my side to have smaller and more frequent feature releases for the project in its early phases. Best, Congxian Marta Paes Moreira 于2020年5月21日周四 下午12:49写道： > +1 for more frequent releases with a shorter (but feedback-informed) > feature set. > > Thanks, Gordon (and Igal)! > > Marta > >

[jira] [Created] (FLINK-17859) [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest version

sam lin created FLINK-17859: --- Summary: [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest version Key: FLINK-17859 URL: https://issues.apache.org/jira/browse/FLINK-17859 Project: Flink

[jira] [Created] (FLINK-17862) The internal class StreamingRuntimeContext is leaked in AbstractUdfStreamOperator

Yangze Guo created FLINK-17862: -- Summary: The internal class StreamingRuntimeContext is leaked in AbstractUdfStreamOperator Key: FLINK-17862 URL: https://issues.apache.org/jira/browse/FLINK-17862

[jira] [Created] (FLINK-17860) Recursively remove channel state directories

Roman Khachatryan created FLINK-17860: - Summary: Recursively remove channel state directories Key: FLINK-17860 URL: https://issues.apache.org/jira/browse/FLINK-17860 Project: Flink Issue

[jira] [Created] (FLINK-17861) Channel state handles, when inlined, duplicate underlying data

Roman Khachatryan created FLINK-17861: - Summary: Channel state handles, when inlined, duplicate underlying data Key: FLINK-17861 URL: https://issues.apache.org/jira/browse/FLINK-17861 Project:

[jira] [Created] (FLINK-17866) InvalidPathException was thrown when running the test cases of PyFlink on Windows

Wei Zhong created FLINK-17866: - Summary: InvalidPathException was thrown when running the test cases of PyFlink on Windows Key: FLINK-17866 URL: https://issues.apache.org/jira/browse/FLINK-17866 Project:

[jira] [Created] (FLINK-17863) flink streaming sql read hive with lots small files need to control parallelism

richt richt created FLINK-17863: --- Summary: flink streaming sql read hive with lots small files need to control parallelism Key: FLINK-17863 URL: https://issues.apache.org/jira/browse/FLINK-17863

[jira] [Created] (FLINK-17864) Update document about removing #registerTableSource

Danny Chen created FLINK-17864: -- Summary: Update document about removing #registerTableSource Key: FLINK-17864 URL: https://issues.apache.org/jira/browse/FLINK-17864 Project: Flink Issue Type:

Re: [DISCUSS] increase "state.backend.fs.memory-threshold" from 1K to 100K

Have created FLINK-17865 [1] to follow this up. Thanks. Best Regards, Yu [1] https://issues.apache.org/jira/browse/FLINK-17865 On Wed, 20 May 2020 at 23:03, Stephan Ewen wrote: > Sounds good to me. > > By the next release, we should have also phased out the old Kafka Source, > which is one

Re: [DISCUSS] Releasing Stateful Functions 2.1.0 soon?

faster iteration definitely helps early-stage projects. +1 Best, Yuan On Thu, May 21, 2020 at 4:14 PM Congxian Qiu wrote: > +1 from my side to have smaller and more frequent feature releases for the > project in its early phases. > > Best, > Congxian > > > Marta Paes Moreira 于2020年5月21日周四

[jira] [Created] (FLINK-17865) Increase default size of `state.backend.fs.memory-threshold`

Yu Li created FLINK-17865: - Summary: Increase default size of `state.backend.fs.memory-threshold` Key: FLINK-17865 URL: https://issues.apache.org/jira/browse/FLINK-17865 Project: Flink Issue Type:

[jira] [Created] (FLINK-17871) Make the default value of attemptFailuresValidityInterval more reasonable

fanxin created FLINK-17871: -- Summary: Make the default value of attemptFailuresValidityInterval more reasonable Key: FLINK-17871 URL: https://issues.apache.org/jira/browse/FLINK-17871 Project: Flink

[jira] [Created] (FLINK-17870) scala shell jars are missing to be shipped to cluster

Jeff Zhang created FLINK-17870: -- Summary: scala shell jars are missing to be shipped to cluster Key: FLINK-17870 URL: https://issues.apache.org/jira/browse/FLINK-17870 Project: Flink Issue

本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群

job graph 阶段 HBaseRowInputFormat.java this.conf = {Configuration@4841} "Configuration: core-default.xml, core-site.xml, hbase-default.xml, hbase-site.xml" quietmode = true allowNullValueProperties = false resources = {ArrayList@4859} size = 2 finalParameters = {Collections$SetFromMap@4860}

[jira] [Created] (FLINK-17874) Writing to hbase throws NPE

chaiyongqiang created FLINK-17874: - Summary: Writing to hbase throws NPE Key: FLINK-17874 URL: https://issues.apache.org/jira/browse/FLINK-17874 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17875) Support state TTL for remote functions

Tzu-Li (Gordon) Tai created FLINK-17875: --- Summary: Support state TTL for remote functions Key: FLINK-17875 URL: https://issues.apache.org/jira/browse/FLINK-17875 Project: Flink Issue

Re: 本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群

Hi, hongxiao Please do not send user question to dev@flink.apache.org , dev@flink.apache.org is used for development discussion and only accept English from convenience consideration. dev-subscr...@flink.apache.org

[jira] [Created] (FLINK-17873) Add check for max concurrent checkpoints under UC mode

Yuan Mei created FLINK-17873: Summary: Add check for max concurrent checkpoints under UC mode Key: FLINK-17873 URL: https://issues.apache.org/jira/browse/FLINK-17873 Project: Flink Issue Type:

[jira] [Created] (FLINK-17872) Update StreamingFileSink documents to add avro formats

Yun Gao created FLINK-17872: --- Summary: Update StreamingFileSink documents to add avro formats Key: FLINK-17872 URL: https://issues.apache.org/jira/browse/FLINK-17872 Project: Flink Issue Type:

Re: [DISCUSS] Releasing Stateful Functions 2.1.0 soon?

Thanks for the positive feedback so far. Lets then set the feature freeze date for Stateful Functions 2.1.0 to be next Wednesday (May 27th). We've made good progress over the past days, all mentioned features merged besides the following: - https://issues.apache.org/jira/browse/FLINK-17875 State

[jira] [Created] (FLINK-17868) Proctime in DDL can not work in batch mode

Jingsong Lee created FLINK-17868: Summary: Proctime in DDL can not work in batch mode Key: FLINK-17868 URL: https://issues.apache.org/jira/browse/FLINK-17868 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17867) Fix Hive-3.1.1 test

Rui Li created FLINK-17867: -- Summary: Fix Hive-3.1.1 test Key: FLINK-17867 URL: https://issues.apache.org/jira/browse/FLINK-17867 Project: Flink Issue Type: Test Components: Connectors /

[jira] [Created] (FLINK-17869) Fix the race condition of aborting unaligned checkpoint

Zhijiang created FLINK-17869: Summary: Fix the race condition of aborting unaligned checkpoint Key: FLINK-17869 URL: https://issues.apache.org/jira/browse/FLINK-17869 Project: Flink Issue Type: