[GitHub] [flink] flinkbot edited a comment on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#issuecomment-547898353 ## CI report: * 4f4e1f0ab95e451357fc3b20c8087dad16168596 : FAILURE [

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964662#comment-16964662 ] Jingsong Lee commented on FLINK-13702: -- Hi [~dwysakowicz] [~jark], Let me summarize

[jira] [Closed] (FLINK-14496) Exclude detach flag from ClusterClient

2019-10-31 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-14496. - Resolution: Fixed master via bf5235e340543b9c4551d2131e8a405bd1e9e0c0 > Exclude detach flag from Cluste

[jira] [Comment Edited] (FLINK-14585) flink connector for sink to apache/incubator-druid

2019-10-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964659#comment-16964659 ] Jark Wu edited comment on FLINK-14585 at 11/1/19 6:55 AM: -- Hi [

[jira] [Commented] (FLINK-14585) flink connector for sink to apache/incubator-druid

2019-10-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964659#comment-16964659 ] Jark Wu commented on FLINK-14585: - Hi [~xiaodao], there is no plan to add druid connecto

[GitHub] [flink] flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10007: [FLINK-14060][runtime] Set slot sharing groups according to logical pipelined regions URL: https://github.com/apache/flink/pull/10007#issuecomment-546673889 ## CI report: * 2f64299fb74a59f77f14f20bed87191389f58317 : FAILURE [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#issuecomment-546671910 ## CI report: * 0697f19b0cce32ea7e70e0c13abe5a4a53d5 : CANCELED [Build](https://t

[GitHub] [flink] TisonKun merged pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
TisonKun merged pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] docete commented on issue #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-31 Thread GitBox
docete commented on issue #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#issuecomment-548685794 ping @wuchong Do you have other concerns about this? Or I would push -f to

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964639#comment-16964639 ] Jark Wu edited comment on FLINK-13702 at 11/1/19 6:36 AM: -- As d

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964639#comment-16964639 ] Jark Wu commented on FLINK-13702: - As discussed with [~lzljs3620320] offline, we will no

[GitHub] [flink] wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-31 Thread GitBox
wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-548682997 I found the new implementation breaks the current BackPressureTracker, because the bloc

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964605#comment-16964605 ] Jingsong Lee edited comment on FLINK-13702 at 11/1/19 6:31 AM: ---

[GitHub] [flink] flinkbot edited a comment on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#issuecomment-547898353 ## CI report: * 4f4e1f0ab95e451357fc3b20c8087dad16168596 : FAILURE [

[GitHub] [flink] flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#issuecomment-546671910 ## CI report: * 0697f19b0cce32ea7e70e0c13abe5a4a53d5 : CANCELED [Build](https://t

[GitHub] [flink] lirui-apache commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-31 Thread GitBox
lirui-apache commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r341463127 ## File path: flink-table/flink-table-ru

[GitHub] [flink] TisonKun commented on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-31 Thread GitBox
TisonKun commented on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#issuecomment-548680003 @flinkbot run travis

[GitHub] [flink] zhuzhurk commented on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

2019-10-31 Thread GitBox
zhuzhurk commented on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#issuecomment-548679618 Rebased onto latest master. This is an

[GitHub] [flink] guoweiM commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-31 Thread GitBox
guoweiM commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r341461919 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/compon

[jira] [Commented] (FLINK-14585) flink connector for sink to apache/incubator-druid

2019-10-31 Thread xiaodao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964632#comment-16964632 ] xiaodao commented on FLINK-14585: - [~jark] Is there a plan to add this connector,if has,

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-31 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r341461372 ## File path: flink-table/flink-table-runt

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-31 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r341460702 ## File path: flink-table/flink-table-runt

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-31 Thread GitBox
JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r341461581 ## File path: flink-table/flink-table-runt

[GitHub] [flink] guoweiM commented on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-31 Thread GitBox
guoweiM commented on issue #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#issuecomment-548677358 First of all, I would like to thank @zhuzhurk and @tillrohrmann for your very thoughtful and comprehensive su

[GitHub] [flink] docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

2019-10-31 Thread GitBox
docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#discussion_r340949659 ## File path: flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVect

[GitHub] [flink] docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

2019-10-31 Thread GitBox
docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#discussion_r340393798 ## File path: flink-connectors/flink-orc/pom.xml ## @@ -62,6 +62,13 @@ under the License.

[GitHub] [flink] docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

2019-10-31 Thread GitBox
docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#discussion_r341459829 ## File path: flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcColumnarRowInputFormat.ja

