[GitHub] [flink] flinkbot commented on issue #11807: [FLINK-16113][table-planner-blink] ExpressionReducer shouldn't escape…

flinkbot commented on issue #11807: [FLINK-16113][table-planner-blink] ExpressionReducer shouldn't escape… URL: https://github.com/apache/flink/pull/11807#issuecomment-616059456 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[GitHub] [flink] libenchao opened a new pull request #11807: [FLINK-16113][table-planner-blink] ExpressionReducer shouldn't escape…

libenchao opened a new pull request #11807: [FLINK-16113][table-planner-blink] ExpressionReducer shouldn't escape… URL: https://github.com/apache/flink/pull/11807 … the reduced string value ## What is the purpose of the change ExpressionReducer shouldn't escape the red

[GitHub] [flink] flinkbot edited a comment on issue #11806: [FLINK-17223][AZP] Clean up disk space on Azure-hosted builders

flinkbot edited a comment on issue #11806: [FLINK-17223][AZP] Clean up disk space on Azure-hosted builders URL: https://github.com/apache/flink/pull/11806#issuecomment-616051441 ## CI report: * 7c034ffcdf78ba9ac64f83c039b30838032da4e4 Travis: [PENDING](https://travis-ci.com/gith

[GitHub] [flink] flinkbot edited a comment on issue #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests

flinkbot edited a comment on issue #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests URL: https://github.com/apache/flink/pull/11805#issuecomment-616030530 ## CI report: * 2670def9536876df7899cf712e329b0c6f70f692

