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

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

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

Github user gallenvara closed the pull request at: https://github.com/apache/flink/pull/1975 --- 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

[GitHub] flink issue #2991: [FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM Me...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2991 +1 to merge this for 1.2 and 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

[GitHub] flink pull request #3109: [FLINK-5329] Fix metric list being cut off

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3109 [FLINK-5329] Fix metric list being cut off This PR fixes the metric list in the WebFrontend job page being cut off. This bug was introduced in bd62fe14ac3e8c382b72c7c16ce1f0a6ee7db77d. To

[GitHub] flink issue #3102: [FLINK-5467] Avoid legacy state for CheckpointedRestoring...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3102 I guess I could try and add an operator that implements ``CheckpointedRestoring`` to our ``RescalingITCase``. --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink issue #3102: [FLINK-5467] Avoid legacy state for CheckpointedRestoring...

Github user uce commented on the issue: https://github.com/apache/flink/pull/3102 Although it feels like a good test is missing for this since no test caught it. @StefanRRichter Do you think it's feasible to add one? --- If your project is set up for it, you can reply to this email

[GitHub] flink issue #3102: [FLINK-5467] Avoid legacy state for CheckpointedRestoring...

Github user uce commented on the issue: https://github.com/apache/flink/pull/3102 Yep. --- 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

[GitHub] flink issue #3106: [FLINK-5118] Fix inconsistent numBytesIn/Out metrics

Github user uce commented on the issue: https://github.com/apache/flink/pull/3106 Yeah, I think counting the buffers is the better way to go. --- 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

[GitHub] flink issue #3106: [FLINK-5118] Fix inconsistent numBytesIn/Out metrics

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3106 Then we could count per buffer. I'd rather not count per record since the deserializer are kind of complicated :( --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink issue #3102: [FLINK-5467] Avoid legacy state for CheckpointedRestoring...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3102 I think this should work. Could you go ahead and merge, @uce ? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[GitHub] flink pull request #3108: [FLINK-5155] Deprecate ValueStateDescriptor constr...

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/3108 [FLINK-5155] Deprecate ValueStateDescriptor constructors with default value I left usage of this in a lot of places to ensure that we don't break anything. The rest of places where the

[GitHub] flink issue #3075: [FLINK-5296] Expose the old AlignedWindowOperators throug...

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/3075 Thanks @aljoscha . Will do that. --- 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

[GitHub] flink pull request #3075: [FLINK-5296] Expose the old AlignedWindowOperators...

Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/3075 --- 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

[GitHub] flink issue #3075: [FLINK-5296] Expose the old AlignedWindowOperators throug...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3075 Thanks for your work! 👍 Could you please close this PR? I merged it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink issue #3106: [FLINK-5118] Fix inconsistent numBytesIn/Out metrics

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3106 Instead of counting bytesOut in the serializer we could do it one level up in the RecordWriter. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-5473) setMaxParallelism() higher than 1 is possible on non-parallel operators

