[jira] [Commented] (FLINK-4827) The scala example of SQL on Streaming Tables with wrong variable name in flink document

2016-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574330#comment-15574330 ] ASF GitHub Bot commented on FLINK-4827: --- GitHub user hzyuemeng1 opened a pull request:

[GitHub] flink pull request #2632: [FLINK-4827][Docs] The scala example of SQL on Str...

2016-10-13 Thread hzyuemeng1
GitHub user hzyuemeng1 opened a pull request: https://github.com/apache/flink/pull/2632 [FLINK-4827][Docs] The scala example of SQL on Streaming Tables with wrong variable name… val env = StreamExecutionEnvironment.getExecutionEnvironment val tEnv =

[jira] [Updated] (FLINK-4827) The scala example of SQL on Streaming Tables with wrong variable name in flink document

2016-10-13 Thread yuemeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-4827: --- Attachment: 0001-The-scala-example-of-SQL-on-Streaming-Tables-with-wr.patch > The scala example of SQL on

[jira] [Comment Edited] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value

2016-10-13 Thread Sajeev Ramakrishnan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15571746#comment-15571746 ] Sajeev Ramakrishnan edited comment on FLINK-4823 at 10/14/16 5:16 AM: --

[GitHub] flink pull request #2631: The scala example of SQL on Streaming Tables with ...

2016-10-13 Thread hzyuemeng1
GitHub user hzyuemeng1 opened a pull request: https://github.com/apache/flink/pull/2631 The scala example of SQL on Streaming Tables with wrong variable name in flink document val env = StreamExecutionEnvironment.getExecutionEnvironment val tEnv =

[jira] [Updated] (FLINK-4827) The scala example of SQL on Streaming Tables with wrong variable name in flink document

