[jira] [Commented] (FLINK-14686) Flink SQL DDL Enhancement

2019-11-26 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983254#comment-16983254 ] Nicholas Jiang commented on FLINK-14686: [~Terry1897] Can I claim some subtasks?

[jira] [Created] (FLINK-14967) Add a utility for creating data types via reflection

2019-11-26 Thread Timo Walther (Jira)
Timo Walther created FLINK-14967: Summary: Add a utility for creating data types via reflection Key: FLINK-14967 URL: https://issues.apache.org/jira/browse/FLINK-14967 Project: Flink Issue Ty

[GitHub] [flink] zjuwangg commented on issue #10318: [FLINK-14721][hive]HiveTableSource implement LimitableTableSource interface

2019-11-26 Thread GitBox
zjuwangg commented on issue #10318: [FLINK-14721][hive]HiveTableSource implement LimitableTableSource interface URL: https://github.com/apache/flink/pull/10318#issuecomment-558972548 cc @xuefuz @bowenli86 @lirui-apache to have a review. -

[jira] [Created] (FLINK-14966) one error in document

2019-11-26 Thread yuzhemin (Jira)
yuzhemin created FLINK-14966: Summary: one error in document Key: FLINK-14966 URL: https://issues.apache.org/jira/browse/FLINK-14966 Project: Flink Issue Type: Improvement Components:

[GitHub] [flink] dawidwys commented on a change in pull request #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

2019-11-26 Thread GitBox
dawidwys commented on a change in pull request #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#discussion_r351133593 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/

[GitHub] [flink] dawidwys commented on a change in pull request #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner

2019-11-26 Thread GitBox
dawidwys commented on a change in pull request #8859: [FLINK-12905][table-planner] Enable querying CatalogViews in legacy planner URL: https://github.com/apache/flink/pull/8859#discussion_r351133325 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/

[GitHub] [flink] caidezhi removed a comment on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning

2019-11-26 Thread GitBox
caidezhi removed a comment on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning URL: https://github.com/apache/flink/pull/10328#issuecomment-558969307 @flinkbot run travis This is an automated message f

[GitHub] [flink] flinkbot commented on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

2019-11-26 Thread GitBox
flinkbot commented on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#issuecomment-558970102 ## CI report: * 38f2c1c450122cae9aa99258c19c6d07e998 : UNKNOWN Bot commands

[GitHub] [flink] flinkbot commented on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

2019-11-26 Thread GitBox
flinkbot commented on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#issuecomment-558970068 ## CI report: * e3aa8e5a567a13f07598ee6fe0e8fb8e72dfb986 : UNKNOWN Bot co

[GitHub] [flink] flinkbot edited a comment on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning URL: https://github.com/apache/flink/pull/10328#issuecomment-558939827 ## CI report: * 5a64c61705e6911b0af7998049c6e064c263dda9 : FAILURE [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] flinkbot edited a comment on issue #10322: [hotfix] Improve error message in JDBCUpsertTableSink

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10322: [hotfix] Improve error message in JDBCUpsertTableSink URL: https://github.com/apache/flink/pull/10322#issuecomment-558530648 ## CI report: * 8dfd3d2d9c4bc9913e4b2de9344a0aaf38aaf23f : SUCCESS [Build](https://travis-ci.com/flink-ci/flink

[GitHub] [flink] caidezhi commented on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning

2019-11-26 Thread GitBox
caidezhi commented on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning URL: https://github.com/apache/flink/pull/10328#issuecomment-558969307 @flinkbot run travis This is an automated message from the

[jira] [Commented] (FLINK-14965) CatalogTableStatistics UNKNOWN should be consistent with TableStats UNKNOWN

2019-11-26 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983241#comment-16983241 ] Terry Wang commented on FLINK-14965: cc [~godfreyhe] > CatalogTableStatistics UNKNO

[jira] [Commented] (FLINK-14965) CatalogTableStatistics UNKNOWN should be consistent with TableStats UNKNOWN

