[jira] [Created] (FLINK-7342) Add support for Regular Expression Operators (RLIKE)

sunjincheng created FLINK-7342: -- Summary: Add support for Regular Expression Operators (RLIKE) Key: FLINK-7342 URL: https://issues.apache.org/jira/browse/FLINK-7342 Project: Flink Issue Type:

Re:Re: KeyBy fields do not support java.lang.Array?

Hi Aljoscha: Thanks for your reply. Look forward to the final solution. Best Regards Xu Pingyong 在 2017-07-31 22:39:38，"Aljoscha Krettek" 写道： >Hi, > >Which version of Flink are you using? This issue should have been resolved at >least by 1.3.0:

[jira] [Created] (FLINK-7341) Update code snippets in documentation

Eron Wright created FLINK-7341: --- Summary: Update code snippets in documentation Key: FLINK-7341 URL: https://issues.apache.org/jira/browse/FLINK-7341 Project: Flink Issue Type: Sub-task

Re: Class Cache

Thank you to those of you who replied. I can't really explain why, but yesterday afternoon, out of the blue, this problem disappeared. Everything was working fine for a while. Until some different strange behavior came up this afternoon. I don't believe any code changes I made should affect

Re: [DISCUSS] Service Authorization (redux)

Dropping Java 7 alone is not enough to move to Akka 2.4+. For that we need at least Scala 2.11. Cheers, Till On Tue, Aug 1, 2017 at 4:22 PM, Aljoscha Krettek wrote: > Hi Eron, > > I think after Dropping support for Java 7 we will move to Akka 2.4+, so we > should be good

[jira] [Created] (FLINK-7340) Taskmanager hung after temporary DNS outage

Joshua Griffith created FLINK-7340: -- Summary: Taskmanager hung after temporary DNS outage Key: FLINK-7340 URL: https://issues.apache.org/jira/browse/FLINK-7340 Project: Flink Issue Type:

[jira] [Created] (FLINK-7339) aggregationToString fails when user defined aggregation contains constants

Stefano Bortoli created FLINK-7339: -- Summary: aggregationToString fails when user defined aggregation contains constants Key: FLINK-7339 URL: https://issues.apache.org/jira/browse/FLINK-7339

[jira] [Created] (FLINK-7338) User Defined aggregation with constants causes error under in lowerbound over window extraction

Stefano Bortoli created FLINK-7338: -- Summary: User Defined aggregation with constants causes error under in lowerbound over window extraction Key: FLINK-7338 URL: https://issues.apache.org/jira/browse/FLINK-7338

Re: [DISCUSS] Table API / SQL internal timestamp handling

Hi everybody, I created FLINK-7337 and will work on this. Best, Fabian [1] https://issues.apache.org/jira/browse/FLINK-7337 2017-08-01 11:36 GMT+02:00 Fabian Hueske : > Hi, > > I think the implementation of the join operator should not depend on the > synchronization of the

[jira] [Created] (FLINK-7337) Refactor handling of time indicator attributes

Fabian Hueske created FLINK-7337: Summary: Refactor handling of time indicator attributes Key: FLINK-7337 URL: https://issues.apache.org/jira/browse/FLINK-7337 Project: Flink Issue Type:

Re: [DISCUSS] Service Authorization (redux)

Hi Eron, I think after Dropping support for Java 7 we will move to Akka 2.4+, so we should be good there. I think quite some users should find a (more) secure Flink interesting. Best, Aljoscha > On 24. Jul 2017, at 03:11, Eron Wright wrote: > > Hello, now might be a

Re: Towards a spec for robust streaming SQL, Part 2

As promised, I went of the document and made some comments. I also added a bit of information about the current SQL support in Flink and its internals. Thanks, Fabian 2017-07-30 13:22 GMT+02:00 Shaoxuan Wang : > Hi Tyler, > Thanks for putting all the efforts into a doc. It

Re: [DISCUSS] Table API / SQL internal timestamp handling

Hi, I think the implementation of the join operator should not depend on the synchronization of the watermarks. If we need to buffer a stream because we have to wait for future records from the other stream to join them, then that's how it is. We cannot change the semantics of the query. It might

[jira] [Created] (FLINK-7336) Remove Flink's futures from AkkaRpcActor

Till Rohrmann created FLINK-7336: Summary: Remove Flink's futures from AkkaRpcActor Key: FLINK-7336 URL: https://issues.apache.org/jira/browse/FLINK-7336 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7334) Replace Flink's futures by CompletableFuture in RpcGateway

Till Rohrmann created FLINK-7334: Summary: Replace Flink's futures by CompletableFuture in RpcGateway Key: FLINK-7334 URL: https://issues.apache.org/jira/browse/FLINK-7334 Project: Flink

[jira] [Created] (FLINK-7335) Remove Flink's own future implementation

Till Rohrmann created FLINK-7335: Summary: Remove Flink's own future implementation Key: FLINK-7335 URL: https://issues.apache.org/jira/browse/FLINK-7335 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7333) Remove Flink's futures from Task

Till Rohrmann created FLINK-7333: Summary: Remove Flink's futures from Task Key: FLINK-7333 URL: https://issues.apache.org/jira/browse/FLINK-7333 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7332) Remove Flink's futures from TaskExecutor

Till Rohrmann created FLINK-7332: Summary: Remove Flink's futures from TaskExecutor Key: FLINK-7332 URL: https://issues.apache.org/jira/browse/FLINK-7332 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7331) Remove Flink's futures from ResourceManager

Till Rohrmann created FLINK-7331: Summary: Remove Flink's futures from ResourceManager Key: FLINK-7331 URL: https://issues.apache.org/jira/browse/FLINK-7331 Project: Flink Issue Type: