Re: [DISCUSS] Releasing Flink 1.4.1

Can we add this to 1.4.1 release? The flink-yarn-kerberos deployment is not working in 1.4.0. https://issues.apache.org/jira/browse/FLINK-8275 Thanks a lot. On Mon, Jan 15, 2018 at 7:53 AM, vishal wrote: > Hello folks, > > https://issues.apache.org/jira/browse/FLINK-8226 . We would want a

Re: [DISCUSS] Releasing Flink 1.4.1

Hello folks, https://issues.apache.org/jira/browse/FLINK-8226 . We would want a schedule on the 1.4.1 version. Without checkpointing and state, CEP is in effect not production ready IMHO. Is there any time line on 1.4.1 ? The earlier the better. Thank you and Regards, Vishal -- Sent

Re: [DISCUSS] Releasing Flink 1.4.1

Can we add this to 1.4.1 release: https://issues.apache.org/jira/browse/FLINK-8406 On Mon, Jan 15, 2018 at 9:42 AM Maciek Próchniak wrote: > thanks Till, > > maciek > > > > On 15/01/2018 12:35, Till Rohrmann wrote: > > Thanks for starting the discussion Gordon. I think we already have some > >

[jira] [Created] (FLINK-8435) Adding BloomFilter/HyperLogLog state as Managed once

Moein Hosseini created FLINK-8435: - Summary: Adding BloomFilter/HyperLogLog state as Managed once Key: FLINK-8435 URL: https://issues.apache.org/jira/browse/FLINK-8435 Project: Flink Issue Ty

Re: [DISCUSS] Releasing Flink 1.4.1

thanks Till, maciek On 15/01/2018 12:35, Till Rohrmann wrote: Thanks for starting the discussion Gordon. I think we already have some good improvements in the 1.4.1 branch. Thus, +1 for releasing 1.4.1 soonish. @Maciek, I'll backport FLINK-7949 to the 1.4.1 release branch. Cheers, Till On

Re: How to Join a dimension table in flink sql

Hi XiangWei, Unfortunately, it's not possible for the Flink SQL API to join a stream with a common dataset now. As a workaround, if the table is just a tiny one, you can achieve a inner/left outer join with the user defined table functions

Re: [DISCUSS] Releasing Flink 1.4.1

Thanks for starting the discussion Gordon. I think we already have some good improvements in the 1.4.1 branch. Thus, +1 for releasing 1.4.1 soonish. @Maciek, I'll backport FLINK-7949 to the 1.4.1 release branch. Cheers, Till On Mon, Jan 15, 2018 at 11:56 AM, Maciek Próchniak wrote: > Hi Gordon

Re: How to Join a dimension table in flink sql

Hi XiangWei, Currently one could implement a udtf to achieve that. (see https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/table/udfs. html#table-functions) BTW, this udtf should carefully dealing with the connections to database server(s), and enable caching if possible can reduce se

Re: When is the scheduled release for 1.4.1 ? We have been waiting for a fix https://issues.apache.org/jira/browse/FLINK-8226 which looks a potential fix

Hi Vishal, Thanks for reporting this. There is no scheduled release for 1.4.1 yet, but I’ve just started a thread to track the remaining issues, so hopefully soon. Could you quickly reply on that thread [1] also so we can more easily keep track of this? Cheers, Gordon [1]  http://apache-flink-

Re: [DISCUSS] Releasing Flink 1.4.1

Hi Gordon, do you think I'd be possible to include https://issues.apache.org/jira/browse/FLINK-7949? thanks, maciek On 15/01/2018 11:49, Tzu-Li (Gordon) Tai wrote: Hi all, I would like to bring up the discussion of releasing Flink 1.4.1. We’ve collected a few issues over the past few weeks,

When is the scheduled release for 1.4.1 ? We have been waiting for a fix https://issues.apache.org/jira/browse/FLINK-8226 which looks a potential fix

This issues has a possible fix in 1.4.1. We have been waiting for a fix https://issues.apache.org/jira/browse/FLINK-8226 which looks a potential fix A simple CEP loop pattern private Pattern, ?> alertPattern = Pattern.>begin("start").where(checkStatusOn) .followedBy("middle").where(ch

[DISCUSS] Releasing Flink 1.4.1

Hi all, I would like to bring up the discussion of releasing Flink 1.4.1. We’ve collected a few issues over the past few weeks, some of which is quite critical. Here’s a list of issues, and their current status, that I’m aware of and IMO should be included: - [FLINK-8275] Flink YARN TMs using wro

How to Join a dimension table in flink sql

Hi all, Is it possible to join records read from a kafka stream with one(or more) dimension tables which are saved as mysql table using flink streaming sql.

[jira] [Created] (FLINK-8434) The new yarn resource manager should take over the running task managers after failover

shuai.xu created FLINK-8434: --- Summary: The new yarn resource manager should take over the running task managers after failover Key: FLINK-8434 URL: https://issues.apache.org/jira/browse/FLINK-8434 Project: