[GitHub] [flink] wulei0302 commented on pull request #13135: [FLINK-18797][docs][examples] Update deprecated forms of keyBy in docs and examples

wulei0302 commented on pull request #13135: URL: https://github.com/apache/flink/pull/13135#issuecomment-673286473 > ## CI report: > * [3b2c0da](https://github.com/apache/flink/commit/3b2c0da11cb0ec78cf24b14c0b70a88df7fff745) Azure:

[jira] [Created] (FLINK-18926) Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section

Wei Zhong created FLINK-18926: - Summary: Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section Key: FLINK-18926 URL: https://issues.apache.org/jira/browse/FLINK-18926

[GitHub] [flink] flinkbot edited a comment on pull request #13135: [FLINK-18797][docs][examples] Update deprecated forms of keyBy in docs and examples

flinkbot edited a comment on pull request #13135: URL: https://github.com/apache/flink/pull/13135#issuecomment-673239905 ## CI report: * 3b2c0da11cb0ec78cf24b14c0b70a88df7fff745 Azure:

[jira] [Created] (FLINK-18927) Add a "Debugging" document under the "Python API" -> "User Guide" -> "Table API" section

Wei Zhong created FLINK-18927: - Summary: Add a "Debugging" document under the "Python API" -> "User Guide" -> "Table API" section Key: FLINK-18927 URL: https://issues.apache.org/jira/browse/FLINK-18927

[GitHub] [flink] tillrohrmann commented on a change in pull request #13131: [FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann commented on a change in pull request #13131: URL: https://github.com/apache/flink/pull/13131#discussion_r469740064 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java ## @@ -117,13 +117,10 @@ protected void

[GitHub] [flink] tillrohrmann commented on a change in pull request #13131: [FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann commented on a change in pull request #13131: URL: https://github.com/apache/flink/pull/13131#discussion_r469740064 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java ## @@ -117,13 +117,10 @@ protected void

[GitHub] [flink] tillrohrmann commented on a change in pull request #13131: [FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann commented on a change in pull request #13131: URL: https://github.com/apache/flink/pull/13131#discussion_r469740064 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java ## @@ -117,13 +117,10 @@ protected void

[GitHub] [flink] flinkbot edited a comment on pull request #13078: [FLINK-18659][hive][orc] Fix streaming write for Hive 1.x Orc table

flinkbot edited a comment on pull request #13078: URL: https://github.com/apache/flink/pull/13078#issuecomment-669935780 ## CI report: * 7b73a977a7a5272e352b5f7af0aaefd619405290 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13135: [FLINK-18797][docs][examples] Update deprecated forms of keyBy in docs and examples

flinkbot edited a comment on pull request #13135: URL: https://github.com/apache/flink/pull/13135#issuecomment-673239905 ## CI report: * 3b2c0da11cb0ec78cf24b14c0b70a88df7fff745 Azure:

[GitHub] [flink] flinkbot commented on pull request #13136: [FLINK-18878][python] Support dependency management for Python Stream…

flinkbot commented on pull request #13136: URL: https://github.com/apache/flink/pull/13136#issuecomment-673306635 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-18801) Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18801: -- Summary: Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table

[GitHub] [flink] flinkbot edited a comment on pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

flinkbot edited a comment on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665526783 ## CI report: * b532233c37983e4dcdf803f43e9560848e5edce1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

flinkbot edited a comment on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-667140037 ## CI report: * 31abcb25fdf72394dbfa91d0ba9e151968375ad7 UNKNOWN * db99952f8166cb4d6337dcb3815e72ff2b49604b UNKNOWN *

[jira] [Created] (FLINK-18934) Idle stream does not advance watermark in connected stream

Truong Duc Kien created FLINK-18934: --- Summary: Idle stream does not advance watermark in connected stream Key: FLINK-18934 URL: https://issues.apache.org/jira/browse/FLINK-18934 Project: Flink

[GitHub] [flink] tzulitai commented on a change in pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

tzulitai commented on a change in pull request #12881: URL: https://github.com/apache/flink/pull/12881#discussion_r469765875 ## File path:

[GitHub] [flink] dannycranmer commented on a change in pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

