[GitHub] [flink] StefanRRichter commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

StefanRRichter commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298170108 ## File path:

[GitHub] [flink] sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298169905 ## File path: pom.xml ## @@ -82,11 +81,13 @@ under the License.

[jira] [Created] (FLINK-13019) IT test for fine-grained recovery

Andrey Zagrebin created FLINK-13019: --- Summary: IT test for fine-grained recovery Key: FLINK-13019 URL: https://issues.apache.org/jira/browse/FLINK-13019 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13018) Serving docs locally with jekyll fails with inotify limit

Nico Kruber created FLINK-13018: --- Summary: Serving docs locally with jekyll fails with inotify limit Key: FLINK-13018 URL: https://issues.apache.org/jira/browse/FLINK-13018 Project: Flink

[GitHub] [flink] wuchong commented on a change in pull request #8850: [FLINK-12954] Supports create(drop) view grammar for sql parser

wuchong commented on a change in pull request #8850: [FLINK-12954] Supports create(drop) view grammar for sql parser URL: https://github.com/apache/flink/pull/8850#discussion_r298160404 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8850: [FLINK-12954] Supports create(drop) view grammar for sql parser

wuchong commented on a change in pull request #8850: [FLINK-12954] Supports create(drop) view grammar for sql parser URL: https://github.com/apache/flink/pull/8850#discussion_r298130713 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

StefanRRichter commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298162033 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8850: [FLINK-12954] Supports create(drop) view grammar for sql parser

wuchong commented on a change in pull request #8850: [FLINK-12954] Supports create(drop) view grammar for sql parser URL: https://github.com/apache/flink/pull/8850#discussion_r298161597 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl

[GitHub] [flink] lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#issuecomment-506333942 cc @bowenli86 @xuefuz @zjuwangg This is an automated message

[GitHub] [flink] lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#issuecomment-506333597 Here's [build result](https://travis-ci.org/lirui-apache/flink/builds/551257514) of my own repo. The connector_hive_1 failed as

[GitHub] [flink] flinkbot commented on issue #8917: [FLINK-13017][docs] do not mount local $HOME into docker

flinkbot commented on issue #8917: [FLINK-13017][docs] do not mount local $HOME into docker URL: https://github.com/apache/flink/pull/8917#issuecomment-506330683 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] NicoK opened a new pull request #8917: [FLINK-13017][docs] do not mount local $HOME into docker

NicoK opened a new pull request #8917: [FLINK-13017][docs] do not mount local $HOME into docker URL: https://github.com/apache/flink/pull/8917 ## What is the purpose of the change Remove the (writable!) mount of a user's $HOME into the dockerized documentation build container in

[jira] [Updated] (FLINK-13017) Broken and irreproducible dockerized docs build

