[GitHub] [flink] flinkbot commented on issue #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37

2019-07-26 Thread GitBox
flinkbot commented on issue #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37 URL: https://github.com/apache/flink/pull/9243#issuecomment-515486131 ## CI report: * ae2528ac686c28a60641e8ea295221a510043e76 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded.

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded. URL: https://github.com/apache/flink/pull/9240#issuecomment-515444385 ## CI report: * 183d83b2c0abf0804c8ce3b68c3546cd05b46741 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9244: [FLINK-13396] Deprecate the BucketingSink.

2019-07-26 Thread GitBox
flinkbot commented on issue #9244: [FLINK-13396] Deprecate the BucketingSink. URL: https://github.com/apache/flink/pull/9244#issuecomment-515493269 ## CI report: * 8e3b712c5c2e003747737d2fb77752a3e10a3279 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/120873450)

[GitHub] [flink] flinkbot edited a comment on issue #9022: [FLINK-13127] Fix --yarnship classpath

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9022: [FLINK-13127] Fix --yarnship classpath URL: https://github.com/apache/flink/pull/9022#issuecomment-512166531 ## CI report: * 277d92daa0e31cc2fced052a1b311cdba0f567e1 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/119436815)

[jira] [Updated] (FLINK-13334) Remove legacy implementation of slot

2019-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13334: --- Labels: pull-request-available (was: ) > Remove legacy implementation of slot >

[jira] [Commented] (FLINK-13436) Add TPC-H queries as E2E tests

2019-07-26 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893934#comment-16893934 ] Xuefu Zhang commented on FLINK-13436: - Maybe we can use Hive data for this, which can verify both

[GitHub] [flink] tillrohrmann commented on a change in pull request #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance.

2019-07-26 Thread GitBox
tillrohrmann commented on a change in pull request #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance. URL: https://github.com/apache/flink/pull/9105#discussion_r307803611 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance.

2019-07-26 Thread GitBox
tillrohrmann commented on a change in pull request #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance. URL: https://github.com/apache/flink/pull/9105#discussion_r307806934 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance.

2019-07-26 Thread GitBox
tillrohrmann commented on a change in pull request #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance. URL: https://github.com/apache/flink/pull/9105#discussion_r307805904 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance.

2019-07-26 Thread GitBox
tillrohrmann commented on a change in pull request #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance. URL: https://github.com/apache/flink/pull/9105#discussion_r307803681 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9132: [FLINK-13245][network] Fix the bug of file resource leak while canceling partition request

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9132: [FLINK-13245][network] Fix the bug of file resource leak while canceling partition request URL: https://github.com/apache/flink/pull/9132#issuecomment-511875353 ## CI report: * 3f40e06e867f0b661c62e8ba690156b3819135d5 : FAILURE

[GitHub] [flink] xuefuz commented on a change in pull request #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37

2019-07-26 Thread GitBox
xuefuz commented on a change in pull request #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37 URL: https://github.com/apache/flink/pull/9239#discussion_r307836551 ## File path: docs/dev/table/catalog.md ## @@ -179,10 +179,11 @@ Currently `HiveCatalog`

[GitHub] [flink] StephanEwen commented on issue #9170: [FLINK-13325][test] Add test to guard the fix for FLINK-13249

2019-07-26 Thread GitBox
StephanEwen commented on issue #9170: [FLINK-13325][test] Add test to guard the fix for FLINK-13249 URL: https://github.com/apache/flink/pull/9170#issuecomment-515535529 I validated that the test indeed fails without the original fix. Will address @zhijiangW's comments and merge

[GitHub] [flink] flinkbot edited a comment on issue #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig URL: https://github.com/apache/flink/pull/9212#issuecomment-514486972 ## CI report: * 68443427c89cca6ef5c1c39685c57c9884e101af : FAILURE

[jira] [Commented] (FLINK-13387) Can not download taskmanger & jobmanager's logs in the old UI

2019-07-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894221#comment-16894221 ] vinoyang commented on FLINK-13387: -- [~Zentol] OK, Glad to sound this message. > Can not download

[GitHub] [flink] yanghua edited a comment on issue #9238: [FLINK-13387][WebUI] Fix log download for old UI

2019-07-26 Thread GitBox
yanghua edited a comment on issue #9238: [FLINK-13387][WebUI] Fix log download for old UI URL: https://github.com/apache/flink/pull/9238#issuecomment-515641316 Hi @zentol When clicking the download button, the behavior is that it will open a new web page and show the content of the whole

[GitHub] [flink] yanghua commented on issue #9238: [FLINK-13387][WebUI] Fix log download for old UI

2019-07-26 Thread GitBox
yanghua commented on issue #9238: [FLINK-13387][WebUI] Fix log download for old UI URL: https://github.com/apache/flink/pull/9238#issuecomment-515641316 Hi @zentol When clicking the download button, the behavior is open a new web page and show the content of the whole log file. There is a

[GitHub] [flink] danny0405 commented on issue #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig

2019-07-26 Thread GitBox
danny0405 commented on issue #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig URL: https://github.com/apache/flink/pull/9212#issuecomment-515641356 Hi @twalthr , i have updated for your review address, please review again if you have time, thanks ~

[GitHub] [flink] danny0405 commented on a change in pull request #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig

2019-07-26 Thread GitBox
danny0405 commented on a change in pull request #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig URL: https://github.com/apache/flink/pull/9212#discussion_r307948160 ## File path:

[jira] [Commented] (FLINK-13432) Set max polling interval threshold for job result polling

2019-07-26 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894226#comment-16894226 ] vinoyang commented on FLINK-13432: -- [~zjffdu] I think it's reasonable. cc [~aljoscha] > Set max

[jira] [Commented] (FLINK-13273) Allow switching planners in SQL Client

2019-07-26 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894235#comment-16894235 ] Tzu-Li (Gordon) Tai commented on FLINK-13273: - It seems like the decision is to include this

[GitHub] [flink] flinkbot edited a comment on issue #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37 URL: https://github.com/apache/flink/pull/9243#issuecomment-515486131 ## CI report: * ae2528ac686c28a60641e8ea295221a510043e76 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9243: [FLINK-13335][sql-parser] Align the SQL CREATE TABLE DDL with FLIP-37 URL: https://github.com/apache/flink/pull/9243#issuecomment-515486131 ## CI report: * ae2528ac686c28a60641e8ea295221a510043e76 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig URL: https://github.com/apache/flink/pull/9212#issuecomment-514486972 ## CI report: * 68443427c89cca6ef5c1c39685c57c9884e101af : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig URL: https://github.com/apache/flink/pull/9212#issuecomment-514486972 ## CI report: * 68443427c89cca6ef5c1c39685c57c9884e101af : FAILURE

[jira] [Created] (FLINK-13444) Translate English content of FLINK-13396 into Chinese

2019-07-26 Thread Jark Wu (JIRA)
Jark Wu created FLINK-13444: --- Summary: Translate English content of FLINK-13396 into Chinese Key: FLINK-13444 URL: https://issues.apache.org/jira/browse/FLINK-13444 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-13159) java.lang.ClassNotFoundException when restore job

2019-07-26 Thread Liu Bo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894254#comment-16894254 ] Liu Bo commented on FLINK-13159: I'm using flink 1.8.1 on yarn session with rocksdb as state backend.

[jira] [Updated] (FLINK-13334) Remove legacy slot implementation

2019-07-26 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-13334: - Summary: Remove legacy slot implementation (was: Remove legacy implementation of slot) > Remove

[GitHub] [flink] flinkbot edited a comment on issue #9245: [FLINK-13334][coordination] Remove legacy implementation of slot

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9245: [FLINK-13334][coordination] Remove legacy implementation of slot URL: https://github.com/apache/flink/pull/9245#issuecomment-515507399 ## CI report: * 2c7c67a0d15016887e9c917fee0bfe34e9d0e131 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9245: [FLINK-13334][coordination] Remove legacy implementation of slot

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9245: [FLINK-13334][coordination] Remove legacy implementation of slot URL: https://github.com/apache/flink/pull/9245#issuecomment-515507399 ## CI report: * 2c7c67a0d15016887e9c917fee0bfe34e9d0e131 : FAILURE

[jira] [Updated] (FLINK-13444) Translate English content of FLINK-13396 into Chinese

2019-07-26 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13444: Issue Type: Sub-task (was: Task) Parent: FLINK-11529 > Translate English content of FLINK-13396

[GitHub] [flink] flinkbot edited a comment on issue #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9212: [FLINK-13338][table-api] Sql conformance is hard to config in TableConfig URL: https://github.com/apache/flink/pull/9212#issuecomment-514486972 ## CI report: * 68443427c89cca6ef5c1c39685c57c9884e101af : FAILURE

[jira] [Commented] (FLINK-13376) FileInputFormat can not be used in batch mode of blink-planner

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893445#comment-16893445 ] Till Rohrmann commented on FLINK-13376: --- [~pnowojski] please help with the review. >

[jira] [Assigned] (FLINK-13384) The back pressure monitoring does not work for StreamSources

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13384: - Assignee: Gary Yao (was: Dawid Wysakowicz) > The back pressure monitoring does not

[jira] [Closed] (FLINK-13397) Remove RollingSink

2019-07-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-13397. Resolution: Done Removed on release-1.9 in 7f386fda8673533aeb0a8e67b54c1c516a55d404

[jira] [Assigned] (FLINK-13399) Create two separate uber jars for each planner

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13399: - Assignee: Dawid Wysakowicz (was: Timo Walther) > Create two separate uber jars for

[jira] [Commented] (FLINK-13325) Add test case for FLINK-13249

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893455#comment-16893455 ] Till Rohrmann commented on FLINK-13325: --- Please take a look at the PR [~zjwang] > Add test case

[jira] [Updated] (FLINK-13427) HiveCatalog's createFunction fails when function name has upper-case characters

2019-07-26 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13427: - Summary: HiveCatalog's createFunction fails when function name has upper-case

[jira] [Assigned] (FLINK-13374) flink-table-planner-blink compile failed for scala-2.12 on travis

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13374: - Assignee: Chesnay Schepler > flink-table-planner-blink compile failed for scala-2.12

[jira] [Commented] (FLINK-13325) Add test case for FLINK-13249

2019-07-26 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893462#comment-16893462 ] zhijiang commented on FLINK-13325: -- Yes, I already reviewed this PR several days ago. Waiting for the

[jira] [Assigned] (FLINK-13421) Unexpected ConcurrentModificationException when RM notifies JM about allocation failure

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13421: - Assignee: Till Rohrmann > Unexpected ConcurrentModificationException when RM notifies

[jira] [Commented] (FLINK-9526) BucketingSink end-to-end test failed on Travis

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893461#comment-16893461 ] Till Rohrmann commented on FLINK-9526: -- [~kkl0u] will take a look at the PR. > BucketingSink

[jira] [Assigned] (FLINK-13421) Unexpected ConcurrentModificationException when RM notifies JM about allocation failure

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13421: - Assignee: Xintong Song (was: Till Rohrmann) > Unexpected

[jira] [Assigned] (FLINK-13390) Clarify the exact meaning of state size when executing incremental checkpoint

2019-07-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-13390: - Assignee: Yun Tang > Clarify the exact meaning of state size when executing

[jira] [Commented] (FLINK-13390) Clarify the exact meaning of state size when executing incremental checkpoint

2019-07-26 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893469#comment-16893469 ] Fabian Hueske commented on FLINK-13390: --- Sure, happy to do so [~yunta]! Thank you :) > Clarify

[jira] [Assigned] (FLINK-13408) Schedule StandaloneResourceManager.setFailUnfulfillableRequest whenever the leadership is acquired

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13408: - Assignee: Xintong Song (was: Xintong (abandoned)) > Schedule

[jira] [Assigned] (FLINK-10368) 'Kerberized YARN on Docker test' unstable

2019-07-26 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10368: Assignee: (was: Dawid Wysakowicz) > 'Kerberized YARN on Docker test'

[jira] [Assigned] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11835: - Assignee: (was: Florian Schmidt) >

[jira] [Commented] (FLINK-12164) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable

2019-07-26 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893475#comment-16893475 ] Biao Liu commented on FLINK-12164: -- Another instance, 

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307645354 ## File path: docs/ops/filesystems/index.md ## @@ -35,32 +35,52 @@

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307644850 ## File path: docs/ops/filesystems/index.md ## @@ -35,32 +35,52 @@

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307645700 ## File path: docs/ops/filesystems/index.md ## @@ -35,32 +35,52 @@

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307642253 ## File path: docs/monitoring/debugging_classloading.md ## @@ -28,17

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307638370 ## File path: docs/dev/batch/connectors.md ## @@ -25,18 +25,10 @@

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307644350 ## File path: docs/ops/filesystems/azure.zh.md ## @@ -38,7 +38,7 @@

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307641027 ## File path: docs/monitoring/debugging_classloading.md ## @@ -28,17

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307646471 ## File path: docs/ops/filesystems/s3.md ## @@ -59,23 +59,24 @@ For

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307643510 ## File path: docs/monitoring/debugging_classloading.zh.md ## @@

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307638733 ## File path: docs/dev/batch/connectors.zh.md ## @@ -25,18 +25,10 @@

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307643865 ## File path: docs/monitoring/debugging_classloading.zh.md ## @@

[GitHub] [flink] alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins

2019-07-26 Thread GitBox
alpinegizmo commented on a change in pull request #9169: [FLINK-12998][docs] Update documentation for file systems loading as plugins URL: https://github.com/apache/flink/pull/9169#discussion_r307644157 ## File path: docs/ops/filesystems/azure.md ## @@ -38,7 +38,7 @@

[GitHub] [flink] ifndef-SleePy commented on issue #9147: [FLINK-11631][test] Harden TaskExecutorITCase

2019-07-26 Thread GitBox
ifndef-SleePy commented on issue #9147: [FLINK-11631][test] Harden TaskExecutorITCase URL: https://github.com/apache/flink/pull/9147#issuecomment-515367620 The Travis building fails again due to known unstable case, see https://issues.apache.org/jira/browse/FLINK-12164.

[GitHub] [flink] flinkbot edited a comment on issue #9233: [FLINK-13415][docs] Document how to use hive connector in scala shell

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9233: [FLINK-13415][docs] Document how to use hive connector in scala shell URL: https://github.com/apache/flink/pull/9233#issuecomment-515340558 ## CI report: * c825e2b8c2b212b1c214218395d577d38b4d7406 : SUCCESS

[jira] [Updated] (FLINK-13228) HadoopRecoverableWriterTest.testCommitAfterNormalClose fails on Travis

2019-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13228: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] carp84 opened a new pull request #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest

2019-07-26 Thread GitBox
carp84 opened a new pull request #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest URL: https://github.com/apache/flink/pull/9235 ## What is the purpose of the change Currently test cases will fail when trying to close the output stream if all data written but

[jira] [Updated] (FLINK-13226) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails on Travis

2019-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13226: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] becketqin opened a new pull request #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc…

2019-07-26 Thread GitBox
becketqin opened a new pull request #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc… URL: https://github.com/apache/flink/pull/9224 …er closure. ## What is the purpose of the change This patch fixes a race condition between the

[GitHub] [flink] becketqin closed pull request #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc…

2019-07-26 Thread GitBox
becketqin closed pull request #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc… URL: https://github.com/apache/flink/pull/9224 This is an automated message from the Apache

[GitHub] [flink] flinkbot commented on issue #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest

2019-07-26 Thread GitBox
flinkbot commented on issue #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest URL: https://github.com/apache/flink/pull/9235#issuecomment-515368015 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] carp84 commented on issue #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest

2019-07-26 Thread GitBox
carp84 commented on issue #9235: [FLINK-13228][tests][filesystems] Harden HadoopRecoverableWriterTest URL: https://github.com/apache/flink/pull/9235#issuecomment-515368196 This should be able to resolve FLINK-12071 also. @flinkbot attention @tillrohrmann @StephanEwen

[jira] [Created] (FLINK-13431) NameNode HA configuration was not loaded when running HiveConnector on Yarn