dannycranmer commented on a change in pull request #12881: URL: https://github.com/apache/flink/pull/12881#discussion_r469766625 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #13111: [FLINK-18220][runtime] Extended OutOfMemoryError message.

tillrohrmann commented on a change in pull request #13111: URL: https://github.com/apache/flink/pull/13111#discussion_r469758699 ## File path: flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java ## @@ -110,51 +112,76 @@ public static boolean

[jira] [Created] (FLINK-18937) Add a "Environment Setup" section to the "Installation" document

Wei Zhong created FLINK-18937: - Summary: Add a "Environment Setup" section to the "Installation" document Key: FLINK-18937 URL: https://issues.apache.org/jira/browse/FLINK-18937 Project: Flink

[jira] [Created] (FLINK-18916) Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18916: - Summary: Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User Guide" section Key: FLINK-18916 URL: https://issues.apache.org/jira/browse/FLINK-18916

[jira] [Created] (FLINK-18923) Add a "CEP" document under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18923: - Summary: Add a "CEP" document under the "Python API" -> "User Guide" section Key: FLINK-18923 URL: https://issues.apache.org/jira/browse/FLINK-18923 Project: Flink

[jira] [Created] (FLINK-18922) Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18922: - Summary: Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User Guide" section Key: FLINK-18922 URL: https://issues.apache.org/jira/browse/FLINK-18922

[jira] [Created] (FLINK-18930) Translate "Hive Dialect" page of "Hive Integration" into Chinese

Rui Li created FLINK-18930: -- Summary: Translate "Hive Dialect" page of "Hive Integration" into Chinese Key: FLINK-18930 URL: https://issues.apache.org/jira/browse/FLINK-18930 Project: Flink Issue

[jira] [Updated] (FLINK-18930) Translate "Hive Dialect" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-18930: --- Component/s: Documentation Connectors / Hive > Translate "Hive Dialect" page of "Hive

[GitHub] [flink] xiaolong-sn commented on a change in pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

xiaolong-sn commented on a change in pull request #13015: URL: https://github.com/apache/flink/pull/13015#discussion_r469741218 ## File path:

[jira] [Updated] (FLINK-18917) Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18917: -- Summary: Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the

[GitHub] [flink] liushui112011 opened a new pull request #13137: Merge pull request #1 from apache/master

liushui112011 opened a new pull request #13137: URL: https://github.com/apache/flink/pull/13137 pull request ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we

[GitHub] [flink] dannycranmer commented on a change in pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

dannycranmer commented on a change in pull request #12881: URL: https://github.com/apache/flink/pull/12881#discussion_r469763944 ## File path:

[jira] [Reopened] (FLINK-18646) Managed memory released check can block RPC thread