[ https://issues.apache.org/jira/browse/FLINK-13017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13017: --- Labels: pull-request-available (was: ) > Broken and irreproducible dockerized docs build >

[GitHub] [flink] 1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298150038 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298146026 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298135855 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298130215 ## File path:

[jira] [Updated] (FLINK-13017) Broken and irreproducible dockerized docs build

[ https://issues.apache.org/jira/browse/FLINK-13017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-13017: Description: The build tools around {{docs/docker}} seem broken and (on my machine) give errors

[GitHub] [flink] 1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298133778 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298148314 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298153219 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298125132 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java

[GitHub] [flink] 1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService

1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService URL: https://github.com/apache/flink/pull/8692#discussion_r298128321 ## File path:

[GitHub] [flink] WeiZhong94 commented on issue #8910: [hotfix][python] Aligns with Java Table API by removing methods exec_env and query_config

WeiZhong94 commented on issue #8910: [hotfix][python] Aligns with Java Table API by removing methods exec_env and query_config URL: https://github.com/apache/flink/pull/8910#issuecomment-506327614 LGTM, +1 This is an

[GitHub] [flink] flinkbot commented on issue #8916: [FLINK-12897][python][docs] Improve the Python Table API docs by adding more examples

flinkbot commented on issue #8916: [FLINK-12897][python][docs] Improve the Python Table API docs by adding more examples URL: https://github.com/apache/flink/pull/8916#issuecomment-506327371 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-12897) Improve the Python Table API docs by adding more examples

[ https://issues.apache.org/jira/browse/FLINK-12897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12897: --- Labels: pull-request-available (was: ) > Improve the Python Table API docs by adding more

[GitHub] [flink] flinkbot commented on issue #8915: [FLINK-13015][table-api-java] Create validators, strategies and transformations required for porting logical expressions

flinkbot commented on issue #8915: [FLINK-13015][table-api-java] Create validators, strategies and transformations required for porting logical expressions URL: https://github.com/apache/flink/pull/8915#issuecomment-506326938 Thanks a lot for your contribution to the Apache Flink

[GitHub] [flink] WeiZhong94 opened a new pull request #8916: [FLINK-12897][python][docs] Improve the Python Table API docs by adding more examples

WeiZhong94 opened a new pull request #8916: [FLINK-12897][python][docs] Improve the Python Table API docs by adding more examples URL: https://github.com/apache/flink/pull/8916 ## What is the purpose of the change *This pull request add more Python Table API and relevant

[jira] [Resolved] (FLINK-9728) Wrong ruby version for building flink docs in docker container

[ https://issues.apache.org/jira/browse/FLINK-9728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-9728. Resolution: Duplicate > Wrong ruby version for building flink docs in docker container >

[GitHub] [flink] zentol merged pull request #8902: [hotfix][docs] fix wrong link in streamfile_sink

zentol merged pull request #8902: [hotfix][docs] fix wrong link in streamfile_sink URL: https://github.com/apache/flink/pull/8902 This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

[ https://issues.apache.org/jira/browse/FLINK-13015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13015: --- Labels: pull-request-available (was: ) > Create validators, strategies and transformations

[GitHub] [flink] dawidwys opened a new pull request #8915: [FLINK-13015][table-api-java] Create validators, strategies and transformations required for porting logical expressions

dawidwys opened a new pull request #8915: [FLINK-13015][table-api-java] Create validators, strategies and transformations required for porting logical expressions URL: https://github.com/apache/flink/pull/8915 ## What is the purpose of the change Create validators, strategies and

[jira] [Created] (FLINK-13017) Broken and irreproducible dockerized docs build

Nico Kruber created FLINK-13017: --- Summary: Broken and irreproducible dockerized docs build Key: FLINK-13017 URL: https://issues.apache.org/jira/browse/FLINK-13017 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-12980) Getting Started - Add Top-Level Section to Existing Documentation

[ https://issues.apache.org/jira/browse/FLINK-12980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-12980. - Resolution: Fixed Fix Version/s: 1.9.0 Merged in master via

[GitHub] [flink] NicoK merged pull request #8873: [FLINK-12639] [docs] add "getting started" section to documentation

NicoK merged pull request #8873: [FLINK-12639] [docs] add "getting started" section to documentation URL: https://github.com/apache/flink/pull/8873 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] sjwiesman commented on a change in pull request #8861: [FLINK-12963][state-processor-api] Add savepoint writer for bootstrapping new savepoints

sjwiesman commented on a change in pull request #8861: [FLINK-12963][state-processor-api] Add savepoint writer for bootstrapping new savepoints URL: https://github.com/apache/flink/pull/8861#discussion_r298141523 ## File path:

[GitHub] [flink] NicoK commented on issue #8873: [FLINK-12639] [docs] add "getting started" section to documentation

NicoK commented on issue #8873: [FLINK-12639] [docs] add "getting started" section to documentation URL: https://github.com/apache/flink/pull/8873#issuecomment-506317642 @flinkbot approve all This is an automated message

[GitHub] [flink] sjwiesman commented on a change in pull request #8861: [FLINK-12963][state-processor-api] Add savepoint writer for bootstrapping new savepoints

sjwiesman commented on a change in pull request #8861: [FLINK-12963][state-processor-api] Add savepoint writer for bootstrapping new savepoints URL: https://github.com/apache/flink/pull/8861#discussion_r298141103 ## File path:

[GitHub] [flink] azagrebin edited a comment on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

azagrebin edited a comment on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#issuecomment-506313023 @StephanEwen Thanks for bringing this up. As @zhijiangW already described, true,

[GitHub] [flink] azagrebin edited a comment on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

azagrebin edited a comment on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#issuecomment-506313023 @StephanEwen Thanks for bringing this up. As @zhijiangW already described, true,

[GitHub] [flink] azagrebin commented on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

azagrebin commented on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#issuecomment-506313023 @StephanEwen Thanks for bringing this up. True, the idea was to drop `IOManager`

[jira] [Updated] (FLINK-11662) Discarded checkpoint can cause Tasks to fail

[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11662: --- Labels: pull-request-available (was: ) > Discarded checkpoint can cause Tasks to fail >

[jira] [Closed] (FLINK-11662) Discarded checkpoint can cause Tasks to fail

[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-11662. -- Resolution: Fixed Fix Version/s: 1.9.0 Merged in: master: b760d55 > Discarded

[GitHub] [flink] StefanRRichter merged pull request #8745: [FLINK-11662] Disable task to fail on checkpoint errors

StefanRRichter merged pull request #8745: [FLINK-11662] Disable task to fail on checkpoint errors URL: https://github.com/apache/flink/pull/8745 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] zhijiangW commented on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

zhijiangW commented on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#issuecomment-506310994 @StephanEwen thanks for sharing the background and bringing this concern! The abstract

[GitHub] [flink] zhijiangW edited a comment on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

zhijiangW edited a comment on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#issuecomment-506310994 @StephanEwen thanks for sharing the background and bringing this concern! The

[jira] [Created] (FLINK-13016) StreamTaskNetworkInput can linger records for longer period of times

Piotr Nowojski created FLINK-13016: -- Summary: StreamTaskNetworkInput can linger records for longer period of times Key: FLINK-13016 URL: https://issues.apache.org/jira/browse/FLINK-13016 Project:

[GitHub] [flink] flinkbot commented on issue #8914: [FLINK-12929] Pass TypeInformation in addSource

flinkbot commented on issue #8914: [FLINK-12929] Pass TypeInformation in addSource URL: https://github.com/apache/flink/pull/8914#issuecomment-506309273 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[jira] [Updated] (FLINK-12929) scala.StreamExecutionEnvironment.addSource does not propagate TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-12929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12929: --- Labels: pull-request-available (was: ) > scala.StreamExecutionEnvironment.addSource does

[jira] [Resolved] (FLINK-12784) Support retention policy for InfluxDB metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-12784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-12784. - Resolution: Fixed Fix Version/s: 1.9.0 Merged in master via

[GitHub] [flink] lombarde opened a new pull request #8914: [FLINK-12929] Pass TypeInformation in addSource

lombarde opened a new pull request #8914: [FLINK-12929] Pass TypeInformation in addSource URL: https://github.com/apache/flink/pull/8914 Co-authored-by: Georg Rollinger ## What is the purpose of the change Fixes https://issues.apache.org/jira/browse/FLINK-12929:

[GitHub] [flink] flinkbot commented on issue #8913: [FLINK-12968][table-common] Preparation for more casting utilities

flinkbot commented on issue #8913: [FLINK-12968][table-common] Preparation for more casting utilities URL: https://github.com/apache/flink/pull/8913#issuecomment-506308460 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] NicoK merged pull request #8668: [FLINK-12784][metrics] Support retention policy for InfluxDB metrics …

NicoK merged pull request #8668: [FLINK-12784][metrics] Support retention policy for InfluxDB metrics … URL: https://github.com/apache/flink/pull/8668 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] ifndef-SleePy edited a comment on issue #8870: [FLINK-12974][checkstyle] Bump checkstyle to 8.14

ifndef-SleePy edited a comment on issue #8870: [FLINK-12974][checkstyle] Bump checkstyle to 8.14 URL: https://github.com/apache/flink/pull/8870#issuecomment-506306235 @hmcl You mean downgrade to an earlier version? I don't think it's a good choice to use an older version. Because I

[GitHub] [flink] twalthr opened a new pull request #8913: [FLINK-12968][table-common] Preparation for more casting utilities

twalthr opened a new pull request #8913: [FLINK-12968][table-common] Preparation for more casting utilities URL: https://github.com/apache/flink/pull/8913 What is the purpose of the change Adds some utilities for more casting utilities and fixes a bug. ## Brief change log

[GitHub] [flink] flinkbot commented on issue #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy…

flinkbot commented on issue #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#issuecomment-506306353 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] ifndef-SleePy commented on issue #8870: [FLINK-12974][checkstyle] Bump checkstyle to 8.14

ifndef-SleePy commented on issue #8870: [FLINK-12974][checkstyle] Bump checkstyle to 8.14 URL: https://github.com/apache/flink/pull/8870#issuecomment-506306235 @hmcl You mean downgrade to an earlier version? I don't think it's a good choice to use an older version. Because I believe 8.12

[jira] [Updated] (FLINK-12709) Implement RestartBackoffTimeStrategyFactoryLoader

[ https://issues.apache.org/jira/browse/FLINK-12709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12709: --- Labels: pull-request-available (was: ) > Implement RestartBackoffTimeStrategyFactoryLoader

[GitHub] [flink] zhuzhurk opened a new pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy…

zhuzhurk opened a new pull request #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912 … restart strategy configs ## What is the purpose of the change *A loader is need to

[GitHub] [flink] asfgit closed pull request #8530: [FLINK-12611][table-planner-blink] Make time indicator nullable in blink

asfgit closed pull request #8530: [FLINK-12611][table-planner-blink] Make time indicator nullable in blink URL: https://github.com/apache/flink/pull/8530 This is an automated message from the Apache Git Service. To respond

[jira] [Closed] (FLINK-12611) Make time indicator nullable in blink

[ https://issues.apache.org/jira/browse/FLINK-12611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12611. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: dac9f78658efda3339977e05591989cc363f3722 >

[jira] [Created] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

Dawid Wysakowicz created FLINK-13015: Summary: Create validators, strategies and transformations required for porting logical expressions Key: FLINK-13015 URL:

[jira] [Updated] (FLINK-13014) ChainBreakTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun updated FLINK-13014: -- Description: Log: [https://api.travis-ci.org/v3/job/551094138/log.txt]   07:12:52.246 [ERROR] Tests

[jira] [Created] (FLINK-13014) ChainBreakTest failed on Travis

Haibo Sun created FLINK-13014: - Summary: ChainBreakTest failed on Travis Key: FLINK-13014 URL: https://issues.apache.org/jira/browse/FLINK-13014 Project: Flink Issue Type: Bug

[GitHub] [flink] StephanEwen commented on issue #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

StephanEwen commented on issue #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#issuecomment-506298639 @zhijiangW Thanks, these are very good comments. Some answers in line. > Maybe we

[jira] [Comment Edited] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873124#comment-16873124 ] Xulang Wan edited comment on FLINK-11774 at 6/27/19 10:55 AM: -- I also

[jira] [Updated] (FLINK-12996) Add predefined type validators, strategies, and transformations

[ https://issues.apache.org/jira/browse/FLINK-12996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-12996: - Affects Version/s: 1.9.0 > Add predefined type validators, strategies, and

[jira] [Updated] (FLINK-12996) Add predefined type validators, strategies, and transformations

[ https://issues.apache.org/jira/browse/FLINK-12996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-12996: - Fix Version/s: 1.9.0 > Add predefined type validators, strategies, and transformations

[GitHub] [flink] mans2singh commented on a change in pull request #8668: [FLINK-12784][metrics] Support retention policy for InfluxDB metrics …

mans2singh commented on a change in pull request #8668: [FLINK-12784][metrics] Support retention policy for InfluxDB metrics … URL: https://github.com/apache/flink/pull/8668#discussion_r298117923 ## File path:

[jira] [Comment Edited] (FLINK-12848) Method equals() in RowTypeInfo should consider fieldsNames

[ https://issues.apache.org/jira/browse/FLINK-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873996#comment-16873996 ] Jark Wu edited comment on FLINK-12848 at 6/27/19 10:40 AM: --- Thanks

[GitHub] [flink] StephanEwen commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

StephanEwen commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#discussion_r298114249 ## File path:

[jira] [Commented] (FLINK-12848) Method equals() in RowTypeInfo should consider fieldsNames

[ https://issues.apache.org/jira/browse/FLINK-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873996#comment-16873996 ] Jark Wu commented on FLINK-12848: - Thanks [~aloyszhang] for the debugging. So let's target this issue to

[GitHub] [flink] StephanEwen commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

StephanEwen commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#discussion_r298113422 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

StephanEwen commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#discussion_r298112193 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

StephanEwen commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#discussion_r298111597 ## File path:

[jira] [Commented] (FLINK-13004) Correct the logic of needToCleanupState in KeyedProcessFunctionWithCleanupState

[ https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873994#comment-16873994 ] Jark Wu commented on FLINK-13004: - [~yunta] (y) > Correct the logic of needToCleanupState in >

[jira] [Commented] (FLINK-12536) Make BufferOrEventSequence#getNext() non-blocking

[ https://issues.apache.org/jira/browse/FLINK-12536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873993#comment-16873993 ] Stephan Ewen commented on FLINK-12536: -- Can you guys share why you believe this is important to

[GitHub] [flink] wuchong commented on a change in pull request #8909: [FLINK-13004][table-runtime-blink] Correct the logic of needToCleanupState in KeyedProcessFunctionWithCleanupState

wuchong commented on a change in pull request #8909: [FLINK-13004][table-runtime-blink] Correct the logic of needToCleanupState in KeyedProcessFunctionWithCleanupState URL: https://github.com/apache/flink/pull/8909#discussion_r298108636 ## File path:

[GitHub] [flink] zjuwangg commented on issue #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

zjuwangg commented on issue #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#issuecomment-506284860 @bowenli86 Sorry a little late to update this pr, please review again when you have time.

[GitHub] [flink] zjuwangg commented on issue #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

zjuwangg commented on issue #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#issuecomment-506284600 rebase and force to push This is an

[GitHub] [flink] StephanEwen commented on a change in pull request #8886: [FLINK-12987][metrics] fix DescriptiveStatisticsHistogram#getCount() not returning the number of elements seen

StephanEwen commented on a change in pull request #8886: [FLINK-12987][metrics] fix DescriptiveStatisticsHistogram#getCount() not returning the number of elements seen URL: https://github.com/apache/flink/pull/8886#discussion_r298101578 ## File path:

[jira] [Updated] (FLINK-13013) Make sure that SingleInputGate can always request partitions

[ https://issues.apache.org/jira/browse/FLINK-13013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13013: --- Description: Currently {{SingleInputGate}} requests partitions only on the first attempt to

[GitHub] [flink] aljoscha commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema

aljoscha commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema URL: https://github.com/apache/flink/pull/8371#issuecomment-506282454 @Wosin could you please rebase and squash the various commits into some commits that make sense, i.e. separate pre-requisites like version

[GitHub] [flink] StephanEwen commented on issue #8877: [FLINK-12984][metrics] only call Histogram#getStatistics() once where possible

StephanEwen commented on issue #8877: [FLINK-12984][metrics] only call Histogram#getStatistics() once where possible URL: https://github.com/apache/flink/pull/8877#issuecomment-506281800 Looks good in general. What is a bit strange is that the dropwizard metrics now have

[jira] [Created] (FLINK-13013) Make sure that SingleInputGate can always request partitions

Piotr Nowojski created FLINK-13013: -- Summary: Make sure that SingleInputGate can always request partitions Key: FLINK-13013 URL: https://issues.apache.org/jira/browse/FLINK-13013 Project: Flink

[jira] [Commented] (FLINK-13013) Make sure that SingleInputGate can always request partitions

[ https://issues.apache.org/jira/browse/FLINK-13013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873978#comment-16873978 ] Piotr Nowojski commented on FLINK-13013: As a hotfix we are attempting to always wake up

[GitHub] [flink] StephanEwen commented on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

StephanEwen commented on issue #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#issuecomment-506278154 Sorry for jumping in late. Initially, we added this dependency to make it possible

[GitHub] [flink] knaufk commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

knaufk commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/8741#discussion_r298093759 ## File path:

[GitHub] [flink] NicoK commented on a change in pull request #8668: [FLINK-12784][metrics] Support retention policy for InfluxDB metrics …

NicoK commented on a change in pull request #8668: [FLINK-12784][metrics] Support retention policy for InfluxDB metrics … URL: https://github.com/apache/flink/pull/8668#discussion_r298092960 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

knaufk commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/8741#discussion_r298093759 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

zhijiangW commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#discussion_r298093109 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8779: [FLINK-12882][network] Remove ExecutionAttemptID argument from ResultPartitionFactory#create

flinkbot edited a comment on issue #8779: [FLINK-12882][network] Remove ExecutionAttemptID argument from ResultPartitionFactory#create URL: https://github.com/apache/flink/pull/8779#issuecomment-503009589 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] azagrebin commented on issue #8779: [FLINK-12882][network] Remove ExecutionAttemptID argument from ResultPartitionFactory#create

azagrebin commented on issue #8779: [FLINK-12882][network] Remove ExecutionAttemptID argument from ResultPartitionFactory#create URL: https://github.com/apache/flink/pull/8779#issuecomment-506270426 @flinkbot approve all

[GitHub] [flink] dianfu commented on issue #8910: [hotfix][python] Aligns with Java Table API by removing methods exec_env and query_config

dianfu commented on issue #8910: [hotfix][python] Aligns with Java Table API by removing methods exec_env and query_config URL: https://github.com/apache/flink/pull/8910#issuecomment-506268938 @WeiZhong94 Thanks a lot for the review. Updated.

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8910: [hotfix][python] Aligns with Java Table API by removing methods exec_env and query_config

WeiZhong94 commented on a change in pull request #8910: [hotfix][python] Aligns with Java Table API by removing methods exec_env and query_config URL: https://github.com/apache/flink/pull/8910#discussion_r298081292 ## File path: flink-python/pyflink/shell.py ## @@ -84,7

[GitHub] [flink] Wosin commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema

Wosin commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema URL: https://github.com/apache/flink/pull/8371#issuecomment-506265879 Hey, Any update on this ?? This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

flinkbot commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#issuecomment-506262493 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-12995) Add Hive-1.2.1 build to Travis

[ https://issues.apache.org/jira/browse/FLINK-12995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12995: --- Labels: pull-request-available (was: ) > Add Hive-1.2.1 build to Travis >

[GitHub] [flink] lirui-apache opened a new pull request #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

lirui-apache opened a new pull request #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911 ## What is the purpose of the change To add Hive-1.2.1 build to Travis. ## Brief change log - Added a Travis

[jira] [Commented] (FLINK-12751) Create file based HA support

[ https://issues.apache.org/jira/browse/FLINK-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873929#comment-16873929 ] Boris Lublinsky commented on FLINK-12751: - Although the kubelet can die, if the node is alive,

<    1   2   3   4   >