[jira] [Created] (FLINK-24568) Configuration equals method does not properly check equality

Jessie Anderson created FLINK-24568: --- Summary: Configuration equals method does not properly check equality Key: FLINK-24568 URL: https://issues.apache.org/jira/browse/FLINK-24568 Project: Flink

Re: [VOTE] Release 1.13.3, release candidate #1

Thanks Chesnay for driving this. +1 (non-binding) - verified the checksums - build 1.13.3-rc1 from sources - went over the pom file diff to see whether we missed newly added dependency in the NOTICE file - went over the release blog post - checked that scala 2.11 and 2.12 artifacts are present in

Re: [DISCUSS] Creating an external connector repository

My opinion of splitting the Flink repositories hasn't changed; I'm still in favor of it. While it would technically be possible to release individual connectors even if they are part of the Flink repo, it is quite a hassle to do so and error prone due to the current branch structure. A split

Re: [DISCUSS] Creating an external connector repository

Hi Arvid, In general I think breaking up the big repo would be a good move with many benefits (which you have outlined already). One concern would be how to proceed with our docs / examples if we were to really separate out all connectors. 1. More real-life examples would essentially now depend o

[DISCUSS] Creating an external connector repository

Dear community, Today I would like to kickstart a series of discussions around creating an external connector repository. The main idea is to decouple the release cycle of Flink with the release cycles of the connectors. This is a common approach in other big data analytics projects and seems to s

Re: Beam with Flink runner - Issues when writing to S3 in Parquet Format

Hi Sandeep and community, I'm a PMC member of the Beam community and also a contributor on Flink. I also used parquet in conjunction with Beam pipelines running with Flink Beam runner. So I should be able to help: I don't think it is a Flink issue as you have a Beam pipeline so you use only

[jira] [Created] (FLINK-24567) Support create tables using CatalogView defination

Xianxun Ye created FLINK-24567: -- Summary: Support create tables using CatalogView defination Key: FLINK-24567 URL: https://issues.apache.org/jira/browse/FLINK-24567 Project: Flink Issue Type: Im

Re: [Discussion] Avoid redundancy of Javadoc @return tag comment

Since images do not work with pony mail, enclosed please find them as attachments. Best regards Jing On Thu, Oct 14, 2021 at 6:43 PM Jing Ge wrote: > Agree. If the description contains more information than the return tag > comment. Part of content overlap is acceptable. Otherwise I think it >

[jira] [Created] (FLINK-24566) Remove CsvFileSystemFormatFactory

Francesco Guardiani created FLINK-24566: --- Summary: Remove CsvFileSystemFormatFactory Key: FLINK-24566 URL: https://issues.apache.org/jira/browse/FLINK-24566 Project: Flink Issue Type: S

[jira] [Created] (FLINK-24565) Port Avro FileSystemFormatFactory to StreamFormat

Francesco Guardiani created FLINK-24565: --- Summary: Port Avro FileSystemFormatFactory to StreamFormat Key: FLINK-24565 URL: https://issues.apache.org/jira/browse/FLINK-24565 Project: Flink

[jira] [Created] (FLINK-24564) Change the default compression to snappy for parquet, orc, avro in table

Jingsong Lee created FLINK-24564: Summary: Change the default compression to snappy for parquet, orc, avro in table Key: FLINK-24564 URL: https://issues.apache.org/jira/browse/FLINK-24564 Project: Fli

[jira] [Created] (FLINK-24563) Comparing timstamp_ltz with result of date_format with specific format throws NullPointerException

Caizhi Weng created FLINK-24563: --- Summary: Comparing timstamp_ltz with result of date_format with specific format throws NullPointerException Key: FLINK-24563 URL: https://issues.apache.org/jira/browse/FLINK-24563