[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

2016-05-09 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15277514#comment-15277514 ] GaoLun commented on FLINK-3879: --- Scatter-gather model divides original iteration into two pa

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

2016-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276921#comment-15276921 ] ASF GitHub Bot commented on FLINK-1502: --- Github user zentol commented on the pull re

[GitHub] flink pull request: [FLINK-1502] [WIP] Basic Metric System

2016-05-09 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1947#issuecomment-217972596 I have updates this PR; it now contains a new feature: configurable system scope. It essentially allows users to decide how Flink entities(Taskmanager, jobs, tasks and op

[jira] [Commented] (FLINK-2926) Add a Strongly Connected Components Library Method

2016-05-09 Thread Martin Liesenberg (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276811#comment-15276811 ] Martin Liesenberg commented on FLINK-2926: -- the issue is FLINK-3888 > Add a Stro

[jira] [Created] (FLINK-3888) Custom Aggregator with Convergence can't be registered directly with DeltaIteration

2016-05-09 Thread Martin Liesenberg (JIRA)
Martin Liesenberg created FLINK-3888: Summary: Custom Aggregator with Convergence can't be registered directly with DeltaIteration Key: FLINK-3888 URL: https://issues.apache.org/jira/browse/FLINK-3888

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

2016-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276761#comment-15276761 ] Greg Hogan commented on FLINK-3879: --- That is a very "meta" question :) Gelly currently c

[jira] [Updated] (FLINK-3883) Rename flink clients for inclusion on system path

2016-05-09 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-3883: Description: I ran into some trouble in preparing a Homebrew formula to install Flink on Mac ([home

[jira] [Commented] (FLINK-3882) Errors in sample Java code for the Elasticsearch 2.x sink

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

[GitHub] flink pull request: [FLINK-3882][docs] Fix errors in sample Java c...

2016-05-09 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1971#issuecomment-217917157 Thanks for the fixes @markreddy. +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

[jira] [Resolved] (FLINK-3877) Create TranslateFunction interface for Graph translators

2016-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-3877. --- Resolution: Fixed Fixed with a27208da88390a1e5dd3ec4102064862c54eb7a0 > Create TranslateFunction inte

[jira] [Commented] (FLINK-3877) Create TranslateFunction interface for Graph translators

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

[GitHub] flink pull request: [FLINK-3877] [gelly] Create TranslateFunction ...

2016-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1968 --- 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-3877) Create TranslateFunction interface for Graph translators

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

[GitHub] flink pull request: [FLINK-3877] [gelly] Create TranslateFunction ...

2016-05-09 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1968#issuecomment-217904645 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-2044) Implementation of Gelly HITS Algorithm

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

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r62518520 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,183 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-3886) Give a better error when the application Main class is not public.

2016-05-09 Thread Niels Basjes (JIRA)
public. > -- > > Key: FLINK-3886 > URL: https://issues.apache.org/jira/browse/FLINK-3886 > Project: Flink > Issue Type: Improvement >Reporter: Niels Basjes >Assignee: Niels Basjes > Attachments:

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

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

[jira] [Created] (FLINK-3887) Improve dependency management for building docs

2016-05-09 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3887: - Summary: Improve dependency management for building docs Key: FLINK-3887 URL: https://issues.apache.org/jira/browse/FLINK-3887 Project: Flink Issue

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

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

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-09 Thread gallenvara
Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r62514632 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,183 @@ +/* + * Licensed to th

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-09 Thread gallenvara
Github user gallenvara commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r62514639 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,183 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-3880) Improve performance of Accumulator map

2016-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276461#comment-15276461 ] ASF GitHub Bot commented on FLINK-3880: --- Github user mxm commented on the pull reque

[jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages

2016-05-09 Thread Niels Basjes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276463#comment-15276463 ] Niels Basjes commented on FLINK-2597: - FYI: I see a close relationship between this is

[GitHub] flink pull request: [FLINK-3880] remove mutex for user accumulator...

2016-05-09 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1976#issuecomment-217888511 Merging after tests pass. --- 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

[GitHub] flink pull request: [FLINK-3880] remove mutex for user accumulator...

2016-05-09 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1976 [FLINK-3880] remove mutex for user accumulators hash map This has been reported as a performance impact. The synchronized lock is not necessary because Flink doesn't perform concurrent updates on the pe

[jira] [Commented] (FLINK-3880) Improve performance of Accumulator map

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

[jira] [Updated] (FLINK-3886) Give a better error when the application Main class is not public.

2016-05-09 Thread Niels Basjes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Niels Basjes updated FLINK-3886: Attachment: FLINK-3886-20160509.patch The proposed change. Please verify if this works/is valid in

[jira] [Created] (FLINK-3886) Give a better error when the application Main class is not public.

2016-05-09 Thread Niels Basjes (JIRA)
Niels Basjes created FLINK-3886: --- Summary: Give a better error when the application Main class is not public. Key: FLINK-3886 URL: https://issues.apache.org/jira/browse/FLINK-3886 Project: Flink

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

2016-05-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276392#comment-15276392 ] Tzu-Li (Gordon) Tai commented on FLINK-3211: On the other hand, if we're aimin

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

2016-05-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276381#comment-15276381 ] Tzu-Li (Gordon) Tai commented on FLINK-3211: [~rmetzger] Hi Robert, I'm halfwa

[jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer

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

[GitHub] flink pull request: [FLINK-3854] Support Avro key-value rolling si...

2016-05-09 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1953#issuecomment-217869409 Ok, thats "normal" right now. @rmetzger if you don't have any more objections I would merge it in a bit. --- If your project is set up for it, you can reply to this em

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

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

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

2016-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-3772. --- Resolution: Implemented > Graph algorithms for vertex and edge degree > --

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

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

[GitHub] flink pull request: [FLINK-3772] [gelly] Graph algorithms for vert...

2016-05-09 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1901#issuecomment-217868088 Closed in 70181b28cf17e25b4b70f21f718ada2537cde2b6 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[GitHub] flink pull request: [FLINK-3772] [gelly] Graph algorithms for vert...

2016-05-09 Thread greghogan
Github user greghogan closed the pull request at: https://github.com/apache/flink/pull/1901 --- 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 e

[jira] [Comment Edited] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-05-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276356#comment-15276356 ] Aljoscha Krettek edited comment on FLINK-3758 at 5/9/16 1:29 PM: ---

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-05-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276356#comment-15276356 ] Aljoscha Krettek commented on FLINK-3758: - Please open a PR. The changes look good

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-05-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276351#comment-15276351 ] Aljoscha Krettek commented on FLINK-3758: - I'm looking at it. :-) > Add possibili

[GitHub] flink pull request: [FLINK-3754][Table]Add a validation phase befo...

2016-05-09 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1958#issuecomment-217862197 Yes, I will also take a look at it. --- 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

[jira] [Commented] (FLINK-3754) Add a validation phase before construct RelNode using TableAPI

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

[jira] [Commented] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp

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

[GitHub] flink pull request: [FLINK-3856] [core] Create types for java.sql....

2016-05-09 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1959#discussion_r62495413 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DateComparator.java --- @@ -59,15 +55,37 @@ public boolean isNormalizedKeyPrefi

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

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

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r62493996 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,183 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp

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

[GitHub] flink pull request: [FLINK-3856] [core] Create types for java.sql....

2016-05-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1959#discussion_r62493248 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DateComparator.java --- @@ -59,15 +55,37 @@ public boolean isNormalizedKeyPrefi

[GitHub] flink pull request: [FLINK-2044] [gelly] Implementation of Gelly H...

2016-05-09 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/1956#discussion_r62493213 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/HITSAlgorithm.java --- @@ -0,0 +1,183 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

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

[jira] [Commented] (FLINK-3883) Rename flink clients for inclusion on system path

2016-05-09 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276313#comment-15276313 ] Greg Hogan commented on FLINK-3883: --- +1 with a consideration for "start-scala-shell.sh"

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

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

[GitHub] flink pull request: [FLINK-3772] [gelly] Graph algorithms for vert...

2016-05-09 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1901#issuecomment-217852205 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-3856) Create types for java.sql.Date/Time/Timestamp

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

[GitHub] flink pull request: [FLINK-3856] [core] Create types for java.sql....

2016-05-09 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/1959#discussion_r62490034 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DateComparator.java --- @@ -59,15 +55,37 @@ public boolean isNormalizedKeyPrefi

[jira] [Updated] (FLINK-3880) Improve performance of Accumulator map

2016-05-09 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3880: -- Summary: Improve performance of Accumulator map (was: Use ConcurrentHashMap for Accumul

[GitHub] flink pull request: [FLINK-2184] Cannot get last element with maxB...

2016-05-09 Thread gallenvara
GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/1975 [FLINK-2184] Cannot get last element with maxBy/minBy. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-05-09 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276266#comment-15276266 ] Konstantin Knauf commented on FLINK-3758: - [~aljoscha] Ping. Going on vacation soo

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

2016-05-09 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276262#comment-15276262 ] GaoLun commented on FLINK-2184: --- I will go on with this issue. :) > Cannot get last element

[jira] [Commented] (FLINK-3856) Create types for java.sql.Date/Time/Timestamp

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

[GitHub] flink pull request: [FLINK-3856] [core] Create types for java.sql....

2016-05-09 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1959#issuecomment-217836281 I will move it to `SqlTimeTypeInfo`. --- 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

[GitHub] flink pull request: [FLINK-3842] [table] Fix handling null record/...

2016-05-09 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/1974 [FLINK-3842] [table] Fix handling null record/row in generated code Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideratio

[jira] [Commented] (FLINK-3842) Fix handling null record/row in generated code

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

[jira] [Created] (FLINK-3885) Revisit parallelism logic

2016-05-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3885: Summary: Revisit parallelism logic Key: FLINK-3885 URL: https://issues.apache.org/jira/browse/FLINK-3885 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-3842) Fix handling null record/row in generated code

2016-05-09 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276181#comment-15276181 ] Timo Walther commented on FLINK-3842: - Thanks for testing. I will rebase it and open a

[jira] [Created] (FLINK-3884) Snapshot quickstart projects don't include snapshot repository

2016-05-09 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3884: -- Summary: Snapshot quickstart projects don't include snapshot repository Key: FLINK-3884 URL: https://issues.apache.org/jira/browse/FLINK-3884 Project: Flink Iss

[jira] [Commented] (FLINK-3883) Rename flink clients for inclusion on system path

2016-05-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276130#comment-15276130 ] Aljoscha Krettek commented on FLINK-3883: - +1 The symlink thing should be fixed qu

[jira] [Commented] (FLINK-3881) Error in Java 8 Documentation Sample

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

[GitHub] flink pull request: [FLINK-3881] [docs] Java 8 Documetation Sample...

2016-05-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1970 --- 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] [Resolved] (FLINK-3881) Error in Java 8 Documentation Sample

2016-05-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3881. -- Resolution: Fixed Fixed via afd0f16b89683212104e7f41dbd3b557b1f02cc5 > Error in Java 8 Document

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

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

[GitHub] flink pull request: [FLINK-3869] Relax window fold generic paramet...

2016-05-09 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1973 [FLINK-3869] Relax window fold generic parameters Before, the WindowFunction in a fold/apply could not emit a type that was different from the accumulator type of the fold. This restriction is

[jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found.

2016-05-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276119#comment-15276119 ] Ufuk Celebi commented on FLINK-3741: I've asked INFRA to clear the caches (https://is

[jira] [Commented] (FLINK-3881) Error in Java 8 Documentation Sample

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

[GitHub] flink pull request: [FLINK-3881] [docs] Java 8 Documetation Sample...

2016-05-09 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1970#issuecomment-217807008 Thanks for your contribution @mans2singh. Changes look good. Will merge this PR. --- If your project is set up for it, you can reply to this email and have your re

[jira] [Commented] (FLINK-3879) Native implementation of HITS algorithm

2016-05-09 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276102#comment-15276102 ] Vasia Kalavri commented on FLINK-3879: -- Hey [~greghogan], [~gallenvara_bg], what's th

[GitHub] flink pull request: Jackson version upgrade: default from 2.4.2 to...

2016-05-09 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1952#issuecomment-217804461 I'm running a last local test and then merging this. Thanks for the work! 😃 --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

2016-05-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276091#comment-15276091 ] Till Rohrmann commented on FLINK-1873: -- I wouldn't like to bake in the dependency on

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

2016-05-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15276074#comment-15276074 ] ASF GitHub Bot commented on FLINK-3772: --- Github user vasia commented on the pull req

[GitHub] flink pull request: [FLINK-3772] [gelly] Graph algorithms for vert...

2016-05-09 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/1901#issuecomment-217799706 I've only left a minor comment @greghogan, otherwise I think it's good to merge. --- If your project is set up for it, you can reply to this email and have your reply app

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

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

[GitHub] flink pull request: [FLINK-3772] [gelly] Graph algorithms for vert...

2016-05-09 Thread vasia
Github user vasia commented on a diff in the pull request: https://github.com/apache/flink/pull/1901#discussion_r62460922 --- Diff: docs/apis/batch/libs/gelly.md --- @@ -2067,7 +2067,92 @@ configuration. - TranslateGraphIds + degree.annotat