[jira] [Commented] (FLINK-6383) Add versioning for AbstractStreamOperator state

2017-04-25 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983153#comment-15983153 ] Aljoscha Krettek commented on FLINK-6383: - I had a quick offline chat with [~plucas] about this

[jira] [Commented] (FLINK-6120) Implement heartbeat logic between JobManager and ResourceManager

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983148#comment-15983148 ] ASF GitHub Bot commented on FLINK-6120: --- Github user zhijiangW commented on the issue:

[jira] [Created] (FLINK-6383) Add versioning for AbstractStreamOperator state

2017-04-25 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6383: --- Summary: Add versioning for AbstractStreamOperator state Key: FLINK-6383 URL: https://issues.apache.org/jira/browse/FLINK-6383 Project: Flink Issue

[GitHub] flink issue #3645: [FLINK-6120][Distributed Coordinator]Implement heartbeat ...

2017-04-25 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/3645 Thank you for reviews! @tillrohrmann --- 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-6382) Support all numeric types for generated graphs in Gelly examples

2017-04-25 Thread Pattarawat Chormai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983144#comment-15983144 ] Pattarawat Chormai commented on FLINK-6382: --- Hi [~greghogan], Since I've been already involving

[jira] [Comment Edited] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983141#comment-15983141 ] Kostas Kloudas edited comment on FLINK-6381 at 4/25/17 4:18 PM: Hi

[jira] [Commented] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983141#comment-15983141 ] Kostas Kloudas commented on FLINK-6381: --- Hi [[~mingleizhang]! I updated the {{Type}} to improvement,

[jira] [Updated] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6381: -- Issue Type: Improvement (was: Bug) > Unnecessary synchronizing object in BucketingSink >

[jira] [Commented] (FLINK-6367) support custom header settings of allow origin

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

[jira] [Commented] (FLINK-6367) support custom header settings of allow origin

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

[GitHub] flink pull request #3769: [FLINK-6367] support custom header settings of all...

2017-04-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3769#discussion_r113241783 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -1333,6 +1333,11 @@

[GitHub] flink pull request #3769: [FLINK-6367] support custom header settings of all...

2017-04-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3769#discussion_r113241117 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorConfig.java --- @@ -78,4 +78,10 @@ public boolean

[jira] [Commented] (FLINK-6367) support custom header settings of allow origin

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

[jira] [Commented] (FLINK-6367) support custom header settings of allow origin

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

[GitHub] flink pull request #3769: [FLINK-6367] support custom header settings of all...

2017-04-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3769#discussion_r113241708 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -1333,6 +1333,11 @@

[GitHub] flink pull request #3769: [FLINK-6367] support custom header settings of all...

2017-04-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3769#discussion_r113241231 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -1333,6 +1333,11 @@

[jira] [Commented] (FLINK-6367) support custom header settings of allow origin

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

[GitHub] flink pull request #3769: [FLINK-6367] support custom header settings of all...

2017-04-25 Thread shijinkui
Github user shijinkui commented on a diff in the pull request: https://github.com/apache/flink/pull/3769#discussion_r113226235 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -701,6 +701,9 @@ @Deprecated public static

[jira] [Created] (FLINK-6382) Support all numeric types for generated graphs in Gelly examples

2017-04-25 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6382: - Summary: Support all numeric types for generated graphs in Gelly examples Key: FLINK-6382 URL: https://issues.apache.org/jira/browse/FLINK-6382 Project: Flink

[jira] [Assigned] (FLINK-5975) Mesos should support adding volumes to launched taskManagers

2017-04-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-5975: Assignee: Addison Higham > Mesos should support adding volumes to launched taskManagers >

[jira] [Commented] (FLINK-6120) Implement heartbeat logic between JobManager and ResourceManager

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983007#comment-15983007 ] ASF GitHub Bot commented on FLINK-6120: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #3645: [FLINK-6120][Distributed Coordinator]Implement heartbeat ...

2017-04-25 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3645 Changes look good to me. Thanks for the contribution @zhijiangW. I will rebase this PR and upon receiving green light from Travis I will merge it. --- If your project is set up for it, you can

[jira] [Comment Edited] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes

2017-04-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983003#comment-15983003 ] Kostas Kloudas edited comment on FLINK-6318 at 4/25/17 2:54 PM: This seems

[jira] [Assigned] (FLINK-6321) RocksDB state backend Checkpointing is not working with KeydCEP.

2017-04-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6321: - Assignee: Kostas Kloudas > RocksDB state backend Checkpointing is not working with

[jira] [Commented] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes

2017-04-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983003#comment-15983003 ] Kostas Kloudas commented on FLINK-6318: --- This seems to be the same as

[jira] [Assigned] (FLINK-6318) NFA serialisation doesn't work with TypeSerializers that load classes