[ https://issues.apache.org/jira/browse/FLINK-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821262#comment-15821262 ] Robert Metzger commented on FLINK-5473: --- That would be the best user experience, yes. >

[jira] [Closed] (FLINK-5470) Requesting non-existing log/stdout file from TM crashes the TM

[ https://issues.apache.org/jira/browse/FLINK-5470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5470. --- Resolution: Duplicate > Requesting non-existing log/stdout file from TM crashes the TM >

[jira] [Created] (FLINK-5475) Extend DC/OS documentation

Till Rohrmann created FLINK-5475: Summary: Extend DC/OS documentation Key: FLINK-5475 URL: https://issues.apache.org/jira/browse/FLINK-5475 Project: Flink Issue Type: Sub-task

[GitHub] flink issue #3106: [FLINK-5118] Fix inconsistent numBytesIn/Out metrics

Github user uce commented on the issue: https://github.com/apache/flink/pull/3106 Good catch. I was wondering whether it is better to count in a consistent way, too, e.g. count the size of each buffer or each record on both A and B (now we have per record on the output side and per

[jira] [Created] (FLINK-5474) Extend DC/OS documentation

Till Rohrmann created FLINK-5474: Summary: Extend DC/OS documentation Key: FLINK-5474 URL: https://issues.apache.org/jira/browse/FLINK-5474 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-5473) setMaxParallelism() higher than 1 is possible on non-parallel operators

[ https://issues.apache.org/jira/browse/FLINK-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821254#comment-15821254 ] Stefan Richter commented on FLINK-5473: --- We could try to automatically set the old parallelism as

[GitHub] flink issue #3104: [FLINK-5150] [webui] Store metrics in sessionStorage

Github user uce commented on the issue: https://github.com/apache/flink/pull/3104 Good catch! --- 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-5150) WebUI metric-related resource leak

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

[jira] [Created] (FLINK-5473) setMaxParallelism() higher than 1 is possible on non-parallel operators

Robert Metzger created FLINK-5473: - Summary: setMaxParallelism() higher than 1 is possible on non-parallel operators Key: FLINK-5473 URL: https://issues.apache.org/jira/browse/FLINK-5473 Project:

[jira] [Commented] (FLINK-5118) Inconsistent records sent/received metrics

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

[jira] [Commented] (FLINK-5118) Inconsistent records sent/received metrics

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

[jira] [Updated] (FLINK-5470) Requesting non-existing log/stdout file from TM crashes the TM

[ https://issues.apache.org/jira/browse/FLINK-5470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5470: - Summary: Requesting non-existing log/stdout file from TM crashes the TM (was: Requesting

[GitHub] flink pull request #3106: [FLINK-5118] Fix inconsistent numBytesIn/Out metri...

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3106#discussion_r95812448 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningRecordSerializer.java --- @@ -99,7 +99,7 @@ public

[jira] [Created] (FLINK-5472) Flink's web server does not support https requests

Till Rohrmann created FLINK-5472: Summary: Flink's web server does not support https requests Key: FLINK-5472 URL: https://issues.apache.org/jira/browse/FLINK-5472 Project: Flink Issue Type:

[jira] [Created] (FLINK-5471) Properly inform JobClientActor about terminated Mesos framework

Till Rohrmann created FLINK-5471: Summary: Properly inform JobClientActor about terminated Mesos framework Key: FLINK-5471 URL: https://issues.apache.org/jira/browse/FLINK-5471 Project: Flink

[GitHub] flink issue #3093: [FLINK-5444] Made Flink UI links relative.

Github user uce commented on the issue: https://github.com/apache/flink/pull/3093 Thanks! LGTM, going to merge this now. --- 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

[GitHub] flink pull request #3093: [FLINK-5444] Made Flink UI links relative.

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3093 --- 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] [Closed] (FLINK-5444) Flink UI uses absolute URLs.

[ https://issues.apache.org/jira/browse/FLINK-5444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5444. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in dff58df, 80f1517

[jira] [Commented] (FLINK-5444) Flink UI uses absolute URLs.

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

[jira] [Commented] (FLINK-5444) Flink UI uses absolute URLs.

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

[jira] [Created] (FLINK-5470) Requesting non-existing log/stdout file from TM crashes the it

Till Rohrmann created FLINK-5470: Summary: Requesting non-existing log/stdout file from TM crashes the it Key: FLINK-5470 URL: https://issues.apache.org/jira/browse/FLINK-5470 Project: Flink

[jira] [Closed] (FLINK-5466) Make production environment default in gulpfile

[ https://issues.apache.org/jira/browse/FLINK-5466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5466. -- Resolution: Fixed Assignee: Ufuk Celebi Fix Version/s: 1.1.5 1.3.0

[GitHub] flink pull request #3100: [FLINK-5466] [webfrontend] Set environment to prod...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3100 --- 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] [Updated] (FLINK-5118) Inconsistent records sent/received metrics

[ https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5118: Fix Version/s: 1.3.0 1.2.0 > Inconsistent records sent/received metrics

[jira] [Updated] (FLINK-5118) Inconsistent records sent/received metrics

[ https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5118: Affects Version/s: 1.3.0 1.2.0 > Inconsistent records sent/received

[jira] [Commented] (FLINK-5118) Inconsistent records sent/received metrics

[ https://issues.apache.org/jira/browse/FLINK-5118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821166#comment-15821166 ] Chesnay Schepler commented on FLINK-5118: - PR at https://github.com/apache/flink/pull/3106 >

[jira] [Commented] (FLINK-5466) Make production environment default in gulpfile

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

[jira] [Created] (FLINK-5469) build_docs.sh -p fails on Windows Subsystem for Linux

Chesnay Schepler created FLINK-5469: --- Summary: build_docs.sh -p fails on Windows Subsystem for Linux Key: FLINK-5469 URL: https://issues.apache.org/jira/browse/FLINK-5469 Project: Flink

[GitHub] flink issue #2991: [FLINK-5321] [metrics] LocalFlinkMiniCluster starts JM Me...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2991 @StephanEwen Could you take another look? --- 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] [Assigned] (FLINK-3871) Add Kafka TableSource with Avro serialization

[ https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3871: - Assignee: Ivan Mushketyk > Add Kafka TableSource with Avro serialization >

[jira] [Commented] (FLINK-5321) FlinkMiniCluster does not start Jobmanager MetricQueryService

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

[GitHub] flink pull request #3107: [FLINK-5441] [table] Directly allow SQL queries on...

GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/3107 [FLINK-5441] [table] Directly allow SQL queries on a Table Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Commented] (FLINK-5441) Directly allow SQL queries on a Table

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

[jira] [Commented] (FLINK-5466) Make production environment default in gulpfile

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

[GitHub] flink issue #3100: [FLINK-5466] [webfrontend] Set environment to production ...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3100 +1 to merge and backport. This is a big improvement when accessing the web UI over a slow connection. --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request #3106: [FLINK-????] FIx inconsistent numBytesIn/Out metri...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3106 [FLINK-] FIx inconsistent numBytesIn/Out metrics This PR fixes _some_ jira issue (i can't find the correct issue ID right now since JIRA is being stupid) regarding inconsistent numBytesIn/Out

[jira] [Commented] (FLINK-5444) Flink UI uses absolute URLs.

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

[GitHub] flink issue #3093: [FLINK-5444] Made Flink UI links relative.

Github user joerg84 commented on the issue: https://github.com/apache/flink/pull/3093 @sachingoel0101 PTAL --- 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,

[GitHub] flink issue #3071: [FLINK-5417][DOCUMENTATION]correct the wrong config file ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3071 When viewing the documentation in firefox there is now a lot of whitespace above the diagram. The dimensions have slightly changed as well :/ --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-5417) Fix the wrong config file name

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

[GitHub] flink issue #3102: [FLINK-5467] Avoid legacy state for CheckpointedRestoring...

Github user uce commented on the issue: https://github.com/apache/flink/pull/3102 I'm not aware of all implications of this change, but this fixes the problem I had. The operator does not checkpoint any legacy operator state. +1 to merge from my side. --- If your project is

[jira] [Commented] (FLINK-5467) Stateless chained tasks set legacy operator state

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

[GitHub] flink pull request #3093: [FLINK-5444] Made Flink UI links relative.

Github user joerg84 commented on a diff in the pull request: https://github.com/apache/flink/pull/3093#discussion_r95783168 --- Diff: flink-runtime-web/web-dashboard/app/scripts/modules/submit/submit.ctrl.coffee --- @@ -167,7 +167,7 @@ angular.module('flinkApp')

[jira] [Commented] (FLINK-5444) Flink UI uses absolute URLs.

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

[GitHub] flink issue #3071: [FLINK-5417][DOCUMENTATION]correct the wrong config file ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/3071 I will take a look at these changes. Just a small note: We are not getting notified of pushed changes, a small comment is always good to get attention ;) --- If your project is set up for

[jira] [Commented] (FLINK-5417) Fix the wrong config file name

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

[GitHub] flink pull request #3090: [FLINK-5432] Fix nested files enumeration in Conti...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3090#discussion_r95782207 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java --- @@ -282,7 +282,7 @@

[jira] [Commented] (FLINK-5421) Explicit restore method in Snapshotable

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

[jira] [Commented] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

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

[GitHub] flink pull request #3074: [FLINK-5421] Explicit restore method in Snapshotab...

Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/3074 --- 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

[GitHub] flink pull request #3105: [FLINK-4641] Support branching CEP patterns

GitHub user chermenin opened a pull request: https://github.com/apache/flink/pull/3105 [FLINK-4641] Support branching CEP patterns Support for branched CEP patterns was added in this PR. After merging that we will be able to use follow code to define more complex patterns:

[jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820897#comment-15820897 ] Till Rohrmann commented on FLINK-4973: -- I think that exactly for these cases it is not good to remove

[jira] [Commented] (FLINK-4641) Support branching CEP patterns

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

[jira] [Updated] (FLINK-5380) Number of outgoing records not reported in web interface

[ https://issues.apache.org/jira/browse/FLINK-5380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5380: Priority: Blocker (was: Major) > Number of outgoing records not reported in web interface

[jira] [Commented] (FLINK-5421) Explicit restore method in Snapshotable

[ https://issues.apache.org/jira/browse/FLINK-5421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820882#comment-15820882 ] Aljoscha Krettek commented on FLINK-5421: - Implemented on master in:

[jira] [Commented] (FLINK-5421) Explicit restore method in Snapshotable

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

[GitHub] flink issue #3074: [FLINK-5421] Explicit restore method in Snapshotable inte...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3074 Thanks for your work! 👍 I merged, could you please close this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request #3104: [FLINK-5150] [webui] Store metrics in sessionStora...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3104 [FLINK-5150] [webui] Store metrics in sessionStorage This PR modifies the webfrontend to no longer store the metrics setup (selected metrics + their values) in localStorage but sessionStorage

[jira] [Commented] (FLINK-5150) WebUI metric-related resource leak

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

[jira] [Assigned] (FLINK-5150) WebUI metric-related resource leak

[ https://issues.apache.org/jira/browse/FLINK-5150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-5150: --- Assignee: Chesnay Schepler > WebUI metric-related resource leak >

[GitHub] flink pull request #3103: [FLINK-5464] [metrics] Prevent some NPEs

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3103 [FLINK-5464] [metrics] Prevent some NPEs This PR prevents some NullPointerExceptions from occurring in the metric system. - When registering a metric that is null the metric is ignored, and

[jira] [Commented] (FLINK-5464) MetricQueryService throws NullPointerException on JobManager

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

[jira] [Created] (FLINK-5468) Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException

Robert Metzger created FLINK-5468: - Summary: Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException Key: FLINK-5468 URL: https://issues.apache.org/jira/browse/FLINK-5468

[jira] [Commented] (FLINK-5464) MetricQueryService throws NullPointerException on JobManager

[ https://issues.apache.org/jira/browse/FLINK-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820801#comment-15820801 ] Chesnay Schepler commented on FLINK-5464: - There are 2 possible cases for this: Either the

[GitHub] flink pull request #3080: [FLINK-4920] Add a Scala Function Gauge

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3080#discussion_r95773028 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala --- @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache Software

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

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

[jira] [Commented] (FLINK-5467) Stateless chained tasks set legacy operator state

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

[jira] [Commented] (FLINK-5467) Stateless chained tasks set legacy operator state

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

[GitHub] flink pull request #3102: [FLINK-5467] Avoid legacy state for CheckpointedRe...

GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/3102 [FLINK-5467] Avoid legacy state for CheckpointedRestoring operators This PR fixes [FLINK-5467]. You can merge this pull request into a Git repository by running: $ git pull

[GitHub] flink issue #3102: [FLINK-5467] Avoid legacy state for CheckpointedRestoring...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3102 cc @uce @aljoscha --- 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

[GitHub] flink issue #3088: [FLINK-5407] Fix savepoints for iterative jobs

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3088 Changes look very good! I fixed the formatting of the newly added methods in `TestingCluster` to conform to Scala coding guidelines. I rebased on master, will wait for Travis to give the

[jira] [Commented] (FLINK-5407) Savepoint for iterative Task fails.

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

[jira] [Assigned] (FLINK-5464) MetricQueryService throws NullPointerException on JobManager

[ https://issues.apache.org/jira/browse/FLINK-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-5464: --- Assignee: Chesnay Schepler > MetricQueryService throws NullPointerException on

[jira] [Commented] (FLINK-5406) add normalization phase for predicate logical plan rewriting between decorrelate query phase and volcano optimization phase

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

[GitHub] flink pull request #3101: [FLINK-5406] [table] add normalization phase for p...

GitHub user godfreyhe opened a pull request: https://github.com/apache/flink/pull/3101 [FLINK-5406] [table] add normalization phase for predicate logical plan rewriting Normalization phase is for predicate logical plan rewriting and is independent of cost module. The rules in

[jira] [Commented] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

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

[GitHub] flink issue #3090: [FLINK-5432] Fix nested files enumeration in ContinuousFi...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3090 The changes look very good! I think it would be good to add a test for nested reading in `ContinuousFileProcessingTest`. --- If your project is set up for it, you can reply to this email and have

[jira] [Assigned] (FLINK-5467) Stateless chained tasks set legacy operator state

[ https://issues.apache.org/jira/browse/FLINK-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-5467: - Assignee: Stefan Richter > Stateless chained tasks set legacy operator state >

[jira] [Created] (FLINK-5467) Stateless chained tasks set legacy operator state

Ufuk Celebi created FLINK-5467: -- Summary: Stateless chained tasks set legacy operator state Key: FLINK-5467 URL: https://issues.apache.org/jira/browse/FLINK-5467 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5466) Make production environment default in gulpfile

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

[GitHub] flink issue #3100: [FLINK-5466] [webfrontend] Set environment to production ...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3100 +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 does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-5466) Make production environment default in gulpfile

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

[GitHub] flink issue #3100: [FLINK-5466] [webfrontend] Set environment to production ...

Github user joerg84 commented on the issue: https://github.com/apache/flink/pull/3100 LGTM, thanks for fixing 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 does not have this feature enabled and

[GitHub] flink issue #3095: [FLINK-5452] [table] Fix SortITCase which will fail under...

Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3095 @fhueske Ah i see, thanks for the explaining. I will try to fix this in another way after #3099 is in. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-5452) Make table unit tests pass under cluster mode

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

  1   2   >