[GitHub] [flink] docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

2019-10-31 Thread GitBox
docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#discussion_r341459203 ## File path: flink-connectors/flink-orc/src/test/java/org/apache/flink/orc/OrcColumnarRowInputFormatTes

[GitHub] [flink] docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

2019-10-31 Thread GitBox
docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#discussion_r341456819 ## File path: flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcBytesColumnVector.

[GitHub] [flink] docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

2019-10-31 Thread GitBox
docete commented on a change in pull request #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#discussion_r341456674 ## File path: flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVect

[GitHub] [flink] flinkbot edited a comment on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions URL: https://github.com/apache/flink/pull/10054#issuecomment-548157564 ## CI report: * d17fd17d0eff661875109372c6c02ed19d7deba8 : SUCCESS [Build](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#issuecomment-547774074 ## CI report: * 5539c384788ae03243a246a891d1700e2f0be719 : FAILURE [Bu

[GitHub] [flink] flinkbot edited a comment on issue #10063: [FLINK-14583] Remove progressLock from ExecutionGraph

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10063: [FLINK-14583] Remove progressLock from ExecutionGraph URL: https://github.com/apache/flink/pull/10063#issuecomment-548660026 ## CI report: * f5782804ed0d6492d4eb46292ee7fd65137e5167 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink

[GitHub] [flink] flinkbot edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#issuecomment-547774074 ## CI report: * 5539c384788ae03243a246a891d1700e2f0be719 : FAILURE [Bu

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964605#comment-16964605 ] Jingsong Lee edited comment on FLINK-13702 at 11/1/19 5:21 AM: ---

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

2019-10-31 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964605#comment-16964605 ] Jingsong Lee commented on FLINK-13702: -- [~dwysakowicz] yes, it depends on our CodeG

[GitHub] [flink] flinkbot edited a comment on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions URL: https://github.com/apache/flink/pull/10054#issuecomment-548157564 ## CI report: * d17fd17d0eff661875109372c6c02ed19d7deba8 : SUCCESS [Build](https:/

[GitHub] [flink] flinkbot edited a comment on issue #10063: [FLINK-14583] Remove progressLock from ExecutionGraph

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10063: [FLINK-14583] Remove progressLock from ExecutionGraph URL: https://github.com/apache/flink/pull/10063#issuecomment-548660026 ## CI report: * f5782804ed0d6492d4eb46292ee7fd65137e5167 : PENDING [Build](https://travis-ci.com/flink-ci/flink

[GitHub] [flink] flinkbot edited a comment on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#issuecomment-548389810 ## CI report: * 47e63a50352681e156100c5a35084ff927292910 : SUCCESS [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions URL: https://github.com/apache/flink/pull/10054#issuecomment-548157564 ## CI report: * d17fd17d0eff661875109372c6c02ed19d7deba8 : SUCCESS [Build](https:/

[GitHub] [flink] flinkbot commented on issue #10063: [FLINK-14583] Remove progressLock from ExecutionGraph

2019-10-31 Thread GitBox
flinkbot commented on issue #10063: [FLINK-14583] Remove progressLock from ExecutionGraph URL: https://github.com/apache/flink/pull/10063#issuecomment-548660026 ## CI report: * f5782804ed0d6492d4eb46292ee7fd65137e5167 : UNKNOWN Bot commands The @flinkbot bot suppo

[GitHub] [flink] flinkbot edited a comment on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#issuecomment-547898353 ## CI report: * 4f4e1f0ab95e451357fc3b20c8087dad16168596 : FAILURE [

[GitHub] [flink] flinkbot commented on issue #10063: [FLINK-14583] Remove progressLock from ExecutionGraph

2019-10-31 Thread GitBox
flinkbot commented on issue #10063: [FLINK-14583] Remove progressLock from ExecutionGraph URL: https://github.com/apache/flink/pull/10063#issuecomment-548657197 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull re

[GitHub] [flink] flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-545092005 ## CI report: * 355939385e2951dd0da0e3fe1da8feb7dbc27f61 : FAILURE [Build](https://travis-ci.com/flink-ci/

[jira] [Updated] (FLINK-14084) Support ZonedTimestampType

2019-10-31 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-14084: - Description: ZonedTimestmapType in FLINK(and other Hadoop SQL engines) choose OffsetDateTime sem

[GitHub] [flink] yanghua opened a new pull request #10063: [FLINK-14583] Remove progressLock from ExecutionGraph

