[jira] [Created] (FLINK-9161) Support AS STRUCT syntax to create named STRUCT in SQL

2018-04-12 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9161: - Summary: Support AS STRUCT syntax to create named STRUCT in SQL Key: FLINK-9161 URL: https://issues.apache.org/jira/browse/FLINK-9161 Project: Flink Issue Type:

[jira] [Created] (FLINK-9162) Scala REPL hanging when running example

2018-04-12 Thread JIRA
陈梓立 created FLINK-9162: -- Summary: Scala REPL hanging when running example Key: FLINK-9162 URL: https://issues.apache.org/jira/browse/FLINK-9162 Project: Flink Issue Type: Bug Components:

Re: [DISCUSS] Releasing Flink 1.5.0

2018-04-12 Thread Christophe Jolif
Hi all, A small patch: https://github.com/apache/flink/pull/5789 (JIRA: https://issues.apache.org/jira/browse/FLINK-9103) was issued to help with SSL certificates in Kubernetes deployment where you don't control your IPs. As this is very small and helpful (at least to me and Edward who issued the

[jira] [Created] (FLINK-9165) Improve CassandraSinkBase to send Collections

2018-04-12 Thread Christopher Hughes (JIRA)
Christopher Hughes created FLINK-9165: - Summary: Improve CassandraSinkBase to send Collections Key: FLINK-9165 URL: https://issues.apache.org/jira/browse/FLINK-9165 Project: Flink Issue

[jira] [Created] (FLINK-9164) times(#,#) quantifier does not seem to work

2018-04-12 Thread Romain Revol (JIRA)
Romain Revol created FLINK-9164: --- Summary: times(#,#) quantifier does not seem to work Key: FLINK-9164 URL: https://issues.apache.org/jira/browse/FLINK-9164 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9166) Performance issue with Flink SQL

2018-04-12 Thread SUBRAMANYA SURESH (JIRA)
SUBRAMANYA SURESH created FLINK-9166: Summary: Performance issue with Flink SQL Key: FLINK-9166 URL: https://issues.apache.org/jira/browse/FLINK-9166 Project: Flink Issue Type: Bug

Re: [jira] [Created] (FLINK-9164) times(#,#) quantifier does not seem to work

2018-04-12 Thread Kostas Kloudas
Hi Romain, What if you remove the AfterMatchSkipStrategy.skipPastLastEvent()? Kostas > On Apr 12, 2018, at 1:19 PM, Romain Revol (JIRA) wrote: > > AfterMatchSkipStrategy.skipPastLastEvent()

[jira] [Created] (FLINK-9167) Approximate KNN with Incremental Insertion

2018-04-12 Thread Alex Klibisz (JIRA)
Alex Klibisz created FLINK-9167: --- Summary: Approximate KNN with Incremental Insertion Key: FLINK-9167 URL: https://issues.apache.org/jira/browse/FLINK-9167 Project: Flink Issue Type: New

[jira] [Created] (FLINK-9163) Harden e2e tests' signal traps and config restoration during abort

2018-04-12 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9163: -- Summary: Harden e2e tests' signal traps and config restoration during abort Key: FLINK-9163 URL: https://issues.apache.org/jira/browse/FLINK-9163 Project: Flink

Re: Multi-stream question

2018-04-12 Thread Fabian Hueske
Hi, Ken's approach of having a joint data type and unioning the streams is good. This will work seamlessly with checkpoints. Timo (in CC) used the same approach to implement a prototype of a multi-way join. A Tuple won't work though because the Tuple serializer does not support null fields. You

Re: Using Slack for online discussions

2018-04-12 Thread Aljoscha Krettek
-1 I would also be in favour of not adding a Slack channel. I see that it can be useful for people because it's a little more direct but I think that having Slack open and also receiving questions and contacts from people there adds more burden on developers that we shouldn't add. Plus, I