[GitHub] KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-11 Thread GitBox
KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469#discussion_r247303924 ## File path: docs/monitoring/logging.md ## @@ -93,7 +93,7 @@ Placeholders can also be used in conjuncti

[GitHub] KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-11 Thread GitBox
KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469#discussion_r247303924 ## File path: docs/monitoring/logging.md ## @@ -93,7 +93,7 @@ Placeholders can also be used in conjuncti

[jira] [Updated] (FLINK-11296) Support truncate in TableAPI

2019-01-11 Thread xuqianjin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-11296: -- Description: Add {{truncate}} support in TableAPI, Add support as follows: ||expression||Expect the re

[GitHub] klion26 commented on issue #7461: [FLINK-11295][configuration] Rename configuration options of queryable-state from query.x to queryable-state.x

2019-01-11 Thread GitBox
klion26 commented on issue #7461: [FLINK-11295][configuration] Rename configuration options of queryable-state from query.x to queryable-state.x URL: https://github.com/apache/flink/pull/7461#issuecomment-453722196 @eaglewatcherwb Thank you for your contribution, overall it is good from my

[GitHub] klion26 commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-11 Thread GitBox
klion26 commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469#discussion_r247303325 ## File path: docs/monitoring/logging.md ## @@ -93,7 +93,7 @@ Placeholders can also be used in conjunctio

[GitHub] klion26 commented on issue #7460: [FLINK-11187] [s3] Use file over stream for writes

2019-01-11 Thread GitBox
klion26 commented on issue #7460: [FLINK-11187] [s3] Use file over stream for writes URL: https://github.com/apache/flink/pull/7460#issuecomment-453721203 @addisonj Thank you for your contribution. The checkstyle did not pass, we could validate the style locally by executing `mvn clean va

[GitHub] KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-11 Thread GitBox
KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469#discussion_r247303165 ## File path: docs/monitoring/logging.md ## @@ -93,7 +93,7 @@ Placeholders can also be used in conjuncti

[GitHub] KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-11 Thread GitBox
KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469#discussion_r247303165 ## File path: docs/monitoring/logging.md ## @@ -93,7 +93,7 @@ Placeholders can also be used in conjuncti

[GitHub] KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-11 Thread GitBox
KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469#discussion_r247303165 ## File path: docs/monitoring/logging.md ## @@ -93,7 +93,7 @@ Placeholders can also be used in conjuncti

[GitHub] klion26 commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-11 Thread GitBox
klion26 commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469#discussion_r247302983 ## File path: docs/monitoring/logging.md ## @@ -93,7 +93,7 @@ Placeholders can also be used in conjunctio

[GitHub] klion26 commented on issue #7472: hh

2019-01-11 Thread GitBox
klion26 commented on issue #7472: hh URL: https://github.com/apache/flink/pull/7472#issuecomment-453720310 @caosuwenwu Why do you want the changes to be merged into master? May be you could close this This is an automated mes

[jira] [Commented] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

2019-01-11 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16740797#comment-16740797 ] Shuyi Chen commented on FLINK-10848: Also, can you please also help me take a look a

[jira] [Commented] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

2019-01-11 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16740796#comment-16740796 ] Shuyi Chen commented on FLINK-10848: Thanks a lot for fixing the issue, [~till.rohrm

[GitHub] TisonKun commented on a change in pull request #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code…

2019-01-11 Thread GitBox
TisonKun commented on a change in pull request #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code… URL: https://github.com/apache/flink/pull/6953#discussion_r247201616 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabilityI

[GitHub] TisonKun commented on issue #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code…

2019-01-11 Thread GitBox
TisonKun commented on issue #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code… URL: https://github.com/apache/flink/pull/6953#issuecomment-453600364 @tillrohrmann I've checked out your branch. It looks good to me that making use of `YarnClusterDescriptor` and `Re

[GitHub] azagrebin commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

2019-01-11 Thread GitBox
azagrebin commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r247198953 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlIncrem

[GitHub] tillrohrmann commented on a change in pull request #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code…

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code… URL: https://github.com/apache/flink/pull/6953#discussion_r246423635 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNHighAvailabil

[jira] [Assigned] (FLINK-11292) Document how to use the new CompositeTypeSerializerSnapshot

2019-01-11 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-11292: Assignee: Yun Tang > Document how to use the new CompositeTypeSerializerSnapshot > --

[GitHub] caosuwenwu opened a new pull request #7472: hh

2019-01-11 Thread GitBox
caosuwenwu opened a new pull request #7472: hh URL: https://github.com/apache/flink/pull/7472 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring the

[GitHub] tillrohrmann closed pull request #7431: [BP-1.7] [FLINK-10848] Remove container requests after successful container allocation

2019-01-11 Thread GitBox
tillrohrmann closed pull request #7431: [BP-1.7] [FLINK-10848] Remove container requests after successful container allocation URL: https://github.com/apache/flink/pull/7431 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[GitHub] tillrohrmann closed pull request #7432: [BP-1.6] [FLINK-10848] Remove container requests after successful container allocation

2019-01-11 Thread GitBox
tillrohrmann closed pull request #7432: [BP-1.6] [FLINK-10848] Remove container requests after successful container allocation URL: https://github.com/apache/flink/pull/7432 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[GitHub] tillrohrmann closed pull request #7430: [FLINK-10848] Remove container requests after successful container allocation

2019-01-11 Thread GitBox
tillrohrmann closed pull request #7430: [FLINK-10848] Remove container requests after successful container allocation URL: https://github.com/apache/flink/pull/7430 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[jira] [Resolved] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

2019-01-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10848. --- Resolution: Fixed Fix Version/s: 1.8.0 1.7.2 1.6

[GitHub] tillrohrmann commented on issue #7430: [FLINK-10848] Remove container requests after successful container allocation

2019-01-11 Thread GitBox
tillrohrmann commented on issue #7430: [FLINK-10848] Remove container requests after successful container allocation URL: https://github.com/apache/flink/pull/7430#issuecomment-453547511 Thanks for the review @gjl and @kisimple. I will address your comments and then merge this PR. ---

[GitHub] tillrohrmann commented on a change in pull request #7430: [FLINK-10848] Remove container requests after successful container allocation

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7430: [FLINK-10848] Remove container requests after successful container allocation URL: https://github.com/apache/flink/pull/7430#discussion_r247146806 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlinkResourc

[jira] [Assigned] (FLINK-10822) Configurable MetricQueryService interval

2019-01-11 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10822: - Assignee: Till Rohrmann (was: Chesnay Schepler) > Configurable MetricQueryService inte

[GitHub] intsmaze opened a new pull request #7471: Update state.md

2019-01-11 Thread GitBox
intsmaze opened a new pull request #7471: Update state.md URL: https://github.com/apache/flink/pull/7471 ## What is the purpose of the change *invoke(Object) is deprecated, Use invoke(Object, Context) instead of it in the document * ## Brief change log - *in

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-10822] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-10822] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247116469 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metri

[GitHub] tillrohrmann commented on issue #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on issue #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#issuecomment-453542393 Thanks for the review @zentol and @zjffdu. I've addressed all your comments: - Renamed `MetricFetcher` into `Met

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247139436 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerC

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247139610 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerC

[jira] [Updated] (FLINK-11283) Accessing the key when processing connected keyed stream

2019-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11283: --- Labels: pull-request-available (was: ) > Accessing the key when processing connected keyed

[GitHub] yanghua opened a new pull request #7470: [FLINK-11283] Accessing the key when processing connected keyed stream

2019-01-11 Thread GitBox
yanghua opened a new pull request #7470: [FLINK-11283] Accessing the key when processing connected keyed stream URL: https://github.com/apache/flink/pull/7470 ## What is the purpose of the change *This pull request introduces a `CoKeyedProcessFunction` for keyed connected stream*

[GitHub] twalthr commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template.

2019-01-11 Thread GitBox
twalthr commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template. URL: https://github.com/apache/flink/pull/6873#discussion_r247130937 ## File path: .github/PULL_REQUEST_TEMPLATE.md ## @@ -70,3 +70,17 @@ This change added

