[jira] [Created] (FLINK-14361) Decorrelate subQuery fail when multi correlate in project

2019-10-09 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14361: Summary: Decorrelate subQuery fail when multi correlate in project Key: FLINK-14361 URL: https://issues.apache.org/jira/browse/FLINK-14361 Project: Flink Iss

[GitHub] [flink] WeiZhong94 commented on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs.

2019-10-09 Thread GitBox
WeiZhong94 commented on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#issuecomment-540416014 @dianfu Thanks for your comments! I have addressed them in the latest commit, please take a look. -

[jira] [Created] (FLINK-14360) Flink on yarn should support obtain delegation tokens of multi hdfs namespaces

2019-10-09 Thread Shen Yinjie (Jira)
Shen Yinjie created FLINK-14360: --- Summary: Flink on yarn should support obtain delegation tokens of multi hdfs namespaces Key: FLINK-14360 URL: https://issues.apache.org/jira/browse/FLINK-14360 Project:

[GitHub] [flink] WeiZhong94 commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

2019-10-09 Thread GitBox
WeiZhong94 commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r54648 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -204,6 +204,26 @@ def eval(s

[GitHub] [flink] flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-539365871 ## CI report: * 1007e8b66d42b613ceafb86457913381a4e27b0f : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#issuecomment-536416616 ## CI report: * 519051016f02b8257eb1e3d5834f36c315816266 : FAILURE [Build](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

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

2019-10-09 Thread GitBox
dianfu 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-540397643

[GitHub] [flink] dianfu commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlob

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #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#discussion_

[GitHub] [flink] dianfu commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlob

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #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#discussion_

[GitHub] [flink] dianfu commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlob

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #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#discussion_

[GitHub] [flink] dianfu commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlob

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #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#discussion_

[GitHub] [flink] dianfu commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlob

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #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#discussion_

[GitHub] [flink] dianfu commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlob

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #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#discussion_

[GitHub] [flink] dianfu commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlob

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #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#discussion_

[GitHub] [flink] dianfu commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlob

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #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#discussion_

[GitHub] [flink] TisonKun removed a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-09 Thread GitBox
TisonKun removed a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-540323951 The problem above is abstractly actions in `(grant|revoke)Leadership` are asynchronous. `(grant|revoke)Leadership` ar

[GitHub] [flink] flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#issuecomment-536416616 ## CI report: * 519051016f02b8257eb1e3d5834f36c315816266 : FAILURE [Build](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802#issuecomment-536264046 ## CI report: * 0587de749d0d7a8c8dcc3dadeb53ae9599255abd : SUCCESS [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

[jira] [Resolved] (FLINK-13361) Add documentation for JDBC connector for Table API & SQL

2019-10-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13361. - Resolution: Fixed 1.10.0: d1d7853c45773ed3ec8b7a577993b080a45f1d77 1.9.2: f09ff5eb6d1e01ea77e87c6b8ba9d5

[GitHub] [flink] wuchong closed pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

2019-10-09 Thread GitBox
wuchong closed pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802 This is an automated message from the Apache Git Service.

[GitHub] [flink] wuchong commented on a change in pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

2019-10-09 Thread GitBox
wuchong commented on a change in pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802#discussion_r38245 ## File path: docs/dev/table/connect.md ## @@ -1076,6 +1077,7 @@ CR

[GitHub] [flink] zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime, tests] Add test coverage to DefaultScheduler

2019-10-09 Thread GitBox
zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime,tests] Add test coverage to DefaultScheduler URL: https://github.com/apache/flink/pull/9872#discussion_r39025 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedule

[GitHub] [flink] wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r37630 ## File path: flink-connectors/flink-hb

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: * 372923b25d5fa8376fc40b18e2bf024

[GitHub] [flink] flinkbot edited a comment on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path URL: https://github.com/apache/flink/pull/9875#issuecomment-540311608 ## CI report: * 3ab8ff37e57d7f9a4e3bc2421f5f978a66022589 : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: * 372923b25d5fa8376fc40b18e2bf024

[GitHub] [flink] flinkbot edited a comment on issue #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802#issuecomment-536264046 ## CI report: * 0587de749d0d7a8c8dcc3dadeb53ae9599255abd : SUCCESS [Build](https://

[GitHub] [flink] KurtYoung commented on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

2019-10-09 Thread GitBox
KurtYoung commented on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#issuecomment-540358588 Sorry for the delay due to flink forward, I will review this ASAP ---

[GitHub] [flink] flinkbot edited a comment on issue #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802#issuecomment-536264046 ## CI report: * 0587de749d0d7a8c8dcc3dadeb53ae9599255abd : SUCCESS [Build](https://

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 : FAILURE [Build](https://travis-

[GitHub] [flink] JingsongLi commented on a change in pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

2019-10-09 Thread GitBox
JingsongLi commented on a change in pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802#discussion_r26702 ## File path: docs/dev/table/connect.md ## @@ -1075,6 +1075,88

[GitHub] [flink] liupc commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

2019-10-09 Thread GitBox
liupc commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-540352478 @dianfu I will update the readme and check it again later, thanks! --

[GitHub] [flink] openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r25165 ## File path: flink-connectors/flink-hb

[GitHub] [flink] openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r25108 ## File path: flink-connectors/flink-hb

[GitHub] [flink] openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r25670 ## File path: flink-connectors/flink-hb

[GitHub] [flink] openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r17232 ## File path: flink-connectors/flink-hb

[GitHub] [flink] openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r25783 ## File path: flink-connectors/flink-hb

[GitHub] [flink] flinkbot edited a comment on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path URL: https://github.com/apache/flink/pull/9875#issuecomment-540311608 ## CI report: * 3ab8ff37e57d7f9a4e3bc2421f5f978a66022589 : PENDING [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-539910284 ## CI report: * e66114b1aa73a82b4c6bcf5c3a16baedb598f8c3 : FAILURE [Build](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#issuecomment-536259382 ## CI report: * be81d3cce668cce8d87bb76da9dc74b182d0a681 : CANCELED [Build](http

[GitHub] [flink] openinx commented on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path

2019-10-09 Thread GitBox
openinx commented on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path URL: https://github.com/apache/flink/pull/9875#issuecomment-540344558 @flinkbot run travis This is an automated message f

[GitHub] [flink] zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime, tests] Add test coverage to DefaultScheduler

2019-10-09 Thread GitBox
zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime,tests] Add test coverage to DefaultScheduler URL: https://github.com/apache/flink/pull/9872#discussion_r17197 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TestExecutionSl

[GitHub] [flink] zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime, tests] Add test coverage to DefaultScheduler

2019-10-09 Thread GitBox
zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime,tests] Add test coverage to DefaultScheduler URL: https://github.com/apache/flink/pull/9872#discussion_r04919 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutio

[GitHub] [flink] zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime, tests] Add test coverage to DefaultScheduler

2019-10-09 Thread GitBox
zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime,tests] Add test coverage to DefaultScheduler URL: https://github.com/apache/flink/pull/9872#discussion_r04549 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionSlotAl

[GitHub] [flink] zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime, tests] Add test coverage to DefaultScheduler

2019-10-09 Thread GitBox
zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime,tests] Add test coverage to DefaultScheduler URL: https://github.com/apache/flink/pull/9872#discussion_r23027 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedule

[jira] [Commented] (FLINK-14356) Support some special RowDeserializationSchema and RowSerializationSchema

2019-10-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948183#comment-16948183 ] Jark Wu commented on FLINK-14356: - Thanks [~hackergin], I think this is a reasonable req

[GitHub] [flink] flinkbot edited a comment on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path URL: https://github.com/apache/flink/pull/9875#issuecomment-540311608 ## CI report: * 3ab8ff37e57d7f9a4e3bc2421f5f978a66022589 : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: * 372923b25d5fa8376fc40b18e2bf024

[GitHub] [flink] flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#issuecomment-536259382 ## CI report: * be81d3cce668cce8d87bb76da9dc74b182d0a681 : CANCELED [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 : FAILURE [Build](https://travis-

