[jira] [Updated] (FLINK-4649) Implement bipartite graph metrics

2016-09-20 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk updated FLINK-4649: -- Description: Implement metrics calculation for a bipartite graph. Should be similar to EdgeMetr

[jira] [Created] (FLINK-4649) Implement bipartite graph metrics

2016-09-20 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-4649: - Summary: Implement bipartite graph metrics Key: FLINK-4649 URL: https://issues.apache.org/jira/browse/FLINK-4649 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4648) Implement bipartite graph generators

2016-09-20 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-4648: - Summary: Implement bipartite graph generators Key: FLINK-4648 URL: https://issues.apache.org/jira/browse/FLINK-4648 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true

2016-09-20 Thread Kirill Morozov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508962#comment-15508962 ] Kirill Morozov commented on FLINK-4506: --- Hi folks! Can anyone make a review of my PR

[jira] [Created] (FLINK-4647) Implement BipartiteGraph reader

2016-09-20 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-4647: - Summary: Implement BipartiteGraph reader Key: FLINK-4647 URL: https://issues.apache.org/jira/browse/FLINK-4647 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-4646) Add BipartiteGraph class

2016-09-20 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk updated FLINK-4646: -- Description: Implement a class to represent a bipartite graph in Flink Gelly. Design discussions

[jira] [Created] (FLINK-4646) Add BipartiteGraph class

2016-09-20 Thread Ivan Mushketyk (JIRA)
Ivan Mushketyk created FLINK-4646: - Summary: Add BipartiteGraph class Key: FLINK-4646 URL: https://issues.apache.org/jira/browse/FLINK-4646 Project: Flink Issue Type: Sub-task Rep

[jira] [Commented] (FLINK-4641) Support branching CEP patterns

2016-09-20 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508942#comment-15508942 ] Ivan Mushketyk commented on FLINK-4641: --- What API should we define for this feature?

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508776#comment-15508776 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on a diff

[GitHub] flink pull request #2510: FLINK-3322 Allow drivers and iterators to reuse th...

2016-09-20 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2510#discussion_r79761429 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/JoinDriver.java --- @@ -128,17 +130,22 @@ public void prepare() throws Exception{

[GitHub] flink pull request #2510: FLINK-3322 Allow drivers and iterators to reuse th...

2016-09-20 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2510#discussion_r79755676 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/JoinDriver.java --- @@ -128,17 +130,22 @@ public void prepare() throws Exception{

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508622#comment-15508622 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on a diff

[GitHub] flink issue #2369: [FLINK-4035] Add a streaming connector for Apache Kafka 0...

2016-09-20 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2369 @cjstehno I would expect this to be in the 1.2.0 major release, which would probably be ~2 months from now according to Flink's past release cycle. The Flink community usually doesn't release major

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508526#comment-15508526 ] ASF GitHub Bot commented on FLINK-4035: --- Github user tzulitai commented on the issue

[GitHub] flink issue #2369: [FLINK-4035] Add a streaming connector for Apache Kafka 0...

2016-09-20 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2369 Looks like we need to rebase this PR on the recently merged Kerberos support. --- 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

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508517#comment-15508517 ] ASF GitHub Bot commented on FLINK-4035: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

2016-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508441#comment-15508441 ] 刘喆 commented on FLINK-4632: --- The container is killed by two reasons: 1, yarn preemption 2, yar

[jira] [Assigned] (FLINK-4406) Implement job master registration at resource manager

2016-09-20 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng reassigned FLINK-4406: - Assignee: zhuhaifeng > Implement job master registration at resource manager > --

[jira] [Commented] (FLINK-4629) Kafka v 0.10 Support