2019-10-31 Thread GitBox
yanghua opened a new pull request #10063: [FLINK-14583] Remove progressLock from ExecutionGraph URL: https://github.com/apache/flink/pull/10063 ## What is the purpose of the change *This pull request removes progressLock from ExecutionGraph* ## Brief change log

[jira] [Updated] (FLINK-14583) Remove progressLock from ExecutionGraph

2019-10-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14583: --- Labels: pull-request-available (was: ) > Remove progressLock from ExecutionGraph >

[GitHub] [flink] hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-31 Thread GitBox
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r341443394 ## File path: flink-python/src/main/java/org/

[GitHub] [flink] hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-31 Thread GitBox
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r341437748 ## File path: flink-python/src/main/java/org/

[GitHub] [flink] hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-31 Thread GitBox
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r341439840 ## File path: flink-python/src/main/java/org/

[GitHub] [flink] hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-31 Thread GitBox
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r341138734 ## File path: flink-python/pom.xml ##

[GitHub] [flink] bowenli86 edited a comment on issue #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions

2019-10-31 Thread GitBox
bowenli86 edited a comment on issue #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions URL: https://github.com/apache/flink/pull/9988#issuecomment-548656200 @xuefuz @lirui-apache @zjuwangg This i

[GitHub] [flink] hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-31 Thread GitBox
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r341148386 ## File path: flink-python/src/main/java/org/

[GitHub] [flink] hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-31 Thread GitBox
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r341149829 ## File path: flink-python/src/main/java/org/

[GitHub] [flink] bowenli86 commented on issue #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions

2019-10-31 Thread GitBox
bowenli86 commented on issue #9988: [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions URL: https://github.com/apache/flink/pull/9988#issuecomment-548656200 @xuefuz @lirui-apache This is an automated me

[GitHub] [flink] hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-31 Thread GitBox
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r341437522 ## File path: flink-python/src/main/java/org/

[GitHub] [flink] hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-31 Thread GitBox
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r341425204 ## File path: flink-python/src/main/java/org/

[GitHub] [flink] hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-10-31 Thread GitBox
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#discussion_r341436206 ## File path: flink-python/src/main/java/org/

[jira] [Created] (FLINK-14591) Execute PlannerBase#mergeParameters every time of calling PlannerBase#translate method

2019-10-31 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-14591: - Summary: Execute PlannerBase#mergeParameters every time of calling PlannerBase#translate method Key: FLINK-14591 URL: https://issues.apache.org/jira/browse/FLINK-14591 Pro

[GitHub] [flink] flinkbot edited a comment on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#issuecomment-548389810 ## CI report: * 47e63a50352681e156100c5a35084ff927292910 : SUCCESS [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#issuecomment-547898353 ## CI report: * 4f4e1f0ab95e451357fc3b20c8087dad16168596 : FAILURE [

[GitHub] [flink] shuai-xu commented on issue #10060: [FLINK-14546] [flink-json] Support map type in flink-json

2019-10-31 Thread GitBox
shuai-xu commented on issue #10060: [FLINK-14546] [flink-json] Support map type in flink-json URL: https://github.com/apache/flink/pull/10060#issuecomment-548654286 Could you add some tests for this change? This is an automat

[GitHub] [flink] shuai-xu edited a comment on issue #10060: [FLINK-14546] [flink-json] Support map type in flink-json

2019-10-31 Thread GitBox
shuai-xu edited a comment on issue #10060: [FLINK-14546] [flink-json] Support map type in flink-json URL: https://github.com/apache/flink/pull/10060#issuecomment-548654286 Thank you for the contribution, could you add some tests for this change?

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-31 Thread GitBox
docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r341441280 ## File path: flink-table/flink-table-runtime-

[GitHub] [flink] TisonKun commented on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true

2019-10-31 Thread GitBox
TisonKun commented on issue #10048: [FLINK-14462][coordination] Remove JobGraph#allowQueuedScheduling flag because it is always true URL: https://github.com/apache/flink/pull/10048#issuecomment-548651855 Thanks for your review and advise @tillrohrmann & @zhuzhurk ! Updated. ---

[GitHub] [flink] flinkbot edited a comment on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#issuecomment-548389810 ## CI report: * 47e63a50352681e156100c5a35084ff927292910 : SUCCESS [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] walterddr closed pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution.

2019-10-31 Thread GitBox
walterddr closed pull request #9733: [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution. URL: https://github.com/apache/flink/pull/9733 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] zhijiangW commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-31 Thread GitBox
zhijiangW commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-548649638 Thanks for the suggestions from @pnowojski and the updates @wsry . I like the cu

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-31 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r341437591 ## File path: flink-runtime/src/main/java/org/apache/fl

