[jira] [Created] (FLINK-6934) Consider moving LRUCache class

mingleizhang created FLINK-6934: --- Summary: Consider moving LRUCache class Key: FLINK-6934 URL: https://issues.apache.org/jira/browse/FLINK-6934 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6933) Refactor NFACompiler to reduce code duplication

Dian Fu created FLINK-6933: -- Summary: Refactor NFACompiler to reduce code duplication Key: FLINK-6933 URL: https://issues.apache.org/jira/browse/FLINK-6933 Project: Flink Issue Type: Bug

Re: [DISCUSS] Table API / SQL features for Flink 1.4.0

Nice timing, Fabian! Your checklist aligns our plans very well. Here are the things we are working on & planning to contribute to release 1.4: 1. DDL (with property waterMark config for source-table, and emit config on result-table) 2. unbounded stream-stream joins (with retraction supported) 3.

[jira] [Created] (FLINK-6932) Update the inaccessible Dataflow Model paper link

mingleizhang created FLINK-6932: --- Summary: Update the inaccessible Dataflow Model paper link Key: FLINK-6932 URL: https://issues.apache.org/jira/browse/FLINK-6932 Project: Flink Issue Type:

Re: [DISCUSS]: Integrating Flink Table API & SQL with CEP

Hi everybody, I just stumbled over this blog post [1] which discusses new features in SQL 2016. Apparently the match_recognize clause is part of that. The blogpost also contains a slide set that presents the pattern matching feature and a link to a 90 page technical report. I thought this might

[DISCUSS] Table API / SQL features for Flink 1.4.0

Hi everybody, I would like to start a discussion about the targeted feature set of the Table API / SQL for Flink 1.4.0. Flink 1.3.0 was released about 2 weeks ago and we have 2.5 months (~11 weeks, until begin of September) left until the feature freeze for Flink 1.4.0. I think it makes sense to

[jira] [Created] (FLINK-6931) Support custom compression formats for checkpoints (+Upgrade/Compatibility)

Stefan Richter created FLINK-6931: - Summary: Support custom compression formats for checkpoints (+Upgrade/Compatibility) Key: FLINK-6931 URL: https://issues.apache.org/jira/browse/FLINK-6931 Project:

[jira] [Created] (FLINK-6930) Selecting window start / end on row-based Tumble/Slide window causes NPE

Fabian Hueske created FLINK-6930: Summary: Selecting window start / end on row-based Tumble/Slide window causes NPE Key: FLINK-6930 URL: https://issues.apache.org/jira/browse/FLINK-6930 Project:

Re: FlinkML on slack

Hi Stravros, Could you also please add me to the Slack channel? My email id is: lokesh.amarn...@gmail.com. Thanks, Lokesh On Thu, Jun 15, 2017 at 6:27 PM, Stavros Kontopoulos < st.kontopou...@gmail.com> wrote: > Ziyad added. > > Stavros > > On Sun, Jun 11, 2017 at 4:45 PM, Ziyad Muhammed

Re: FlinkML on slack

Ziyad added. Stavros On Sun, Jun 11, 2017 at 4:45 PM, Ziyad Muhammed wrote: > Hi Stavros > > Could you please send me an invite to the slack channel? > > Best > Ziyad > > > On Sun, Jun 11, 2017 at 1:53 AM, Stavros Kontopoulos < > st.kontopou...@gmail.com> wrote: > > > @Henry

Re: Tracking API

Ah, now I see what you mean. I’m afraid there’s no built-in functionality for that. You probably have to follow the API calls yourself. Best, Aljoscha > On 15. Jun 2017, at 12:54, Ameet BD wrote: > > Hello, > > I want to know which CEP API resulted in a call to a

Re: Tracking API

Hello, I want to know which CEP API resulted in a call to a certain invocation of submitTask function. I think the stack trace will not tell me that because they are in different thread contexts. Regards, Ameet On Thu, Jun 15, 2017 at 3:16 PM, Aljoscha Krettek wrote: >

Re: [DISCUSS] Reorganize Table API / SQL documentation

Hi, I merged the feature branch back to the master and the release-1.3 branch and deleted it. There are still a few gaps in the docs that need to be filled (there are JIRAs for those), but the overall structure looks good IMO and most aspects of the APIs are covered. Cheers, Fabian 2017-05-28

[jira] [Created] (FLINK-6929) Add documentation for Table API OVER windows

Fabian Hueske created FLINK-6929: Summary: Add documentation for Table API OVER windows Key: FLINK-6929 URL: https://issues.apache.org/jira/browse/FLINK-6929 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-19: Improved BLOB storage architecture

Hi Biao, you're right that the BlobServer won't live in the JM in FLIP-6. Instead it will either be part of the RM or the dispatcher component depending on the actual implementation. The requirements for the BlobServer should, however, be the same. Concerning the question about Flink's

Re: [DISCUSS]: Integrating Flink Table API & SQL with CEP

@Jark: You should now have the permissions to create pages in the Flink wiki. Cheers, Till On Thu, Jun 15, 2017 at 5:11 AM, Jark Wu wrote: > Hi Till, > > Could you grant me the edit permission of Flink WIKI? My id is imjark. > > Thanks, > Jark Wu > > 2017-06-15 0:07 GMT+08:00

[jira] [Created] (FLINK-6928) Kafka source: default topic needs to exist

Erik van Oosten created FLINK-6928: -- Summary: Kafka source: default topic needs to exist Key: FLINK-6928 URL: https://issues.apache.org/jira/browse/FLINK-6928 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6925) Add CONCAT/CONCAT_WS supported in SQL

sunjincheng created FLINK-6925: -- Summary: Add CONCAT/CONCAT_WS supported in SQL Key: FLINK-6925 URL: https://issues.apache.org/jira/browse/FLINK-6925 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] FLIP-19: Improved BLOB storage architecture

I have the same concern with Chesnay Schepler. AFIK Flink does not support DC as well as Mapreduce and Spark. We only support DC in DataSet API. And DC in flink do not support local files. Is this a good change to refactor DC too? I have another concern, currently BLOB server has some conflicts

[jira] [Created] (FLINK-6924) ADD LOG/LPAD/RPAD/BIN supported in TableAPI

sunjincheng created FLINK-6924: -- Summary: ADD LOG/LPAD/RPAD/BIN supported in TableAPI Key: FLINK-6924 URL: https://issues.apache.org/jira/browse/FLINK-6924 Project: Flink Issue Type: Sub-task