[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327958374 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[jira] [Commented] (FLINK-14201) SQL supports redis sink connector

[ https://issues.apache.org/jira/browse/FLINK-14201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937463#comment-16937463 ] Yangze Guo commented on FLINK-14201: [~alfredlu] Yes, you're right. I couldn't find

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327957126 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] flinkbot commented on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot commented on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961 ## CI report: * 8fffbbc4bc605ccedad7412ac2292d3488261

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954961 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327955120 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327955101 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327955120 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954988 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954961 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954939 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954679 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954701 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954620 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954701 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954599 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954679 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954640 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327954911 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] flinkbot commented on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot commented on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534874281 Thanks a lot for your contribution to the Apache Flink project.

[jira] [Updated] (FLINK-14018) Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

[ https://issues.apache.org/jira/browse/FLINK-14018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14018: --- Labels: pull-request-available (was: ) > Add Python building blocks to make sure the basic

[GitHub] [flink] dianfu opened a new pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

dianfu opened a new pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766 ## What is the purpose of the change *This pull request adds the Python bu

[GitHub] [flink] lamber-ken commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

lamber-ken commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534872356 > @tillrohrmann Could you please take a look at this instance above? I think it is the same as I've reported in [FLINK-13417](https://

[GitHub] [flink] TisonKun commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

TisonKun commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534871672 @tillrohrmann Could you please take a look at this instance above? I think it is the same as I've reported in [FLINK-13417](https://issu

[GitHub] [flink] Mrart commented on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

Mrart commented on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-534871400 @zentol Could you help review again，I have add A config option。I sorry for delay。

[GitHub] [flink] lamber-ken commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

lamber-ken commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534870799 hi, @TisonKun follow bellow tips, I had rebuild flink and run `tools/releasing/collect_license_files.sh build-target`, but travi

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[jira] [Commented] (FLINK-14201) SQL supports redis sink connector

[ https://issues.apache.org/jira/browse/FLINK-14201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937434#comment-16937434 ] Zijie Lu commented on FLINK-14201: -- [~karmagyz] There is a redis connector in the follo

[jira] [Commented] (FLINK-14201) SQL supports redis sink connector

[ https://issues.apache.org/jira/browse/FLINK-14201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937431#comment-16937431 ] Yangze Guo commented on FLINK-14201: Thanks for the feedback [~alfredlu]. AFAIK, Fli

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

flinkbot edited a comment on issue #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#issuecomment-527387437 ## CI report: * 1bd21c6cd2d430b9827b903e80f31c55bcb04750 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python f

flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534087366 ## CI report:

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9765: [FLINK-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM

flinkbot edited a comment on issue #9765: [FLINK-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM URL: https://github.com/apache/flink/pull/9765#issuecomment-534839485 ## CI report: * 67210a4c8e0fc74c15091faee8096d7c44e9fe49 : SUCCESS [Build](https://travis-ci.com/fli

[jira] [Created] (FLINK-14201) SQL supports redis sink connector

Zijie Lu created FLINK-14201: Summary: SQL supports redis sink connector Key: FLINK-14201 URL: https://issues.apache.org/jira/browse/FLINK-14201 Project: Flink Issue Type: Wish Componen

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r316978992 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClus

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r327931437 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBa

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r327931310 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBa

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r327931275 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessio

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r327931833 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClus

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r327932732 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/Ya

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

HuangZhenQiu commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r327932221 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClus

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

flinkbot edited a comment on issue #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#issuecomment-527387437 ## CI report: * 1bd21c6cd2d430b9827b903e80f31c55bcb04750 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750#issuecomment-534370339 ## CI report: * 9ea7a2157e67850fe26c893969108694d2525284 : SUCCESS [Build](https://travis-ci.com/f

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

flinkbot edited a comment on issue #8912: [FLINK-12709] [runtime] Implement new generation restart strategy loader which also respects legacy… URL: https://github.com/apache/flink/pull/8912#issuecomment-527387437 ## CI report: * 1bd21c6cd2d430b9827b903e80f31c55bcb04750 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9301: [FLINK-13469][state] Ensure resource used by StateMapSnapshot will be released if snapshot fails

flinkbot edited a comment on issue #9301: [FLINK-13469][state] Ensure resource used by StateMapSnapshot will be released if snapshot fails URL: https://github.com/apache/flink/pull/9301#issuecomment-516855887 ## CI report: * dae038f150dbe42e451e9a42f5a6a060b162a5ef : FAILURE [Bu

[GitHub] [flink] flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python f

flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534087366 ## CI report:

[GitHub] [flink] carp84 commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

carp84 commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-534844656 What's more, I think we should split the `StateBackendTestBase. testMapState` case to explicitly test each `MapState` operation interfa

[GitHub] [flink] flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522106295 ## CI report: * 78654e8f80aa0b1a01654e7684f4610eb1d3aff4 : SUCCESS [

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] carp84 commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

carp84 commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-534844195 > There have been some tests for `MapState.isEmpty` in `StateBackendTestBase.testMapState`, do you actually mean other tests for `MapS

[GitHub] [flink] flinkbot edited a comment on issue #9765: [FLINK-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM

flinkbot edited a comment on issue #9765: [FLINK-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM URL: https://github.com/apache/flink/pull/9765#issuecomment-534839485 ## CI report: * 67210a4c8e0fc74c15091faee8096d7c44e9fe49 : PENDING [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

flinkbot edited a comment on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#issuecomment-534832110 ## CI report: * 936857429eb4fa0e47440e142a688ac1505d85ec : FAILURE [Build](https://travis-c

[GitHub] [flink] flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750#issuecomment-534370339 ## CI report: * 9ea7a2157e67850fe26c893969108694d2525284 : SUCCESS [Build](https://travis-ci.com/f

[GitHub] [flink] dianfu commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function e

dianfu commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534842612 @sunjincheng121 I have updat

[GitHub] [flink] flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python f

flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534087366 ## CI report:

[GitHub] [flink] flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522106295 ## CI report: * 78654e8f80aa0b1a01654e7684f4610eb1d3aff4 : SUCCESS [

[jira] [Resolved] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng resolved FLINK-14179. -- Resolution: Fixed > Wrong description of SqlCommand.SHOW_FUNCTIONS > -

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] flinkbot commented on issue #9765: [FLINK-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM

flinkbot commented on issue #9765: [FLINK-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM URL: https://github.com/apache/flink/pull/9765#issuecomment-534839485 ## CI report: * 67210a4c8e0fc74c15091faee8096d7c44e9fe49 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9763: [FLINK-13037][docs-zh] Translate "Concepts -> Glossary" page into Chinese

flinkbot edited a comment on issue #9763: [FLINK-13037][docs-zh] Translate "Concepts -> Glossary" page into Chinese URL: https://github.com/apache/flink/pull/9763#issuecomment-534828530 ## CI report: * 301e466b5a04494d5e5b3ed0531024227c32e8fc : FAILURE [Build](https://travis-ci.

[GitHub] [flink] flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750#issuecomment-534370339 ## CI report: * 9ea7a2157e67850fe26c893969108694d2525284 : SUCCESS [Build](https://travis-ci.com/f

[GitHub] [flink] wsry commented on a change in pull request #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

wsry commented on a change in pull request #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750#discussion_r327920270 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.jav

[GitHub] [flink] flinkbot commented on issue #9765: [Flink-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM

flinkbot commented on issue #9765: [Flink-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM URL: https://github.com/apache/flink/pull/9765#issuecomment-534837781 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[GitHub] [flink] wangxiyuan opened a new pull request #9765: [Flink-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM

wangxiyuan opened a new pull request #9765: [Flink-14126][test] Disable Xpack.ml for elasticsearch 6.0+ on ARM URL: https://github.com/apache/flink/pull/9765 ## What is the purpose of the change Elasticsearch Xpack Machine Learning function is enabled by default if the versi

[GitHub] [flink] flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522106295 ## CI report: * 78654e8f80aa0b1a01654e7684f4610eb1d3aff4 : SUCCESS [

[jira] [Commented] (FLINK-9749) Rework Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937374#comment-16937374 ] Shimin Yang commented on FLINK-9749: Hi [~kkl0u], that would be nice. One more questi

[GitHub] [flink] Rishi55 commented on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

Rishi55 commented on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-534836750 Hi @tzulitai, I modified my changes according to your suggestions. Please review. -

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

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 #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

flinkbot edited a comment on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#issuecomment-534832110 ## CI report: * 936857429eb4fa0e47440e142a688ac1505d85ec : PENDING [Build](https://travis-c

[GitHub] [flink] wsry commented on a change in pull request #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

wsry commented on a change in pull request #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750#discussion_r327918636 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.jav

[jira] [Updated] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side

[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14200: Fix Version/s: 1.9.1 > Temporal Table Function Joins do not work on Tables (only TableSources) on > the q

[GitHub] [flink] flinkbot edited a comment on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11

flinkbot edited a comment on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11 URL: https://github.com/apache/flink/pull/9744#issuecomment-533988291 ## CI report: * 8210403a33cf3a6908980378fae9ee8d567afdb1 : SUCCESS [Build](https://travis-ci.com/flink-ci/fl

[jira] [Commented] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side

[ https://issues.apache.org/jira/browse/FLINK-14200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937367#comment-16937367 ] Jark Wu commented on FLINK-14200: - Hi [~BenoitParis], thanks for reporting this. I think

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#discussion_r327917799 ## File path: flink-table/flink-sql-parser/src/main/java/org

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#discussion_r327917280 ## File path: flink-table/flink-table-planner-blink/src/test

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#discussion_r327917230 ## File path: flink-table/flink-table-planner-blink/src/test

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#discussion_r327917159 ## File path: flink-table/flink-sql-parser/src/main/java/org

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] flinkbot edited a comment on issue #9763: [FLINK-13037][docs-zh] Translate "Concepts -> Glossary" page into Chinese

flinkbot edited a comment on issue #9763: [FLINK-13037][docs-zh] Translate "Concepts -> Glossary" page into Chinese URL: https://github.com/apache/flink/pull/9763#issuecomment-534828530 ## CI report: * 301e466b5a04494d5e5b3ed0531024227c32e8fc : PENDING [Build](https://travis-ci.

[GitHub] [flink] flinkbot commented on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

flinkbot commented on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#issuecomment-534832110 ## CI report: * 936857429eb4fa0e47440e142a688ac1505d85ec : UNKNOWN ---

[GitHub] [flink] flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534387866 ## CI report: * 5b73b3d6319447fd2d81b48183d9f22012133a6b : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/

[GitHub] [flink] KurtYoung commented on a change in pull request #9761: [FLINK-14031][examples][table]Added the blink planner dependency and …

KurtYoung commented on a change in pull request #9761: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9761#discussion_r327914514 ## File path: flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/

[GitHub] [flink] KurtYoung commented on a change in pull request #9761: [FLINK-14031][examples][table]Added the blink planner dependency and …

KurtYoung commented on a change in pull request #9761: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9761#discussion_r327914357 ## File path: flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/

[GitHub] [flink] KurtYoung commented on a change in pull request #9761: [FLINK-14031][examples][table]Added the blink planner dependency and …

KurtYoung commented on a change in pull request #9761: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9761#discussion_r327914739 ## File path: flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/

[jira] [Commented] (FLINK-12939) Translate "Apache Kafka Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937356#comment-16937356 ] Jeff Yang commented on FLINK-12939: --- Here is the [PR|https://github.com/apache/flink/p

[GitHub] [flink] flinkbot commented on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

flinkbot commented on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#issuecomment-534830699 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] yangjf2019 opened a new pull request #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

yangjf2019 opened a new pull request #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764 ## What is the purpose of the change *Translate "Apache Kafka Connector" page into Chinese* ## Bri

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#discussion_r327908022 ## File path: flink-table/flink-sql-parser/src/main/codegen/

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#discussion_r327908022 ## File path: flink-table/flink-sql-parser/src/main/codegen/

[GitHub] [flink] highfei2011 closed pull request #9415: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into C…

highfei2011 closed pull request #9415: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into C… URL: https://github.com/apache/flink/pull/9415 This is an automated message from the Apache Git Service. To respon

[GitHub] [flink] highfei2011 commented on issue #9415: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into C…

highfei2011 commented on issue #9415: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into C… URL: https://github.com/apache/flink/pull/9415#issuecomment-534829104 Open a new PR. This is an automated message fr

[GitHub] [flink] GatsbyNewton commented on issue #9761: [FLINK-14031][examples][table]Added the blink planner dependency and …

GatsbyNewton commented on issue #9761: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9761#issuecomment-534828890 @KurtYoung This is a new PR. Could you please kindly help to review the code changes? Thank you.

[GitHub] [flink] flinkbot commented on issue #9763: [FLINK-13037][docs-zh] Translate "Concepts -> Glossary" page into Chinese

flinkbot commented on issue #9763: [FLINK-13037][docs-zh] Translate "Concepts -> Glossary" page into Chinese URL: https://github.com/apache/flink/pull/9763#issuecomment-534828530 ## CI report: * 301e466b5a04494d5e5b3ed0531024227c32e8fc : UNKNOWN -

[GitHub] [flink] flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534387866 ## CI report: * 5b73b3d6319447fd2d81b48183d9f22012133a6b : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/

[GitHub] [flink] flinkbot edited a comment on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11

flinkbot edited a comment on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11 URL: https://github.com/apache/flink/pull/9744#issuecomment-533988291 ## CI report: * 8210403a33cf3a6908980378fae9ee8d567afdb1 : SUCCESS [Build](https://travis-ci.com/flink-ci/fl

[jira] [Comment Edited] (FLINK-13037) Translate "Concepts -> Glossary" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16888463#comment-16888463 ] Jeff Yang edited comment on FLINK-13037 at 9/25/19 2:46 AM:

  1   2   3   4   5   >