[jira] [Created] (FLINK-10012) Support setStreamTimeCharacteristic for Python API

vinoyang created FLINK-10012: Summary: Support setStreamTimeCharacteristic for Python API Key: FLINK-10012 URL: https://issues.apache.org/jira/browse/FLINK-10012 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-10011) Old job resurrected during HA failover

Elias Levy created FLINK-10011: -- Summary: Old job resurrected during HA failover Key: FLINK-10011 URL: https://issues.apache.org/jira/browse/FLINK-10011 Project: Flink Issue Type: Bug

Re: [RESULT][VOTE] Release 1.5.2, release candidate #2

Great job and Thanks Chesnay Cheers, Yaz On Tue, Jul 31, 2018 at 2:31 PM Thomas Weise wrote: > Thanks to Chesnay for running the release and getting it completed quickly! > > > On Tue, Jul 31, 2018 at 2:02 AM Fabian Hueske wrote: > > > Thanks Chesnay! > > > > 2018-07-31 10:59 GMT+02:00 vino yan

Re: [RESULT][VOTE] Release 1.5.2, release candidate #2

Thanks to Chesnay for running the release and getting it completed quickly! On Tue, Jul 31, 2018 at 2:02 AM Fabian Hueske wrote: > Thanks Chesnay! > > 2018-07-31 10:59 GMT+02:00 vino yang : > > > Thanks for releasing Flink 1.5.2, Chesnay! > > > > Thanks. > > Vino. > > > > 2018-07-31 16:49 GMT+0

[jira] [Created] (FLINK-10010) Deprecate unused BaseAlignedWindowAssigner related components

Rong Rong created FLINK-10010: - Summary: Deprecate unused BaseAlignedWindowAssigner related components Key: FLINK-10010 URL: https://issues.apache.org/jira/browse/FLINK-10010 Project: Flink Issu

Re: [ANNOUNCE] Apache Flink 1.5.2 released

Congratulations, community! On Tue, Jul 31, 2018 at 1:44 AM Chesnay Schepler wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink 1.5.2, which is the second bugfix release for the Apache Flink 1.5 > series. > > Apache Flink® is an open-source stream process

[jira] [Created] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

Xingcan Cui created FLINK-10009: --- Summary: Fix the casting problem for function TIMESTAMPADD in Table Key: FLINK-10009 URL: https://issues.apache.org/jira/browse/FLINK-10009 Project: Flink Issu

[jira] [Created] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

Xingcan Cui created FLINK-10008: --- Summary: Improve the LOG function in Table to support bases less than 1 Key: FLINK-10008 URL: https://issues.apache.org/jira/browse/FLINK-10008 Project: Flink

[jira] [Created] (FLINK-10007) Security vulnerability in website build infrastructure

Fabian Hueske created FLINK-10007: - Summary: Security vulnerability in website build infrastructure Key: FLINK-10007 URL: https://issues.apache.org/jira/browse/FLINK-10007 Project: Flink Issu

[jira] [Created] (FLINK-10006) Improve logging in BarrierBuffer

Nico Kruber created FLINK-10006: --- Summary: Improve logging in BarrierBuffer Key: FLINK-10006 URL: https://issues.apache.org/jira/browse/FLINK-10006 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

Chesnay Schepler created FLINK-10005: Summary: StreamingFileSink ignores checkpoint/processing time rolling policies Key: FLINK-10005 URL: https://issues.apache.org/jira/browse/FLINK-10005 Project

[jira] [Created] (FLINK-10004) Test instability in OneInputStreamTaskTest#testWatermarkMetrics

Nico Kruber created FLINK-10004: --- Summary: Test instability in OneInputStreamTaskTest#testWatermarkMetrics Key: FLINK-10004 URL: https://issues.apache.org/jira/browse/FLINK-10004 Project: Flink

[jira] [Created] (FLINK-10003) Encoder interface inefficient when wanting to use more sophisticated outputstreams

Chesnay Schepler created FLINK-10003: Summary: Encoder interface inefficient when wanting to use more sophisticated outputstreams Key: FLINK-10003 URL: https://issues.apache.org/jira/browse/FLINK-10003