2019-07-26 Thread Hongtao Zhang (JIRA)
Hongtao Zhang created FLINK-13431: - Summary: NameNode HA configuration was not loaded when running HiveConnector on Yarn Key: FLINK-13431 URL: https://issues.apache.org/jira/browse/FLINK-13431

[jira] [Updated] (FLINK-13391) Blink-planner should not invoke deprecated getReturnType of TableSource

2019-07-26 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13391: Priority: Critical (was: Major) > Blink-planner should not invoke deprecated getReturnType of

[jira] [Resolved] (FLINK-13407) Fix thread visibility of checked SlotManager.failUnfulfillableRequest in StandaloneResourceManagerTest

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-13407. --- Resolution: Fixed Fix Version/s: (was: 1.10.0) Fixed via 1.10.0:

[jira] [Updated] (FLINK-13415) Document how to use hive connector in scala shell

2019-07-26 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13415: --- Labels: pull-request-available (was: ) > Document how to use hive connector in scala shell

[GitHub] [flink] zjffdu opened a new pull request #9233: [FLINK-13415][docs] Document how to use hive connector in scala shell

2019-07-26 Thread GitBox
zjffdu opened a new pull request #9233: [FLINK-13415][docs] Document how to use hive connector in scala shell URL: https://github.com/apache/flink/pull/9233 ## What is the purpose of the change The purpose of this PR is to add docs about how to use hive connector in scala shell via

[GitHub] [flink] flinkbot commented on issue #9233: [FLINK-13415][docs] Document how to use hive connector in scala shell

2019-07-26 Thread GitBox
flinkbot commented on issue #9233: [FLINK-13415][docs] Document how to use hive connector in scala shell URL: https://github.com/apache/flink/pull/9233#issuecomment-515338213 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] tillrohrmann closed pull request #9126: [FLINK-13407][tests][coordination] Get SlotManager.failUnfulfillableRequest in main thread of StandaloneResourceManager for verification

2019-07-26 Thread GitBox
tillrohrmann closed pull request #9126: [FLINK-13407][tests][coordination] Get SlotManager.failUnfulfillableRequest in main thread of StandaloneResourceManager for verification URL: https://github.com/apache/flink/pull/9126

[jira] [Commented] (FLINK-13421) Unexpected ConcurrentModificationException when RM notifies JM about allocation failure

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893397#comment-16893397 ] Till Rohrmann commented on FLINK-13421: --- Did you observe this while testing Flink or was it a test

[jira] [Commented] (FLINK-13421) Unexpected ConcurrentModificationException when RM notifies JM about allocation failure

2019-07-26 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893396#comment-16893396 ] Till Rohrmann commented on FLINK-13421: --- That is a good finding [~zhuzh]. I need to take a closer

[jira] [Commented] (FLINK-13421) Unexpected ConcurrentModificationException when RM notifies JM about allocation failure

2019-07-26 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893402#comment-16893402 ] Zhu Zhu commented on FLINK-13421: - We observed in when running stability test on Flink 1.9. The log is

[GitHub] [flink] dawidwys commented on issue #9225: [FLINK-13387] Can not download taskmanger & jobmanagers logs in the old UI

2019-07-26 Thread GitBox
dawidwys commented on issue #9225: [FLINK-13387] Can not download taskmanger & jobmanagers logs in the old UI URL: https://github.com/apache/flink/pull/9225#issuecomment-515341715 I didn't go through the whole PR, but duplicating a whole endpoint seems a bit unnecessary. Can't we just

[GitHub] [flink] wuchong commented on a change in pull request #9211: [FLINK-13393][FLINK-13391][table-planner-blink] Fix source conversion and source return type

2019-07-26 Thread GitBox
wuchong commented on a change in pull request #9211: [FLINK-13393][FLINK-13391][table-planner-blink] Fix source conversion and source return type URL: https://github.com/apache/flink/pull/9211#discussion_r307618315 ## File path:

[jira] [Assigned] (FLINK-13356) Add documentation for TopN in blink planner

2019-07-26 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13356: --- Assignee: Jing Zhang > Add documentation for TopN in blink planner >

