Re: [ANNOUNCE] Apache Flink 1.14.0 released

2021-09-30 Thread JING ZHANG
Great! Thanks David, Joe, Xintong and everyone who makes this possible. Best, JING ZHANG Leonard Xu 于2021年10月1日周五 上午10:20写道: > Congratulations! > > Thanks Dawid, Xintong and Joe for being our release managers and everyone > who contributed to this release. > > Best, > Leonard > > > 在

Re: [DISCUSS] Releasing Flink 1.13.3

2021-09-30 Thread Leonard Xu
> From the SQL primary key issue side, all backports are merged. Feel free to > proceed with the release. The changelog ordering mechanism is pretty important for SQL users, thanks Timo for the backports effort. >> I can help Leonard with the PMC bits for the 1.13.3 release. Thanks Chesnay

Re: [ANNOUNCE] Apache Flink 1.14.0 released

2021-09-30 Thread Leonard Xu
Congratulations! Thanks Dawid, Xintong and Joe for being our release managers and everyone who contributed to this release. Best, Leonard > 在 2021年9月30日,21:45,David Morávek 写道: > > Thanks Dawid, Xintong and Joe for being really great release managers and > everyone else who helped making

[jira] [Created] (FLINK-24432) RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method

2021-09-30 Thread Victor Xu (Jira)
Victor Xu created FLINK-24432: - Summary: RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method Key: FLINK-24432 URL: https://issues.apache.org/jira/browse/FLINK-24432 Project: Flink

[jira] [Created] (FLINK-24431) [Kinesis][EFO] EAGER registration strategy does not work when job fails over

2021-09-30 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-24431: - Summary: [Kinesis][EFO] EAGER registration strategy does not work when job fails over Key: FLINK-24431 URL: https://issues.apache.org/jira/browse/FLINK-24431

[jira] [Created] (FLINK-24430) Clean up log pollution

2021-09-30 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-24430: - Summary: Clean up log pollution Key: FLINK-24430 URL: https://issues.apache.org/jira/browse/FLINK-24430 Project: Flink Issue Type: Technical Debt

Re: [Flink blogs]

2021-09-30 Thread Till Rohrmann
Hi Etienne, Great to see that you want to write about one of the topics you have worked on! Spreading the word about changes/improvements/new features is always super important. As a general recommendation I think you should write about the topic you are most excited about. This usually results

Re: [ANNOUNCE] Apache Flink 1.14.0 released

2021-09-30 Thread David Morávek
Thanks Dawid, Xintong and Joe for being really great release managers and everyone else who helped making this release possible! <3 Best, D. On Thu, Sep 30, 2021 at 3:31 PM Till Rohrmann wrote: > Thanks a lot for being our release managers Dawid, Xintong and Joe. Also a > big thanks to

Re: [ANNOUNCE] Apache Flink 1.14.0 released

2021-09-30 Thread Till Rohrmann
Thanks a lot for being our release managers Dawid, Xintong and Joe. Also a big thanks to everyone who contributed to this release and helped make it happen! Cheers, Till On Thu, Sep 30, 2021 at 10:12 AM Caizhi Weng wrote: > Congratulations! > > As a side note, I notice that the

Re: [ANNOUNCE] Flink mailing lists archive service has migrated to Apache Archive service

2021-09-30 Thread Robert Metzger
@Matthias Pohl : I've also been annoyed by this 30 days limit, but I'm not aware of a way to globally change the default. I would ask in #asfinfra in the asf slack. On Thu, Sep 30, 2021 at 12:19 PM Till Rohrmann wrote: > Thanks for the hint with the managed search engines Matthias. I think this

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

2021-09-30 Thread Till Rohrmann
Hi Sandeep, I am not a Beam expert. The problem might be caused by the used S3 filesystem implementation. Have you tried whether the same problem occurs when using vanilla Flink's latest version? Alternatively, you could also reach out to the Beam community or ask on Flink's user ML whether

Re: Is anyone still using the 1.11-1.13 Burndown/Bugs/Sprint Kanban boards?

2021-09-30 Thread Till Rohrmann
I think it should be fine to remove these boards. So +1 for removing them from my side. Cheers, Till On Mon, Sep 6, 2021 at 1:13 PM Chesnay Schepler wrote: > Is anyone still using one of these boards? I would like to remove them > unless they are still of value to someone. > > >

[jira] [Created] (FLINK-24429) Port FileSystemTableSink to new Unified Sink API (FLIP-143)