[ https://issues.apache.org/jira/browse/FLINK-18646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-18646: --- > Managed memory released check can block RPC thread >

[jira] [Updated] (FLINK-18646) Managed memory released check can block RPC thread

[ https://issues.apache.org/jira/browse/FLINK-18646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18646: -- Fix Version/s: 1.10.2 > Managed memory released check can block RPC thread >

[jira] [Updated] (FLINK-18646) Managed memory released check can block RPC thread

[ https://issues.apache.org/jira/browse/FLINK-18646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18646: -- Affects Version/s: 1.12.0 1.10.1 > Managed memory released check can

[jira] [Closed] (FLINK-18646) Managed memory released check can block RPC thread

[ https://issues.apache.org/jira/browse/FLINK-18646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18646. - Resolution: Fixed Fixed via 1.10.2: 3e17833eec5f5062260eaef2cc06421dabbd7f56 > Managed memory

[jira] [Created] (FLINK-18917) Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18917: - Summary: Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" section Key: FLINK-18917 URL:

[jira] [Created] (FLINK-18921) Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18921: - Summary: Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" section Key: FLINK-18921 URL: https://issues.apache.org/jira/browse/FLINK-18921

[jira] [Updated] (FLINK-18920) Move the "Dependency Management" document from the old Python Table API documentation to the "Python API" -> "User Guide" section

[ https://issues.apache.org/jira/browse/FLINK-18920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18920: -- Summary: Move the "Dependency Management" document from the old Python Table API documentation to the

[jira] [Created] (FLINK-18928) Move the "Common Questions" document from the old Python Table API documentation to the "Python API" section with a new name "FAQ"

Wei Zhong created FLINK-18928: - Summary: Move the "Common Questions" document from the old Python Table API documentation to the "Python API" section with a new name "FAQ" Key: FLINK-18928 URL:

[jira] [Created] (FLINK-18929) Add a "API Docs" link (linked to the generated sphinx docs) under the "Python API" section

Wei Zhong created FLINK-18929: - Summary: Add a "API Docs" link (linked to the generated sphinx docs) under the "Python API" section Key: FLINK-18929 URL: https://issues.apache.org/jira/browse/FLINK-18929

[GitHub] [flink] rkhachatryan commented on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

rkhachatryan commented on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-673306098 Thanks a lot for updating the PR, @echauchot, I'll take a look. Meantime, let CI run :) @flinkbot run azure

[GitHub] [flink] tillrohrmann commented on a change in pull request #13131: [FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann commented on a change in pull request #13131: URL: https://github.com/apache/flink/pull/13131#discussion_r469740064 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java ## @@ -117,13 +117,10 @@ protected void

[jira] [Updated] (FLINK-18878) Support dependency management for Python StreamExecutionEnvironment.

[ https://issues.apache.org/jira/browse/FLINK-18878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18878: --- Labels: pull-request-available (was: ) > Support dependency management for Python

[jira] [Updated] (FLINK-18922) Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18922: -- Summary: Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User

[jira] [Updated] (FLINK-18923) Add a "CEP" document under the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18923: -- Summary: Add a "CEP" document under the "Python API" -> "User Guide" -> "Table API" section (was:

[jira] [Created] (FLINK-18933) Delete the old Python Table API document section

Wei Zhong created FLINK-18933: - Summary: Delete the old Python Table API document section Key: FLINK-18933 URL: https://issues.apache.org/jira/browse/FLINK-18933 Project: Flink Issue Type:

[jira] [Created] (FLINK-18932) Add a "Overview" document under the "Python API" section

Wei Zhong created FLINK-18932: - Summary: Add a "Overview" document under the "Python API" section Key: FLINK-18932 URL: https://issues.apache.org/jira/browse/FLINK-18932 Project: Flink Issue

[GitHub] [flink] azagrebin commented on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

azagrebin commented on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-673311395 Thanks for the review @zhuzhurk I addressed the comments This is an automated message from the Apache Git

[GitHub] [flink] tillrohrmann commented on pull request #13131: [FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann commented on pull request #13131: URL: https://github.com/apache/flink/pull/13131#issuecomment-673310776 Thanks for the review @zentol. Merging this PR now. This is an automated message from the Apache Git

[jira] [Updated] (FLINK-18912) Add a Table API tutorial link(lined to try-flink/python_table_api.md) under the "Python API" -> "GettingStart" -> "Tutorial" section

[ https://issues.apache.org/jira/browse/FLINK-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18912: -- Summary: Add a Table API tutorial link(lined to try-flink/python_table_api.md) under the "Python

[jira] [Created] (FLINK-18935) CompletedOperationCache accepts new operations after closeAsync has been called

Till Rohrmann created FLINK-18935: - Summary: CompletedOperationCache accepts new operations after closeAsync has been called Key: FLINK-18935 URL: https://issues.apache.org/jira/browse/FLINK-18935

[jira] [Updated] (FLINK-18912) Add a Table API tutorial link(linked to try-flink/python_table_api.md) under the "Python API" -> "GettingStart" -> "Tutorial" section

[ https://issues.apache.org/jira/browse/FLINK-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18912: -- Summary: Add a Table API tutorial link(linked to try-flink/python_table_api.md) under the "Python

[GitHub] [flink] flinkbot commented on pull request #13137: Merge pull request #1 from apache/master

flinkbot commented on pull request #13137: URL: https://github.com/apache/flink/pull/13137#issuecomment-673319857 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #13137: Merge pull request #1 from apache/master

flinkbot commented on pull request #13137: URL: https://github.com/apache/flink/pull/13137#issuecomment-673330303 ## CI report: * c0c9a3f90370c4b491db29c85b0e79050f21fef0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] tillrohrmann closed pull request #13129: [BP-1.10][FLINK-18646] Verify memory manager empty in a separate thread with larger timeout

tillrohrmann closed pull request #13129: URL: https://github.com/apache/flink/pull/13129 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Closed] (FLINK-18902) Cannot serve results of asynchronous REST operations in per-job mode

[ https://issues.apache.org/jira/browse/FLINK-18902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18902. - Resolution: Fixed Fixed via master: ee0f55fbba7c9408e3f8647f913260adb4b2c7ab 1.11.2:

[GitHub] [flink] tillrohrmann commented on pull request #13129: [BP-1.10][FLINK-18646] Verify memory manager empty in a separate thread with larger timeout

tillrohrmann commented on pull request #13129: URL: https://github.com/apache/flink/pull/13129#issuecomment-673335350 Manually merged via 3e17833eec5f5062260eaef2cc06421dabbd7f56 This is an automated message from the Apache

[jira] [Created] (FLINK-18918) Add a "Connectors" document under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18918: - Summary: Add a "Connectors" document under the "Python API" -> "User Guide" section Key: FLINK-18918 URL: https://issues.apache.org/jira/browse/FLINK-18918 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13078: [FLINK-18659][hive][orc] Fix streaming write for Hive 1.x Orc table

flinkbot edited a comment on pull request #13078: URL: https://github.com/apache/flink/pull/13078#issuecomment-669935780 ## CI report: * 7b73a977a7a5272e352b5f7af0aaefd619405290 Azure:

[GitHub] [flink] lirui-apache commented on pull request #13078: [FLINK-18659][hive][orc] Fix streaming write for Hive 1.x Orc table

lirui-apache commented on pull request #13078: URL: https://github.com/apache/flink/pull/13078#issuecomment-673296136 @JingsongLi I have enabled mr orc writer tests for 2.x This is an automated message from the Apache Git

[jira] [Closed] (FLINK-2169) Add ParquetTableSource

[ https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-2169. --- Resolution: Fixed > Add ParquetTableSource > -- > > Key:

[GitHub] [flink] flinkbot edited a comment on pull request #12899: [FLINK-16699][k8s] Support accessing secured services via K8s secrets

flinkbot edited a comment on pull request #12899: URL: https://github.com/apache/flink/pull/12899#issuecomment-658162074 ## CI report: * c6edb8841a675096cab4c0e866c3b95c1f3801bf Azure:

[jira] [Created] (FLINK-18931) Translate "Hive Streaming" page of "Hive Integration" into Chinese

Rui Li created FLINK-18931: -- Summary: Translate "Hive Streaming" page of "Hive Integration" into Chinese Key: FLINK-18931 URL: https://issues.apache.org/jira/browse/FLINK-18931 Project: Flink

[GitHub] [flink] mbalassi commented on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

mbalassi commented on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-673303866 Thank you for the PR, @miklosgergely. Let's investigate those test failures. This is an automated message from

[jira] [Updated] (FLINK-18921) Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18921: -- Summary: Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide"

[GitHub] [flink] tzulitai commented on a change in pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

tzulitai commented on a change in pull request #12881: URL: https://github.com/apache/flink/pull/12881#discussion_r469749157 ## File path:

[jira] [Updated] (FLINK-18920) Move the "Dependency Management" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18920: -- Summary: Move the "Dependency Management" document from the old Python Table API documentation to the

[jira] [Updated] (FLINK-18919) Move the "User Defined Functions" document and "Vectorized User Defined Functions" document from the old Python Table API documentation to the "Python API" -> "User Guid

[ https://issues.apache.org/jira/browse/FLINK-18919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18919: -- Summary: Move the "User Defined Functions" document and "Vectorized User Defined Functions" document

[jira] [Updated] (FLINK-18918) Add a "Connectors" document under the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18918: -- Summary: Add a "Connectors" document under the "Python API" -> "User Guide" -> "Table API" section

[GitHub] [flink] tillrohrmann commented on pull request #13132: [BP-1.11][FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann commented on pull request #13132: URL: https://github.com/apache/flink/pull/13132#issuecomment-673315291 AZP has passed. Merging this PR now. This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] tillrohrmann commented on pull request #13133: [BP-1.10][FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann commented on pull request #13133: URL: https://github.com/apache/flink/pull/13133#issuecomment-673315365 Travis has passed. Merging this PR now. This is an automated message from the Apache Git Service. To

[GitHub] [flink] mbalassi commented on a change in pull request #13128: [FLINK-18795][hbase] Support for HBase 2

mbalassi commented on a change in pull request #13128: URL: https://github.com/apache/flink/pull/13128#discussion_r469766403 ## File path: flink-connectors/flink-connector-hbase/README.md ## @@ -0,0 +1,97 @@ +# Flink HBase Connector + +This connector provides classes that

[GitHub] [flink] tzulitai commented on a change in pull request #12944: [FLINK-18513][Kinesis] Add AWS SDK v2.x dependency and KinesisProxyV2

tzulitai commented on a change in pull request #12944: URL: https://github.com/apache/flink/pull/12944#discussion_r469769449 ## File path: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/util/AwsV2UtilTest.java ## @@ -0,0

[GitHub] [flink] tillrohrmann closed pull request #13132: [BP-1.11][FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann closed pull request #13132: URL: https://github.com/apache/flink/pull/13132 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] tillrohrmann closed pull request #13133: [BP-1.10][FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann closed pull request #13133: URL: https://github.com/apache/flink/pull/13133 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] tillrohrmann commented on pull request #13132: [BP-1.11][FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann commented on pull request #13132: URL: https://github.com/apache/flink/pull/13132#issuecomment-673334337 Manually merged via 7e975a49717a7122ab2394397726e5c8fb1c047b This is an automated message from the Apache

[GitHub] [flink] tillrohrmann commented on pull request #13133: [BP-1.10][FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann commented on pull request #13133: URL: https://github.com/apache/flink/pull/13133#issuecomment-673334880 Manually merged via fd7b3719616435cd2aebf65929dbc193a53e68f3 This is an automated message from the Apache

[jira] [Updated] (FLINK-18913) Add a "TableEnvironment" document under the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18913: -- Summary: Add a "TableEnvironment" document under the "Python API" -> "User Guide" -> "Table API"

[jira] [Updated] (FLINK-18916) Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User Guide" -> "Table API" section

[ https://issues.apache.org/jira/browse/FLINK-18916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18916: -- Summary: Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User

[jira] [Updated] (FLINK-18914) Move the "Python DataTypes" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section with a new name "DataTypes"

[ https://issues.apache.org/jira/browse/FLINK-18914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18914: -- Summary: Move the "Python DataTypes" document from the old Python Table API documentation to the

[GitHub] [flink] tillrohrmann commented on pull request #13129: [BP-1.10][FLINK-18646] Verify memory manager empty in a separate thread with larger timeout

tillrohrmann commented on pull request #13129: URL: https://github.com/apache/flink/pull/13129#issuecomment-673313560 Travis has passed. Merging this PR now. This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * d98d4b17c52db1cea0fe0308b5330175c30e90da Azure:

[GitHub] [flink] flinkbot commented on pull request #13136: [FLINK-18878][python] Support dependency management for Python Stream…

flinkbot commented on pull request #13136: URL: https://github.com/apache/flink/pull/13136#issuecomment-673313436 ## CI report: * 6098b6b0563eded5c97787f55094467b82a88593 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176816#comment-17176816 ] Juan Sanchez commented on FLINK-16142: -- Yes [~trohrmann], that is correct. > Memory Leak causes

[GitHub] [flink] wangxiyuan opened a new pull request #13138: Update README.md

wangxiyuan opened a new pull request #13138: URL: https://github.com/apache/flink/pull/13138 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[GitHub] [flink] flinkbot edited a comment on pull request #12899: [FLINK-16699][k8s] Support accessing secured services via K8s secrets

flinkbot edited a comment on pull request #12899: URL: https://github.com/apache/flink/pull/12899#issuecomment-658162074 ## CI report: * c6edb8841a675096cab4c0e866c3b95c1f3801bf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

flinkbot edited a comment on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665526783 ## CI report: * b532233c37983e4dcdf803f43e9560848e5edce1 Azure:

[jira] [Created] (FLINK-18936) Update documentation about user-defined aggregate functions

Timo Walther created FLINK-18936: Summary: Update documentation about user-defined aggregate functions Key: FLINK-18936 URL: https://issues.apache.org/jira/browse/FLINK-18936 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * d98d4b17c52db1cea0fe0308b5330175c30e90da Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

dannycranmer commented on a change in pull request #12881: URL: https://github.com/apache/flink/pull/12881#discussion_r469762021 ## File path:

[GitHub] [flink] tillrohrmann closed pull request #13131: [FLINK-18902][rest] Allow request serving while the REST handlers are shutting down

tillrohrmann closed pull request #13131: URL: https://github.com/apache/flink/pull/13131 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Updated] (FLINK-18914) Move the "Python DataTypes" document from the old Python Table API documentation to the "Python API" -> "User Guide" section with a new name "DataTypes"

[ https://issues.apache.org/jira/browse/FLINK-18914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18914: -- Summary: Move the "Python DataTypes" document from the old Python Table API documentation to the

[jira] [Created] (FLINK-18920) Move the "Dependency Management" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section

Wei Zhong created FLINK-18920: - Summary: Move the "Dependency Management" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section Key: FLINK-18920 URL:

[jira] [Created] (FLINK-18919) Move the "User Defined Functions" document and "Vectorized User Defined Functions" document from the old Python Table API documentation to the "Python API" -> "User Guid

Wei Zhong created FLINK-18919: - Summary: Move the "User Defined Functions" document and "Vectorized User Defined Functions" document from the old Python Table API documentation to the "Python API" -> "User Guide" section Key:

[GitHub] [flink] azagrebin removed a comment on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

azagrebin removed a comment on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-673311395 Thanks for the review @zhuzhurk I addressed the comments This is an automated message from the

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176807#comment-17176807 ] Till Rohrmann commented on FLINK-16142: --- Just to double check [~paguan], you are no longer

[GitHub] [flink] flinkbot edited a comment on pull request #13071: [FLINK-18751][Coordination] Implement SlotSharingExecutionSlotAllocator

flinkbot edited a comment on pull request #13071: URL: https://github.com/apache/flink/pull/13071#issuecomment-669310861 ## CI report: * 2233727954b8a6272c4a772a03bccc08b5e97720 UNKNOWN * 07fd40233580c1641fda58742e015144d767c2fe UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #13136: [FLINK-18878][python] Support dependency management for Python Stream…

flinkbot edited a comment on pull request #13136: URL: https://github.com/apache/flink/pull/13136#issuecomment-673313436 ## CI report: * 6098b6b0563eded5c97787f55094467b82a88593 Azure:

[GitHub] [flink] wangxiyuan closed pull request #13138: Update README.md

wangxiyuan closed pull request #13138: URL: https://github.com/apache/flink/pull/13138 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] flinkbot edited a comment on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

flinkbot edited a comment on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-667140037 ## CI report: * 31abcb25fdf72394dbfa91d0ba9e151968375ad7 UNKNOWN * db99952f8166cb4d6337dcb3815e72ff2b49604b UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12899: [FLINK-16699][k8s] Support accessing secured services via K8s secrets

flinkbot edited a comment on pull request #12899: URL: https://github.com/apache/flink/pull/12899#issuecomment-658162074 ## CI report: * c6edb8841a675096cab4c0e866c3b95c1f3801bf Azure:

[jira] [Commented] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176833#comment-17176833 ] Piotr Nowojski commented on FLINK-18808: {quote} At present, a record may be broadcast to

[jira] [Updated] (FLINK-18219) Improve exception if jar submission hits OOM

[ https://issues.apache.org/jira/browse/FLINK-18219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18219: -- Labels: pull-request-available usability (was: pull-request-available) > Improve exception

[jira] [Updated] (FLINK-18220) Improve exception if finalizeOnmaster hits OOM

[ https://issues.apache.org/jira/browse/FLINK-18220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18220: -- Labels: pull-request-available usability (was: pull-request-available) > Improve exception

  1   2   3   >