[jira] [Created] (FLINK-18870) [Kinesis][EFO] Update Kinesis Consumer website to reflect EFO

Danny Cranmer created FLINK-18870: - Summary: [Kinesis][EFO] Update Kinesis Consumer website to reflect EFO Key: FLINK-18870 URL: https://issues.apache.org/jira/browse/FLINK-18870 Project: Flink

[jira] [Created] (FLINK-18871) Non-deterministic function could break retract mechanism

Benchao Li created FLINK-18871: -- Summary: Non-deterministic function could break retract mechanism Key: FLINK-18871 URL: https://issues.apache.org/jira/browse/FLINK-18871 Project: Flink Issue Ty

[jira] [Created] (FLINK-18872) Aggregate with mini-batch does not respect state retention

Benchao Li created FLINK-18872: -- Summary: Aggregate with mini-batch does not respect state retention Key: FLINK-18872 URL: https://issues.apache.org/jira/browse/FLINK-18872 Project: Flink Issue

[jira] [Created] (FLINK-18873) Make the WatermarkStrategy API more scala friendly

Dawid Wysakowicz created FLINK-18873: Summary: Make the WatermarkStrategy API more scala friendly Key: FLINK-18873 URL: https://issues.apache.org/jira/browse/FLINK-18873 Project: Flink Is

[jira] [Created] (FLINK-18874) Support conversion between Table and DataStream

Shuiqiang Chen created FLINK-18874: -- Summary: Support conversion between Table and DataStream Key: FLINK-18874 URL: https://issues.apache.org/jira/browse/FLINK-18874 Project: Flink Issue Typ

[jira] [Created] (FLINK-18875) DESCRIBE table can return the table properties

Kaibo Zhou created FLINK-18875: -- Summary: DESCRIBE table can return the table properties Key: FLINK-18875 URL: https://issues.apache.org/jira/browse/FLINK-18875 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-18876) BlobServer moves file with an open FileInputStream

Chesnay Schepler created FLINK-18876: Summary: BlobServer moves file with an open FileInputStream Key: FLINK-18876 URL: https://issues.apache.org/jira/browse/FLINK-18876 Project: Flink Is

Re: [DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API

Hi Xuannan, sorry for joining the discussion so late. I agree that this is a very nice and useful feature. However, the impact it has to many components in the stack requires more discussion in my opinion. 1) Separation of concerns: The current design seems to mix different layers. We should

Re: Adding a new "Docker Images" component to Jira

Thanks for the feedback. Transaction committed. On Mon, Aug 10, 2020 at 5:34 AM Matt Wang wrote: > +1 for unifying Deployment / Docker, Dockerfiles and Release System / > Docker into Docker. > > > -- > > Best, > Matt Wang > > > On 08/10/2020 11:21，Yang Wang wrote： > +1 for the unifying of the co

Re: [DISCUSS] Planning Flink 1.12

I updated the release date in the Wiki page. On Sun, Aug 9, 2020 at 8:18 PM Yun Tang wrote: > +1 for extending the feature freeze due date. > > From: Zhijiang > Sent: Thursday, August 6, 2020 17:05 > To: dev > Subject: Re: [DISCUSS] Planning Flink 1.12 > > +1 o

Re: [DISCUSS] Upgrade HBase connector to 2.2.x

@Jark: Thanks for bringing up these concerns. All the problems you've mentioned are "solvable": - uber jar: Bahir could provide a hbase1 uber jar (we could theoretically also add a dependency from flink to bahir and provide the uber jar from Flink) - e2e tests: we know that the connector is stable,

Re: Status of FLIPs

Thanks for cleaning up our Wiki. Seth and Timo: Can you check the status of the FLIPs mentioned in (3) ? On Wed, Aug 5, 2020 at 9:23 AM jincheng sun wrote: > Good job Dian! > Thank you for helping to maintain the state of FLIPs which is very > important for the community to understand the progr

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

I think this sounds good. +1 On Wed, Aug 5, 2020 at 8:37 PM jincheng sun wrote: > Hi David, Thank you for sharing the problems with the current document, > and I agree with you as I also got the same feedback from Chinese users. I > am often contacted by users to ask questions such as whether Py

[jira] [Created] (FLINK-18877) Faulty BinarySection.equals()

Timo Walther created FLINK-18877: Summary: Faulty BinarySection.equals() Key: FLINK-18877 URL: https://issues.apache.org/jira/browse/FLINK-18877 Project: Flink Issue Type: Bug Compo

[jira] [Created] (FLINK-18878) Support dependency management for Python StreamExecutionEnvironment.