2019-11-26 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983240#comment-16983240 ] Terry Wang commented on FLINK-14965: HiveStatsUtil.DEFAULT_STATS_ZERO_CONST should a

[jira] [Created] (FLINK-14965) CatalogTableStatistics UNKNOWN should be consistent with TableStats UNKNOWN

2019-11-26 Thread Terry Wang (Jira)
Terry Wang created FLINK-14965: -- Summary: CatalogTableStatistics UNKNOWN should be consistent with TableStats UNKNOWN Key: FLINK-14965 URL: https://issues.apache.org/jira/browse/FLINK-14965 Project: Flin

[jira] [Comment Edited] (FLINK-7990) Strange behavior when configuring Logback for logging

2019-11-26 Thread Nathan Howell (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983236#comment-16983236 ] Nathan Howell edited comment on FLINK-7990 at 11/27/19 7:36 AM: ---

[jira] [Commented] (FLINK-7990) Strange behavior when configuring Logback for logging

2019-11-26 Thread Nathan Howell (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983236#comment-16983236 ] Nathan Howell commented on FLINK-7990: -- We may have hit this same issue a while ago,

[jira] [Commented] (FLINK-14740) Create OperatorID for OperatorMetricGroup which in batch job

2019-11-26 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983235#comment-16983235 ] lining commented on FLINK-14740: Alternatively, we could add the owner‘s id to the metri

[jira] [Updated] (FLINK-14740) Create OperatorID for OperatorMetricGroup which in batch job

2019-11-26 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14740: --- Attachment: screenshot-1.png > Create OperatorID for OperatorMetricGroup which in batch job > -

[GitHub] [flink] pnowojski commented on a change in pull request #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

2019-11-26 Thread GitBox
pnowojski commented on a change in pull request #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#discussion_r351129443 ## File path: docs/monitoring/metrics.md ## @@ -1139,6 +1139,12 @@ Metrics r

[GitHub] [flink] flinkbot commented on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

2019-11-26 Thread GitBox
flinkbot commented on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330#issuecomment-558965842 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-14189) Extend TaskExecutor to support dynamic slot allocation

2019-11-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14189: --- Labels: pull-request-available (was: ) > Extend TaskExecutor to support dynamic slot alloca

[GitHub] [flink] xintongsong opened a new pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation

2019-11-26 Thread GitBox
xintongsong opened a new pull request #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation URL: https://github.com/apache/flink/pull/10330 ## What is the purpose of the change This PR is part fo FLIP-56. It extends `TaskExecutor` to support dynamic s

[jira] [Commented] (FLINK-14952) Yarn containers can exceed physical memory limits when using BoundedBlockingSubpartition.

2019-11-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983233#comment-16983233 ] Piotr Nowojski commented on FLINK-14952: What options do we have? I think there

[GitHub] [flink] caidezhi removed a comment on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning

2019-11-26 Thread GitBox
caidezhi removed a comment on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning URL: https://github.com/apache/flink/pull/10328#issuecomment-558963301 @flinkbot run travis This is an automated message f

[jira] [Commented] (FLINK-7990) Strange behavior when configuring Logback for logging

2019-11-26 Thread Phillip.K.Moon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983230#comment-16983230 ] Phillip.K.Moon commented on FLINK-7990: --- I am facing same problem on Flink 1.9.1 

[GitHub] [flink] caidezhi commented on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning

2019-11-26 Thread GitBox
caidezhi commented on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning URL: https://github.com/apache/flink/pull/10328#issuecomment-558963301 @flinkbot run travis This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on issue #10322: [hotfix] Improve error message in JDBCUpsertTableSink

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10322: [hotfix] Improve error message in JDBCUpsertTableSink URL: https://github.com/apache/flink/pull/10322#issuecomment-558530648 ## CI report: * 8dfd3d2d9c4bc9913e4b2de9344a0aaf38aaf23f : SUCCESS [Build](https://travis-ci.com/flink-ci/flink

[jira] [Commented] (FLINK-14950) Support getKey in WindowOperator.Context

2019-11-26 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983221#comment-16983221 ] Jiayi Liao commented on FLINK-14950: [~SleePy] Thanks for your attention. 1. For ex

[GitHub] [flink] flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building URL: https://github.com/apache/flink/pull/10275#issuecomment-556931854 ## CI report: * f6c984aee2adafa83829762496ad13b75e8e : SUCCESS [Build](https://t

[GitHub] [flink] flinkbot commented on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

2019-11-26 Thread GitBox
flinkbot commented on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#issuecomment-558959949 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

2019-11-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12785: --- Labels: pull-request-available (was: ) > RocksDB savepoint recovery can use a lot of unmana

[GitHub] [flink] klion26 opened a new pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

2019-11-26 Thread GitBox
klion26 opened a new pull request #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329 ## What is the purpose of the change Currently `RocksDBWriteBatchWrapper` will flush the batch just b

[GitHub] [flink] link3280 commented on a change in pull request #10322: [hotfix] Improve error message in JDBCUpsertTableSink

2019-11-26 Thread GitBox
link3280 commented on a change in pull request #10322: [hotfix] Improve error message in JDBCUpsertTableSink URL: https://github.com/apache/flink/pull/10322#discussion_r351120237 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsertTab

[GitHub] [flink] klion26 commented on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout

2019-11-26 Thread GitBox
klion26 commented on issue #10305: [FLINK-14892][docs] Add documentation for checkpoint directory layout URL: https://github.com/apache/flink/pull/10305#issuecomment-558956398 @pnowojski @wuchong thanks for the review and merging. ---

[jira] [Created] (FLINK-14964) Support configure remote flink jar

2019-11-26 Thread Zili Chen (Jira)
Zili Chen created FLINK-14964: - Summary: Support configure remote flink jar Key: FLINK-14964 URL: https://issues.apache.org/jira/browse/FLINK-14964 Project: Flink Issue Type: Improvement

[GitHub] [flink] JingsongLi commented on a change in pull request #10322: [hotfix] Improve error message in JDBCUpsertTableSink

2019-11-26 Thread GitBox
JingsongLi commented on a change in pull request #10322: [hotfix] Improve error message in JDBCUpsertTableSink URL: https://github.com/apache/flink/pull/10322#discussion_r351117657 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsertT

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351115435 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/schedule

[GitHub] [flink] KarmaGYZ commented on a change in pull request #10322: [hotfix] Improve error message in JDBCUpsertTableSink

2019-11-26 Thread GitBox
KarmaGYZ commented on a change in pull request #10322: [hotfix] Improve error message in JDBCUpsertTableSink URL: https://github.com/apache/flink/pull/10322#discussion_r351115075 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsertTab

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351113073 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r35639 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] flinkbot edited a comment on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10328: [FLINK-14962] fix findbugs WMI_WRONG_MAP_ITERATOR warning URL: https://github.com/apache/flink/pull/10328#issuecomment-558939827 ## CI report: * 5a64c61705e6911b0af7998049c6e064c263dda9 : FAILURE [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351109706 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351109706 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building URL: https://github.com/apache/flink/pull/10275#issuecomment-556931854 ## CI report: * f6c984aee2adafa83829762496ad13b75e8e : SUCCESS [Build](https://t

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351108406 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] HuangZhenQiu commented on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster

2019-11-26 Thread GitBox
HuangZhenQiu commented on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster URL: https://github.com/apache/flink/pull/9711#issuecomment-558941994 @aljoscha Given @tillrohrmann Is on vacation, would you please help to review this PR?

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351106122 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351105959 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351105998 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] flinkbot edited a comment on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support URL: https://github.com/apache/flink/pull/10327#issuecomment-558927258 ## CI report: * c3a6514c8b6c984190d4d60fb50b6313851ebba5 : FAILURE [Build](https://travis-ci

[GitHub] [flink] flinkbot commented on issue #10328: FLINK-14962 fix findbugs WMI_WRONG_MAP_ITERATOR warning

2019-11-26 Thread GitBox
flinkbot commented on issue #10328: FLINK-14962 fix findbugs WMI_WRONG_MAP_ITERATOR warning URL: https://github.com/apache/flink/pull/10328#issuecomment-558939827 ## CI report: * 5a64c61705e6911b0af7998049c6e064c263dda9 : UNKNOWN Bot commands The @flinkbot bot su

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351104775 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/schedule

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351104775 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/schedule

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351104548 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351104548 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[jira] [Commented] (FLINK-14962) FindBugs warnings: Inefficient use of keySet iterator instead of entrySet iterator

2019-11-26 Thread Dezhi Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983179#comment-16983179 ] Dezhi Cai commented on FLINK-14962: --- I create a PR as my first contribution to flink.