2016-09-20 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508374#comment-15508374 ] Tzu-Li (Gordon) Tai commented on FLINK-4629: I just recalled that I have actua

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-09-20 Thread delding
Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 Hi @fhueske , I have updated this PR to address your comments. In this change, only one MutationActions and two ArralyList are needed for entire stream, MutationActions is now resettable. But I repla

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507872#comment-15507872 ] ASF GitHub Bot commented on FLINK-2055: --- Github user delding commented on the issue:

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-09-20 Thread Simone Robutti (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507774#comment-15507774 ] Simone Robutti commented on FLINK-4035: --- The PR for kerberos integration for Kafka 0

[jira] [Resolved] (FLINK-3670) Kerberos: Improving long-running streaming jobs

2016-09-20 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan resolved FLINK-3670. Resolution: Fixed Fix Version/s: 1.2.0 Resolved as part of FLINK-3929

[jira] [Assigned] (FLINK-3670) Kerberos: Improving long-running streaming jobs

2016-09-20 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan reassigned FLINK-3670: -- Assignee: Vijay Srinivasaraghavan (was: Eron Wright ) > Kerberos: Impr

[jira] [Resolved] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

2016-09-20 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan resolved FLINK-3239. Resolution: Fixed Fix Version/s: 1.2.0 Resolved as part of FLINK-3929

[GitHub] flink pull request #934: Framesize fix

2016-09-20 Thread kl0u
Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/934 --- 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 enabled

[jira] [Resolved] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-09-20 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3929. --- Resolution: Fixed Fix Version/s: 1.2.0 > Support for Kerberos Authentication wi

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507665#comment-15507665 ] ASF GitHub Bot commented on FLINK-3929: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2275: FLINK-3929 Support for Kerberos Authentication wit...

2016-09-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2275 --- 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 enab

[jira] [Updated] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

2016-09-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4640: - Description: The following program {code} DataStream> src = env.fromElements(new Tuple2("a", 1L))

[jira] [Resolved] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2016-09-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2662. -- Resolution: Fixed Fix Version/s: 1.1.3 1.2.0 Fixed for 1.1.3 with a7f6

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507622#comment-15507622 ] ASF GitHub Bot commented on FLINK-2662: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2508: [FLINK-2662] [dataSet] Translate union with multip...

2016-09-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2508 --- 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 enab

[jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507587#comment-15507587 ] ASF GitHub Bot commented on FLINK-4361: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2472: [FLINK-4361] Introduce Flink's own future abstraction

2016-09-20 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2472 The naming is not super nice, I agree. But there is a clear benefit for Java 8 familiar people to stick with something established. +1 for this from my side. Next time we get inv

[jira] [Commented] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants

2016-09-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507579#comment-15507579 ] Stephan Ewen commented on FLINK-4644: - It was initially used by the web frontend, IIRC

[jira] [Commented] (FLINK-4645) Hard to register Kryo Serializers due to generics

2016-09-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507572#comment-15507572 ] Stephan Ewen commented on FLINK-4645: - I think both methods have the same erasure (bin

[jira] [Commented] (FLINK-3930) Implement Service-Level Authorization

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507535#comment-15507535 ] ASF GitHub Bot commented on FLINK-3930: --- Github user vijikarthi commented on the iss

[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

2016-09-20 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2425 @rmetzger I have added internals documentation section and provided details on how secure cookie is implemented. I will address the missing Netty data transfer secure cookie part in FLINK-4635. Pl

[jira] [Commented] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

2016-09-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507442#comment-15507442 ] Stephan Ewen commented on FLINK-4640: - Have a fix and nice tests. Waiting for the CI t

[jira] [Commented] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

2016-09-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507323#comment-15507323 ] Stephan Ewen commented on FLINK-4640: - Okay, so the {{keyBy(1).fold(...)}} case can be

[jira] [Commented] (FLINK-4645) Hard to register Kryo Serializers due to generics

2016-09-20 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507285#comment-15507285 ] Greg Hogan commented on FLINK-4645: --- {{registerTypeWithKryoSerializer}} is in the public

[jira] [Commented] (FLINK-3988) Add data set connector to DistributedLog

2016-09-20 Thread John Lonergan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507259#comment-15507259 ] John Lonergan commented on FLINK-3988: -- Anyone fancy collaborating? > Add data set c

[jira] [Commented] (FLINK-3987) Add data stream connector to DistributedLog

2016-09-20 Thread John Lonergan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507255#comment-15507255 ] John Lonergan commented on FLINK-3987: -- Anyone fancy collaborating? > Add data strea

[jira] [Created] (FLINK-4645) Hard to register Kryo Serializers due to generics

2016-09-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4645: --- Summary: Hard to register Kryo Serializers due to generics Key: FLINK-4645 URL: https://issues.apache.org/jira/browse/FLINK-4645 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4629) Kafka v 0.10 Support

2016-09-20 Thread Mariano Gonzalez (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507154#comment-15507154 ] Mariano Gonzalez commented on FLINK-4629: - [~tzulitai] The mailing list was my fir

[jira] [Commented] (FLINK-4560) enforcer java version as 1.7

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507137#comment-15507137 ] ASF GitHub Bot commented on FLINK-4560: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2458: [FLINK-4560] enforcer java version as 1.7

2016-09-20 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2458 We already gave up Java 6, and setting the source and target version in the Maven compiler plugin already prevents Java 6 usage. That is why I am wondering... --- If your project is set up for

[jira] [Created] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants

2016-09-20 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4644: - Summary: Deprecate "flink.base.dir.path" from ConfigConstants Key: FLINK-4644 URL: https://issues.apache.org/jira/browse/FLINK-4644 Project: Flink

[jira] [Commented] (FLINK-4640) Serialization of the initialValue of a Fold on WindowedStream fails

2016-09-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507104#comment-15507104 ] Stephan Ewen commented on FLINK-4640: - I actually reproduced the error BOTH on the {{K

[GitHub] flink pull request #2519: [docs] Small improvements to the docs.

2016-09-20 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2519#discussion_r79654882 --- Diff: docs/quickstart/run_example_quickstart.md --- @@ -125,21 +125,21 @@ public class WikipediaAnalysis { } {% endhighlight %} -I ad

[GitHub] flink pull request #2519: [docs] Small improvements to the docs.

2016-09-20 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2519#discussion_r79655043 --- Diff: docs/quickstart/run_example_quickstart.md --- @@ -125,21 +125,21 @@ public class WikipediaAnalysis { } {% endhighlight %} -I ad

[GitHub] flink pull request #2519: [docs] Small improvements to the docs.

2016-09-20 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2519#discussion_r79655828 --- Diff: docs/quickstart/run_example_quickstart.md --- @@ -277,8 +277,8 @@ The number in front of each line tells you on which parallel instance of the pri

[jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507066#comment-15507066 ] ASF GitHub Bot commented on FLINK-4361: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2472: [FLINK-4361] Introduce Flink's own future abstract...

2016-09-20 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2472#discussion_r79656257 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/Future.java --- @@ -0,0 +1,156 @@ +/* + * Licensed to the Apache Software Founda

[jira] [Commented] (FLINK-4533) Unprotected access to meters in StatsDReporter#report()

2016-09-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507024#comment-15507024 ] Chesnay Schepler commented on FLINK-4533: - there already is a comment within repor

[jira] [Resolved] (FLINK-4533) Unprotected access to meters in StatsDReporter#report()

2016-09-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-4533. --- Resolution: Won't Fix > Unprotected access to meters in StatsDReporter#report() >

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507021#comment-15507021 ] ASF GitHub Bot commented on FLINK-4248: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507023#comment-15507023 ] ASF GitHub Bot commented on FLINK-4248: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

2016-09-20 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79652535 --- Diff: flink-core/src/main/java/org/apache/flink/types/parser/SqlDateParser.java --- @@ -0,0 +1,134 @@ +/* + * Licensed to the Apache Software Foun

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

2016-09-20 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79652411 --- Diff: flink-core/src/test/java/org/apache/flink/types/parser/SqlTimestampParserTest.java --- @@ -0,0 +1,69 @@ +/* + * Licensed to the Apache Soft

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507010#comment-15507010 ] ASF GitHub Bot commented on FLINK-4520: --- Github user haoch commented on the issue:

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

2016-09-20 Thread haoch
Github user haoch commented on the issue: https://github.com/apache/flink/pull/2487 @StephanEwen thanks for the comments, I think it's both ok to keep this in the core or as an separated project, but the concern is it maybe better for community development to centralize qualified libr

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507001#comment-15507001 ] ASF GitHub Bot commented on FLINK-4248: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

2016-09-20 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79651336 --- Diff: flink-core/src/test/java/org/apache/flink/types/parser/SqlTimeParserTest.java --- @@ -0,0 +1,63 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506986#comment-15506986 ] ASF GitHub Bot commented on FLINK-4248: --- Github user fhueske commented on a diff in

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

2016-09-20 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79650020 --- Diff: flink-core/src/test/java/org/apache/flink/types/parser/SqlDateParserTest.java --- @@ -0,0 +1,64 @@ +/* + * Licensed to the Apache Software

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

2016-09-20 Thread haoch
Github user haoch commented on the issue: https://github.com/apache/flink/pull/2487 @mushketyk I have added lots of java docs as required in latest commit: https://github.com/apache/flink/pull/2487/commits/4699f9c3dfc4ce0a9837eb60579c76d50b346f03, please continue to help review. ---

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506964#comment-15506964 ] ASF GitHub Bot commented on FLINK-4520: --- Github user haoch commented on the issue:

[jira] [Created] (FLINK-4643) Average Clustering Coefficient

2016-09-20 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4643: - Summary: Average Clustering Coefficient Key: FLINK-4643 URL: https://issues.apache.org/jira/browse/FLINK-4643 Project: Flink Issue Type: New Feature Comp

[jira] [Commented] (FLINK-4560) enforcer java version as 1.7

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506901#comment-15506901 ] ASF GitHub Bot commented on FLINK-4560: --- Github user shijinkui commented on the issu

[GitHub] flink issue #2458: [FLINK-4560] enforcer java version as 1.7

2016-09-20 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2458 @greghogan exactly 3.0.3 will be OK. This limit is some module require, I forget where it is, I am sorry.. --- If your project is set up for it, you can reply to this email and have your reply app

[GitHub] flink issue #2458: [FLINK-4560] enforcer java version as 1.7

2016-09-20 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2458 Would this be useful to prevent building Flink with Maven 3.3.x? https://maven.apache.org/enforcer/enforcer-rules/versionRanges.html https://maven.apache.org/enforcer/enforcer-rules/ --

[jira] [Commented] (FLINK-4560) enforcer java version as 1.7

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506858#comment-15506858 ] ASF GitHub Bot commented on FLINK-4560: --- Github user greghogan commented on the issu

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506812#comment-15506812 ] ASF GitHub Bot commented on FLINK-4248: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #2303: [FLINK-4248] [core] [table] CsvTableSource does no...

2016-09-20 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/2303#discussion_r79632225 --- Diff: flink-core/src/test/java/org/apache/flink/types/parser/SqlDateParserTest.java --- @@ -0,0 +1,64 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #2523: [FLINK-4556] Make Queryable State Key-Group Aware

2016-09-20 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2523 [FLINK-4556] Make Queryable State Key-Group Aware This PR addresses [FLINK-4556] and makes queryable state aware of key-groups. You can merge this pull request into a Git repository by runn

[jira] [Created] (FLINK-4642) Remove unnecessary Guava dependency from flink-streaming-java

2016-09-20 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4642: --- Summary: Remove unnecessary Guava dependency from flink-streaming-java Key: FLINK-4642 URL: https://issues.apache.org/jira/browse/FLINK-4642 Project: Flink Is

[GitHub] flink issue #2522: Parameterize Flink version in Quickstart bash script

2016-09-20 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2522 Looks good, merging this... --- 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

[GitHub] flink issue #2513: [hotfix] RescalingITCase

2016-09-20 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2513 Looks good to me, merging this... --- 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 enable

[jira] [Commented] (FLINK-4556) Make Queryable State Key-Group Aware

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506795#comment-15506795 ] ASF GitHub Bot commented on FLINK-4556: --- GitHub user StefanRRichter opened a pull re

[jira] [Resolved] (FLINK-4268) Add a parsers for BigDecimal/BigInteger

2016-09-20 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4268. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 5c02988b05c56f524fc8c65b15e16b0c24278a5e.

[jira] [Commented] (FLINK-4268) Add a parsers for BigDecimal/BigInteger

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506783#comment-15506783 ] ASF GitHub Bot commented on FLINK-4268: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2304: [FLINK-4268] [core] Add parsers for BigDecimal/Big...

2016-09-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2304 --- 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 enab

[jira] [Assigned] (FLINK-4556) Make Queryable State Key-Group Aware

2016-09-20 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4556: - Assignee: Stefan Richter > Make Queryable State Key-Group Aware > ---

[GitHub] flink pull request #2522: Parameterize Flink version in Quickstart bash scri...

2016-09-20 Thread chobeat
GitHub user chobeat opened a pull request: https://github.com/apache/flink/pull/2522 Parameterize Flink version in Quickstart bash script You can merge this pull request into a Git repository by running: $ git pull https://github.com/radicalbit/flink FLINK-4301 Alternatively

[jira] [Commented] (FLINK-4560) enforcer java version as 1.7

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506752#comment-15506752 ] ASF GitHub Bot commented on FLINK-4560: --- Github user shijinkui commented on the issu

[GitHub] flink issue #2458: [FLINK-4560] enforcer java version as 1.7

2016-09-20 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2458 hi, @StephanEwen There are much difference between JDK 6 and JDK 7+. It's better for compatible low version JDK,but there are better performance for Scala with Lambda support, and JDK 7 a

[GitHub] flink pull request #2472: [FLINK-4361] Introduce Flink's own future abstract...

2016-09-20 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2472#discussion_r79623763 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/Future.java --- @@ -0,0 +1,156 @@ +/* + * Licensed to the Apache Softwa

[jira] [Closed] (FLINK-4638) Fix exception message for MemorySegment

2016-09-20 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4638. - Resolution: Fixed Fixed in 7a25bf5cee9ab94525ed0284cbf399d2c33f70cf > Fix exception message for MemorySeg

[GitHub] flink pull request #2472: [FLINK-4361] Introduce Flink's own future abstract...

2016-09-20 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2472#discussion_r79622945 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/Future.java --- @@ -0,0 +1,156 @@ +/* + * Licensed to the Apache Softwa

[GitHub] flink issue #2508: [FLINK-2662] [dataSet] Translate union with multiple outp...

2016-09-20 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2508 Thanks, merging then --- 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,

[jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506714#comment-15506714 ] ASF GitHub Bot commented on FLINK-4361: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506724#comment-15506724 ] ASF GitHub Bot commented on FLINK-4361: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506717#comment-15506717 ] ASF GitHub Bot commented on FLINK-2662: --- Github user fhueske commented on the issue:

[jira] [Updated] (FLINK-4638) Fix exception message for MemorySegment

2016-09-20 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4638: -- Fix Version/s: 1.2.0 > Fix exception message for MemorySegment > ---

[GitHub] flink issue #2304: [FLINK-4268] [core] Add parsers for BigDecimal/BigInteger

2016-09-20 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2304 Thanks again for the review @fhueske. I will fix your comments and merge this. --- 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

[jira] [Commented] (FLINK-4268) Add a parsers for BigDecimal/BigInteger

2016-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15506699#comment-15506699 ] ASF GitHub Bot commented on FLINK-4268: --- Github user twalthr commented on the issue:

[jira] [Updated] (FLINK-4572) Convert to negative in LongValueToIntValue

2016-09-20 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4572: -- Fix Version/s: 1.2.0 > Convert to negative in LongValueToIntValue >

[jira] [Updated] (FLINK-4594) Validate lower bound in MathUtils.checkedDownCast

2016-09-20 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4594: -- Fix Version/s: 1.2.0 > Validate lower bound in MathUtils.checkedDownCast > -

  1   2   3   >