2017-04-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6318: - Assignee: Kostas Kloudas > NFA serialisation doesn't work with TypeSerializers that load

[GitHub] flink pull request #3714: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-04-25 Thread rtudoran
Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3714#discussion_r113214399 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,353 @@ +/* + *

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[jira] [Commented] (FLINK-6368) Grouping keys in stream aggregations have wrong order

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

[GitHub] flink pull request #3768: [FLINK-6368][table] Grouping keys in stream aggreg...

2017-04-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3768 --- 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-6368) Grouping keys in stream aggregations have wrong order

2017-04-25 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6368. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 1.3.0:

[GitHub] flink issue #3752: [FLINK-6306] [filesystem-connectors] Sink for eventually ...

2017-04-25 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3752 This is a very nice addition, thank's a lot for contributing it! Flink 1.3 is approaching feature freeze and there are a few critical issues that @tzulitai and me are working on. Once we

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982951#comment-15982951 ] ASF GitHub Bot commented on FLINK-6306: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-6368) Grouping keys in stream aggregations have wrong order

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982943#comment-15982943 ] ASF GitHub Bot commented on FLINK-6368: --- Github user twalthr commented on the issue:

[GitHub] flink issue #3768: [FLINK-6368][table] Grouping keys in stream aggregations ...

2017-04-25 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3768 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 enabled and wishes so, or if the

[jira] [Commented] (FLINK-6337) Remove the buffer provider from PartitionRequestServerHandler

2017-04-25 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982936#comment-15982936 ] Ufuk Celebi commented on FLINK-6337: Just double checked this and I think you are right. We currently

[jira] [Commented] (FLINK-6136) Separate EmbeddedNonHaServices and NonHaServices

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982921#comment-15982921 ] ASF GitHub Bot commented on FLINK-6136: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #3622: [FLINK-6136] Separate EmbeddedHaServices and StandaloneHa...

2017-04-25 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3622 Rebased onto the latest `master`. --- 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] [Updated] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6381: Description: It seems that currently there are two places should not employ the {{synchronized}}

[jira] [Updated] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6381: Description: It seems that currently there are two places should not employ the {{synchronized}}

[jira] [Commented] (FLINK-3347) TaskManager (or its ActorSystem) need to restart in case they notice quarantine

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982915#comment-15982915 ] ASF GitHub Bot commented on FLINK-3347: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2696: [FLINK-3347] [akka] Add QuarantineMonitor which shuts a q...

2017-04-25 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2696 I propose to merge this PR into the master such that it is disabled per default. This entails that we don't require our own heartbeats from the TMs to the `JobManager`. This will make

[jira] [Commented] (FLINK-6302) Documentation build error on ruby 2.4

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

[GitHub] flink pull request #3720: [FLINK-6302] Documentation build error on ruby 2.4

2017-04-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3720#discussion_r113201398 --- Diff: docs/Gemfile.lock --- @@ -30,18 +30,19 @@ GEM redcarpet (~> 3.1) safe_yaml (~> 1.0) toml (~> 0.1.0) -

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982904#comment-15982904 ] ASF GitHub Bot commented on FLINK-6306: --- Github user sjwiesman commented on the issue:

[GitHub] flink issue #3752: [FLINK-6306] [filesystem-connectors] Sink for eventually ...

2017-04-25 Thread sjwiesman
Github user sjwiesman commented on the issue: https://github.com/apache/flink/pull/3752 @tzulitai you took interest in the jira ticket, would you be willing to review this? --- 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-6302) Documentation build error on ruby 2.4

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

[GitHub] flink pull request #3720: [FLINK-6302] Documentation build error on ruby 2.4

2017-04-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3720#discussion_r113198925 --- Diff: docs/Gemfile.lock --- @@ -30,18 +30,19 @@ GEM redcarpet (~> 3.1) safe_yaml (~> 1.0) toml (~> 0.1.0) -

[jira] [Closed] (FLINK-6361) Finalize the AggregateFunction interface and refactoring built-in aggregates

2017-04-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6361. Resolution: Implemented Fix Version/s: 1.3.0 Implemented with

[GitHub] flink pull request #3762: [FLINK-6361] [table] Refactoring the AggregateFunc...

2017-04-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3762 --- 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-6361) Finalize the AggregateFunction interface and refactoring built-in aggregates

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

[jira] [Commented] (FLINK-6155) Allow to specify endpoint names

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982887#comment-15982887 ] ASF GitHub Bot commented on FLINK-6155: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #3596: [FLINK-6155] Introduce an endpoint id for RpcEndpoints

2017-04-25 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3596 I think I have to correct myself. In the general case, there might be the need to connect from the dispatcher component to `ResourceManager`. If the `ResourceManager` runs in a different

[GitHub] flink pull request #3720: [FLINK-6302] Documentation build error on ruby 2.4