[jira] [Comment Edited] (FLINK-14962) FindBugs warnings: Inefficient use of keySet iterator instead of entrySet iterator

2019-11-26 Thread Dezhi Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983179#comment-16983179 ] Dezhi Cai edited comment on FLINK-14962 at 11/27/19 5:42 AM: -

[jira] [Comment Edited] (FLINK-14962) FindBugs warnings: Inefficient use of keySet iterator instead of entrySet iterator

2019-11-26 Thread Dezhi Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983179#comment-16983179 ] Dezhi Cai edited comment on FLINK-14962 at 11/27/19 5:42 AM: -

[GitHub] [flink] flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10275: [FLINK-14733][runtime] Introduce a builder for flexible ResourceProfile building URL: https://github.com/apache/flink/pull/10275#issuecomment-556931854 ## CI report: * f6c984aee2adafa83829762496ad13b75e8e : SUCCESS [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#issuecomment-555395817 ## CI report: * 09feda98fa486bb4c3aaf8bba3806cae08b53c23 : SUCCESS [Build](https://travis-ci.c

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351102967 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351102603 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[jira] [Updated] (FLINK-14963) Massive Duplicated Useless Oss Message in jobmanager.log

2019-11-26 Thread Eric Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Lee updated FLINK-14963: - Description: When I was using AliCloud Oss as the external file system for flink checkpoints, there wer

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351101643 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

2019-11-26 Thread GitBox
zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#discussion_r351101643 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/schedule

[jira] [Created] (FLINK-14963) Massive Duplicated Useless Oss Message in jobmanager.log

2019-11-26 Thread Eric Lee (Jira)
Eric Lee created FLINK-14963: Summary: Massive Duplicated Useless Oss Message in jobmanager.log Key: FLINK-14963 URL: https://issues.apache.org/jira/browse/FLINK-14963 Project: Flink Issue Type:

[jira] [Updated] (FLINK-14962) FindBugs warnings: Inefficient use of keySet iterator instead of entrySet iterator

2019-11-26 Thread Dezhi Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dezhi Cai updated FLINK-14962: -- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > FindBugs warnings: Inefficient use of

[jira] [Updated] (FLINK-14962) FindBugs warnings: Inefficient use of keySet iterator instead of entrySet iterator

2019-11-26 Thread Dezhi Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dezhi Cai updated FLINK-14962: -- Description: FindBugs report WMI_WRONG_MAP_ITERATOR warnings on master. related class :  org.apache.

[GitHub] [flink] flinkbot edited a comment on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support URL: https://github.com/apache/flink/pull/10327#issuecomment-558927258 ## CI report: * c3a6514c8b6c984190d4d60fb50b6313851ebba5 : PENDING [Build](https://travis-ci

[GitHub] [flink] flinkbot commented on issue #10328: FLINK-14962 fix findbugs WMI_WRONG_MAP_ITERATOR warning

2019-11-26 Thread GitBox
flinkbot commented on issue #10328: FLINK-14962 fix findbugs WMI_WRONG_MAP_ITERATOR warning URL: https://github.com/apache/flink/pull/10328#issuecomment-558932932 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-14962) FindBugs warnings: Inefficient use of keySet iterator instead of entrySet iterator

2019-11-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14962: --- Labels: pull-request-available (was: ) > FindBugs warnings: Inefficient use of keySet itera

