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

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

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

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15607336#comment-15607336 ] Zhijiang Wang commented on FLINK-4911: -- FLINK-3539 tries to realize eventual consistency between JM

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

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15607498#comment-15607498 ] Tzu-Li (Gordon) Tai commented on FLINK-4905: Had a quick look at this. The only place we're

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

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

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

[ 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-4912) Introduce RECONCILING state in ExecutionGraph

[ 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-4915) Define parameters for reconciliation

[ 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] [Comment Edited] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

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

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

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] [Assigned] (FLINK-4923) Expose input/output queued buffers and buffer usage as a metric for a Task

[ 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

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

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

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

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:

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

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

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

[ 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] [Commented] (FLINK-3976) Alias fields of physical plan node to avoid name collision with Calcite protected fields

[ https://issues.apache.org/jira/browse/FLINK-3976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604393#comment-15604393 ] Jark Wu commented on FLINK-3976: Ah! I have also encountered this issue a few months ago when I upgraded

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

[ https://issues.apache.org/jira/browse/FLINK-4762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604466#comment-15604466 ] ASF GitHub Bot commented on FLINK-4762: --- Github user fhueske commented on the issue:

[jira] [Closed] (FLINK-3976) Alias fields of physical plan node to avoid name collision with Calcite protected fields

[ https://issues.apache.org/jira/browse/FLINK-3976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-3976. -- Resolution: Fixed fixed by FLINK-4590 > Alias fields of physical plan node to avoid name collision with

[jira] [Commented] (FLINK-4600) Support min/max aggregations for Date/Time/Timestamp/Intervals

[ https://issues.apache.org/jira/browse/FLINK-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604336#comment-15604336 ] Jark Wu commented on FLINK-4600: Hi [~miaoever] , do you still have a chance to implement this issue ? >

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

Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2616#discussion_r84697528 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JobVertexDetailsHandler.java --- @@ -99,11 +83,34 @@ public String

[GitHub] flink pull request #2689: [FLINK-4903] [futures] Introduce synchronous futur...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2689 [FLINK-4903] [futures] Introduce synchronous future operations The synchronous future operations are executed by the thread which adds the operation if the future is already completed or

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

[ https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604779#comment-15604779 ] ASF GitHub Bot commented on FLINK-4733: --- Github user rmetzger commented on a diff in the pull

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

[ https://issues.apache.org/jira/browse/FLINK-4773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4773. --- Resolution: Fixed Implemented in 77258a007ae4dde525d0274bb4d63e76d834bfe0 and

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

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2688 Thanks for the PR @wuchong. Changes look good to me. +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

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

[ https://issues.apache.org/jira/browse/FLINK-4903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604655#comment-15604655 ] ASF GitHub Bot commented on FLINK-4903: --- GitHub user tillrohrmann opened a pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604837#comment-15604837 ] ASF GitHub Bot commented on FLINK-4733: --- Github user zentol commented on the issue:

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

Aljoscha Krettek created FLINK-4907: --- Summary: Add Test for Timers/State Provided by AbstractStreamOperator Key: FLINK-4907 URL: https://issues.apache.org/jira/browse/FLINK-4907 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604566#comment-15604566 ] Stefan Richter commented on FLINK-4883: --- Sure, here is the example from the mailing list: {code}

[jira] [Created] (FLINK-4904) Add a limit for how much data may be spilled in checkpoint alignments

Stephan Ewen created FLINK-4904: --- Summary: Add a limit for how much data may be spilled in checkpoint alignments Key: FLINK-4904 URL: https://issues.apache.org/jira/browse/FLINK-4904 Project: Flink

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

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2673 OK, I could reproduce the issue on my setup, but I have no idea why this happens. I checked the jar file and the Calcite classes seem to be correctly relocated (files are at correct location in jar

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

[ https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604780#comment-15604780 ] ASF GitHub Bot commented on FLINK-4733: --- Github user rmetzger commented on a diff in the pull

[jira] [Created] (FLINK-4906) Use constants for the name of system-defined metrics

Chesnay Schepler created FLINK-4906: --- Summary: Use constants for the name of system-defined metrics Key: FLINK-4906 URL: https://issues.apache.org/jira/browse/FLINK-4906 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604835#comment-15604835 ] ASF GitHub Bot commented on FLINK-4733: --- Github user zentol commented on a diff in the pull request:

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

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2616#discussion_r84868336 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JobVertexDetailsHandler.java --- @@ -99,11 +83,34 @@ public String

[jira] [Updated] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine

[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-3347: Fix Version/s: 1.1.4 1.2.0 > TaskManager ActorSystems need to restart themselves

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604599#comment-15604599 ] ASF GitHub Bot commented on FLINK-4864: --- Github user fhueske commented on the issue:

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

[ https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604826#comment-15604826 ] ASF GitHub Bot commented on FLINK-4733: --- Github user zentol commented on a diff in the pull request:

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

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2616 Will rebase now, this will also fix the test failure. --- 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] [Commented] (FLINK-4888) instantiated job manager metrics missing important job statistics

[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604536#comment-15604536 ] ASF GitHub Bot commented on FLINK-4888: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #2683: [FLINK-4888][metrics] instantiated job manager met...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2683#discussion_r84846296 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1828,6 +1828,33 @@ class JobManager(

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

Till Rohrmann created FLINK-4903: Summary: Introduce non async future methods Key: FLINK-4903 URL: https://issues.apache.org/jira/browse/FLINK-4903 Project: Flink Issue Type: Improvement

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

[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-3347: Summary: TaskManager (or its ActorSystem) need to restart in case they notice quarantine (was:

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

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

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

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

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

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

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

[ 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] [Commented] (FLINK-4733) Port WebFrontend to new metric system

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

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

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

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

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

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

[ 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

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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605411#comment-15605411 ] Ufuk Celebi commented on FLINK-4911: I guess this issue supercedes/has as subtask FLINK-3539? >

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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-4911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605490#comment-15605490 ] Stephan Ewen commented on FLINK-4911: - I think this is different. The "syncing" part basically

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

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

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

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

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

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] [Commented] (FLINK-3035) Redis as State Backend

[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605429#comment-15605429 ] ASF GitHub Bot commented on FLINK-3035: --- Github user asfgit closed the pull request at:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605445#comment-15605445 ] ASF GitHub Bot commented on FLINK-4910: --- GitHub user StefanRRichter opened a pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605463#comment-15605463 ] ASF GitHub Bot commented on FLINK-4910: --- Github user StefanRRichter commented on the issue:

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

[ https://issues.apache.org/jira/browse/FLINK-4639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605430#comment-15605430 ] ASF GitHub Bot commented on FLINK-4639: --- Github user asfgit closed the pull request at:

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

[ https://issues.apache.org/jira/browse/FLINK-4762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605428#comment-15605428 ] ASF GitHub Bot commented on FLINK-4762: --- Github user asfgit closed the pull request at:

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

[ 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] [Created] (FLINK-4912) Introduce RECONCILIATING state in ExecutionGraph

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:

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

[ 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

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

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] [Commented] (FLINK-4450) update storm version to 1.0.0

[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605393#comment-15605393 ] ASF GitHub Bot commented on FLINK-4450: --- Github user liuyuzhong commented on the issue:

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

[ 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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605218#comment-15605218 ] Stephan Ewen commented on FLINK-4218: - Fixed in 1.1.4 via 198f2b072761d6e6ca93ff5e93bf6391ed736260 >

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

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:

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

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

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

[ 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

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

[ 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-4910) Introduce safety net for closing file system streams

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

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

[ https://issues.apache.org/jira/browse/FLINK-4888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604971#comment-15604971 ] Philipp von dem Bussche commented on FLINK-4888: [~Zentol] thanks for that. There is a map

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-4773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605034#comment-15605034 ] ASF GitHub Bot commented on FLINK-4773: --- Github user zentol closed the pull request at:

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

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

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

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

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

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

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

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

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

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-4907) Add Test for Timers/State Provided by AbstractStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605123#comment-15605123 ] Kostas Kloudas commented on FLINK-4907: --- [~aljoscha] thanks for reporting this. I have already

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

[ https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

[ https://issues.apache.org/jira/browse/FLINK-4298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15605219#comment-15605219 ] Stephan Ewen commented on FLINK-4298: - Fixed in 1.1.4 via 17bb96dd64305fdfaffdd049cd95dbb760b72504 >

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

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

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

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

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

[ 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 >

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

[ 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

  1   2   >