[GitHub] [flink] flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-545092005 ## CI report: * 355939385e2951dd0da0e3fe1da8feb7dbc27f61 : FAILURE [Build](https://travis-ci.com/flink-ci/

[GitHub] [flink] lirui-apache commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-31 Thread GitBox
lirui-apache commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r341436387 ## File path: flink-table/flink-table-ru

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-31 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r341436331 ## File path: flink-runtime/src/main/java/org/apache/fl

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-31 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r341436102 ## File path: flink-runtime/src/main/java/org/apache/fl

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

2019-10-31 Thread GitBox
zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r341436098 ## File path: flink-runtime/src/main/java/org/apache/fl

[GitHub] [flink] lirui-apache commented on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

2019-10-31 Thread GitBox
lirui-apache commented on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#issuecomment-548646669 @xuefuz @bowenli86 Thanks for the review. Just updated the PR to address your comments. -

[GitHub] [flink] JingsongLi commented on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

2019-10-31 Thread GitBox
JingsongLi commented on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#issuecomment-548645119 > @JingsongLi Thanks a lot for the PR! > > I wonder if exposing catalog manager

[GitHub] [flink] xuefuz commented on a change in pull request #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions

2019-10-31 Thread GitBox
xuefuz commented on a change in pull request #10054: [FLINK-14221][table] support drop temp system functions and temp catalog functions URL: https://github.com/apache/flink/pull/10054#discussion_r341399463 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flin

[GitHub] [flink] KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-31 Thread GitBox
KurtYoung commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341434266 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableS

[GitHub] [flink] lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

2019-10-31 Thread GitBox
lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#discussion_r341433876 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hi

[GitHub] [flink] lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

2019-10-31 Thread GitBox
lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#discussion_r341433464 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

2019-10-31 Thread GitBox
lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#discussion_r341433057 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

2019-10-31 Thread GitBox
lirui-apache commented on a change in pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#discussion_r341432718 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog

[GitHub] [flink] flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-545092005 ## CI report: * 355939385e2951dd0da0e3fe1da8feb7dbc27f61 : FAILURE [Build](https://travis-ci.com/flink-ci/

[jira] [Created] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

2019-10-31 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-14590: - Summary: Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" Key: FLINK-14590 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Commented] (FLINK-14585) flink connector for sink to apache/incubator-druid

2019-10-31 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964544#comment-16964544 ] hailong wang commented on FLINK-14585: -- +1 from my side. Around me, there are many

[GitHub] [flink] danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-31 Thread GitBox
danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341426749 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableS

[GitHub] [flink] danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-31 Thread GitBox
danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341428615 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/expression

[GitHub] [flink] danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-31 Thread GitBox
danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341428236 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/Waterm

[GitHub] [flink] danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-31 Thread GitBox
danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341430630 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/Tabl

[GitHub] [flink] danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-31 Thread GitBox
danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341425950 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableS

[GitHub] [flink] danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-31 Thread GitBox
danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341426521 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableS

[GitHub] [flink] danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-31 Thread GitBox
danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341427377 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableS

[GitHub] [flink] danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-31 Thread GitBox
danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341425829 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableS

[GitHub] [flink] danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema

2019-10-31 Thread GitBox
danny0405 commented on a change in pull request #9994: [FLINK-14322][table-api] Add watermark information in TableSchema URL: https://github.com/apache/flink/pull/9994#discussion_r341427986 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableS

[GitHub] [flink] hequn8128 edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobPara

2019-10-31 Thread GitBox
hequn8128 edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-5486394

[GitHub] [flink] hequn8128 commented on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters)

2019-10-31 Thread GitBox
hequn8128 commented on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-548639442

[jira] [Commented] (FLINK-14501) Move ClusterDescriptor/ClusterSpecification creation from the CustomCommandLine to a ClusterClientFactory

2019-10-31 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964531#comment-16964531 ] Yang Wang commented on FLINK-14501: --- Glad to see that Jira has been resolved. I will a

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

2019-10-31 Thread GitBox
docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#discussion_r341428358 ## File path: flink-table/flink-table-runtime-

[GitHub] [flink] TisonKun commented on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

2019-10-31 Thread GitBox
TisonKun commented on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-548636537 Thanks for your review @kl0u ! Integrate comments, squash commits and rebase on master. Merging once travis gives green. --

[GitHub] [flink] sunjincheng121 edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJo

2019-10-31 Thread GitBox
sunjincheng121 edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-54

  1   2   3   4   5   >