[GitHub] [flink] flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * ab6e2e33d46724a5694a66b13bba1d8a6fdbbdc1 Travis: [PENDI

[GitHub] [flink] flinkbot commented on issue #11806: [FLINK-17223][AZP] Clean up disk space on Azure-hosted builders

flinkbot commented on issue #11806: [FLINK-17223][AZP] Clean up disk space on Azure-hosted builders URL: https://github.com/apache/flink/pull/11806#issuecomment-616051441 ## CI report: * 7c034ffcdf78ba9ac64f83c039b30838032da4e4 UNKNOWN Bot commands The @flinkbot b

[GitHub] [flink] dianfu commented on issue #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests

dianfu commented on issue #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests URL: https://github.com/apache/flink/pull/11805#issuecomment-616050038 @rmetzger Thanks a lot for the review. I will merge it once the tests passed

[GitHub] [flink] flinkbot commented on issue #11806: [FLINK-17223][AZP] Clean up disk space on Azure-hosted builders

flinkbot commented on issue #11806: [FLINK-17223][AZP] Clean up disk space on Azure-hosted builders URL: https://github.com/apache/flink/pull/11806#issuecomment-616048700 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review yo

[jira] [Updated] (FLINK-17223) System.IO.IOException: No space left on device in misc profile on free Azure builders

[ https://issues.apache.org/jira/browse/FLINK-17223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17223: --- Labels: pull-request-available (was: ) > System.IO.IOException: No space left on device in

[GitHub] [flink] rmetzger opened a new pull request #11806: [FLINK-17223][AZP] Clean up disk space on Azure-hosted builders

rmetzger opened a new pull request #11806: [FLINK-17223][AZP] Clean up disk space on Azure-hosted builders URL: https://github.com/apache/flink/pull/11806 ## What is the purpose of the change Due to a recent change in the machines provided by Azure, the available disk space has redu

[jira] [Commented] (FLINK-17188) Failed to download conda when running python tests

[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086769#comment-17086769 ] Robert Metzger commented on FLINK-17188: Thanks a lot > Failed to download cond

[jira] [Comment Edited] (FLINK-17188) Failed to download conda when running python tests

[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086769#comment-17086769 ] Robert Metzger edited comment on FLINK-17188 at 4/19/20, 5:58 AM:

[jira] [Assigned] (FLINK-17188) Failed to download conda when running python tests

[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-17188: -- Assignee: Huang Xingbo > Failed to download conda when running python tests > ---

[jira] [Comment Edited] (FLINK-15641) Support to start init container

[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086760#comment-17086760 ] ouyangwulin edited comment on FLINK-15641 at 4/19/20, 5:38 AM: ---

[jira] [Commented] (FLINK-15641) Support to start init container

[ https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086760#comment-17086760 ] ouyangwulin commented on FLINK-15641: - [~fly_in_gis]，in progressing. > Support to s

[GitHub] [flink] zhengcanbin edited a comment on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters

zhengcanbin edited a comment on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters URL: https://github.com/apache/flink/pull/11708#issuecomment-616018548 Thanks for your review @tillrohrmann! I have addressed your comments and look

[GitHub] [flink] flinkbot edited a comment on issue #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests

flinkbot edited a comment on issue #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests URL: https://github.com/apache/flink/pull/11805#issuecomment-616030530 ## CI report: * 2670def9536876df7899cf712e329b0c6f70f692

[GitHub] [flink] flinkbot commented on issue #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests

flinkbot commented on issue #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests URL: https://github.com/apache/flink/pull/11805#issuecomment-616030530 ## CI report: * 2670def9536876df7899cf712e329b0c6f70f692 UNKNOW

[jira] [Comment Edited] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086740#comment-17086740 ] Dian Fu edited comment on FLINK-17068 at 4/19/20, 4:37 AM: --- Ju

[jira] [Commented] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086740#comment-17086740 ] Dian Fu commented on FLINK-17068: - Just make it clear: this issue is because the permiss

[GitHub] [flink] flinkbot commented on issue #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests

flinkbot commented on issue #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests URL: https://github.com/apache/flink/pull/11805#issuecomment-616028131 Thanks a lot for your contribution to the Apache Flink project. I'm the @

[jira] [Assigned] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17068: --- Assignee: Dian Fu > ERROR at teardown of TableConfigTests.test_get_set_decimal_context > --

[jira] [Updated] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context

[ https://issues.apache.org/jira/browse/FLINK-17068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17068: --- Labels: pull-request-available test-stability (was: test-stability) > ERROR at teardown of

[GitHub] [flink] dianfu opened a new pull request #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests

dianfu opened a new pull request #11805: [FLINK-17068][python][tests] Ensure the permission of scripts set correctly before executing the Python tests URL: https://github.com/apache/flink/pull/11805 ## What is the purpose of the change *This pull request add the executable permis

[jira] [Created] (FLINK-17234) Show more error messages in taskmanager's log

Kurt Young created FLINK-17234: -- Summary: Show more error messages in taskmanager's log Key: FLINK-17234 URL: https://issues.apache.org/jira/browse/FLINK-17234 Project: Flink Issue Type: Improve

[jira] [Updated] (FLINK-17234) Show more error messages in taskmanager's log

[ https://issues.apache.org/jira/browse/FLINK-17234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17234: --- Description: I created a csv table in sql client and trying to view the table content by executing

[jira] [Commented] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086732#comment-17086732 ] Canbin Zheng commented on FLINK-17196: -- Thanks, [~fly_in_gis]! They are already in

[GitHub] [flink] flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * 66188949ff1646c298d32df7fe45c6745f771bc1 Travis: [FAILU

[GitHub] [flink] zhengcanbin commented on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters

zhengcanbin commented on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters URL: https://github.com/apache/flink/pull/11708#issuecomment-616018548 Thanks for your comments @tillrohrmann! I have addressed your comments and look forwa

[GitHub] [flink] flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * 66188949ff1646c298d32df7fe45c6745f771bc1 Travis: [FAILU

[jira] [Commented] (FLINK-17226) Remove Prometheus relocations

[ https://issues.apache.org/jira/browse/FLINK-17226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086729#comment-17086729 ] molsion commented on FLINK-17226: - [~chesnay] I don't quite understand the question, can

[GitHub] [flink] flinkbot edited a comment on issue #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

flinkbot edited a comment on issue #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy URL: https://github.com/apache/flink/pull/11770#issuecomment-614523163 ## CI report: * d8568c4f9d43b9cd0b9cb47e6f8a9ddd8a57ec1c Travis: [SUCCESS](https://travis-ci.com/g

[GitHub] [flink] KurtYoung commented on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

KurtYoung commented on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#issuecomment-616013579 There is an e2e tests failure: "Dependency shading of table modules test" --

[jira] [Commented] (FLINK-17229) Add a flink-sql-client-sdk module

[ https://issues.apache.org/jira/browse/FLINK-17229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086724#comment-17086724 ] godfrey he commented on FLINK-17229: [~molsion] if you want to submit jobs and acces

[jira] [Commented] (FLINK-17177) Handle ERROR event correctly in KubernetesResourceManager#onError

[ https://issues.apache.org/jira/browse/FLINK-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086719#comment-17086719 ] Yang Wang commented on FLINK-17177: --- [~felixzheng], thanks a lot. Let's try to figure

[GitHub] [flink] flinkbot edited a comment on issue #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

flinkbot edited a comment on issue #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy URL: https://github.com/apache/flink/pull/11770#issuecomment-614523163 ## CI report: * d8568c4f9d43b9cd0b9cb47e6f8a9ddd8a57ec1c Travis: [PENDING](https://travis-ci.com/g

[jira] [Commented] (FLINK-17229) Add a flink-sql-client-sdk module

[ https://issues.apache.org/jira/browse/FLINK-17229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086716#comment-17086716 ] molsion commented on FLINK-17229: - [~godfreyhe], thank you for your answer, but is flink

[GitHub] [flink] flinkbot edited a comment on issue #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

flinkbot edited a comment on issue #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy URL: https://github.com/apache/flink/pull/11770#issuecomment-614523163 ## CI report: * 395043eb6bbd4b1dc2dffa1a463ddf7a36401132 Travis: [SUCCESS](https://travis-ci.com/g

[GitHub] [flink] flinkbot edited a comment on issue #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy

flinkbot edited a comment on issue #11770: [FLINK-17014][runtime] Implement PipelinedRegionSchedulingStrategy URL: https://github.com/apache/flink/pull/11770#issuecomment-614523163 ## CI report: * 395043eb6bbd4b1dc2dffa1a463ddf7a36401132 Travis: [SUCCESS](https://travis-ci.com/g

[GitHub] [flink] flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * 42e0607b996d640983cddede30eb1281944c1c64 Travis: [SUCCESS](https://tra

[jira] [Commented] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086706#comment-17086706 ] Zhu Zhu commented on FLINK-17075: - Thanks for the explanation! I think the heartbeat way

[GitHub] [flink] flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * 42e0607b996d640983cddede30eb1281944c1c64 Travis: [SUCCESS](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * 42e0607b996d640983cddede30eb1281944c1c64 Travis: [PENDING](https://tra

[GitHub] [flink] flinkbot commented on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

flinkbot commented on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * 42e0607b996d640983cddede30eb1281944c1c64 UNKNOWN Bot commands

[GitHub] [flink] flinkbot commented on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

flinkbot commented on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog URL: https://github.com/apache/flink/pull/11804#issuecomment-615957826 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] bowenli86 opened a new pull request #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

bowenli86 opened a new pull request #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog URL: https://github.com/apache/flink/pull/11804 ## What is the purpose of the change add documentation for JDBCCatalog and PostgresCatalog ## Brief change

[jira] [Updated] (FLINK-16473) add documentation for JDBCCatalog and PostgresCatalog

[ https://issues.apache.org/jira/browse/FLINK-16473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16473: --- Labels: pull-request-available (was: ) > add documentation for JDBCCatalog and PostgresCata

[jira] [Updated] (FLINK-16473) add documentation for JDBCCatalog and PostgresCatalog

[ https://issues.apache.org/jira/browse/FLINK-16473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16473: - Summary: add documentation for JDBCCatalog and PostgresCatalog (was: add documentation for PostgresJDBC

[jira] [Commented] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per query in SQL

[ https://issues.apache.org/jira/browse/FLINK-17173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086655#comment-17086655 ] Jiahui Jiang commented on FLINK-17173: -- [~danny0405] I'd love to contribute the fea

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410746156 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410746366 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/event/Read

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410746363 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/event/AddS

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410746390 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/event/Sour

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410746103 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410746233 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410745362 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410745364 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410746237 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410745342 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410744838 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410735535 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410737305 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410745424 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410737187 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410736100 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation.

StephanEwen commented on a change in pull request #11554: [FLINK-15101][connector/common] Add SourceCoordinator implementation. URL: https://github.com/apache/flink/pull/11554#discussion_r410744704 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinato

[GitHub] [flink] flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * 66188949ff1646c298d32df7fe45c6745f771bc1 Travis: [FAILU

[jira] [Commented] (FLINK-16155) Translate "Operator/Process Function" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086580#comment-17086580 ] Xu Bai commented on FLINK-16155: Hi~[~jark] l'm very happy to communicate with you. Thi

[GitHub] [flink] flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * 66188949ff1646c298d32df7fe45c6745f771bc1 Travis: [PENDI

[GitHub] [flink] flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * d34a27ea803c0203027ec4cc5fb751bb30d51bad Travis: [FAILU

[GitHub] [flink] flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * d34a27ea803c0203027ec4cc5fb751bb30d51bad Travis: [FAILU

[GitHub] [flink] flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#issuecomment-612000686 ## CI report: * f52f4a10b99fa573ffeb63f16491d735cc157a4b UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#issuecomment-612000686 ## CI report: * f52f4a10b99fa573ffeb63f16491d735cc157a4b UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container

flinkbot edited a comment on issue #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container URL: https://github.com/apache/flink/pull/11707#issuecomment-612573622 ## CI report: * 4f0e56971c9ef4876abab1352f7e0468ef712a92 UNKNOWN * 40701c83ad09fa7e5d7c678015ed9

[GitHub] [flink] flinkbot edited a comment on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters

flinkbot edited a comment on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters URL: https://github.com/apache/flink/pull/11708#issuecomment-612587571 ## CI report: * 77fea16c342424d8b0ce3950d5738bfc43dcb3cc UNKNOWN * 2

[GitHub] [flink] flinkbot edited a comment on issue #11803: [hotfix][config][docs] Deprecate taskmanager.numberOfTaskSlots in mesos_task_manager_configuration.html

flinkbot edited a comment on issue #11803: [hotfix][config][docs] Deprecate taskmanager.numberOfTaskSlots in mesos_task_manager_configuration.html URL: https://github.com/apache/flink/pull/11803#issuecomment-615861324 ## CI report: * a8101f9f9ca854333bacf980e33d14115088eac7 Travi

[GitHub] [flink] aljoscha commented on issue #11696: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint

aljoscha commented on issue #11696: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint URL: https://github.com/apache/flink/pull/11696#issuecomment-615894182 @flinkbot run azure

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * 213179008a58c7

[jira] [Closed] (FLINK-16600) Respect the rest.bind-port for the Kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-16600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-16600. - Resolution: Fixed master(1.11) via 7a7aaec9745461da9590c61f6ba75be64388d397 > Respect the rest.bind-por

[GitHub] [flink] TisonKun closed pull request #11705: [FLINK-16600][k8s] Fix not respecting the RestOptions.BIND_PORT for the Kubernetes setup

TisonKun closed pull request #11705: [FLINK-16600][k8s] Fix not respecting the RestOptions.BIND_PORT for the Kubernetes setup URL: https://github.com/apache/flink/pull/11705 This is an automated message from the Apache Git S

[jira] [Updated] (FLINK-17189) Table with processing time attribute can not be read from Hive catalog

[ https://issues.apache.org/jira/browse/FLINK-17189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17189: Fix Version/s: (was: 1.10.1) 1.10.2 > Table with processing time attribute can not

[jira] [Updated] (FLINK-17189) Table with processing time attribute can not be read from Hive catalog

[ https://issues.apache.org/jira/browse/FLINK-17189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17189: Fix Version/s: 1.11.0 1.10.1 > Table with processing time attribute can not be read fro

[jira] [Commented] (FLINK-16819) Got KryoException while using UDAF in flink1.9

[ https://issues.apache.org/jira/browse/FLINK-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086501#comment-17086501 ] Jark Wu commented on FLINK-16819: - Glad to hear that too [~neighborhood]! > Got KryoEx

[jira] [Closed] (FLINK-16379) Introduce fromValues in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-16379. Resolution: Fixed Implemented in 6b3e037b7073c06412210cc82843924e8a3c9eee > Introduce fro

[GitHub] [flink] dawidwys closed pull request #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

dawidwys closed pull request #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290 This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink] flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#issuecomment-612000686 ## CI report: * f52f4a10b99fa573ffeb63f16491d735cc157a4b UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container

flinkbot edited a comment on issue #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container URL: https://github.com/apache/flink/pull/11707#issuecomment-612573622 ## CI report: * 4f0e56971c9ef4876abab1352f7e0468ef712a92 UNKNOWN * 40701c83ad09fa7e5d7c678015ed9

[jira] [Commented] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086485#comment-17086485 ] Yang Wang commented on FLINK-17196: --- Just one quick reminder, if we completely separat

[jira] [Comment Edited] (FLINK-16819) Got KryoException while using UDAF in flink1.9

[ https://issues.apache.org/jira/browse/FLINK-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086483#comment-17086483 ] Lsw_aka_laplace edited comment on FLINK-16819 at 4/18/20, 3:05 PM: ---

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * 213179008a58c7

[GitHub] [flink] flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#issuecomment-612000686 ## CI report: * f52f4a10b99fa573ffeb63f16491d735cc157a4b UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * d34a27ea803c0203027ec4cc5fb751bb30d51bad Travis: [FAILU

[jira] [Commented] (FLINK-16819) Got KryoException while using UDAF in flink1.9

[ https://issues.apache.org/jira/browse/FLINK-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086483#comment-17086483 ] Lsw_aka_laplace commented on FLINK-16819: - [~jark]  These jobs which I mentioned

[GitHub] [flink] wangyang0918 commented on issue #11705: [FLINK-16600][k8s] Fix not respecting the RestOptions.BIND_PORT for the Kubernetes setup

wangyang0918 commented on issue #11705: [FLINK-16600][k8s] Fix not respecting the RestOptions.BIND_PORT for the Kubernetes setup URL: https://github.com/apache/flink/pull/11705#issuecomment-615885320 @TisonKun @zhengcanbin I have checked the test and changes again. If we set `rest.bind-por

[jira] [Comment Edited] (FLINK-17229) Add a flink-sql-client-sdk module

[ https://issues.apache.org/jira/browse/FLINK-17229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086477#comment-17086477 ] godfrey he edited comment on FLINK-17229 at 4/18/20, 3:00 PM:

[GitHub] [flink] godfreyhe commented on a change in pull request #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

godfreyhe commented on a change in pull request #11727: [FLINK-17106][table] Support create and drop view in Flink SQL URL: https://github.com/apache/flink/pull/11727#discussion_r410708396 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/plan

[GitHub] [flink] godfreyhe commented on a change in pull request #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

godfreyhe commented on a change in pull request #11727: [FLINK-17106][table] Support create and drop view in Flink SQL URL: https://github.com/apache/flink/pull/11727#discussion_r410708396 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/plan

[GitHub] [flink] flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition

flinkbot edited a comment on issue #11786: [FLINK-17208][network] Reduce redundant data available notifications of PipelinedSubpartition URL: https://github.com/apache/flink/pull/11786#issuecomment-615087816 ## CI report: * d34a27ea803c0203027ec4cc5fb751bb30d51bad Travis: [PENDI

[GitHub] [flink] flinkbot edited a comment on issue #11803: [hotfix][config][docs] Deprecate taskmanager.numberOfTaskSlots in mesos_task_manager_configuration.html

flinkbot edited a comment on issue #11803: [hotfix][config][docs] Deprecate taskmanager.numberOfTaskSlots in mesos_task_manager_configuration.html URL: https://github.com/apache/flink/pull/11803#issuecomment-615861324 ## CI report: * a8101f9f9ca854333bacf980e33d14115088eac7 Travi

[GitHub] [flink] flinkbot edited a comment on issue #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container

flinkbot edited a comment on issue #11707: [FLINK-15648][k8s] Introduce CPU limit support for JM/TM Container URL: https://github.com/apache/flink/pull/11707#issuecomment-612573622 ## CI report: * 4f0e56971c9ef4876abab1352f7e0468ef712a92 UNKNOWN * ae7d6fac92d028c50b0b027da50ae

  1   2   >