2021-09-30 Thread Alexander Preuss (Jira)
Alexander Preuss created FLINK-24429: Summary: Port FileSystemTableSink to new Unified Sink API (FLIP-143) Key: FLINK-24429 URL: https://issues.apache.org/jira/browse/FLINK-24429 Project: Flink

Re: [DISCUSS] Releasing Flink 1.13.3

2021-09-30 Thread Timo Walther
Thanks Chesnay and Leonard for helping here. From the SQL primary key issue side, all backports are merged. Feel free to proceed with the release. Regards, Timo On 30.09.21 11:29, Chesnay Schepler wrote: I can help Leonard with the PMC bits for the 1.13.3 release. On 27/09/2021 21:26,

[jira] [Created] (FLINK-24428) Fix casting between interval types

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24428: --- Summary: Fix casting between interval types Key: FLINK-24428 URL: https://issues.apache.org/jira/browse/FLINK-24428 Project: Flink Issue Type:

[jira] [Created] (FLINK-24427) Hide Scala in flink-table-planner from API

2021-09-30 Thread Timo Walther (Jira)
Timo Walther created FLINK-24427: Summary: Hide Scala in flink-table-planner from API Key: FLINK-24427 URL: https://issues.apache.org/jira/browse/FLINK-24427 Project: Flink Issue Type:

[jira] [Created] (FLINK-24426) Add support for cast from a string to an INTERVAL

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24426: --- Summary: Add support for cast from a string to an INTERVAL Key: FLINK-24426 URL: https://issues.apache.org/jira/browse/FLINK-24426 Project: Flink

[jira] [Created] (FLINK-24425) Add support for casting from a single type to the corresponding array

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24425: --- Summary: Add support for casting from a single type to the corresponding array Key: FLINK-24425 URL: https://issues.apache.org/jira/browse/FLINK-24425 Project:

[jira] [Created] (FLINK-24424) CAST from invalid CHAR/VARCHAR/STRING to TIMESTAMP_LTZ throws NPE

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24424: --- Summary: CAST from invalid CHAR/VARCHAR/STRING to TIMESTAMP_LTZ throws NPE Key: FLINK-24424 URL: https://issues.apache.org/jira/browse/FLINK-24424 Project:

Re: [ANNOUNCE] Flink mailing lists archive service has migrated to Apache Archive service

2021-09-30 Thread Till Rohrmann
Thanks for the hint with the managed search engines Matthias. I think this is quite helpful. Cheers, Till On Wed, Sep 15, 2021 at 4:27 PM Matthias Pohl wrote: > Thanks Leonard for the announcement. I guess that is helpful. > > @Robert is there any way we can change the default setting to

[jira] [Created] (FLINK-24423) Cast from TIME to TIMESTAMP currently uses Epoch Date

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24423: --- Summary: Cast from TIME to TIMESTAMP currently uses Epoch Date Key: FLINK-24423 URL: https://issues.apache.org/jira/browse/FLINK-24423 Project: Flink

[jira] [Created] (FLINK-24422) When creating a TIMESTAMP_LTZ only allow Instant

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24422: --- Summary: When creating a TIMESTAMP_LTZ only allow Instant Key: FLINK-24422 URL: https://issues.apache.org/jira/browse/FLINK-24422 Project: Flink Issue

[jira] [Created] (FLINK-24421) Casting from a string to a DATE and TIME allows incomplete strings

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24421: --- Summary: Casting from a string to a DATE and TIME allows incomplete strings Key: FLINK-24421 URL: https://issues.apache.org/jira/browse/FLINK-24421 Project:

[jira] [Created] (FLINK-24420) Casting to a "narrower" type doesn't throw exception but follows Java overflow

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24420: --- Summary: Casting to a "narrower" type doesn't throw exception but follows Java overflow Key: FLINK-24420 URL: https://issues.apache.org/jira/browse/FLINK-24420

[jira] [Created] (FLINK-24419) Casting to a bounded BINARY/VARBANIRY doesn't trim to the specified precision

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24419: --- Summary: Casting to a bounded BINARY/VARBANIRY doesn't trim to the specified precision Key: FLINK-24419 URL: https://issues.apache.org/jira/browse/FLINK-24419

Re: [DISCUSS] Releasing Flink 1.13.3

2021-09-30 Thread Chesnay Schepler
I can help Leonard with the PMC bits for the 1.13.3 release. On 27/09/2021 21:26, Martijn Visser wrote: Hi Timo, Sounds good to me. However, I still need a PMC to make to the release. I definitely volunteer to help out with keeping track of things, communication etc. Hopefully there's a PMC