2016-10-13 Thread yuemeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-4827: --- Summary: The scala example of SQL on Streaming Tables with wrong variable name in flink document (was: The

[jira] [Updated] (FLINK-4827) The code example use scala of SQL on Streaming Tables with wrong variable name in flink document

2016-10-13 Thread yuemeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-4827: --- Description: val env = StreamExecutionEnvironment.getExecutionEnvironment val tEnv =

[jira] [Updated] (FLINK-4827) The code example use scala of SQL on Streaming Tables with wrong variable name in flink document

2016-10-13 Thread yuemeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-4827: --- Description: val env = StreamExecutionEnvironment.getExecutionEnvironment val tEnv =

[jira] [Updated] (FLINK-4827) The code example use scala of SQL on Streaming Tables with wrong variable name in flink document

2016-10-13 Thread yuemeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-4827: --- Summary: The code example use scala of SQL on Streaming Tables with wrong variable name in flink document

[jira] [Updated] (FLINK-4827) The example use scala of SQL on Streaming Tables with wrong variable name

2016-10-13 Thread yuemeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-4827: --- Summary: The example use scala of SQL on Streaming Tables with wrong variable name (was: Sql on streaming

[jira] [Updated] (FLINK-4827) Sql on streaming example use scala with wrong variable name

2016-10-13 Thread yuemeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuemeng updated FLINK-4827: --- Description: val env = StreamExecutionEnvironment.getExecutionEnvironment val tEnv =

[jira] [Created] (FLINK-4827) Sql on streaming example use scala with wrong variable name

2016-10-13 Thread yuemeng (JIRA)
yuemeng created FLINK-4827: -- Summary: Sql on streaming example use scala with wrong variable name Key: FLINK-4827 URL: https://issues.apache.org/jira/browse/FLINK-4827 Project: Flink Issue Type:

[GitHub] flink pull request #2588: [FLINK-4735] [cluster management] Migrate some job...

2016-10-13 Thread KurtYoung
Github user KurtYoung closed the pull request at: https://github.com/apache/flink/pull/2588 --- 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-4339) Implement Slot Pool Core

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

[jira] [Commented] (FLINK-4735) Migrate some job execution related akka messages to rpc calls

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

[jira] [Resolved] (FLINK-4339) Implement Slot Pool Core

2016-10-13 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-4339. --- Resolution: Fixed Fix Version/s: (was: 1.2.0) > Implement Slot Pool Core >

[GitHub] flink pull request #2497: [FLINK-4339][cluster management] Implement Slot Po...

2016-10-13 Thread KurtYoung
Github user KurtYoung closed the pull request at: https://github.com/apache/flink/pull/2497 --- 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] [Resolved] (FLINK-4735) Migrate some job execution related akka messages to rpc calls

2016-10-13 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-4735. --- Resolution: Fixed > Migrate some job execution related akka messages to rpc calls >

[jira] [Commented] (FLINK-3932) Implement State Backend Security

2016-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573487#comment-15573487 ] ASF GitHub Bot commented on FLINK-3932: --- Github user vijikarthi commented on the issue:

[GitHub] flink issue #2589: FLINK-3932 State Backend Security

2016-10-13 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2589 Are we waiting for any additional review? --- 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] [Updated] (FLINK-4826) Add keytab based kerberos support for Mesos environment

2016-10-13 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan updated FLINK-4826: --- Summary: Add keytab based kerberos support for Mesos environment (was: Add

[jira] [Updated] (FLINK-4826) Add keytab based kerberos support to run Flink in Mesos environment

2016-10-13 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan updated FLINK-4826: --- Summary: Add keytab based kerberos support to run Flink in Mesos environment

[jira] [Updated] (FLINK-4826) Add keytab based kerberos support in Mesos environment

2016-10-13 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan updated FLINK-4826: --- Summary: Add keytab based kerberos support in Mesos environment (was: Add

[jira] [Created] (FLINK-4826) Add keytab based kerberos support to run Flink in Mesos environment

2016-10-13 Thread Vijay Srinivasaraghavan (JIRA)
Vijay Srinivasaraghavan created FLINK-4826: -- Summary: Add keytab based kerberos support to run Flink in Mesos environment Key: FLINK-4826 URL: https://issues.apache.org/jira/browse/FLINK-4826

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319026 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319240 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318311 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

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

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

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319036 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319084 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

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

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

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83310436 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318300 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83316946 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83309671 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318661 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318228 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83310338 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83308572 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83310395 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83308865 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-13 Thread qingdao81
Github user qingdao81 commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83307880 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[jira] [Closed] (FLINK-4561) replace all the scala version as a `scala.binary.version` property

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4561. - Resolution: Won't Fix > replace all the scala version as a `scala.binary.version` property >

[jira] [Commented] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573068#comment-15573068 ] Greg Hogan commented on FLINK-4370: --- [~StephanEwen] have you discovered a third way? Our options so far

[jira] [Closed] (FLINK-3302) Save Taskmanager Metrics per Job

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3302. - Resolution: Not A Problem > Save Taskmanager Metrics per Job > > >

[jira] [Resolved] (FLINK-4188) Support for outer joins on DataStream

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-4188. --- Resolution: Duplicate > Support for outer joins on DataStream > -

[jira] [Commented] (FLINK-3302) Save Taskmanager Metrics per Job

2016-10-13 Thread Pieter Hameete (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573012#comment-15573012 ] Pieter Hameete commented on FLINK-3302: --- Hi Greg, I haven't used Flink for a while but the new

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83290431 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83289172 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83288193 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83290286 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[jira] [Commented] (FLINK-3302) Save Taskmanager Metrics per Job

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572952#comment-15572952 ] Greg Hogan commented on FLINK-3302: --- I recently closed the aforementioned FLINK-3263 since these

[jira] [Closed] (FLINK-2223) Web frontend shows wrong accumulator results for latest job

2016-10-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2223. --- Resolution: Invalid > Web frontend shows wrong accumulator results for latest job >

[jira] [Closed] (FLINK-2247) Improve the way memory is reported in the web frontend

2016-10-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2247. --- Resolution: Invalid We no longer show such warnings in the WebFrontend. We are also showing

[jira] [Closed] (FLINK-2222) Memory/CPU graphs in web frontend are not well formatted using Chrome/Safari

2016-10-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-. --- Resolution: Invalid No longer valid as we no longer show graphs in the WebFrontend. >

[jira] [Commented] (FLINK-2247) Improve the way memory is reported in the web frontend

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572863#comment-15572863 ] Greg Hogan commented on FLINK-2247: --- It doesn't look like these warnings are present in the new web

[jira] [Commented] (FLINK-2222) Memory/CPU graphs in web frontend are not well formatted using Chrome/Safari

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572830#comment-15572830 ] Greg Hogan commented on FLINK-: --- Is this fixed since we no longer have memory/CPU graphs? And

[jira] [Commented] (FLINK-4373) Introduce SlotID, AllocationID, ResourceProfile

2016-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572813#comment-15572813 ] ASF GitHub Bot commented on FLINK-4373: --- GitHub user StephanEwen opened a pull request:

[GitHub] flink pull request #2630: [FLINK-4373] [cluster management] Introduce Alloca...

2016-10-13 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2630 [FLINK-4373] [cluster management] Introduce AllocationID, ResourceProfile, and AllocatedSlot These classes are introduced as part of the cluster management rework (FLIP-6) The

[jira] [Commented] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

2016-10-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572810#comment-15572810 ] Fabian Hueske commented on FLINK-1890: -- I'd keep the issue open. I'll add the starter tag to it.

[jira] [Updated] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

2016-10-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1890: - Labels: starter (was: ) > Add note to docs that ReadFields annotations are currently not

[jira] [Commented] (FLINK-2223) Web frontend shows wrong accumulator results for latest job

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572799#comment-15572799 ] Greg Hogan commented on FLINK-2223: --- Is this still an issue? > Web frontend shows wrong accumulator

[jira] [Resolved] (FLINK-2024) Table API mentioned only in Batch in documentation site

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-2024. --- Resolution: Fixed This is fixed in the 1.1 and 1.2-SNAPSHOT documentation currently linked to from

[jira] [Commented] (FLINK-1472) Web frontend config overview shows wrong value

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572753#comment-15572753 ] Greg Hogan commented on FLINK-1472: --- Building a registry of configuration options will be

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-10-13 Thread Philipp von dem Bussche (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572723#comment-15572723 ] Philipp von dem Bussche commented on FLINK-2821: [~StephanEwen] yes more than happy to try

[jira] [Resolved] (FLINK-1936) Normalize keys and default values in ConfigConstants.java

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-1936. --- Resolution: Fixed > Normalize keys and default values in ConfigConstants.java >

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-10-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572671#comment-15572671 ] Stephan Ewen commented on FLINK-2821: - That's pretty amazing. [~philipp.bussche] do you have the time

[jira] [Resolved] (FLINK-787) Custom termination criterion in delta iteration

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-787. -- Resolution: Duplicate > Custom termination criterion in delta iteration >

[jira] [Commented] (FLINK-720) Forbid catching exceptions only with "e.printStackTrace()" using Checkstyle

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572652#comment-15572652 ] Greg Hogan commented on FLINK-720: -- Are we still looking to add this check? > Forbid catching exceptions

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-10-13 Thread Philipp von dem Bussche (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572639#comment-15572639 ] Philipp von dem Bussche commented on FLINK-2821: [~mxm] thats awesome ! That might work

[jira] [Commented] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572633#comment-15572633 ] Greg Hogan commented on FLINK-1890: --- Do we still want this documented or can we close this issue? > Add

[jira] [Resolved] (FLINK-4117) Wait for CuratorFramework connection to be established

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-4117. --- Resolution: Cannot Reproduce > Wait for CuratorFramework connection to be established >

[jira] [Updated] (FLINK-4117) Wait for CuratorFramework connection to be established

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4117: -- Description: Received the following error when locally running {{mvn verify}}. Searching on the error

[jira] [Updated] (FLINK-4117) Wait for CuratorFramework connection to be established

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4117: -- Description: Received the following error when locally running {{mvn verify}}. Searching on the error

[jira] [Commented] (FLINK-4129) HITSAlgorithm should test for element-wise convergence

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572513#comment-15572513 ] Greg Hogan commented on FLINK-4129: --- [~vkalavri] what do you think we should do with this issue? This is

[jira] [Resolved] (FLINK-2603) Flink hangs before starting execution

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-2603. --- Resolution: Not A Problem I believe this is due to a configured limit in the size of Akka messages as

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-10-13 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572364#comment-15572364 ] Maximilian Michels commented on FLINK-2821: --- Just out of fun, I actually tried that and got the

[GitHub] flink issue #2562: [FLINK-4691] [table] Add group-windows for streaming tabl...

2016-10-13 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2562 @fhueske I updated the PR. The only thing that is missing now are tests for the `DataStreamAggregate` class. I will add unit tests tomorrow. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-4691) Add group-windows for streaming tables

2016-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572347#comment-15572347 ] ASF GitHub Bot commented on FLINK-4691: --- Github user twalthr commented on the issue:

[jira] [Assigned] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-4824: - Assignee: Greg Hogan > CliFrontend shows misleading error message when main() method returns

[GitHub] flink issue #2497: [FLINK-4339][cluster management] Implement Slot Pool core...

2016-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2497 Merged into the `flip-6` feature branch in 48c936eeda7b265f32bbf9f14d15f78eae15c06f --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-4339) Implement Slot Pool Core

2016-10-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572293#comment-15572293 ] ASF GitHub Bot commented on FLINK-4339: --- Github user StephanEwen commented on the issue:

  1   2   >