[jira] [Created] (FLINK-10002) WebUI shows logs unfriendly, especially when the amount of logs is large

zhangxinyu created FLINK-10002: -- Summary: WebUI shows logs unfriendly, especially when the amount of logs is large Key: FLINK-10002 URL: https://issues.apache.org/jira/browse/FLINK-10002 Project: Flink

[jira] [Created] (FLINK-10001) Improve Kubernetes documentation

Till Rohrmann created FLINK-10001: - Summary: Improve Kubernetes documentation Key: FLINK-10001 URL: https://issues.apache.org/jira/browse/FLINK-10001 Project: Flink Issue Type: Improvement

Re: [RESULT][VOTE] Release 1.5.2, release candidate #2

Thanks Chesnay! 2018-07-31 10:59 GMT+02:00 vino yang : > Thanks for releasing Flink 1.5.2, Chesnay! > > Thanks. > Vino. > > 2018-07-31 16:49 GMT+08:00 Till Rohrmann : > > > Thanks Chesnay for being our release manager and thanks to the community > > for all the work! > > > > Cheers, > > Till > >

Re: [RESULT][VOTE] Release 1.5.2, release candidate #2

Thanks for releasing Flink 1.5.2, Chesnay! Thanks. Vino. 2018-07-31 16:49 GMT+08:00 Till Rohrmann : > Thanks Chesnay for being our release manager and thanks to the community > for all the work! > > Cheers, > Till > > On Tue, Jul 31, 2018 at 10:17 AM Timo Walther wrote: > > > Thanks for managin

Re: [RESULT][VOTE] Release 1.5.2, release candidate #2

Thanks Chesnay for being our release manager and thanks to the community for all the work! Cheers, Till On Tue, Jul 31, 2018 at 10:17 AM Timo Walther wrote: > Thanks for managing the release process Chesnay! > > Timo > > Am 31.07.18 um 10:05 schrieb Chesnay Schepler: > > I'm happy to announce t

[ANNOUNCE] Apache Flink 1.5.2 released

|The Apache Flink community is very happy to announce the release of Apache Flink 1.5.2, which is the second bugfix release for the Apache Flink 1.5 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data stream

Re: Consuming data from dynamoDB streams to flink

Done! Thank you :-) 2018-07-31 6:41 GMT+02:00 Ying Xu : > Thanks Fabian and Thomas. > > Please assign FLINK-4582 to the following username: > *yxu-apache > * > > If needed I can get a ICLA or CCLA whichever is proper. >

Re: Questions about join and exactly-once

Hi Minglei, 1. Not sure if you are asking for a specific problem, but IMO the main challenge is that there are many different ways (and meanings) to join two streams. The required semantics always depend on the concrete use case. If you want to perform an simple equality join with SQL semantics, y

Re: [RESULT][VOTE] Release 1.5.2, release candidate #2

Thanks for managing the release process Chesnay! Timo Am 31.07.18 um 10:05 schrieb Chesnay Schepler: I'm happy to announce that we have approved this release. There are 5 approving votes, 3 of which are binding: * Yaz (non-binding) * Thomas (non-binding) * Till (binding) * Timo (binding) * Ch

[RESULT][VOTE] Release 1.5.2, release candidate #2

I'm happy to announce that we have approved this release. There are 5 approving votes, 3 of which are binding: * Yaz (non-binding) * Thomas (non-binding) * Till (binding) * Timo (binding) * Chesnay (binding) There is 1 disapproving vote: * Piotr (non-binding) Thanks everyone! On 26.07.2018

[jira] [Created] (FLINK-10000) There's a mistake in the comments of CoGroupedStreams.java

Shimin Yang created FLINK-1: --- Summary: There's a mistake in the comments of CoGroupedStreams.java Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project: Flink Issu

[jira] [Created] (FLINK-9999) Add ISNUMERIC supported in Table API/SQL

vinoyang created FLINK-: --- Summary: Add ISNUMERIC supported in Table API/SQL Key: FLINK- URL: https://issues.apache.org/jira/browse/FLINK- Project: Flink Issue Type: Sub-task C