[jira] [Resolved] (FLINK-13360) Add documentation for HBase connector for Table API & SQL

2019-10-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13360. - Resolution: Fixed 1.10.0: 592fba617655d26fbbafdde3f03d267022cc3a94 1.9.2: 42027a4d9572d329d64f684d7e393a

[GitHub] [flink] wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r15438 ## File path: flink-connectors/flink-hb

[GitHub] [flink] wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r15200 ## File path: flink-connectors/flink-hb

[GitHub] [flink] wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
wuchong commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r15080 ## File path: flink-connectors/flink-hb

[GitHub] [flink] wuchong closed pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-09 Thread GitBox
wuchong closed pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799 This is an automated message from the Apache Git Servic

[jira] [Commented] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

2019-10-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948174#comment-16948174 ] Jark Wu commented on FLINK-14359: - Thanks [~openinx] for taking this. I assigned this is

[jira] [Updated] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

2019-10-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14359: Issue Type: New Feature (was: Bug) > Create a module called flink-sql-connector-hbase to shade HBase > --

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

2019-10-09 Thread GitBox
flinkbot 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-54030298

[jira] [Assigned] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

2019-10-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14359: --- Assignee: Zheng Hu > Create a module called flink-sql-connector-hbase to shade HBase >

[GitHub] [flink] flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-539910284 ## CI report: * e66114b1aa73a82b4c6bcf5c3a16baedb598f8c3 : FAILURE [Build](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#issuecomment-539968272 ## CI report: * 372923b25d5fa8376fc40b18e2bf024

[GitHub] [flink] flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#issuecomment-536259382 ## CI report: * be81d3cce668cce8d87bb76da9dc74b182d0a681 : CANCELED [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 : FAILURE [Build](https://travis-

[jira] [Commented] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

2019-10-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948166#comment-16948166 ] Jingsong Lee commented on FLINK-14359: -- [~openinx] Good~ feel free to take this tic

[jira] [Commented] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

2019-10-09 Thread Zheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948164#comment-16948164 ] Zheng Hu commented on FLINK-14359: -- Also FYI [~jark] > Create a module called flink-sq

[jira] [Commented] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

2019-10-09 Thread Zheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948163#comment-16948163 ] Zheng Hu commented on FLINK-14359: -- [~lzljs3620320] I'm interested in this task, Mind

[GitHub] [flink] TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-09 Thread GitBox
TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-540323951 The problem above is abstractly actions in `(grant|revoke)Leadership` are asynchronous. `(grant|revoke)Leadership` are synchr

[GitHub] [flink] TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-09 Thread GitBox
TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-540322366 Thanks for opening this pull request. I have one concern about the synchronization between `Dispatcher` and `JobGraphStore`.

[GitHub] [flink] JingsongLi commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
JingsongLi commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r14855 ## File path: flink-connectors/flink

[GitHub] [flink] JingsongLi commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
JingsongLi commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r14364 ## File path: flink-connectors/flink

[GitHub] [flink] JingsongLi commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
JingsongLi commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r15283 ## File path: flink-connectors/flink

[GitHub] [flink] flinkbot edited a comment on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path URL: https://github.com/apache/flink/pull/9875#issuecomment-540311608 ## CI report: * 3ab8ff37e57d7f9a4e3bc2421f5f978a66022589 : PENDING [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-539910284 ## CI report: * e66114b1aa73a82b4c6bcf5c3a16baedb598f8c3 : FAILURE [Build](https://travis-ci.com/flink-

[GitHub] [flink] wuchong commented on a change in pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

2019-10-09 Thread GitBox
wuchong commented on a change in pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802#discussion_r13932 ## File path: docs/dev/table/connect.md ## @@ -1075,6 +1076,143 @@

[GitHub] [flink] wuchong commented on a change in pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

2019-10-09 Thread GitBox
wuchong commented on a change in pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802#discussion_r14037 ## File path: docs/dev/table/connect.md ## @@ -1075,6 +1076,143 @@

[GitHub] [flink] wuchong commented on a change in pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