2017-04-25 Thread mtunique
Github user mtunique commented on a diff in the pull request: https://github.com/apache/flink/pull/3720#discussion_r113186869 --- Diff: docs/Gemfile.lock --- @@ -30,18 +30,19 @@ GEM redcarpet (~> 3.1) safe_yaml (~> 1.0) toml (~> 0.1.0) -

[jira] [Commented] (FLINK-6302) Documentation build error on ruby 2.4

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

[GitHub] flink pull request #3720: [FLINK-6302] Documentation build error on ruby 2.4

2017-04-25 Thread mtunique
Github user mtunique commented on a diff in the pull request: https://github.com/apache/flink/pull/3720#discussion_r113186880 --- Diff: docs/Gemfile.lock --- @@ -30,18 +30,19 @@ GEM redcarpet (~> 3.1) safe_yaml (~> 1.0) toml (~> 0.1.0) -

[jira] [Commented] (FLINK-6302) Documentation build error on ruby 2.4

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

[jira] [Commented] (FLINK-6155) Allow to specify endpoint names

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982835#comment-15982835 ] ASF GitHub Bot commented on FLINK-6155: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #3596: [FLINK-6155] Introduce an endpoint id for RpcEndpoints

2017-04-25 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3596 Thanks for the review @StephanEwen. You're right that it should not be necessary to assign a name to the `TaskExecutor` and the `ResourceManager`. Will change it so that these components assign

[jira] [Commented] (FLINK-6367) support custom header settings of allow origin

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

[GitHub] flink pull request #3769: [FLINK-6367] support custom header settings of all...

2017-04-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3769#discussion_r113178604 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -701,6 +701,9 @@ @Deprecated public static

[jira] [Assigned] (FLINK-6367) support custom header settings of allow origin

2017-04-25 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui reassigned FLINK-6367: Assignee: shijinkui > support custom header settings of allow origin >

[jira] [Commented] (FLINK-6367) support custom header settings of allow origin

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982783#comment-15982783 ] ASF GitHub Bot commented on FLINK-6367: --- GitHub user shijinkui opened a pull request:

[GitHub] flink pull request #3769: [FLINK-6367] support custom header settings of all...

2017-04-25 Thread shijinkui
GitHub user shijinkui opened a pull request: https://github.com/apache/flink/pull/3769 [FLINK-6367] support custom header settings of allow origin `jobmanager.web.access-control-allow-origin`: Enable custom access control parameter for allow origin header, default is `*`.

[jira] [Commented] (FLINK-6107) Add custom checkstyle for flink-streaming-java

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982781#comment-15982781 ] ASF GitHub Bot commented on FLINK-6107: --- Github user zentol commented on the issue:

[GitHub] flink issue #3567: [FLINK-6107] Add custom checkstyle for flink-streaming-ja...

2017-04-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3567 @aljoscha i believe enough earth rotations have passed :) --- 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

[jira] [Assigned] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-6381: --- Assignee: mingleizhang > Unnecessary synchronizing object in BucketingSink >

[jira] [Issue Comment Deleted] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6381: Comment: was deleted (was: It seems that currently there are two places should not employ the

[jira] [Updated] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6381: Description: It seems that currently there are two places should not employ the {{synchronized}}

[jira] [Commented] (FLINK-6302) Documentation build error on ruby 2.4

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982766#comment-15982766 ] ASF GitHub Bot commented on FLINK-6302: --- Github user zentol commented on the issue:

[jira] [Comment Edited] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982763#comment-15982763 ] mingleizhang edited comment on FLINK-6381 at 4/25/17 11:59 AM: --- It seems

[GitHub] flink issue #3720: [FLINK-6302] Documentation build error on ruby 2.4

2017-04-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3720 I can confirm that you can build the docs on W10 with the Linux Subsystem. --- 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] [Comment Edited] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982763#comment-15982763 ] mingleizhang edited comment on FLINK-6381 at 4/25/17 11:58 AM: --- It seems

[jira] [Commented] (FLINK-6367) support custom header settings of allow origin

2017-04-25 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982764#comment-15982764 ] shijinkui commented on FLINK-6367: -- [~greghogan] We need configure some special allow_origin. For

[jira] [Commented] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982763#comment-15982763 ] mingleizhang commented on FLINK-6381: - It seems that currently there are two places should not employ

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

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

[GitHub] flink pull request #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics rep...

2017-04-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3736#discussion_r113167440 --- Diff: flink-dist/src/main/assemblies/opt.xml --- @@ -95,5 +95,12 @@ flink-metrics-statsd-${project.version}.jar

[jira] [Created] (FLINK-6381) Unnecessary synchronizing object in BucketingSink