[GitHub] blublinsky commented on issue #7446: Added Model serving - implementation of the Flip -23.

2019-01-11 Thread GitBox
blublinsky commented on issue #7446: Added Model serving - implementation of the Flip -23. URL: https://github.com/apache/flink/pull/7446#issuecomment-453532269 That is the only one that I know off Boris Lublinsky FDP Architect boris.lublin...@lightbend.com https://www.light

[GitHub] twalthr commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template.

2019-01-11 Thread GitBox
twalthr commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template. URL: https://github.com/apache/flink/pull/6873#discussion_r247130183 ## File path: .github/PULL_REQUEST_TEMPLATE.md ## @@ -70,3 +70,17 @@ This change added

[GitHub] KarmaGYZ opened a new pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-11 Thread GitBox
KarmaGYZ opened a new pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469 ## What is the purpose of the change This PR correct the usage of LOG.error ## Brief change log - Correct the usage of LOG.erro

[jira] [Closed] (FLINK-11308) flink sql In the case when statement has a large in statement error: class DataStreamCalcRule$1933 grows beyond 64 KB

2019-01-11 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11308. Resolution: Duplicate This is a duplicate of FLINK-8921. As a workaround people can always impleme

[jira] [Updated] (FLINK-11308) flink sql In the case when statement has a large in statement error: class DataStreamCalcRule$1933 grows beyond 64 KB

