[jira] [Commented] (FLINK-4604) Add support for standard deviation/variance

2016-10-25 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607653#comment-15607653 ] Anton Mushin commented on FLINK-4604: - Hello [~fhueske], thanks for your answer! I add

[jira] [Updated] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

2016-10-25 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng updated FLINK-4923: -- Description: We should expose the following Metrics on the TaskIOMetricGroup: 1. Buffers.numIn: receive

[jira] [Updated] (FLINK-4923) Expose input/output buffers and bufferPoll usage as a metric for a Task

2016-10-25 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng updated FLINK-4923: -- Summary: Expose input/output buffers and bufferPoll usage as a metric for a Task (was: Expose input/out

[jira] [Updated] (FLINK-4923) Expose input/output buffers and bufferPool usage as a metric for a Task

2016-10-25 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng updated FLINK-4923: -- Summary: Expose input/output buffers and bufferPool usage as a metric for a Task (was: Expose input/out

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-10-25 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607635#comment-15607635 ] Renkai Ge commented on FLINK-4883: -- I found a way to distinguish normal scala instances a

[jira] [Commented] (FLINK-4911) Non-disruptive JobManager Failures via Reconciliation

2016-10-25 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607630#comment-15607630 ] Zhijiang Wang commented on FLINK-4911: -- Hi Stephan, the sub-tasks 2 and 3 are the sam

[jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

2016-10-25 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607498#comment-15607498 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4905 at 10/26/16 5:39 AM: --

[jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

2016-10-25 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607498#comment-15607498 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4905 at 10/26/16 5:37 AM: --

[jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

2016-10-25 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607498#comment-15607498 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4905 at 10/26/16 5:37 AM: --

[jira] [Commented] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

2016-10-25 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607498#comment-15607498 ] Tzu-Li (Gordon) Tai commented on FLINK-4905: Had a quick look at this. The onl

[jira] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

2016-10-25 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607498#comment-15607498 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4905 at 10/26/16 5:35 AM: --

[jira] [Commented] (FLINK-4911) Non-disruptive JobManager Failures via Reconciliation

2016-10-25 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15607336#comment-15607336 ] Zhijiang Wang commented on FLINK-4911: -- FLINK-3539 tries to realize eventual consiste

[jira] [Assigned] (FLINK-4915) Define parameters for reconciliation

2016-10-25 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-4915: Assignee: Zhijiang Wang > Define parameters for reconciliation > --

[jira] [Assigned] (FLINK-4912) Introduce RECONCILING state in ExecutionGraph

2016-10-25 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-4912: Assignee: Zhijiang Wang > Introduce RECONCILING state in ExecutionGraph > -

[jira] [Assigned] (FLINK-4914) Define parameters for reconciliation

2016-10-25 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-4914: Assignee: Zhijiang Wang > Define parameters for reconciliation > --

[jira] [Assigned] (FLINK-4923) Expose input/output queued buffers and buffer usage as a metric for a Task

2016-10-25 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng reassigned FLINK-4923: - Assignee: zhuhaifeng > Expose input/output queued buffers and buffer usage as a metric for a Task

[jira] [Updated] (FLINK-4923) Expose input/output queued buffers and buffer usage as a metric for a Task

2016-10-25 Thread zhuhaifeng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuhaifeng updated FLINK-4923: -- Component/s: Metrics > Expose input/output queued buffers and buffer usage as a metric for a Task >

[jira] [Created] (FLINK-4923) Expose input/output queued buffers and buffer usage as a metric for a Task

2016-10-25 Thread zhuhaifeng (JIRA)
zhuhaifeng created FLINK-4923: - Summary: Expose input/output queued buffers and buffer usage as a metric for a Task Key: FLINK-4923 URL: https://issues.apache.org/jira/browse/FLINK-4923 Project: Flink

[jira] [Created] (FLINK-4922) Write documentation

2016-10-25 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4922: --- Summary: Write documentation Key: FLINK-4922 URL: https://issues.apache.org/jira/browse/FLINK-4922 Project: Flink Issue Type: Sub-task Reporter: Er

[jira] [Created] (FLINK-4921) Upgrade to Mesos 1.0.1

2016-10-25 Thread Eron Wright (JIRA)
Eron Wright created FLINK-4921: --- Summary: Upgrade to Mesos 1.0.1 Key: FLINK-4921 URL: https://issues.apache.org/jira/browse/FLINK-4921 Project: Flink Issue Type: Sub-task Reporter:

[GitHub] flink pull request #2691: [FLINK-4910] Introduce safety net for closing file...

2016-10-25 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2691 [FLINK-4910] Introduce safety net for closing file system streams This PR introduces a safety net against leaking/unclosed streams obtained through ``FileSystem``. The main addition

[GitHub] flink issue #2644: [FLINK-4837] flink-streaming-akka source connector

2016-10-25 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2644 Thank you! --- 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-4837) flink-streaming-akka source connector

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

[GitHub] flink issue #2653: [FLINK-4469] [table] Add support for user defined table f...

2016-10-25 Thread shaoxuan-wang
Github user shaoxuan-wang commented on the issue: https://github.com/apache/flink/pull/2653 Jack, Giving this for the second thought, I feel we can just use LATERAL and INNER/LEFT JOIN (which is already supported by Calcite) instead of introducing "CROSS/OUTER APPLY" . Let u

[GitHub] flink issue #2678: [FLINK-4879] [Kafka-Connector] class KafkaTableSource sho...

2016-10-25 Thread hzyuemeng1
Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/2678 thanks for ur review,i am very interesting about Table SQL,and want to make it better 2016-10-24 hzyuemeng1 发件人:Jark 发送时间:2016-10-24 09

[GitHub] flink issue #2673: [FLINK-4864] [table] Shade Calcite dependency in flink-ta...

2016-10-25 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2673 Thank you for looking into the details of this. If the user who ran into the issue is using Java, they can fix the issue themselves by relocating our or their Calcite version locally. If th

[jira] [Commented] (FLINK-4864) Shade Calcite dependency in flink-table

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

[GitHub] flink pull request #2692: [FLINK-4913][yarn] include user jar in system clas...

2016-10-25 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2692 [FLINK-4913][yarn] include user jar in system class loader When deploying a Yarn cluster for a single job, this change pre-configures the cluster to include the user jar(s) on all nodes. This eli

[GitHub] flink pull request #2644: [FLINK-4837] flink-streaming-akka source connector

2016-10-25 Thread sbcd90
Github user sbcd90 closed the pull request at: https://github.com/apache/flink/pull/2644 --- 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-4879) class KafkaTableSource should be public just like KafkaTableSink

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

[GitHub] flink issue #2644: [FLINK-4837] flink-streaming-akka source connector

2016-10-25 Thread sbcd90
Github user sbcd90 commented on the issue: https://github.com/apache/flink/pull/2644 Hello @rmetzger , I'll open a new PR in bahir. Closing this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project do

[jira] [Commented] (FLINK-4837) flink-streaming-akka source connector

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

[jira] [Commented] (FLINK-4837) flink-streaming-akka source connector

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

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15606049#comment-15606049 ] ASF GitHub Bot commented on FLINK-4469: --- Github user shaoxuan-wang commented on the

[jira] [Created] (FLINK-4920) Add a Scala Function Gauge

2016-10-25 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4920: --- Summary: Add a Scala Function Gauge Key: FLINK-4920 URL: https://issues.apache.org/jira/browse/FLINK-4920 Project: Flink Issue Type: Improvement Comp

[GitHub] flink pull request #2690: [FLINK-4894] [network] Don't request buffer after ...

2016-10-25 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/2690 [FLINK-4894] [network] Don't request buffer after writing to partition After emitting a record via the RecordWriter, we eagerly requested a new buffer for the next emit on that channel (although it's no

[jira] [Created] (FLINK-4919) Add secure cookie support for the cluster deployed in Mesos environment

2016-10-25 Thread Vijay Srinivasaraghavan (JIRA)
Vijay Srinivasaraghavan created FLINK-4919: -- Summary: Add secure cookie support for the cluster deployed in Mesos environment Key: FLINK-4919 URL: https://issues.apache.org/jira/browse/FLINK-4919

[jira] [Created] (FLINK-4918) Add SSL support to Mesos artifact server

2016-10-25 Thread Vijay Srinivasaraghavan (JIRA)
Vijay Srinivasaraghavan created FLINK-4918: -- Summary: Add SSL support to Mesos artifact server Key: FLINK-4918 URL: https://issues.apache.org/jira/browse/FLINK-4918 Project: Flink Is

[jira] [Commented] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

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

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

2016-10-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-3222. --- Resolution: Won't Fix > Incorrect shift amount in OperatorCheckpointStats#hashCode() > ---

[jira] [Created] (FLINK-4917) Deprecate "CheckpointedAsynchronously" interface

2016-10-25 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4917: --- Summary: Deprecate "CheckpointedAsynchronously" interface Key: FLINK-4917 URL: https://issues.apache.org/jira/browse/FLINK-4917 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-4916) BufferSpiller should distribute files across temp directories

2016-10-25 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4916: --- Summary: BufferSpiller should distribute files across temp directories Key: FLINK-4916 URL: https://issues.apache.org/jira/browse/FLINK-4916 Project: Flink Is

[GitHub] flink issue #2673: [FLINK-4864] [table] Shade Calcite dependency in flink-ta...

2016-10-25 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2673 The problem is only present if the Flink application is compiled with the Scala compiler. If I use the Java Quickstart, everything works until the CALCITE-1461 bug appears. @rmetzger pointed me into

[jira] [Commented] (FLINK-4864) Shade Calcite dependency in flink-table

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

[GitHub] flink pull request #2688: [FLINK-4762] [table] Use plural in time interval u...

2016-10-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2688 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Updated] (FLINK-4912) Introduce RECONCILING state in ExecutionGraph

2016-10-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4912: Summary: Introduce RECONCILING state in ExecutionGraph (was: Introduce RECONCILIATING state in Exec

[jira] [Created] (FLINK-4914) Define parameters for reconciliation

2016-10-25 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4914: --- Summary: Define parameters for reconciliation Key: FLINK-4914 URL: https://issues.apache.org/jira/browse/FLINK-4914 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-4911) Non-disruptive JobManager Failures via Reconciliation

2016-10-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4911: Summary: Non-disruptive JobManager Failures via Reconciliation (was: Non-disruptive JobManager Fai

[jira] [Updated] (FLINK-4911) Non-disruptive JobManager Failures

2016-10-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4911: Description: JobManager failures can be handled in a non-disruptive way - by *reconciling* the new

[jira] [Created] (FLINK-4915) Define parameters for reconciliation

2016-10-25 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4915: --- Summary: Define parameters for reconciliation Key: FLINK-4915 URL: https://issues.apache.org/jira/browse/FLINK-4915 Project: Flink Issue Type: Sub-task

[GitHub] flink issue #2691: [FLINK-4910] Introduce safety net for closing file system...

2016-10-25 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2691 R @StephanEwen and whoever is interested. --- 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 fea

[jira] [Commented] (FLINK-4911) Non-disruptive JobManager Failures

2016-10-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15605490#comment-15605490 ] Stephan Ewen commented on FLINK-4911: - I think this is different. The "syncing" part b

[jira] [Created] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

2016-10-25 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4913: - Summary: Per-job Yarn clusters: include user jar in system class loader Key: FLINK-4913 URL: https://issues.apache.org/jira/browse/FLINK-4913 Project: Flin

[jira] [Created] (FLINK-4912) Introduce RECONCILIATING state in ExecutionGraph

2016-10-25 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4912: --- Summary: Introduce RECONCILIATING state in ExecutionGraph Key: FLINK-4912 URL: https://issues.apache.org/jira/browse/FLINK-4912 Project: Flink Issue Type: Sub-

[GitHub] flink pull request #2521: [FLINK-4639] [table] Make Calcite features more pl...

2016-10-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2521 --- 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-4910) Introduce safety net for closing file system streams

2016-10-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15605463#comment-15605463 ] ASF GitHub Bot commented on FLINK-4910: --- Github user StefanRRichter commented on the

[jira] [Closed] (FLINK-3035) Redis as State Backend

2016-10-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3035. Resolution: Won't Fix Closed because Redis is not a good fit to serve as a state backend for Flink

[jira] [Commented] (FLINK-4910) Introduce safety net for closing file system streams

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

[GitHub] flink pull request #1617: [FLINK-3035] Redis as State Backend

2016-10-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1617 --- 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] [Closed] (FLINK-4762) Use plural in time interval units

2016-10-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4762. Resolution: Implemented Fix Version/s: 1.2.0 Implemented for 1.2.0 with 11fa089d6ae8ef8f8a884

[jira] [Commented] (FLINK-4911) Non-disruptive JobManager Failures

2016-10-25 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15605411#comment-15605411 ] Ufuk Celebi commented on FLINK-4911: I guess this issue supercedes/has as subtask FLIN

[jira] [Closed] (FLINK-4639) Make Calcite features more pluggable

2016-10-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4639. Resolution: Fixed Fix Version/s: 1.2.0 Fixed for 1.2.0 with dc0b3430f8d243b1876125e4949e733ae

[jira] [Commented] (FLINK-4762) Use plural in time interval units

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

[jira] [Commented] (FLINK-3035) Redis as State Backend

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

[jira] [Commented] (FLINK-4639) Make Calcite features more pluggable

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

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

2016-10-25 Thread liuyuzhong
Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2439 Sorry.forget to check it. I will do it tomorrow. --- 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] [Created] (FLINK-4911) Non-disruptive JobManager Failures

2016-10-25 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4911: --- Summary: Non-disruptive JobManager Failures Key: FLINK-4911 URL: https://issues.apache.org/jira/browse/FLINK-4911 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

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

[jira] [Commented] (FLINK-4832) Count/Sum 0 elements

2016-10-25 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15605349#comment-15605349 ] Aljoscha Krettek commented on FLINK-4832: - +1 That's exactly what I said earlier .

[jira] [Created] (FLINK-4910) Introduce safety net for closing file system streams

2016-10-25 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4910: - Summary: Introduce safety net for closing file system streams Key: FLINK-4910 URL: https://issues.apache.org/jira/browse/FLINK-4910 Project: Flink Issue Ty

[jira] [Assigned] (FLINK-4910) Introduce safety net for closing file system streams

2016-10-25 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4910: - Assignee: Stefan Richter > Introduce safety net for closing file system streams > ---

[jira] [Created] (FLINK-4909) JDBC Input format cast exception management

2016-10-25 Thread Stefano Bortoli (JIRA)
Stefano Bortoli created FLINK-4909: -- Summary: JDBC Input format cast exception management Key: FLINK-4909 URL: https://issues.apache.org/jira/browse/FLINK-4909 Project: Flink Issue Type: Imp

[GitHub] flink issue #2690: [FLINK-4894] [network] Don't request buffer after writing...

2016-10-25 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2690 PS: I would like to apply this to the `release-1.1` branch as well. --- 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 no

[GitHub] flink issue #2684: Add EvaluateDataSet Operation for LabeledVector - This cl...

2016-10-25 Thread thvasilo
Github user thvasilo commented on the issue: https://github.com/apache/flink/pull/2684 Thank you for your contribution Thomas! The changes look mostly fine I think, my only concern is the need to cast the types in lines [215-216](https://github.com/apache/flink/pull/2684/file

[jira] [Commented] (FLINK-4908) Add docs about evaluate operation to all predictors

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

[jira] [Created] (FLINK-4908) Add docs about evaluate operation to all predictors

2016-10-25 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-4908: -- Summary: Add docs about evaluate operation to all predictors Key: FLINK-4908 URL: https://issues.apache.org/jira/browse/FLINK-4908 Project: Flink

[GitHub] flink issue #2689: [FLINK-4903] [futures] Introduce synchronous future opera...

2016-10-25 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2689 The changes look good. +1 to merge after Travis passes. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-4894) Don't block on buffer request after broadcastEvent

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

[jira] [Commented] (FLINK-4894) Don't block on buffer request after broadcastEvent

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

[jira] [Commented] (FLINK-4298) Clean up Storm Compatibility Dependencies

2016-10-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15605219#comment-15605219 ] Stephan Ewen commented on FLINK-4298: - Fixed in 1.1.4 via 17bb96dd64305fdfaffdd049cd95

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

2016-10-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15605218#comment-15605218 ] Stephan Ewen commented on FLINK-4218: - Fixed in 1.1.4 via 198f2b072761d6e6ca93ff5e93bf

[jira] [Closed] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails

2016-10-25 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4619. -- Resolution: Fixed Fixed in {{b05c3c1}} (master), {{6624348}} (release-1.1). > JobManager does not answe

[jira] [Commented] (FLINK-4903) Introduce non async future methods

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

[jira] [Commented] (FLINK-4907) Add Test for Timers/State Provided by AbstractStreamOperator

2016-10-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15605123#comment-15605123 ] Kostas Kloudas commented on FLINK-4907: --- [~aljoscha] thanks for reporting this. I ha

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

2016-10-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-2662: -- Reopened due to the bug reported by [~ymarzougui]. > CompilerException: "Bug: Plan generation for U

[GitHub] flink pull request #2614: [FLINK-4773] Intoduce OperatorIOMetricGroup

2016-10-25 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/2614 --- 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-4733) Port WebFrontend to new metric system

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