Shuiqiang Chen created FLINK-18878: -- Summary: Support dependency management for Python StreamExecutionEnvironment. Key: FLINK-18878 URL: https://issues.apache.org/jira/browse/FLINK-18878 Project: Fli

Re: [DISCUSS] Upgrade HBase connector to 2.2.x

Hi All, I am also fairly torn on this one, however unless we are vigilant in keeping the flink repository relatively lean the number of modules will just keep increasing and pose an increasingly greater maintainability challenge. Less frequently used connectors are a strong candidate to be maintai

[jira] [Created] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink

Shuiqiang Chen created FLINK-18879: -- Summary: Support Row Serialization and Deserialization schemas for DataStream source/sink Key: FLINK-18879 URL: https://issues.apache.org/jira/browse/FLINK-18879

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

Thank you for your positive feedback Seth ! Would you please vote in the voting mail thread. Thank you! Best, Jincheng Seth Wiesman 于2020年8月10日周一 下午10:34写道： > I think this sounds good. +1 > > On Wed, Aug 5, 2020 at 8:37 PM jincheng sun > wrote: > >> Hi David, Thank you for sharing the problem

[jira] [Created] (FLINK-18880) Allow to configure the heap memory used by the gateway server

Dian Fu created FLINK-18880: --- Summary: Allow to configure the heap memory used by the gateway server Key: FLINK-18880 URL: https://issues.apache.org/jira/browse/FLINK-18880 Project: Flink Issue Ty

[jira] [Created] (FLINK-18881) Modify the Access Broken Link

weizheng created FLINK-18881: Summary: Modify the Access Broken Link Key: FLINK-18881 URL: https://issues.apache.org/jira/browse/FLINK-18881 Project: Flink Issue Type: Improvement Compo

[jira] [Created] (FLINK-18882) Investigate supporting Hive interval type

Rui Li created FLINK-18882: -- Summary: Investigate supporting Hive interval type Key: FLINK-18882 URL: https://issues.apache.org/jira/browse/FLINK-18882 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18883) Support reduce() operation for Python KeyedStream.

Hequn Cheng created FLINK-18883: --- Summary: Support reduce() operation for Python KeyedStream. Key: FLINK-18883 URL: https://issues.apache.org/jira/browse/FLINK-18883 Project: Flink Issue Type:

[jira] [Created] (FLINK-18884) Add chaining strategy and slot sharing group interfaces for DataStream

Shuiqiang Chen created FLINK-18884: -- Summary: Add chaining strategy and slot sharing group interfaces for DataStream Key: FLINK-18884 URL: https://issues.apache.org/jira/browse/FLINK-18884 Project: F

[jira] [Created] (FLINK-18885) Add partitioning interfaces for Python DataStream.

Shuiqiang Chen created FLINK-18885: -- Summary: Add partitioning interfaces for Python DataStream. Key: FLINK-18885 URL: https://issues.apache.org/jira/browse/FLINK-18885 Project: Flink Issue

[jira] [Created] (FLINK-18887) Add ElasticSearch connector for Python DataStream API

Shuiqiang Chen created FLINK-18887: -- Summary: Add ElasticSearch connector for Python DataStream API Key: FLINK-18887 URL: https://issues.apache.org/jira/browse/FLINK-18887 Project: Flink Iss

[jira] [Created] (FLINK-18886) Support Kafka connectors for Python DataStream API

Shuiqiang Chen created FLINK-18886: -- Summary: Support Kafka connectors for Python DataStream API Key: FLINK-18886 URL: https://issues.apache.org/jira/browse/FLINK-18886 Project: Flink Issue

[jira] [Created] (FLINK-18888) Add ElasticSearch connector for Python DataStream API

Shuiqiang Chen created FLINK-1: -- Summary: Add ElasticSearch connector for Python DataStream API Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project: Flink Iss

Re: [DISCUSS] Upgrade HBase connector to 2.2.x

Hi, all I’m +1 to support HBase 2.x and also keep the HBase1.x in flink project. IIRC, HBase1.x is still widely used in production in the early discussion of this thread according to HBase PMC memeber Yu Li and OpenInx’s investigation. Moving HBase1.x connector to Bahir means the HBase1.x con

[jira] [Created] (FLINK-18889) New Async Table Function type inference fails

Mulan created FLINK-18889: - Summary: New Async Table Function type inference fails Key: FLINK-18889 URL: https://issues.apache.org/jira/browse/FLINK-18889 Project: Flink Issue Type: Bug Com

Re: [DISCUSS][Release 1.12] Stale blockers and build instabilities

Hi team, 2 weeks have passed since the last update. None of the test stabilities I've mentioned have been addressed since then. Here's an updated status report of Blockers and Test instabilities: Blockers : Currently 3 blockers (