[jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

2016-04-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long

[jira] [Updated] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release

2016-04-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

[jira] [Updated] (FLINK-3733) registeredTypesWithKryoSerializers is not assigned in ExecutionConfig#deserializeUserCode()

2016-04-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3733: -- Description: {code} if (serializedRegisteredTypesWithKryoSerializers != null) {

[jira] [Updated] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close

2016-04-18 Thread Chenguang He (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chenguang He updated FLINK-3782: Description: ByteArrayOutputStream and ObjectOutputStream should close @Test public void

[jira] [Created] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close

2016-04-18 Thread Chenguang He (JIRA)
Chenguang He created FLINK-3782: --- Summary: ByteArrayOutputStream and ObjectOutputStream should close Key: FLINK-3782 URL: https://issues.apache.org/jira/browse/FLINK-3782 Project: Flink Issue

[jira] [Updated] (FLINK-3782) ByteArrayOutputStream and ObjectOutputStream should close

2016-04-18 Thread Chenguang He (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chenguang He updated FLINK-3782: Description: @Test public void testSerializability() { try {

[jira] [Resolved] (FLINK-3068) Add a Table API configuration to TableEnvironment

2016-04-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-3068. -- Resolution: Fixed Fix Version/s: 1.1.0 Implemented with

[jira] [Assigned] (FLINK-3068) Add a Table API configuration to TableEnvironment

2016-04-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-3068: Assignee: Fabian Hueske > Add a Table API configuration to TableEnvironment >

[jira] [Commented] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal()

2016-04-18 Thread Chenguang He (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246347#comment-15246347 ] Chenguang He commented on FLINK-3781: - Sorry for inconvenient comments above. i forget to rebase my

[jira] [Commented] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal()

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246344#comment-15246344 ] ASF GitHub Bot commented on FLINK-3781: --- GitHub user gaoyike opened a pull request:

[GitHub] flink pull request: [FLINK-3781] BlobClient may be left unclosed i...

2016-04-18 Thread gaoyike
GitHub user gaoyike opened a pull request: https://github.com/apache/flink/pull/1908 [FLINK-3781] BlobClient may be left unclosed in BlobCache#deleteGlobal() Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[GitHub] flink pull request: [FLINK-2259][ml] Add Train-Testing Splitters

2016-04-18 Thread rawkintrevo
Github user rawkintrevo commented on the pull request: https://github.com/apache/flink/pull/1898#issuecomment-211507574 Any thoughts on this approach or go ahead and write docs/prepare to merge? --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246213#comment-15246213 ] ASF GitHub Bot commented on FLINK-2259: --- Github user rawkintrevo commented on the pull request:

[jira] [Commented] (FLINK-3708) Scala API for CEP

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246128#comment-15246128 ] ASF GitHub Bot commented on FLINK-3708: --- Github user rmetzger commented on a diff in the pull

[jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246186#comment-15246186 ] ASF GitHub Bot commented on FLINK-3477: --- Github user ggevay commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine ...

2016-04-18 Thread ggevay
Github user ggevay commented on a diff in the pull request: https://github.com/apache/flink/pull/1517#discussion_r60105060 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/base/ReduceOperatorBase.java --- @@ -54,6 +54,32 @@ @Internal public class

[jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246167#comment-15246167 ] ASF GitHub Bot commented on FLINK-3477: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-3708) Scala API for CEP

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246165#comment-15246165 ] ASF GitHub Bot commented on FLINK-3708: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2544] Add Java 8 version for building P...

2016-04-18 Thread skavulya
Github user skavulya commented on the pull request: https://github.com/apache/flink/pull/1882#issuecomment-211498750 @StephanEwen Adding "Assume" statements is a good idea. We could limit them to the affected tests. --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246133#comment-15246133 ] ASF GitHub Bot commented on FLINK-2544: --- Github user skavulya commented on the pull request:

[jira] [Commented] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal()

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246129#comment-15246129 ] ASF GitHub Bot commented on FLINK-3781: --- Github user gaoyike closed the pull request at:

[GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine ...

2016-04-18 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1517#discussion_r60104097 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/base/ReduceOperatorBase.java --- @@ -54,6 +54,32 @@ @Internal public

[GitHub] flink pull request: [FLINK-3708] Scala API for CEP (initial).

2016-04-18 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/1905#discussion_r60104038 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/FollowedByPattern.scala --- @@ -0,0 +1,34 @@ +/*

[jira] [Commented] (FLINK-3708) Scala API for CEP

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246163#comment-15246163 ] ASF GitHub Bot commented on FLINK-3708: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3708] Scala API for CEP (initial).

2016-04-18 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/1905#discussion_r60103959 --- Diff: flink-libraries/flink-cep-scala/pom.xml --- @@ -0,0 +1,216 @@ + + +http://maven.apache.org/POM/4.0.0;

[GitHub] flink pull request: [FLINK-3708] Scala API for CEP (initial).

2016-04-18 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1905#discussion_r60102619 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/FollowedByPattern.scala --- @@ -0,0 +1,34 @@ +/* + *

[GitHub] flink pull request: [FLINK-3781] BlobClient may be left unclosed i...

2016-04-18 Thread gaoyike
Github user gaoyike closed the pull request at: https://github.com/apache/flink/pull/1907 --- 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

[jira] [Commented] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal()

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246122#comment-15246122 ] ASF GitHub Bot commented on FLINK-3781: --- GitHub user gaoyike opened a pull request:

[GitHub] flink pull request: [FLINK-3781] BlobClient may be left unclosed i...

2016-04-18 Thread gaoyike
GitHub user gaoyike opened a pull request: https://github.com/apache/flink/pull/1907 [FLINK-3781] BlobClient may be left unclosed in BlobCache#deleteGlobal() Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-3708) Scala API for CEP

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15246119#comment-15246119 ] ASF GitHub Bot commented on FLINK-3708: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3708] Scala API for CEP (initial).

2016-04-18 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1905#discussion_r60102211 --- Diff: flink-libraries/flink-cep-scala/pom.xml --- @@ -0,0 +1,216 @@ + + +http://maven.apache.org/POM/4.0.0;

[jira] [Created] (FLINK-3781) BlobClient may be left unclosed in BlobCache#deleteGlobal()

2016-04-18 Thread Ted Yu (JIRA)
Ted Yu created FLINK-3781: - Summary: BlobClient may be left unclosed in BlobCache#deleteGlobal() Key: FLINK-3781 URL: https://issues.apache.org/jira/browse/FLINK-3781 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245987#comment-15245987 ] ASF GitHub Bot commented on FLINK-2259: --- Github user tillrohrmann commented on the pull request:

[GitHub] flink pull request: [FLINK-2259][ml] Add Train-Testing Splitters

2016-04-18 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1898#issuecomment-211471397 Yes the failing tests are most likely caused by the build infrastructure. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Updated] (FLINK-3779) Add support for queryable state

2016-04-18 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-3779: --- Description: Flink offers state abstractions for user functions in order to guarantee fault-tolerant

[jira] [Created] (FLINK-3780) Jaccard Similarity

2016-04-18 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3780: - Summary: Jaccard Similarity Key: FLINK-3780 URL: https://issues.apache.org/jira/browse/FLINK-3780 Project: Flink Issue Type: New Feature Components:

[jira] [Comment Edited] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement

2016-04-18 Thread Chenguang He (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245967#comment-15245967 ] Chenguang He edited comment on FLINK-2832 at 4/18/16 4:39 PM: -- d

[GitHub] flink pull request: [FLINK-3778] [shell] Forward configuration fro...

2016-04-18 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1906 [FLINK-3778] [shell] Forward configuration from FlinkILoop to ScalaShellRemoteStreamEnvironment Thanks for contributing to Apache Flink. Before you open your pull request, please take the

[jira] [Commented] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement

2016-04-18 Thread Chenguang He (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245967#comment-15245967 ] Chenguang He commented on FLINK-2832: - d value(0.032600) is correct for a sampling with size of 5000.

[jira] [Commented] (FLINK-3778) ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245968#comment-15245968 ] ASF GitHub Bot commented on FLINK-3778: --- GitHub user tillrohrmann opened a pull request:

[jira] [Created] (FLINK-3779) Add support for queryable state

2016-04-18 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3779: -- Summary: Add support for queryable state Key: FLINK-3779 URL: https://issues.apache.org/jira/browse/FLINK-3779 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3708) Scala API for CEP

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245917#comment-15245917 ] ASF GitHub Bot commented on FLINK-3708: --- GitHub user StefanRRichter opened a pull request:

[GitHub] flink pull request: [FLINK-3708] Scala API for CEP (initial).

2016-04-18 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/1905 [FLINK-3708] Scala API for CEP (initial). This module flink-cep-scala adds a Scala pendant for the Java CEP API to Flink. I created Scala classes for Pattern and

[jira] [Created] (FLINK-3778) ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration

2016-04-18 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3778: Summary: ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration Key: FLINK-3778 URL: https://issues.apache.org/jira/browse/FLINK-3778 Project:

[jira] [Updated] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

2016-04-18 Thread Andrea Sella (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrea Sella updated FLINK-3774: Assignee: Till Rohrmann (was: Andrea Sella) > Flink configuration is not correctly forwarded to

[jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode()

2016-04-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3222: -- Description: Here is related code: {code} result = 31 * result + (int) (subTaskStats.length ^

[jira] [Commented] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245871#comment-15245871 ] ASF GitHub Bot commented on FLINK-3774: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request: [FLINK-3774] [shell] Forwards Flink configurat...

2016-04-18 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1904 [FLINK-3774] [shell] Forwards Flink configuration to PlanExecutor Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Closed] (FLINK-3770) Fix TriangleEnumerator performance

2016-04-18 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3770. - Resolution: Fixed > Fix TriangleEnumerator performance > -- > >

[jira] [Commented] (FLINK-3770) Fix TriangleEnumerator performance

2016-04-18 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245868#comment-15245868 ] Greg Hogan commented on FLINK-3770: --- Implemented with 85fcfc4d43feddacb76f2d14229229340174fed8 > Fix

[jira] [Commented] (FLINK-3773) Scanners are left unclosed in SqlExplainTest

2016-04-18 Thread Saikat Maitra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245865#comment-15245865 ] Saikat Maitra commented on FLINK-3773: -- [~fhueske] Thank you Fabian. Regards Saikat > Scanners are

[jira] [Commented] (FLINK-3770) Fix TriangleEnumerator performance

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245863#comment-15245863 ] ASF GitHub Bot commented on FLINK-3770: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request: [FLINK-3770] [gelly] Fix TriangleEnumerator pe...

2016-04-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1899 --- 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

[jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245832#comment-15245832 ] ASF GitHub Bot commented on FLINK-3665: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3665] Implemented sort orders support i...

2016-04-18 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1848#issuecomment-211422717 Hi @dawidwys, thanks for the update and the extensive tests you added! I had a few minor comments and I am not sure about the tests that check the correctness of

[jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245829#comment-15245829 ] ASF GitHub Bot commented on FLINK-3665: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3665] Implemented sort orders support i...

2016-04-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1848#discussion_r60075546 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/PartitionITCase.java --- @@ -546,43 +549,264 @@ public void

[jira] [Commented] (FLINK-3587) Bump Calcite version to 1.7.0

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245794#comment-15245794 ] ASF GitHub Bot commented on FLINK-3587: --- Github user zentol commented on the pull request:

[GitHub] flink pull request: [FLINK-3587] Bump Calcite version to 1.7.0

2016-04-18 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1897#issuecomment-211412641 Merging. --- 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 pull request: [FLINK-3665] Implemented sort orders support i...

2016-04-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1848#discussion_r60075060 --- Diff: flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/PartitionITCase.java --- @@ -546,43 +549,264 @@ public void

[jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245824#comment-15245824 ] ASF GitHub Bot commented on FLINK-3665: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245813#comment-15245813 ] ASF GitHub Bot commented on FLINK-3665: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3665] Implemented sort orders support i...

2016-04-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1848#discussion_r60074102 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/PartitionNode.java --- @@ -90,13 +90,20 @@ public SemanticProperties

[GitHub] flink pull request: [FLINK-3665] Implemented sort orders support i...

2016-04-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1848#discussion_r60073978 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/PartitionNode.java --- @@ -90,13 +90,20 @@ public SemanticProperties

[jira] [Closed] (FLINK-3587) Bump Calcite version to 1.7.0

2016-04-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3587. --- Resolution: Fixed Implemented in 367687df1e2107e07622d3ffb0fdf0466bce7ff1 > Bump Calcite

[jira] [Commented] (FLINK-3664) Create a method to easily Summarize a DataSet

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245789#comment-15245789 ] ASF GitHub Bot commented on FLINK-3664: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request: [FLINK-3587] Bump Calcite version to 1.7.0

2016-04-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1897 --- 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

[jira] [Commented] (FLINK-3587) Bump Calcite version to 1.7.0

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245810#comment-15245810 ] ASF GitHub Bot commented on FLINK-3587: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-3664) Create a method to easily Summarize a DataSet

2016-04-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3664. --- Resolution: Fixed Fix Version/s: 1.1.0 Implemented in

[jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245793#comment-15245793 ] ASF GitHub Bot commented on FLINK-3665: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-3665) Range partitioning lacks support to define sort orders

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245790#comment-15245790 ] ASF GitHub Bot commented on FLINK-3665: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3665] Implemented sort orders support i...

2016-04-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1848#discussion_r60071991 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java --- @@ -98,6 +102,23 @@ public PartitionOperator(DataSet

[GitHub] flink pull request: [FLINK-3665] Implemented sort orders support i...

2016-04-18 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1848#discussion_r60071774 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/Keys.java --- @@ -183,9 +193,13 @@ public String toString() {

[GitHub] flink pull request: [FLINK-3664] Create method to easily summarize...

2016-04-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1859 --- 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

[jira] [Commented] (FLINK-3664) Create a method to easily Summarize a DataSet

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245782#comment-15245782 ] ASF GitHub Bot commented on FLINK-3664: --- Github user zentol commented on the pull request:

[GitHub] flink pull request: FLINK-3773 Scanners are left unclosed in SqlEx...

2016-04-18 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1902#issuecomment-211405228 Merging. --- 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 pull request: [FLINK-3664] Create method to easily summarize...

2016-04-18 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1859#issuecomment-211407719 Merging. --- 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

[jira] [Closed] (FLINK-3773) Scanners are left unclosed in SqlExplainTest

2016-04-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3773. --- Resolution: Fixed Fix Version/s: 1.1.0 Fixed in

[jira] [Commented] (FLINK-3773) Scanners are left unclosed in SqlExplainTest

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245761#comment-15245761 ] ASF GitHub Bot commented on FLINK-3773: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request: FLINK-3773 Scanners are left unclosed in SqlEx...

2016-04-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1902 --- 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

[jira] [Commented] (FLINK-3772) Graph algorithms for vertex and edge degree

2016-04-18 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245760#comment-15245760 ] Greg Hogan commented on FLINK-3772: --- Each of the "join" methods is implemented as a {{coGroup}} as is

[jira] [Commented] (FLINK-3773) Scanners are left unclosed in SqlExplainTest

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245753#comment-15245753 ] ASF GitHub Bot commented on FLINK-3773: --- Github user zentol commented on the pull request:

[jira] [Commented] (FLINK-3748) Add CASE function to Table API

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245744#comment-15245744 ] ASF GitHub Bot commented on FLINK-3748: --- Github user twalthr commented on the pull request:

[GitHub] flink pull request: [FLINK-3748] [table] Add CASE function to Tabl...

2016-04-18 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1893#issuecomment-211403149 Thanks for reviewing @fhueske! I will 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

[jira] [Updated] (FLINK-3771) Methods for translating Graphs

2016-04-18 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3771: -- Description: Provide methods for translation of the type or value of graph labels, vertex values, and

[jira] [Updated] (FLINK-3771) Methods for translating Graphs

2016-04-18 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-3771: -- Description: Provide methods for translation of the type or value of graph labels, vertex values, and

[jira] [Commented] (FLINK-3770) Fix TriangleEnumerator performance

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245638#comment-15245638 ] ASF GitHub Bot commented on FLINK-3770: --- Github user greghogan commented on the pull request:

[GitHub] flink pull request: [FLINK-3770] [gelly] Fix TriangleEnumerator pe...

2016-04-18 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1899#issuecomment-211376216 Merging ... --- 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

[jira] [Commented] (FLINK-3748) Add CASE function to Table API

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245635#comment-15245635 ] ASF GitHub Bot commented on FLINK-3748: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3748] [table] Add CASE function to Tabl...

2016-04-18 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1893#issuecomment-211375912 Looks good to me. --- 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

[jira] [Commented] (FLINK-3770) Fix TriangleEnumerator performance

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245629#comment-15245629 ] ASF GitHub Bot commented on FLINK-3770: --- Github user greghogan commented on a diff in the pull

[jira] [Commented] (FLINK-3768) Clustering Coefficient

2016-04-18 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245621#comment-15245621 ] Greg Hogan commented on FLINK-3768: --- Yes, same objective but different implementations. This

[jira] [Commented] (FLINK-3749) Improve decimal handling

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245578#comment-15245578 ] ASF GitHub Bot commented on FLINK-3749: --- Github user vasia commented on the pull request:

[GitHub] flink pull request: [FLINK-3749] [table] Improve decimal handling

2016-04-18 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1881#issuecomment-211358495 @twalthr I see your point. Is it possible to support at least decimals of double precision without running into the risk of returning wrong results? If not, I don't think

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

2016-04-18 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245568#comment-15245568 ] Vasia Kalavri commented on FLINK-1707: -- Hi [~joseprupi], take a look at the {{flink-gelly-examples}}

[jira] [Commented] (FLINK-3770) Fix TriangleEnumerator performance

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245563#comment-15245563 ] ASF GitHub Bot commented on FLINK-3770: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-3770] [gelly] Fix TriangleEnumerator pe...

2016-04-18 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1899#issuecomment-211355794 Looks good to me. --- 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

[jira] [Commented] (FLINK-3211) Add AWS Kinesis streaming connector

2016-04-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245562#comment-15245562 ] Robert Metzger commented on FLINK-3211: --- According to LEGAL-198, we have to make the streaming

[jira] [Commented] (FLINK-3770) Fix TriangleEnumerator performance

2016-04-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245554#comment-15245554 ] ASF GitHub Bot commented on FLINK-3770: --- Github user vasia commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-3770] [gelly] Fix TriangleEnumerator pe...

2016-04-18 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1899#issuecomment-211354538 Thanks for this PR! Apart from a minor comment, it looks good to merge. --- If your project is set up for it, you can reply to this email and have your reply appear on

  1   2   >