2019-01-11 Thread tivanli (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tivanli updated FLINK-11308: Description: flink sql In the case when statement has a large in statement bug. When using the "case when

[jira] [Created] (FLINK-11308) flink sql In the case when statement has a large in statement error: class DataStreamCalcRule$1933 grows beyond 64 KB

2019-01-11 Thread tivanli (JIRA)
tivanli created FLINK-11308: --- Summary: flink sql In the case when statement has a large in statement error: class DataStreamCalcRule$1933 grows beyond 64 KB Key: FLINK-11308 URL: https://issues.apache.org/jira/browse/FL

[GitHub] zjffdu commented on a change in pull request #7455: [FLINK-11288][build] Exclude flink-ml from flink-dist

2019-01-11 Thread GitBox
zjffdu commented on a change in pull request #7455: [FLINK-11288][build] Exclude flink-ml from flink-dist URL: https://github.com/apache/flink/pull/7455#discussion_r247116908 ## File path: flink-dist/src/main/assemblies/opt.xml ## @@ -75,14 +75,6 @@

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247116799 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntime

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247116469 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metri

[GitHub] zjffdu commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
zjffdu commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247115542 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonito

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247115144 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metri

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247114859 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerC

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247114976 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metri

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247114658 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerC

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247114609 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerC

[GitHub] tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
tillrohrmann commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247113839 ## File path: docs/_includes/generated/web_configuration.html ## @@ -52,6 +52,11 @@

[jira] [Updated] (FLINK-11307) Set up nightly tests with Java 9

2019-01-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11307: - Fix Version/s: 1.8.0 > Set up nightly tests with Java 9 > - > >

[jira] [Updated] (FLINK-11307) Set up nightly tests with Java 9

2019-01-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11307: - Summary: Set up nightly tests with Java 9 (was: Set up nightly to run Tests with Java 9 ) > Set up ni

[jira] [Assigned] (FLINK-11307) Set up nightly tests with Java 9

2019-01-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-11307: Assignee: Gary Yao > Set up nightly tests with Java 9 > - > >

[jira] [Created] (FLINK-11307) Set up nightly to run Tests with Java 9

2019-01-11 Thread Gary Yao (JIRA)
Gary Yao created FLINK-11307: Summary: Set up nightly to run Tests with Java 9 Key: FLINK-11307 URL: https://issues.apache.org/jira/browse/FLINK-11307 Project: Flink Issue Type: Test C

[jira] [Updated] (FLINK-11307) Set up nightly tests with Java 9

2019-01-11 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-11307: - Affects Version/s: 1.8.0 > Set up nightly tests with Java 9 > - > >

[GitHub] kl0u closed pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins.

2019-01-11 Thread GitBox
kl0u closed pull request #6871: [FLINK-10583][FLINK-10584][table] Add State Retention to temporal joins. URL: https://github.com/apache/flink/pull/6871 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenanc

[jira] [Closed] (FLINK-11306) Bump derby from 10.10.1.1 to 10.14.2.0

2019-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11306. Resolution: Fixed Fix Version/s: 1.8.0 master: 205f9064897bfcf5f8988d38deb5a407f9a7

[jira] [Updated] (FLINK-11306) Bump derby from 10.10.1.1 to 10.14.2.0

2019-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11306: - Component/s: (was: Core) Build System Batch Connect

[jira] [Updated] (FLINK-11306) Bump derby from 10.10.1.1 to 10.14.2.0

2019-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11306: - Issue Type: Improvement (was: Bug) > Bump derby from 10.10.1.1 to 10.14.2.0 > -

[jira] [Reopened] (FLINK-11306) Bump derby from 10.10.1.1 to 10.14.2.0

2019-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-11306: -- > Bump derby from 10.10.1.1 to 10.14.2.0 > -- > >

[jira] [Closed] (FLINK-11306) Bump derby from 10.10.1.1 to 10.14.2.0

2019-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11306. Resolution: Fixed > Bump derby from 10.10.1.1 to 10.14.2.0 > -

[GitHub] zentol closed pull request #7468: [FLINK-11306] Bump derby from 10.10.1.1 to 10.14.2.0

2019-01-11 Thread GitBox
zentol closed pull request #7468: [FLINK-11306] Bump derby from 10.10.1.1 to 10.14.2.0 URL: https://github.com/apache/flink/pull/7468 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a f

[jira] [Closed] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

2019-01-11 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-11301. --- Resolution: Fixed > Travis failed: No output has been received in the last 10m0s > -

[jira] [Commented] (FLINK-11301) Travis failed: No output has been received in the last 10m0s

2019-01-11 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16740321#comment-16740321 ] Hequn Cheng commented on FLINK-11301: - Sorry, it seems travis will overwrite the log

[GitHub] FaxianZhao commented on a change in pull request #7344: [FLINK-4369] Optimize evict performance for the TriggerResult.FIRE_AND_PURGE

2019-01-11 Thread GitBox
FaxianZhao commented on a change in pull request #7344: [FLINK-4369] Optimize evict performance for the TriggerResult.FIRE_AND_PURGE URL: https://github.com/apache/flink/pull/7344#discussion_r247088129 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runt

[GitHub] FaxianZhao commented on a change in pull request #7344: [FLINK-4369] Optimize evict performance for the TriggerResult.FIRE_AND_PURGE

2019-01-11 Thread GitBox
FaxianZhao commented on a change in pull request #7344: [FLINK-4369] Optimize evict performance for the TriggerResult.FIRE_AND_PURGE URL: https://github.com/apache/flink/pull/7344#discussion_r247088129 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runt

[GitHub] FaxianZhao commented on a change in pull request #7344: [FLINK-4369] Optimize evict performance for the TriggerResult.FIRE_AND_PURGE

2019-01-11 Thread GitBox
FaxianZhao commented on a change in pull request #7344: [FLINK-4369] Optimize evict performance for the TriggerResult.FIRE_AND_PURGE URL: https://github.com/apache/flink/pull/7344#discussion_r247087864 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runt

[jira] [Assigned] (FLINK-11292) Document how to use the new CompositeTypeSerializerSnapshot

2019-01-11 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-11292: --- Assignee: (was: Tzu-Li (Gordon) Tai) > Document how to use the new Comp

[GitHub] TisonKun commented on issue #7340: [FLINK-11174] [prometheus] Flink Metrics Prometheus label values supp…

2019-01-11 Thread GitBox
TisonKun commented on issue #7340: [FLINK-11174] [prometheus] Flink Metrics Prometheus label values supp… URL: https://github.com/apache/flink/pull/7340#issuecomment-453489843 @zentol thanks for your advice. Updated for addressing comments. Please give it a review later :-) --

[GitHub] zentol commented on issue #7454: [FLINK-11270] Update profiles

2019-01-11 Thread GitBox
zentol commented on issue #7454: [FLINK-11270] Update profiles URL: https://github.com/apache/flink/pull/7454#issuecomment-453483755 Test failures caused by queryable-state issue, which was fixed in https://github.com/apache/flink/commit/157a26724557b287b3dff5b9e24aff447acae824. --

[GitHub] TisonKun commented on a change in pull request #7340: [FLINK-11174] [prometheus] Flink Metrics Prometheus label values supp…

2019-01-11 Thread GitBox
TisonKun commented on a change in pull request #7340: [FLINK-11174] [prometheus] Flink Metrics Prometheus label values supp… URL: https://github.com/apache/flink/pull/7340#discussion_r247078640 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metr

[jira] [Commented] (FLINK-11220) Can not Select row time field in JOIN query

2019-01-11 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16740287#comment-16740287 ] sunjincheng commented on FLINK-11220: - Sounds Good![~dian.fu] , [~jark]   Looking f

[GitHub] zentol closed pull request #7467: Update state.md

2019-01-11 Thread GitBox
zentol closed pull request #7467: Update state.md URL: https://github.com/apache/flink/pull/7467 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork), the

[jira] [Updated] (FLINK-11154) Upgrade Netty to 4.1.32

2019-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11154: - Fix Version/s: shaded-6.0 > Upgrade Netty to 4.1.32 > --- > >

[GitHub] fhueske commented on issue #7446: Added Model serving - implementation of the Flip -23.

2019-01-11 Thread GitBox
fhueske commented on issue #7446: Added Model serving - implementation of the Flip -23. URL: https://github.com/apache/flink/pull/7446#issuecomment-453480280 Hi @blublinsky, thank you for this contribution! Model serving is a common requirement for many Flink users and it would be great to

[jira] [Commented] (FLINK-11154) Upgrade Netty to 4.1.32

2019-01-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16740283#comment-16740283 ] Chesnay Schepler commented on FLINK-11154: -- flink-shaded master: 735c20c1e63f65

[GitHub] zentol commented on a change in pull request #7340: [FLINK-11174] [prometheus] Flink Metrics Prometheus label values supp…

2019-01-11 Thread GitBox
zentol commented on a change in pull request #7340: [FLINK-11174] [prometheus] Flink Metrics Prometheus label values supp… URL: https://github.com/apache/flink/pull/7340#discussion_r247072481 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metric

[GitHub] fhueske commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template.

2019-01-11 Thread GitBox
fhueske commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template. URL: https://github.com/apache/flink/pull/6873#discussion_r247071123 ## File path: .github/PULL_REQUEST_TEMPLATE.md ## @@ -70,3 +70,17 @@ This change added

[GitHub] fhueske commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template.

2019-01-11 Thread GitBox
fhueske commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template. URL: https://github.com/apache/flink/pull/6873#discussion_r247069242 ## File path: .github/PULL_REQUEST_TEMPLATE.md ## @@ -70,3 +70,17 @@ This change added

[GitHub] zentol commented on a change in pull request #7340: [FLINK-11174] [prometheus] Flink Metrics Prometheus label values supp…

2019-01-11 Thread GitBox
zentol commented on a change in pull request #7340: [FLINK-11174] [prometheus] Flink Metrics Prometheus label values supp… URL: https://github.com/apache/flink/pull/7340#discussion_r247067028 ## File path: docs/monitoring/metrics.md ## @@ -652,7 +652,6 @@ of your Flink dis

[GitHub] zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247066292 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metrics/Met

[GitHub] zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247066277 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/metrics/Met

[GitHub] zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247063941 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerConfigu

[GitHub] zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247062924 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerConfigu

[GitHub] zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247062860 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerConfigu

[GitHub] zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
zentol commented on a change in pull request #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#discussion_r247062376 ## File path: docs/_includes/generated/web_configuration.html ## @@ -52,6 +52,11 @@

[GitHub] zentol commented on issue #7459: [FLINK-11300] Make MetricFetcher update interval configurable

2019-01-11 Thread GitBox
zentol commented on issue #7459: [FLINK-11300] Make MetricFetcher update interval configurable URL: https://github.com/apache/flink/pull/7459#issuecomment-453463107 Can you update the JIRA reference to FLINK-10822? I already created a JIRA for implementing this a while ago. -

[jira] [Reopened] (FLINK-11224) Log is missing in scala-shell

2019-01-11 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reopened FLINK-11224: -- > Log is missing in scala-shell > - > > Key: F

[jira] [Closed] (FLINK-11224) Log is missing in scala-shell

2019-01-11 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-11224. Resolution: Fixed Fix Version/s: 1.7.2 1.6.4 Fixed in 1.7.2 via:

[GitHub] twalthr commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template.

2019-01-11 Thread GitBox
twalthr commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template. URL: https://github.com/apache/flink/pull/6873#discussion_r247050725 ## File path: .github/PULL_REQUEST_TEMPLATE.md ## @@ -70,3 +70,17 @@ This change added

[GitHub] JaryZhen commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc

2019-01-11 Thread GitBox
JaryZhen commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#discussion_r247049869 ## File path: docs/dev/table/streaming/time_attributes.md ## @@ -317,9 +323,15 @@ class UserActionSource

[GitHub] JaryZhen commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc

2019-01-11 Thread GitBox
JaryZhen commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#discussion_r247049482 ## File path: docs/dev/table/streaming/time_attributes.md ## @@ -284,13 +284,19 @@ public class UserActi

[GitHub] twalthr commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template.

2019-01-11 Thread GitBox
twalthr commented on a change in pull request #6873: [hotfix] Add Review Progress section to PR description template. URL: https://github.com/apache/flink/pull/6873#discussion_r247050200 ## File path: .github/PULL_REQUEST_TEMPLATE.md ## @@ -70,3 +70,17 @@ This change added

[jira] [Closed] (FLINK-11224) Log is missing in scala-shell

2019-01-11 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-11224. Resolution: Fixed Fix Version/s: 1.8.0 Fixed via be4706171f68e487ce3f409232e829b681

[GitHub] KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc

2019-01-11 Thread GitBox
KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#discussion_r247047820 ## File path: docs/dev/table/streaming/time_attributes.md ## @@ -284,13 +284,19 @@ public class UserActi

[GitHub] KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc

2019-01-11 Thread GitBox
KarmaGYZ commented on a change in pull request #7466: [FLINK-11304] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#discussion_r247047906 ## File path: docs/dev/table/streaming/time_attributes.md ## @@ -317,9 +323,15 @@ class UserActionSource

[GitHub] dawidwys closed pull request #7371: [FLINK-11224][scala-shell] Log is missing in scala-shell

2019-01-11 Thread GitBox
dawidwys closed pull request #7371: [FLINK-11224][scala-shell] Log is missing in scala-shell URL: https://github.com/apache/flink/pull/7371 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this

[jira] [Updated] (FLINK-11306) Bump derby from 10.10.1.1 to 10.14.2.0

2019-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11306: --- Labels: pull-request-available (was: ) > Bump derby from 10.10.1.1 to 10.14.2.0 > -

[GitHub] JaryZhen commented on issue #7466: [FLINK-11304] Fix typo in time attributes doc

2019-01-11 Thread GitBox
JaryZhen commented on issue #7466: [FLINK-11304] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#issuecomment-453445002 @KarmaGYZ Thanks, I fixed that :) This is an automated message from the Apa

[GitHub] JaryZhen removed a comment on issue #7466: [FLINK-11304] Fix typo in time attributes doc

2019-01-11 Thread GitBox
JaryZhen removed a comment on issue #7466: [FLINK-11304] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#issuecomment-453440345 I don't know why this happened while in doc is right but in **md** not ![image](https://user-images.githubusercontent.com/132161

  1   2   >