[jira] [Updated] (FLINK-13357) Add documentation for PartitionableTableSource and PartitionableTableSink

2019-07-26 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13357: Priority: Minor (was: Major) > Add documentation for PartitionableTableSource and PartitionableTableSink

[GitHub] [flink] StephanEwen commented on issue #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool

2019-07-26 Thread GitBox
StephanEwen commented on issue #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool URL: https://github.com/apache/flink/pull/8841#issuecomment-515345425 Manually merged in dac02696a9bdb3ecdfd084b784a43e74ca3d9098

[jira] [Updated] (FLINK-13358) Add documentation for InputFormatTableSource and OutputFormatTableSink

2019-07-26 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13358: Priority: Minor (was: Major) > Add documentation for InputFormatTableSource and OutputFormatTableSink >

[GitHub] [flink] StephanEwen closed pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool

2019-07-26 Thread GitBox
StephanEwen closed pull request #8841: [FLINK-12765][coordinator] Bookkeeping of available resources of allocated slots in SlotPool URL: https://github.com/apache/flink/pull/8841 This is an automated message from the Apache

[jira] [Resolved] (FLINK-12765) Bookkeeping of available resources of allocated slots in SlotPool.

2019-07-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-12765. -- Resolution: Fixed Fixed in - 1.9.0 via 0b1dafd52d380a8c1b312fa5cf51185367cfd83d - master

[jira] [Closed] (FLINK-12765) Bookkeeping of available resources of allocated slots in SlotPool.

2019-07-26 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-12765. > Bookkeeping of available resources of allocated slots in SlotPool. >

[GitHub] [flink] flinkbot edited a comment on issue #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance.

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance. URL: https://github.com/apache/flink/pull/9105#issuecomment-511499675 ## CI report: *

[GitHub] [flink] hudaowan opened a new pull request #9234: Release 1.8

2019-07-26 Thread GitBox
hudaowan opened a new pull request #9234: Release 1.8 URL: https://github.com/apache/flink/pull/9234 ## 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

[GitHub] [flink] zentol closed pull request #9234: Release 1.8

2019-07-26 Thread GitBox
zentol closed pull request #9234: Release 1.8 URL: https://github.com/apache/flink/pull/9234 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[jira] [Resolved] (FLINK-13289) Blink-planner should setKeyFields to upsert table sink

2019-07-26 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13289. - Resolution: Fixed Fixed in 1.10.0: 35237ae8c42f2184717d8f5eee1cf8efed2c63c7 Fixed in 1.9.0:

[GitHub] [flink] flinkbot edited a comment on issue #9224: [FLINK-13266] [connectors / kafka] Fix race condition between transaction commit and produc…

2019-07-26 Thread GitBox
flinkbot edited a comment on issue #9224: [FLINK-13266] [connectors / kafka] Fix race condition between transaction commit and produc… URL: https://github.com/apache/flink/pull/9224#issuecomment-514889442 ## CI report: * 78b445e8a5fb88c8c7f7080f1e6d9fdf89a5a594 : FAILURE

[jira] [Updated] (FLINK-13192) Add tests for different Hive table formats

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13192: --- Priority: Blocker (was: Major) > Add tests for different Hive table formats >

[jira] [Updated] (FLINK-13423) Unable to find function in hive 1

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13423: --- Priority: Blocker (was: Major) > Unable to find function in hive 1 > - > >

[jira] [Updated] (FLINK-13424) HiveCatalog should add hive version in conf

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13424: --- Priority: Blocker (was: Major) > HiveCatalog should add hive version in conf >

[jira] [Updated] (FLINK-13352) Using hive connector with hive-1.2.1 needs libfb303 jar

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13352: --- Priority: Blocker (was: Major) > Using hive connector with hive-1.2.1 needs libfb303 jar >

[jira] [Updated] (FLINK-13012) Handle default partition name of Hive table

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13012: --- Priority: Blocker (was: Major) > Handle default partition name of Hive table >

[jira] [Updated] (FLINK-13012) Handle default partition name of Hive table

2019-07-26 Thread Rui Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13012: --- Fix Version/s: 1.9.0 > Handle default partition name of Hive table >

  1   2   3   4   >