[GitHub] [flink] caidezhi opened a new pull request #10328: FLINK-14962 fix findbugs WMI_WRONG_MAP_ITERATOR warning

2019-11-26 Thread GitBox
caidezhi opened a new pull request #10328: FLINK-14962 fix findbugs WMI_WRONG_MAP_ITERATOR warning URL: https://github.com/apache/flink/pull/10328 This PR fixes WMI_WRONG_MAP_ITERATOR warnings reported by FindBugs. related class : org.apache.flink.formats.parquet.ParquetMapInputForm

[jira] [Created] (FLINK-14962) FindBugs warnings: Inefficient use of keySet iterator instead of entrySet iterator

2019-11-26 Thread Dezhi Cai (Jira)
Dezhi Cai created FLINK-14962: - Summary: FindBugs warnings: Inefficient use of keySet iterator instead of entrySet iterator Key: FLINK-14962 URL: https://issues.apache.org/jira/browse/FLINK-14962 Project:

[jira] [Updated] (FLINK-14961) Join with a LookupableTableSource: Expected results are inconsistent when using SQL expressions or UDF

2019-11-26 Thread Rockey Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rockey Cui updated FLINK-14961: --- Attachment: TASKINFO.png > Join with a LookupableTableSource: Expected results are inconsistent when

[jira] [Updated] (FLINK-14961) Join with a LookupableTableSource: Expected results are inconsistent when using SQL expressions or UDF

2019-11-26 Thread Rockey Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rockey Cui updated FLINK-14961: --- Attachment: (was: 企业微信截图_15748270288763.png) > Join with a LookupableTableSource: Expected resul

[jira] [Updated] (FLINK-14961) Join with a LookupableTableSource: Expected results are inconsistent when using SQL expressions or UDF

2019-11-26 Thread Rockey Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rockey Cui updated FLINK-14961: --- Attachment: EVAL.png > Join with a LookupableTableSource: Expected results are inconsistent when >

[jira] [Commented] (FLINK-14961) Join with a LookupableTableSource: Expected results are inconsistent when using SQL expressions or UDF

2019-11-26 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983170#comment-16983170 ] hailong wang commented on FLINK-14961: -- Thanks [~Rockey Cui] for exposing this. The

[jira] [Updated] (FLINK-14961) Join with a LookupableTableSource: Expected results are inconsistent when using SQL expressions or UDF

2019-11-26 Thread Rockey Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rockey Cui updated FLINK-14961: --- Attachment: FUNC.jpg > Join with a LookupableTableSource: Expected results are inconsistent when >

[jira] [Updated] (FLINK-14961) Join with a LookupableTableSource: Expected results are inconsistent when using SQL expressions or UDF

2019-11-26 Thread Rockey Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rockey Cui updated FLINK-14961: --- Attachment: (was: 1574826850(1).jpg) > Join with a LookupableTableSource: Expected results are i

[jira] [Updated] (FLINK-14961) Join with a LookupableTableSource: Expected results are inconsistent when using SQL expressions or UDF

2019-11-26 Thread Rockey Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rockey Cui updated FLINK-14961: --- Attachment: (was: 企业微信截图_157482739422.png) > Join with a LookupableTableSource: Expected results

[GitHub] [flink] flinkbot commented on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support

2019-11-26 Thread GitBox
flinkbot commented on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support URL: https://github.com/apache/flink/pull/10327#issuecomment-558927258 ## CI report: * c3a6514c8b6c984190d4d60fb50b6313851ebba5 : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#issuecomment-555395817 ## CI report: * 09feda98fa486bb4c3aaf8bba3806cae08b53c23 : SUCCESS [Build](https://travis-ci.c

[jira] [Commented] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

2019-11-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983164#comment-16983164 ] Zhu Zhu commented on FLINK-14566: - Thanks [~ykt836] for the feedback. Agreed that we ca

[jira] [Comment Edited] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

2019-11-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983126#comment-16983126 ] Zhu Zhu edited comment on FLINK-14566 at 11/27/19 4:32 AM: --- I'

