[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=15820447#comment-15820447 ] ASF GitHub Bot commented on FLINK-5444: --- Github user sachingoel0101 commented on a diff in the pull

[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

[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 pull request #3093: [FLINK-5444] Made Flink UI links relative.

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

[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=15820582#comment-15820582 ] ASF GitHub Bot commented on FLINK-5452: --- Github user fhueske commented on the issue:

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

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3095 Thanks for looking into this issue @KurtYoung I agree that this is rather an issue with the tests and not with the actual code. However, I would fix the tests a bit differently. The goal of

[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=15820593#comment-15820593 ] ASF GitHub Bot commented on FLINK-5452: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3095: [FLINK-5452] [table] Fix SortITCase which will fai...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3095#discussion_r95754128 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/table/SortITCase.scala --- @@ -57,14 +57,8 @@ class SortITCase(

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

[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] [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-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] [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=15820598#comment-15820598 ] ASF GitHub Bot commented on FLINK-5452: --- Github user fhueske commented on the issue:

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

Ufuk Celebi created FLINK-5466: -- Summary: Make production environment default in gulpfile Key: FLINK-5466 URL: https://issues.apache.org/jira/browse/FLINK-5466 Project: Flink Issue Type:

[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

[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 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_r95741031 --- 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=15820456#comment-15820456 ] ASF GitHub Bot commented on FLINK-5444: --- Github user joerg84 commented on a diff in the pull

[jira] [Updated] (FLINK-5462) Flink job fails due to java.util.concurrent.CancellationException while snapshotting

[ https://issues.apache.org/jira/browse/FLINK-5462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5462: -- Attachment: application-1484132267957-0005 I've attached the full log. > Flink job fails due

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

[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

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

Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/3093#discussion_r95749646 --- 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=15820553#comment-15820553 ] ASF GitHub Bot commented on FLINK-5444: --- Github user sachingoel0101 commented on a diff in the pull

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

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3095 It might make sense to wait with this PR until #3099 is in --- 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

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

[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

[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=15820588#comment-15820588 ] ASF GitHub Bot commented on FLINK-5452: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3095: [FLINK-5452] [table] Fix SortITCase which will fai...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3095#discussion_r95753661 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/SortITCase.scala --- @@ -79,14 +73,8 @@ class SortITCase(

[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=15820585#comment-15820585 ] ASF GitHub Bot commented on FLINK-5452: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3095: [FLINK-5452] [table] Fix SortITCase which will fai...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3095#discussion_r95753596 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/SortITCase.scala --- @@ -55,14 +55,8 @@ class SortITCase(

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

[GitHub] flink pull request #3099: [FLINK-5268] Split TableProgramsTestBase into Tabl...

GitHub user mtunique opened a pull request: https://github.com/apache/flink/pull/3099 [FLINK-5268] Split TableProgramsTestBase into TableProgramsCollectionTestBase and TableProgramsClusterTestBase …TestBase and TableProgramsClusterTestBase Thanks for contributing to

[jira] [Commented] (FLINK-5268) Split TableProgramsTestBase into TableProgramsCollectionTestBase and TableProgramsClusterTestBase

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

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

GitHub user uce opened a pull request: https://github.com/apache/flink/pull/3100 [FLINK-5466] [webfrontend] Set environment to production in gulpfile The default environment was set to `development`, which leads to very large generated JS files. When building the web UI we

[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=15820615#comment-15820615 ] ASF GitHub Bot commented on FLINK-5466: --- GitHub user uce opened a pull request:

[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] [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] [Assigned] (FLINK-5441) Directly allow SQL queries on a Table

[ https://issues.apache.org/jira/browse/FLINK-5441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-5441: -- Assignee: Jark Wu > Directly allow SQL queries on a Table > - > >

[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

[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

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

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

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

[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

[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

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

[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

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

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

[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

[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

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

[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

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

[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

[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

[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

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

[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

[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

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

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

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

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

[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-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] [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 #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 @@

[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

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

  1   2   >