[GitHub] flink issue #2616: [FLINK-4733] Port WebInterface to metric system

2016-10-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2616 Note that 2 new methods were introduced into the `StreamConfig`: `setChainStart() / isChainStart()` to better determine which output counter should be used for the task. Previously this used the same

[jira] [Commented] (FLINK-4773) Introduce an OperatorIOMetricGroup

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

[GitHub] flink issue #2616: [FLINK-4733] Port WebInterface to metric system

2016-10-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2616 @rmetzger Rebased version is up. --- 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

[jira] [Commented] (FLINK-4733) Port WebFrontend to new metric system

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

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

2016-10-25 Thread Yassine Marzougui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-2662: - Attachment: Bug.java I ran into the same problem with Flink 1.1.3 when trying to perform

[jira] [Assigned] (FLINK-4050) FlinkKafkaProducer API Refactor

2016-10-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4050: - Assignee: Robert Metzger > FlinkKafkaProducer API Refactor >

[GitHub] flink issue #2521: [FLINK-4639] [table] Make Calcite features more pluggable

2016-10-25 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2521 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 fea

[GitHub] flink issue #2688: [FLINK-4762] [table] Use plural in time interval units

2016-10-25 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2688 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 fea

[jira] [Comment Edited] (FLINK-4888) instantiated job manager metrics missing important job statistics

2016-10-25 Thread Philipp von dem Bussche (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15604971#comment-15604971 ] Philipp von dem Bussche edited comment on FLINK-4888 at 10/25/16 10:57 AM: -

[jira] [Commented] (FLINK-4762) Use plural in time interval units

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

[jira] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics

2016-10-25 Thread Philipp von dem Bussche (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15604971#comment-15604971 ] Philipp von dem Bussche commented on FLINK-4888: [~Zentol] thanks for that

[jira] [Commented] (FLINK-4639) Make Calcite features more pluggable

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

[GitHub] flink pull request #2616: [FLINK-4733] Port WebInterface to metric system

2016-10-25 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2616#discussion_r84696513 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JobDetailsHandler.java --- @@ -147,11 +143,36 @@ public String handle

  1   2   >