[jira] [Created] (FLINK-24418) Support cast of RAW() to BINARY/VARBINARY/BYTES

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24418: --- Summary: Support cast of RAW() to BINARY/VARBINARY/BYTES Key: FLINK-24418 URL: https://issues.apache.org/jira/browse/FLINK-24418 Project: Flink Issue

[jira] [Created] (FLINK-24417) Add Flink 1.14 MigrationVersion

2021-09-30 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-24417: Summary: Add Flink 1.14 MigrationVersion Key: FLINK-24417 URL: https://issues.apache.org/jira/browse/FLINK-24417 Project: Flink Issue Type:

[jira] [Created] (FLINK-24416) Casting a TIMESTAMP_LTZ to STRING doesn't include timezone id

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24416: --- Summary: Casting a TIMESTAMP_LTZ to STRING doesn't include timezone id Key: FLINK-24416 URL: https://issues.apache.org/jira/browse/FLINK-24416 Project: Flink

[jira] [Created] (FLINK-24415) Casting a STRING to a TIME() results in loss of fractional seconds

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24415: --- Summary: Casting a STRING to a TIME() results in loss of fractional seconds Key: FLINK-24415 URL: https://issues.apache.org/jira/browse/FLINK-24415 Project:

[jira] [Created] (FLINK-24414) Casting a decimal to a String doesn't do left zero padding

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24414: --- Summary: Casting a decimal to a String doesn't do left zero padding Key: FLINK-24414 URL: https://issues.apache.org/jira/browse/FLINK-24414 Project: Flink

[jira] [Created] (FLINK-24413) Casting to a CHAR() and VARCHAR() doesn't trip the string to the specified precision

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24413: --- Summary: Casting to a CHAR() and VARCHAR() doesn't trip the string to the specified precision Key: FLINK-24413 URL: https://issues.apache.org/jira/browse/FLINK-24413

Re: [Flink blogs]

2021-09-30 Thread Fabian Paul
Hi Etienne, Thanks for reaching out I think your list already looks very appealing. > * - metrics (https://github.com/apache/flink/pull/14510): it was > dealing with delimiters. I think it is a bit low level for a blog post ? > * I am also unsure whether this a good fit to present. I can only

Re: [ANNOUNCE] Apache Flink 1.14.0 released

2021-09-30 Thread Caizhi Weng
Congratulations! As a side note, I notice that the MigrationVersion enum class is missing a 1.14 version, which should be added by the release managers. 在 2021年9月30日星期四,Etienne Chauchot 写道: > Thanks and congrats to everyone involved! > > Best > > Etienne Chauchot > > > On 29/09/2021 15:59,

[jira] [Created] (FLINK-24412) retract stream join on topN error

2021-09-30 Thread sandy du (Jira)
sandy du created FLINK-24412: Summary: retract stream join on topN error Key: FLINK-24412 URL: https://issues.apache.org/jira/browse/FLINK-24412 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24411) Add docs navigation for release notes

2021-09-30 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-24411: --- Summary: Add docs navigation for release notes Key: FLINK-24411 URL: https://issues.apache.org/jira/browse/FLINK-24411 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24410) Upgrade Confluent Platform OSS version in end-to-end tests

2021-09-30 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-24410: -- Summary: Upgrade Confluent Platform OSS version in end-to-end tests Key: FLINK-24410 URL: https://issues.apache.org/jira/browse/FLINK-24410 Project: Flink

[jira] [Created] (FLINK-24409) Kafka topics with periods in their names generate a constant stream of errors

2021-09-30 Thread Brad Davis (Jira)
Brad Davis created FLINK-24409: -- Summary: Kafka topics with periods in their names generate a constant stream of errors Key: FLINK-24409 URL: https://issues.apache.org/jira/browse/FLINK-24409 Project:

Re: [ANNOUNCE] Apache Flink 1.14.0 released

2021-09-30 Thread Etienne Chauchot
Thanks and congrats to everyone involved! Best Etienne Chauchot On 29/09/2021 15:59, Dawid Wysakowicz wrote: The Apache Flink community is very happy to announce the release of Apache Flink 1.14.0. Apache Flink® is an open-source stream processing framework for distributed,

[jira] [Created] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecVa

2021-09-30 Thread shengkui leng (Jira)
shengkui leng created FLINK-24408: - Summary: org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecValues$200" grows beyond 64 KB