[jira] [Created] (FLINK-7010) Lamdba expression in flatMap throws InvalidTypesException in DataSet

Fang Yong created FLINK-7010: Summary: Lamdba expression in flatMap throws InvalidTypesException in DataSet Key: FLINK-7010 URL: https://issues.apache.org/jira/browse/FLINK-7010 Project: Flink

[jira] [Created] (FLINK-7009) dogstatsd mode in statsd reporter

David Brinegar created FLINK-7009: - Summary: dogstatsd mode in statsd reporter Key: FLINK-7009 URL: https://issues.apache.org/jira/browse/FLINK-7009 Project: Flink Issue Type: Improvement

Re: 4 DataStream using RichCoFlatMapFunction

All: If I want to connect to 4 streams using RichCoFlatMapFunction. How I can do this. RichCoFlatMapFunction only support connecting 2 datastream. Thanks. -- View this message in context:

[jira] [Created] (FLINK-7008) Update NFA state only when the NFA changes.

Kostas Kloudas created FLINK-7008: - Summary: Update NFA state only when the NFA changes. Key: FLINK-7008 URL: https://issues.apache.org/jira/browse/FLINK-7008 Project: Flink Issue Type:

[GitHub] flink-shaded pull request #1: [FLINK-6981] Add flink-shaded-guava module

Github user zentol closed the pull request at: https://github.com/apache/flink-shaded/pull/1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink-shaded issue #1: [FLINK-6981] Add flink-shaded-guava module

Github user rmetzger commented on the issue: https://github.com/apache/flink-shaded/pull/1 Thanks. +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[GitHub] flink-shaded issue #1: [FLINK-6981] Add flink-shaded-guava module

Github user zentol commented on the issue: https://github.com/apache/flink-shaded/pull/1 @rmetzger I've addressed your comments. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[GitHub] flink-shaded pull request #1: [FLINK-6981] Add flink-shaded-guava module

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/1#discussion_r124037728 --- Diff: flink-shaded-guava-18/pom.xml --- @@ -0,0 +1,99 @@ + + +http://maven.apache.org/POM/4.0.0;

Re: [DISCUSS] Changing Flink's shading model

Sounds good! On Mon, Jun 26, 2017 at 4:36 PM, Chesnay Schepler wrote: > I do believe the full dependency version of, say guava, should be apparent > from the dependency > declaration of a Flink pom. Just for clarity purposes. > > We could still include the full version in

[GitHub] flink-shaded pull request #1: [FLINK-6981] Add flink-shaded-guava module

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/1#discussion_r124035371 --- Diff: flink-shaded-guava-18/pom.xml --- @@ -0,0 +1,99 @@ + + +http://maven.apache.org/POM/4.0.0;

[GitHub] flink-shaded pull request #1: [FLINK-6981] Add flink-shaded-guava module

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/1#discussion_r124034795 --- Diff: flink-shaded-guava-18/pom.xml --- @@ -0,0 +1,99 @@ + + +http://maven.apache.org/POM/4.0.0;

[GitHub] flink-shaded pull request #1: [FLINK-6981] Add flink-shaded-guava module

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/1#discussion_r124034556 --- Diff: flink-shaded-guava-18/pom.xml --- @@ -0,0 +1,99 @@ + + +http://maven.apache.org/POM/4.0.0;

[GitHub] flink-shaded pull request #1: [FLINK-6981] Add flink-shaded-guava module

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/1#discussion_r124033958 --- Diff: flink-shaded-guava-18/pom.xml --- @@ -0,0 +1,99 @@ + + +http://maven.apache.org/POM/4.0.0;

[GitHub] flink-shaded pull request #1: [FLINK-6981] Add flink-shaded-guava module

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/1#discussion_r124033232 --- Diff: flink-shaded-guava-18/pom.xml --- @@ -0,0 +1,99 @@ + + +http://maven.apache.org/POM/4.0.0;

[GitHub] flink-shaded pull request #1: [FLINK-6981] Add flink-shaded-guava module

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/1#discussion_r124032886 --- Diff: flink-shaded-guava-18/pom.xml --- @@ -0,0 +1,99 @@ + + +http://maven.apache.org/POM/4.0.0;

[GitHub] flink-shaded pull request #1: [FLINK-6981] Add flink-shaded-guava module

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/1#discussion_r124032645 --- Diff: flink-shaded-guava-18/pom.xml --- @@ -0,0 +1,99 @@ + + +http://maven.apache.org/POM/4.0.0;

[jira] [Created] (FLINK-7007) Add README to "flink-shaded.git" repository

Robert Metzger created FLINK-7007: - Summary: Add README to "flink-shaded.git" repository Key: FLINK-7007 URL: https://issues.apache.org/jira/browse/FLINK-7007 Project: Flink Issue Type: Task

[GitHub] flink-shaded pull request #2: Include minor version / remove non-existing gu...