[jira] [Commented] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

2019-11-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983161#comment-16983161 ] Kurt Young commented on FLINK-14566: I think memory weight is not required for now,

[GitHub] [flink] flinkbot commented on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support

2019-11-26 Thread GitBox
flinkbot commented on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support URL: https://github.com/apache/flink/pull/10327#issuecomment-558922468 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-14914) refactor CatalogFunction interface and impls to add language field

2019-11-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14914: --- Labels: pull-request-available (was: ) > refactor CatalogFunction interface and impls to ad

[GitHub] [flink] HuangZhenQiu commented on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support

2019-11-26 Thread GitBox
HuangZhenQiu commented on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support URL: https://github.com/apache/flink/pull/10327#issuecomment-558922055 @bowenli86 @xuefuz Please review the PR for adding language support in catalog function.

[GitHub] [flink] HuangZhenQiu opened a new pull request #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support

2019-11-26 Thread GitBox
HuangZhenQiu opened a new pull request #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support URL: https://github.com/apache/flink/pull/10327 ## What is the purpose of the change Refactor CatalogFunction interface and impls to add language field so that the la

[GitHub] [flink] flinkbot edited a comment on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time URL: https://github.com/apache/flink/pull/8746#issuecomment-528887595 ## CI report: * ed381a566a61e9d5e0677cc0b68e1eee4a4bf46d : SUCCESS [Build](https://travis-ci.com/f

[GitHub] [flink] flinkbot edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#issuecomment-555395817 ## CI report: * 09feda98fa486bb4c3aaf8bba3806cae08b53c23 : SUCCESS [Build](https://travis-ci.c

[jira] [Created] (FLINK-14961) Join with a LookupableTableSource: Expected results are inconsistent when using SQL expressions or UDF

2019-11-26 Thread Rockey Cui (Jira)
Rockey Cui created FLINK-14961: -- Summary: Join with a LookupableTableSource: Expected results are inconsistent when using SQL expressions or UDF Key: FLINK-14961 URL: https://issues.apache.org/jira/browse/FLINK-14961

[jira] [Closed] (FLINK-11491) Support all TPC-DS queries

2019-11-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11491. -- Resolution: Fixed merged to master: 20c983c26262057c4d59bd591aed89969a8ff525 > Support all TPC-DS que

[jira] [Updated] (FLINK-14813) Expose the new mechanism implemented in FLINK-14472 as a "is back-pressured" metric

2019-11-26 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14813: --- Description: {   "id": "0.Shuffle.BackPressure.isBackPressured",  "value":  "true" } (was: {   "id": "0.Shu

[GitHub] [flink] KurtYoung merged pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries

2019-11-26 Thread GitBox
KurtYoung merged pull request #10239: [FLINK-11491][end2end] Support all TPC-DS queries URL: https://github.com/apache/flink/pull/10239 This is an automated message from the Apache Git Service. To respond to the message, ple

[jira] [Commented] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?

2019-11-26 Thread Donghui Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983147#comment-16983147 ] Donghui Xu commented on FLINK-13482: [~azagrebin] I can kill the Flink process manua

[GitHub] [flink] flinkbot edited a comment on issue #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any excep

2019-11-26 Thread GitBox
flinkbot edited a comment on issue #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception URL: https://github.com/apache/flink/pull/10314#issuecomment-558163426 ## CI report: * 12e3

[GitHub] [flink] jinglining commented on a change in pull request #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

2019-11-26 Thread GitBox
jinglining commented on a change in pull request #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#discussion_r351078692 ## File path: docs/monitoring/metrics.md ## @@ -1139,6 +1139,12 @@ Metrics

[jira] [Commented] (FLINK-14936) Introduce MemoryManager#computeMemorySize to calculate managed memory from a fraction

2019-11-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983134#comment-16983134 ] Zhu Zhu commented on FLINK-14936: - I like the idea to introduce the {{LimittingMemoryMan

  1   2   3   4   5   >