2017-04-25 Thread mingleizhang (JIRA)
mingleizhang created FLINK-6381: --- Summary: Unnecessary synchronizing object in BucketingSink Key: FLINK-6381 URL: https://issues.apache.org/jira/browse/FLINK-6381 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6361) Finalize the AggregateFunction interface and refactoring built-in aggregates

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982655#comment-15982655 ] ASF GitHub Bot commented on FLINK-6361: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3762: [FLINK-6361] [table] Refactoring the AggregateFunction in...

2017-04-25 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3762 Thanks, will merge then --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[jira] [Commented] (FLINK-6361) Finalize the AggregateFunction interface and refactoring built-in aggregates

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982650#comment-15982650 ] ASF GitHub Bot commented on FLINK-6361: --- Github user shaoxuan-wang commented on the issue:

[GitHub] flink issue #3762: [FLINK-6361] [table] Refactoring the AggregateFunction in...

2017-04-25 Thread shaoxuan-wang
Github user shaoxuan-wang commented on the issue: https://github.com/apache/flink/pull/3762 Hi @fhueske , it is good to have a dedicated Iterable for pair-merge. Please go ahead. Thanks. --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Updated] (FLINK-6373) Add runtime support for distinct aggregation over grouped windows

2017-04-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6373: -- Component/s: Table API & SQL > Add runtime support for distinct aggregation over grouped

[jira] [Updated] (FLINK-6377) Support map types in the Table / SQL API

2017-04-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6377: -- Component/s: Table API & SQL > Support map types in the Table / SQL API >

[jira] [Updated] (FLINK-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token.

2017-04-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6376: -- Component/s: YARN Security > when deploy flink cluster on the yarn, it is lack

[jira] [Updated] (FLINK-6374) In yarn cluster model, the -ys parameter is not take effect.

2017-04-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6374: -- Component/s: YARN > In yarn cluster model, the -ys parameter is not take effect. >

[jira] [Commented] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982630#comment-15982630 ] ASF GitHub Bot commented on FLINK-6288: --- Github user gyfora commented on the issue:

[GitHub] flink issue #3766: [FLINK-6288] fix FlinkKafkaProducer's custom Partitioner ...

2017-04-25 Thread gyfora
Github user gyfora commented on the issue: https://github.com/apache/flink/pull/3766 Hi, Thanks for the PR! The first problem I noticed with this approach is that it will not work if users want to partition dynamically created topics (my use case actually). We

[jira] [Comment Edited] (FLINK-6337) Remove the buffer provider from PartitionRequestServerHandler

2017-04-25 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982574#comment-15982574 ] zhijiang edited comment on FLINK-6337 at 4/25/17 9:20 AM: -- Hey [~uce], Thank you

[jira] [Commented] (FLINK-5752) Support push down projections for HBaseTableSource

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982607#comment-15982607 ] ASF GitHub Bot commented on FLINK-5752: --- Github user ramkrish86 commented on the issue:

[GitHub] flink issue #3760: FLINK-5752 Support push down projections for HBaseTableSo...

2017-04-25 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/3760 @tonycox Thanks for the comment? Just curious. Any reason for the repush - is it for checking the test failures again? --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

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

[GitHub] flink pull request #3714: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-04-25 Thread rtudoran
Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3714#discussion_r113143239 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala --- @@ -0,0 +1,169 @@ +/* +

[jira] [Assigned] (FLINK-6208) Implement skip till next match strategy

2017-04-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6208: - Assignee: Dawid Wysakowicz > Implement skip till next match strategy >

[jira] [Commented] (FLINK-5752) Support push down projections for HBaseTableSource

2017-04-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982597#comment-15982597 ] ASF GitHub Bot commented on FLINK-5752: --- Github user tonycox commented on the issue:

[jira] [Created] (FLINK-6380) BlobService concurrency issues between delete and put/get methods

2017-04-25 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-6380: -- Summary: BlobService concurrency issues between delete and put/get methods Key: FLINK-6380 URL: https://issues.apache.org/jira/browse/FLINK-6380 Project: Flink

[GitHub] flink issue #3760: FLINK-5752 Support push down projections for HBaseTableSo...

2017-04-25 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/3760 @ramkrish86 Hi, Thank you for the PR. Could you repush commit? ``` git commit --amend gut push origin FLINK-5752 -f ``` --- If your project is set up for it, you can reply to this

[jira] [Updated] (FLINK-5030) Support hostname verification

2017-04-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5030: -- Fix Version/s: (was: 1.2.1) 1.2.2 > Support hostname verification >

[jira] [Updated] (FLINK-5808) Missing verification for setParallelism and setMaxParallelism

2017-04-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5808: -- Fix Version/s: (was: 1.2.1) 1.2.2 > Missing verification for

[jira] [Updated] (FLINK-5908) Blob Cache can (rarely) get corrupted on failed blob downloads

2017-04-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5908: -- Fix Version/s: (was: 1.2.1) 1.2.2 > Blob Cache can (rarely) get

<    1   2   3   >