2019-10-09 Thread GitBox
wuchong commented on a change in pull request #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802#discussion_r13168 ## File path: docs/dev/table/connect.md ## @@ -1075,6 +1075,88 @@ C

[jira] [Commented] (FLINK-14339) The checkpoint ID count wrong on restore savepoint log

2019-10-09 Thread king's uncle (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948152#comment-16948152 ] king's uncle commented on FLINK-14339: -- Yes, But we want to see current checkpoint

[GitHub] [flink] JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-09 Thread GitBox
JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r13600 ## File path: docs/dev/table/connect.md ## @@ -1115,12 +1106

[jira] [Created] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

2019-10-09 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-14359: Summary: Create a module called flink-sql-connector-hbase to shade HBase Key: FLINK-14359 URL: https://issues.apache.org/jira/browse/FLINK-14359 Project: Flink

[GitHub] [flink] JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-09 Thread GitBox
JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r13084 ## File path: docs/dev/table/connect.md ## @@ -49,6 +49,7 @@

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r07912 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -204,6 +204,26 @@ def eval(self,

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r07873 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -204,6 +204,26 @@ def eval(self,

[GitHub] [flink] dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs.

2019-10-09 Thread GitBox
dianfu commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#discussion_r08079 ## File path: flink-python/pyflink/table/tests/test_udf.py ## @@ -204,6 +204,26 @@ def eval(self,

[jira] [Commented] (FLINK-13567) Avro Confluent Schema Registry nightly end-to-end test failed on Travis

2019-10-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948149#comment-16948149 ] Yu Li commented on FLINK-13567: --- Another instance: https://api.travis-ci.org/v3/job/595592

[GitHub] [flink] TisonKun commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-09 Thread GitBox
TisonKun commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#discussion_r12163 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DefaultDispatc

[GitHub] [flink] openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect

2019-10-09 Thread GitBox
openinx commented on a change in pull request #9866: [FLINK-14349][hbase] Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect URL: https://github.com/apache/flink/pull/9866#discussion_r12118 ## File path: flink-connectors/flink-hb

[GitHub] [flink] wuchong commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-09 Thread GitBox
wuchong commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r6 ## File path: docs/dev/table/connect.md ## @@ -49,6 +49,7 @@ Th

[GitHub] [flink] wuchong commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-09 Thread GitBox
wuchong commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r10277 ## File path: docs/dev/table/connect.md ## @@ -1115,12 +1106,15

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

2019-10-09 Thread GitBox
flinkbot 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-54030298

[GitHub] [flink] flinkbot commented on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path

2019-10-09 Thread GitBox
flinkbot commented on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path URL: https://github.com/apache/flink/pull/9875#issuecomment-540311608 ## CI report: * 3ab8ff37e57d7f9a4e3bc2421f5f978a66022589 : UNKNOWN Bot commands The @flin

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 : SUCCESS [Build](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9529: [FLINK-12979]Allowing set an empty line delimiter at end of an message using CsvRowSerializationSchema

2019-10-09 Thread GitBox
flinkbot edited a comment on issue #9529: [FLINK-12979]Allowing set an empty line delimiter at end of an message using CsvRowSerializationSchema URL: https://github.com/apache/flink/pull/9529#issuecomment-524607772 ## CI report: * 88ae31ca30e15c2af5fb6d396673bf07eedfc5c3 : SUCCES

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

2019-10-09 Thread GitBox
flinkbot 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-540302986

[jira] [Commented] (FLINK-14352) Dependencies section in Connect page of Table is broken

2019-10-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948132#comment-16948132 ] Jingsong Lee commented on FLINK-14352: -- [~karmagyz] Ah.. you are right, unstable ve

[jira] [Closed] (FLINK-14352) Dependencies section in Connect page of Table is broken

2019-10-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-14352. Resolution: Invalid > Dependencies section in Connect page of Table is broken > --

[GitHub] [flink] flinkbot commented on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path

2019-10-09 Thread GitBox
flinkbot commented on issue #9875: [hotfix][docs] Fix the incorrect scala checkstyle configure file path URL: https://github.com/apache/flink/pull/9875#issuecomment-540302059 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revie

  1   2   3   4   >