Github user asfgit closed the pull request at: https://github.com/apache/flink-shaded/pull/2 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Re: [DISCUSS] Changing Flink's shading model

I do believe the full dependency version of, say guava, should be apparent from the dependency declaration of a Flink pom. Just for clarity purposes. We could still include the full version in the version of the module though, i.e org.apache.flink flink-shaded-guava18 1.0-18.0 On

[jira] [Created] (FLINK-7006) Base class using POJOs for Gelly algorithms

Greg Hogan created FLINK-7006: - Summary: Base class using POJOs for Gelly algorithms Key: FLINK-7006 URL: https://issues.apache.org/jira/browse/FLINK-7006 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Release 1.3.2 planning

I just opened a PR which should be included in the next bug fix release for the Table API: https://issues.apache.org/jira/browse/FLINK-7005 Timo Am 23.06.17 um 14:09 schrieb Robert Metzger: Thanks Haohui. The first main task for the release management is to come up with a timeline :) Lets

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

Hi everybody, Shaoxuan, Timo, and I compiled a list of features from the replies to this thread, features that didn't make it into 1.3, and some additional ones. We also graded them by importance, tried to assess the effort, and added links to JIRAs (some existed already others were created) and

[GitHub] flink-shaded pull request #2: Include minor version / remove non-existing gu...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/2#discussion_r124003439 --- Diff: pom.xml --- @@ -30,10 +30,10 @@ under the License. org.apache.flink flink-shaded -1 +1.0 --- End

[GitHub] flink-shaded issue #2: Include minor version / remove non-existing guava chi...

Github user rmetzger commented on the issue: https://github.com/apache/flink-shaded/pull/2 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or

[GitHub] flink-shaded pull request #2: Include minor version / remove non-existing gu...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/2#discussion_r124002219 --- Diff: pom.xml --- @@ -30,10 +30,10 @@ under the License. org.apache.flink flink-shaded -1 +1.0 --- End

[GitHub] flink-shaded pull request #2: Include minor version / remove non-existing gu...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/2#discussion_r124001438 --- Diff: pom.xml --- @@ -30,10 +30,10 @@ under the License. org.apache.flink flink-shaded -1 +1.0 --- End

[GitHub] flink-shaded pull request #2: Include minor version / remove non-existing gu...

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink-shaded/pull/2#discussion_r124001072 --- Diff: pom.xml --- @@ -30,10 +30,10 @@ under the License. org.apache.flink flink-shaded -1 +1.0 --- End

Re: [DISCUSS] Changing Flink's shading model

Sounds good. If the libraries follow semantic versioning properly, we could try and only have the major version in the module name? On Mon, Jun 26, 2017 at 2:45 PM, Chesnay Schepler wrote: > You're raising good points, now i see why having the version in the name > is

Re: [DISCUSS] Changing Flink's shading model

You're raising good points, now i see why having the version in the name is useful. I'll adjust my PR accordingly. And yes, ideally we only release the modified modules, not everything again. On 26.06.2017 14:29, Stephan Ewen wrote: How should it work when one of the shaded dependencies is

Re: [DISCUSS] Changing Flink's shading model

How should it work when one of the shaded dependencies is updated? We probably do not want to release all of them, just because the overall version number is in their version number. How about that: - Under normal circumstances, we only increase the version of the root project, when we add /

Re: [DISCUSS] Changing Flink's shading model

the guava version is already included in the version of the flink-shaded module. For example, for the first release of flink-shaded-guava the version would be 1-18.0. 1 is the version of flink-shaded itself, 18.0 is the guava version. On 26.06.2017 14:01, Stephan Ewen wrote: Looks good,

Re: [DISCUSS] Changing Flink's shading model

+1 on including dependency version.  Original message From: Stephan Ewen Date: 6/26/17 5:01 AM (GMT-08:00) To: dev@flink.apache.org Subject: Re: [DISCUSS] Changing Flink's shading model Looks good, thanks Chesnay!. How about including the dependency

Re: [DISCUSS] Changing Flink's shading model

Looks good, thanks Chesnay!. How about including the dependency version names in the module names, like "flink-shaded-guava-18.0"? On Mon, Jun 26, 2017 at 11:49 AM, Chesnay Schepler wrote: > The new repo was created and is accessible here: >

[jira] [Created] (FLINK-7005) Optimization steps are missing for nested registered tables

Timo Walther created FLINK-7005: --- Summary: Optimization steps are missing for nested registered tables Key: FLINK-7005 URL: https://issues.apache.org/jira/browse/FLINK-7005 Project: Flink

[jira] [Created] (FLINK-7004) Switch to Travis Trusty image

Chesnay Schepler created FLINK-7004: --- Summary: Switch to Travis Trusty image Key: FLINK-7004 URL: https://issues.apache.org/jira/browse/FLINK-7004 Project: Flink Issue Type: Improvement