[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 30584219a51b9fcf400e7124356422d3ce3dcbf2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14317: URL: https://github.com/apache/flink/pull/14317#issuecomment-739722178 ## CI report: * 30da4a1bb767333e186368eb2591905eac446239 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14331: [FLINK-20514][python] Introduce StreamExecPythonGroupTableAggregateRule and StreamExecPythonGroupTableAggregate

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14331: URL: https://github.com/apache/flink/pull/14331#issuecomment-740479953 ## CI report: * 133be44ccebae156ae968d892f0c24c2647bcab2 Azure:

[GitHub] [flink] godfreyhe merged pull request #14335: [FLINK-20511][table-planner-blink] Deprecate the classes in scala `nodes.exec` package

2020-12-09 Thread GitBox
godfreyhe merged pull request #14335: URL: https://github.com/apache/flink/pull/14335 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

[jira] [Closed] (FLINK-20511) Deprecate the classes in scala `nodes.exec` package

2020-12-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20511. -- Resolution: Done master: 4930d72f16a63a9dd65b96eadaab940e605ea8c0 > Deprecate the classes in scala

[GitHub] [flink] fsk119 commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-12-09 Thread GitBox
fsk119 commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539088462 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java ## @@ -36,6 +38,23 @@ static

[jira] [Commented] (FLINK-20545) SQLClientSchemaRegistryITCase compilation failed

2020-12-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246352#comment-17246352 ] Dawid Wysakowicz commented on FLINK-20545: -- Where did this happen? On azure? It is most

[GitHub] [flink] flinkbot edited a comment on pull request #13879: [FLINK-19832][coordination] Do not schedule shared slot bulk if some slots have failed immediately

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #13879: URL: https://github.com/apache/flink/pull/13879#issuecomment-720415853 ## CI report: * 792aa8c7e17b2a44a4507488ef7c0c5af183e9b8 Azure:

[jira] [Closed] (FLINK-20545) SQLClientSchemaRegistryITCase compilation failed

2020-12-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-20545. Resolution: Cannot Reproduce > SQLClientSchemaRegistryITCase compilation failed >

[jira] [Commented] (FLINK-20545) SQLClientSchemaRegistryITCase compilation failed

2020-12-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246353#comment-17246353 ] Dawid Wysakowicz commented on FLINK-20545: -- If it happens for you locally make sure you can

[jira] [Comment Edited] (FLINK-20526) Enable logback scan configuration by default

2020-12-09 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246337#comment-17246337 ] xiaozilong edited comment on FLINK-20526 at 12/9/20, 9:08 AM: -- The

[jira] [Assigned] (FLINK-20491) Support Broadcast State in BATCH execution mode

2020-12-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-20491: Assignee: Dawid Wysakowicz (was: Aljoscha Krettek) > Support Broadcast State in

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14315: URL: https://github.com/apache/flink/pull/14315#issuecomment-739151875 ## CI report: * 7d81f10ae1ee99ae852e4333e9ac766c44f563cf Azure:

[GitHub] [flink] wangxiyuan opened a new pull request #14345: [hot fix]Fix elasticsearch e2e test on arm64

2020-12-09 Thread GitBox
wangxiyuan opened a new pull request #14345: URL: https://github.com/apache/flink/pull/14345 ## What is the purpose of the change The e2e test `SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)` runs fail on arm64. This patch fixed the failure. ## Brief

[jira] [Comment Edited] (FLINK-20527) Support side output for late events in Flink SQL

2020-12-09 Thread tonychan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246220#comment-17246220 ] tonychan edited comment on FLINK-20527 at 12/9/20, 9:22 AM: i know ,but the

[jira] [Comment Edited] (FLINK-20491) Support Broadcast State in BATCH execution mode

2020-12-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246383#comment-17246383 ] Dawid Wysakowicz edited comment on FLINK-20491 at 12/9/20, 9:22 AM:

[jira] [Commented] (FLINK-20491) Support Broadcast State in BATCH execution mode

2020-12-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246383#comment-17246383 ] Dawid Wysakowicz commented on FLINK-20491: -- Hey [~aljoscha] Thanks for starting the work on

[GitHub] [flink] flinkbot commented on pull request #14345: [hot fix]Fix elasticsearch e2e test on arm64

2020-12-09 Thread GitBox
flinkbot commented on pull request #14345: URL: https://github.com/apache/flink/pull/14345#issuecomment-741647105 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] zhuxiaoshang commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-12-09 Thread GitBox
zhuxiaoshang commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539145192 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java ## @@ -36,6 +38,23 @@

[GitHub] [flink] dianfu closed pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

2020-12-09 Thread GitBox
dianfu closed pull request #14317: URL: https://github.com/apache/flink/pull/14317 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 to

[jira] [Assigned] (FLINK-20508) Introduce PythonStreamGroupTableAggregateOperator

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20508: --- Assignee: Huang Xingbo > Introduce PythonStreamGroupTableAggregateOperator >

[GitHub] [flink] flinkbot commented on pull request #14345: [hot fix]Fix elasticsearch e2e test on arm64

2020-12-09 Thread GitBox
flinkbot commented on pull request #14345: URL: https://github.com/apache/flink/pull/14345#issuecomment-741650636 ## CI report: * 630a32fbfd5312fda6c81eb873429defe8c0c966 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-20482) Support General Python UDF for Map Operation in Python Table API

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20482. --- Resolution: Fixed Merged to master via 2d0e7387176b00ad7f0ef70b0de985cea7911317 > Support General Python

[jira] [Closed] (FLINK-20508) Introduce PythonStreamGroupTableAggregateOperator

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20508. --- Resolution: Fixed > Introduce PythonStreamGroupTableAggregateOperator >

[jira] [Commented] (FLINK-20541) ClusterID is not used in the method!

2020-12-09 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246399#comment-17246399 ] lixiaobao commented on FLINK-20541: --- Assign to me, please! > ClusterID is not used in the method! >

[GitHub] [flink] rmetzger opened a new pull request #14346: [FLINK-20354] Rework standalone docs pages

2020-12-09 Thread GitBox
rmetzger opened a new pull request #14346: URL: https://github.com/apache/flink/pull/14346 ## What is the purpose of the change Update the Standalone Resource Provider pages. ## Brief change log - Rewrite the main standalone page, merging information from the local

[GitHub] [flink] flinkbot edited a comment on pull request #14345: [hot fix]Fix elasticsearch e2e test on arm64

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14345: URL: https://github.com/apache/flink/pull/14345#issuecomment-741650636 ## CI report: * 630a32fbfd5312fda6c81eb873429defe8c0c966 UNKNOWN * cf44b765bfd107b3fc2ebfa984b28b8df9b09ac5 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14315: URL: https://github.com/apache/flink/pull/14315#issuecomment-739151875 ## CI report: * 7890576ec8c791313d5a309a3488b1de846e2e47 Azure:

[jira] [Created] (FLINK-20546) Misuse of the method in KafkaDynamicTableFactoryTest

2020-12-09 Thread zoucao (Jira)
zoucao created FLINK-20546: -- Summary: Misuse of the method in KafkaDynamicTableFactoryTest Key: FLINK-20546 URL: https://issues.apache.org/jira/browse/FLINK-20546 Project: Flink Issue Type:

[GitHub] [flink] q977734161 closed pull request #14342: [FLINK-20541][client] ClusterID is not used in the method!

2020-12-09 Thread GitBox
q977734161 closed pull request #14342: URL: https://github.com/apache/flink/pull/14342 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] becketqin commented on pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

2020-12-09 Thread GitBox
becketqin commented on pull request #14314: URL: https://github.com/apache/flink/pull/14314#issuecomment-741672588 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #13907: URL: https://github.com/apache/flink/pull/13907#issuecomment-721230727 ## CI report: * 49181d26aa6a07bc289544ad0d55929fd2c89377 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

2020-12-09 Thread GitBox
pnowojski commented on a change in pull request #13551: URL: https://github.com/apache/flink/pull/13551#discussion_r539175307 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/PseudoRandomValueSelector.java ## @@ -0,0 +1,61

[jira] [Closed] (FLINK-20541) ClusterID is not used in the method!

2020-12-09 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lixiaobao closed FLINK-20541. - Resolution: Not A Problem > ClusterID is not used in the method! >

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

2020-12-09 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246418#comment-17246418 ] Suhan Mao edited comment on FLINK-18202 at 12/9/20, 10:21 AM: -- I will give

[GitHub] [flink] Myasuka commented on a change in pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

2020-12-09 Thread GitBox
Myasuka commented on a change in pull request #14341: URL: https://github.com/apache/flink/pull/14341#discussion_r539183408 ## File path: docs/_includes/generated/rocksdb_configurable_configuration.html ## @@ -20,6 +20,12 @@ MemorySize The amount of

[GitHub] [flink] flinkbot edited a comment on pull request #14345: [hot fix]Fix elasticsearch e2e test on arm64

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14345: URL: https://github.com/apache/flink/pull/14345#issuecomment-741650636 ## CI report: * 630a32fbfd5312fda6c81eb873429defe8c0c966 UNKNOWN * cf44b765bfd107b3fc2ebfa984b28b8df9b09ac5 Azure:

[GitHub] [flink] flinkbot commented on pull request #14346: [FLINK-20354] Rework standalone docs pages

2020-12-09 Thread GitBox
flinkbot commented on pull request #14346: URL: https://github.com/apache/flink/pull/14346#issuecomment-741680007 ## CI report: * 1feff43f3fba39641c0403e7968dfca592b400d9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13879: [FLINK-19832][coordination] Do not schedule shared slot bulk if some slots have failed immediately

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #13879: URL: https://github.com/apache/flink/pull/13879#issuecomment-720415853 ## CI report: * 792aa8c7e17b2a44a4507488ef7c0c5af183e9b8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14337: [FLINK-20512][table-planner-blink] Introduce getDesc(), getOutputType(), replaceInput(int, ExecEdge, ExecNode) methods for ExecNode

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14337: URL: https://github.com/apache/flink/pull/14337#issuecomment-740618645 ## CI report: * caadedc97ac9261a88bed069eeca6ddc08064aa5 Azure:

[jira] [Comment Edited] (FLINK-20491) Support Broadcast State in BATCH execution mode

2020-12-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246383#comment-17246383 ] Dawid Wysakowicz edited comment on FLINK-20491 at 12/9/20, 9:23 AM:

[GitHub] [flink] dianfu commented on a change in pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

2020-12-09 Thread GitBox
dianfu commented on a change in pull request #14317: URL: https://github.com/apache/flink/pull/14317#discussion_r539111733 ## File path: flink-python/pyflink/table/table.py ## @@ -759,6 +759,27 @@ def drop_columns(self, *fields: Union[str, Expression]) -> 'Table':

[jira] [Commented] (FLINK-20545) SQLClientSchemaRegistryITCase compilation failed

2020-12-09 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246391#comment-17246391 ] Echo Lee commented on FLINK-20545: -- [~dwysakowicz] Thank you for the link. Now the problem is solved.

[GitHub] [flink] zhuxiaoshang commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-12-09 Thread GitBox
zhuxiaoshang commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539145192 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java ## @@ -36,6 +38,23 @@

[jira] [Assigned] (FLINK-20506) Support FlatMap Operation in Python Table API

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20506: --- Assignee: Dian Fu > Support FlatMap Operation in Python Table API >

[jira] [Assigned] (FLINK-20507) Support Aggregate Operation in Python Table API

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20507: --- Assignee: Dian Fu (was: Huang Xingbo) > Support Aggregate Operation in Python Table API >

[jira] [Assigned] (FLINK-20507) Support Aggregate Operation in Python Table API

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20507: --- Assignee: Huang Xingbo (was: Dian Fu) > Support Aggregate Operation in Python Table API >

[GitHub] [flink] flinkbot edited a comment on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #13907: URL: https://github.com/apache/flink/pull/13907#issuecomment-721230727 ## CI report: * 49181d26aa6a07bc289544ad0d55929fd2c89377 Azure:

[GitHub] [flink] flinkbot commented on pull request #14346: [FLINK-20354] Rework standalone docs pages

2020-12-09 Thread GitBox
flinkbot commented on pull request #14346: URL: https://github.com/apache/flink/pull/14346#issuecomment-741664794 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] pnowojski edited a comment on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

2020-12-09 Thread GitBox
pnowojski edited a comment on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-741675386 > Can we overcome it by reading some system property at the time of ConfigOption creation? We didn't like this idea, as it would require to modify the production

[GitHub] [flink] pnowojski commented on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

2020-12-09 Thread GitBox
pnowojski commented on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-741675386 > Can we overcome it by reading some system property at the time of ConfigOption creation? We didn't like this idea, as it would require to modify the production code.

[GitHub] [flink] flinkbot edited a comment on pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14314: URL: https://github.com/apache/flink/pull/14314#issuecomment-739134416 ## CI report: * c1d1df5f7d7a29caf6738857c6072056c6c3d696 Azure:

[jira] [Commented] (FLINK-20491) Support Broadcast State in BATCH execution mode

2020-12-09 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246380#comment-17246380 ] Aljoscha Krettek commented on FLINK-20491: -- I posted a first PoC as a PR. Right now, what I'm

[jira] [Assigned] (FLINK-20491) Support Broadcast State in BATCH execution mode

2020-12-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-20491: Assignee: Aljoscha Krettek (was: Dawid Wysakowicz) > Support Broadcast State in

[GitHub] [flink] rmetzger commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-09 Thread GitBox
rmetzger commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r539141570 ## File path: docs/deployment/resource-providers/standalone/docker.md ## @@ -352,6 +352,27 @@ as described in [how to run the Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14315: URL: https://github.com/apache/flink/pull/14315#issuecomment-739151875 ## CI report: * 7d81f10ae1ee99ae852e4333e9ac766c44f563cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14337: [FLINK-20512][table-planner-blink] Introduce getDesc(), getOutputType(), replaceInput(int, ExecEdge, ExecNode) methods for ExecNode

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14337: URL: https://github.com/apache/flink/pull/14337#issuecomment-740618645 ## CI report: * caadedc97ac9261a88bed069eeca6ddc08064aa5 Azure:

[jira] [Commented] (FLINK-20508) Introduce PythonStreamGroupTableAggregateOperator

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246393#comment-17246393 ] Dian Fu commented on FLINK-20508: - Merged to master via f756bfe173877e85ae174030ca3a613d88649837 >

[jira] [Assigned] (FLINK-20507) Support Aggregate Operation in Python Table API

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20507: --- Assignee: Huang Xingbo > Support Aggregate Operation in Python Table API >

[jira] [Assigned] (FLINK-20506) Support FlatMap Operation in Python Table API

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20506: --- Assignee: Huang Xingbo (was: Dian Fu) > Support FlatMap Operation in Python Table API >

[GitHub] [flink] zhuxiaoshang commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-12-09 Thread GitBox
zhuxiaoshang commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539145192 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java ## @@ -36,6 +38,23 @@

[jira] [Updated] (FLINK-20354) Rework standalone deployment documentation page

2020-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20354: --- Labels: pull-request-available (was: ) > Rework standalone deployment documentation page >

[GitHub] [flink] Myasuka commented on a change in pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

2020-12-09 Thread GitBox
Myasuka commented on a change in pull request #14341: URL: https://github.com/apache/flink/pull/14341#discussion_r539051783 ## File path: docs/_includes/generated/rocksdb_configuration.html ## @@ -46,7 +52,7 @@

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

2020-12-09 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246418#comment-17246418 ] Suhan Mao commented on FLINK-18202: --- I will give an introduction about 3 ways: 1.  DynamicMessage and

[GitHub] [flink] Myasuka commented on a change in pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

2020-12-09 Thread GitBox
Myasuka commented on a change in pull request #14341: URL: https://github.com/apache/flink/pull/14341#discussion_r539183408 ## File path: docs/_includes/generated/rocksdb_configurable_configuration.html ## @@ -20,6 +20,12 @@ MemorySize The amount of

[GitHub] [flink] flinkbot edited a comment on pull request #14331: [FLINK-20514][python] Introduce StreamExecPythonGroupTableAggregateRule and StreamExecPythonGroupTableAggregate

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14331: URL: https://github.com/apache/flink/pull/14331#issuecomment-740479953 ## CI report: * 133be44ccebae156ae968d892f0c24c2647bcab2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14287: URL: https://github.com/apache/flink/pull/14287#issuecomment-737189475 ## CI report: * c18a2749aa654bc476c27d213a1bc4fb8d1a77fe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14258: URL: https://github.com/apache/flink/pull/14258#issuecomment-735471233 ## CI report: * 6231f2a9df2da3020b9f979c14154232f5bf072e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14287: URL: https://github.com/apache/flink/pull/14287#issuecomment-737189475 ## CI report: * dd11c4462dad256e255c4351c3bbbcf9ce92a5a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14292: [FLINK-20456][docs] Make streaming SQL concepts more approachable

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14292: URL: https://github.com/apache/flink/pull/14292#issuecomment-737644985 ## CI report: * 023089909048230b211d7cb9e5f9cdee432ed411 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14292: [FLINK-20456][docs] Make streaming SQL concepts more approachable

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14292: URL: https://github.com/apache/flink/pull/14292#issuecomment-737644985 ## CI report: * c6ce81f794da8c8249aa4d0a9f52aa8730b6c45c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13964: [FLINK-19314][coordination] Add DeclarativeSlotPoolBridge

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #13964: URL: https://github.com/apache/flink/pull/13964#issuecomment-723100396 ## CI report: * aa2a35104a430e3dada923f364ceff82d4fcc87d Azure:

[jira] [Updated] (FLINK-20422) Remove {{ site.baseurl }} from .html files in flink documentation

2020-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20422: --- Labels: pull-request-available (was: ) > Remove {{ site.baseurl }} from .html files in

[jira] [Updated] (FLINK-20550) Wrong savepoint config in some docs

2020-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20550: --- Labels: pull-request-available (was: ) > Wrong savepoint config in some docs >

[GitHub] [flink] flinkbot commented on pull request #14350: [FLINK-20422] Remove site.baseurl from remaining .html templates

2020-12-09 Thread GitBox
flinkbot commented on pull request #14350: URL: https://github.com/apache/flink/pull/14350#issuecomment-741789271 ## CI report: * c225b511666b2f1b5c411ab5ea917df43ffe338d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-20551) Make SQL documentation Blink only

2020-12-09 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246578#comment-17246578 ] Seth Wiesman commented on FLINK-20551: -- [~twalthr] FYI I'm going to work on this but I will need

[GitHub] [flink] flinkbot edited a comment on pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14258: URL: https://github.com/apache/flink/pull/14258#issuecomment-735471233 ## CI report: * f69f7b1ae8182c07f34e237d3e220d111d40ce16 Azure:

[jira] [Updated] (FLINK-19490) Document SOMAXCONN OS limit on blob server backlog

2020-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19490: --- Labels: pull-request-available (was: ) > Document SOMAXCONN OS limit on blob server

[GitHub] [flink] tillrohrmann commented on a change in pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

2020-12-09 Thread GitBox
tillrohrmann commented on a change in pull request #14258: URL: https://github.com/apache/flink/pull/14258#discussion_r539415678 ## File path: docs/deployment/resource-providers/mesos.md ## @@ -26,226 +26,242 @@ under the License. * This will be replaced by the TOC {:toc}

[jira] [Assigned] (FLINK-20512) Introduce getDescription, getOutputType, replaceInput methods for ExecNode

2020-12-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20512: -- Assignee: godfrey he > Introduce getDescription, getOutputType, replaceInput methods for

[jira] [Updated] (FLINK-20512) Introduce getDescription, getOutputType, replaceInput methods for ExecNode

2020-12-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20512: --- Description: We will introduce {{getDescription()}} method which returns the description

[GitHub] [flink] flinkbot edited a comment on pull request #14258: [FLINK-20356][docs] Updated Mesos documentation.

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14258: URL: https://github.com/apache/flink/pull/14258#issuecomment-735471233 ## CI report: * f69f7b1ae8182c07f34e237d3e220d111d40ce16 Azure:

[GitHub] [flink] zentol commented on a change in pull request #13964: [FLINK-19314][coordination] Add DeclarativeSlotPoolBridge

2020-12-09 Thread GitBox
zentol commented on a change in pull request #13964: URL: https://github.com/apache/flink/pull/13964#discussion_r539483005 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridge.java ## @@ -0,0 +1,680 @@ +/* + *

[GitHub] [flink] liuyufei9527 commented on a change in pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

2020-12-09 Thread GitBox
liuyufei9527 commented on a change in pull request #14341: URL: https://github.com/apache/flink/pull/14341#discussion_r539302090 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java

[GitHub] [flink] AHeise commented on pull request #13551: [FLINK-19520][configuration] Add randomization of checkpoint config.

2020-12-09 Thread GitBox
AHeise commented on pull request #13551: URL: https://github.com/apache/flink/pull/13551#issuecomment-741781038 > but via for example adding a temporary log message somewhere in the `StreamTask` or network stack what alignment option was used after all? I mean there could be a potential

[jira] [Assigned] (FLINK-19013) Log start/end of state restoration

2020-12-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-19013: Assignee: (was: Chesnay Schepler) > Log start/end of state restoration >

[jira] [Closed] (FLINK-11261) BlobServer moves file with open OutputStream

2020-12-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11261. Resolution: Duplicate > BlobServer moves file with open OutputStream >

[GitHub] [flink] zentol commented on a change in pull request #13964: [FLINK-19314][coordination] Add DeclarativeSlotPoolBridge

2020-12-09 Thread GitBox
zentol commented on a change in pull request #13964: URL: https://github.com/apache/flink/pull/13964#discussion_r539526403 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridgeTest.java ## @@ -0,0 +1,209 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #14337: [FLINK-20512][table-planner-blink] Introduce getDesc(), getOutputType(), replaceInput(int, ExecEdge, ExecNode) methods for ExecNode

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14337: URL: https://github.com/apache/flink/pull/14337#issuecomment-740618645 ## CI report: * 66d3d46b8805046c9dad3e660bf5acf795999631 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14328: [FLINK-19659][table-planner] Array type supports equals and not_equal…

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14328: URL: https://github.com/apache/flink/pull/14328#issuecomment-740445577 ## CI report: * d05d4f7df4446697093e8feea44c75b8a3a60722 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14347: [FLINK-20483][python] Support Pandas UDF for Map Operation in Python Table API

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14347: URL: https://github.com/apache/flink/pull/14347#issuecomment-741764329 ## CI report: * 1e95f0353e4eeabfa89314e35ddf5a54d62050f8 Azure:

[GitHub] [flink] zentol commented on a change in pull request #13964: [FLINK-19314][coordination] Add DeclarativeSlotPoolBridge

2020-12-09 Thread GitBox
zentol commented on a change in pull request #13964: URL: https://github.com/apache/flink/pull/13964#discussion_r539597408 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridge.java ## @@ -0,0 +1,680 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #14351: [FLINK-19490][conf] Document SOMAXCONN limit for 'blob.fetch.backlog'

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14351: URL: https://github.com/apache/flink/pull/14351#issuecomment-741868057 ## CI report: * 2819ce6bf6d0a7fc2f009728c8d21412262857ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14287: [FLINK-20352][docs] Updated CLI documentation.

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14287: URL: https://github.com/apache/flink/pull/14287#issuecomment-737189475 ## CI report: * c18a2749aa654bc476c27d213a1bc4fb8d1a77fe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * 37d3b02971986addded4356b88a493b824244b2e Azure:

[jira] [Updated] (FLINK-20549) New ExecutionContext doesn't inherit classloader from previous context

2020-12-09 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-20549: --- Description: When users change session properties from SQL client, {{LocalExecutor}} creates a new

[GitHub] [flink] flinkbot edited a comment on pull request #14345: [hot fix]Fix elasticsearch e2e test on arm64

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14345: URL: https://github.com/apache/flink/pull/14345#issuecomment-741650636 ## CI report: * 630a32fbfd5312fda6c81eb873429defe8c0c966 UNKNOWN * cf44b765bfd107b3fc2ebfa984b28b8df9b09ac5 Azure:

[GitHub] [flink] XComp commented on a change in pull request #14346: [FLINK-20354] Rework standalone docs pages

2020-12-09 Thread GitBox
XComp commented on a change in pull request #14346: URL: https://github.com/apache/flink/pull/14346#discussion_r539307215 ## File path: docs/deployment/resource-providers/standalone/docker.md ## @@ -204,191 +198,25 @@ You can provide the following additional command line

[GitHub] [flink] flinkbot edited a comment on pull request #14331: [FLINK-20514][python] Introduce StreamExecPythonGroupTableAggregateRule and StreamExecPythonGroupTableAggregate

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14331: URL: https://github.com/apache/flink/pull/14331#issuecomment-740479953 ## CI report: * b365d4d901d59b59e01b057ce331c64fbd1a5c2d Azure:

[jira] [Closed] (FLINK-14348) YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a fails to delete files

2020-12-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-14348. Resolution: Cannot Reproduce > YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a

  1   2   3   4   >