[GitHub] [flink] wuchong commented on a change in pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

wuchong commented on a change in pull request #13141: URL: https://github.com/apache/flink/pull/13141#discussion_r470424738 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/runtime/stream/table/TableSourceITCase.scala ## @@ -81,6 +81,51 @@

[jira] [Closed] (FLINK-18794) Custom metric doesn't work in flink1.11.1

[ https://issues.apache.org/jira/browse/FLINK-18794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee closed FLINK-18794. Fix Version/s: (was: 1.11.2) Resolution: Not A Problem > Custom metric doesn't work in

[jira] [Commented] (FLINK-18794) Custom metric doesn't work in flink1.11.1

[ https://issues.apache.org/jira/browse/FLINK-18794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177507#comment-17177507 ] JasonLee commented on FLINK-18794: -- Hi Chesnay   Now Flink Web UI can display custom metric. I don't

[GitHub] [flink] flinkbot edited a comment on pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

flinkbot edited a comment on pull request #13140: URL: https://github.com/apache/flink/pull/13140#issuecomment-673481657 ## CI report: * cc8ddc039efdf3720bfaa29e2bff86df4ea2e346 Azure:

[jira] [Commented] (FLINK-18899) The property yarn.application-attempts default value is not none

[ https://issues.apache.org/jira/browse/FLINK-18899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177479#comment-17177479 ] Robert Metzger commented on FLINK-18899: [~fly_in_gis] What do you think about this ticket? Does

[jira] [Commented] (FLINK-18841) CVE-2018-10237 and CWE-400 occurred in flink dependency

[ https://issues.apache.org/jira/browse/FLINK-18841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177478#comment-17177478 ] Robert Metzger commented on FLINK-18841: Re CVE-2018-10237, there's been recently a discussion

[GitHub] [flink] flinkbot edited a comment on pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

flinkbot edited a comment on pull request #13140: URL: https://github.com/apache/flink/pull/13140#issuecomment-673481657 ## CI report: * 95d62f551c4f2215fca8982bddaccde0d0238ef0 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=17177475#comment-17177475 ] ming li commented on FLINK-18808: - Hi, [~pnowojski]. Sorry, I'm still a little confused. In fact, in

[GitHub] [flink] flinkbot edited a comment on pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

flinkbot edited a comment on pull request #13140: URL: https://github.com/apache/flink/pull/13140#issuecomment-673481657 ## CI report: * 95d62f551c4f2215fca8982bddaccde0d0238ef0 Azure:

[GitHub] [flink] shuiqiangchen commented on pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

shuiqiangchen commented on pull request #13140: URL: https://github.com/apache/flink/pull/13140#issuecomment-673872174 @hequn8128 Thank you for your comments, I have updated the PR according to your comments, please have a look at it.

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

shuiqiangchen commented on a change in pull request #13140: URL: https://github.com/apache/flink/pull/13140#discussion_r470399135 ## File path: flink-python/pyflink/datastream/tests/test_data_stream.py ## @@ -322,6 +323,86 @@ def test_keyed_stream_partitioning(self):

[jira] [Updated] (FLINK-18940) Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData"

[ https://issues.apache.org/jira/browse/FLINK-18940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jack sun updated FLINK-18940: - Attachment: 2.png > Cannot cast "org.apache.flink.table.data.RowData" to >

[jira] [Updated] (FLINK-18940) Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData"

[ https://issues.apache.org/jira/browse/FLINK-18940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jack sun updated FLINK-18940: - Attachment: 1.png > Cannot cast "org.apache.flink.table.data.RowData" to >

[jira] [Commented] (FLINK-18794) Custom metric doesn't work in flink1.11.1

[ https://issues.apache.org/jira/browse/FLINK-18794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177452#comment-17177452 ] JasonLee commented on FLINK-18794: -- the DAG is as follows !image-2020-08-14-11-23-35-767.png! >

[jira] [Updated] (FLINK-18794) Custom metric doesn't work in flink1.11.1

[ https://issues.apache.org/jira/browse/FLINK-18794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-18794: - Attachment: image-2020-08-14-11-22-49-424.png > Custom metric doesn't work in flink1.11.1 >

[jira] [Updated] (FLINK-18794) Custom metric doesn't work in flink1.11.1

[ https://issues.apache.org/jira/browse/FLINK-18794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-18794: - Attachment: image-2020-08-14-11-23-35-767.png > Custom metric doesn't work in flink1.11.1 >

[jira] [Updated] (FLINK-18794) Custom metric doesn't work in flink1.11.1

[ https://issues.apache.org/jira/browse/FLINK-18794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-18794: - Attachment: image-2020-08-14-11-23-02-670.png > Custom metric doesn't work in flink1.11.1 >

[jira] [Updated] (FLINK-18794) Custom metric doesn't work in flink1.11.1

[ https://issues.apache.org/jira/browse/FLINK-18794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-18794: - Attachment: image-2020-08-14-11-22-17-403.png > Custom metric doesn't work in flink1.11.1 >

[jira] [Comment Edited] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

[ https://issues.apache.org/jira/browse/FLINK-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177438#comment-17177438 ] Xingcan Cui edited comment on FLINK-7865 at 8/14/20, 2:56 AM: -- Hi

[jira] [Assigned] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

[ https://issues.apache.org/jira/browse/FLINK-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7865: -- Assignee: (was: Xingcan Cui) > Remove predicate restrictions on TableFunction left outer

[jira] [Commented] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

[ https://issues.apache.org/jira/browse/FLINK-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177438#comment-17177438 ] Xingcan Cui commented on FLINK-7865: Hi [~godfreyhe], it took me some time to think about how to do

[jira] [Commented] (FLINK-18940) Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData"

[ https://issues.apache.org/jira/browse/FLINK-18940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177435#comment-17177435 ] jack sun commented on FLINK-18940: -- [~twalthr] yep , I append it to the description > Cannot cast

[GitHub] [flink] hequn8128 commented on a change in pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

hequn8128 commented on a change in pull request #13140: URL: https://github.com/apache/flink/pull/13140#discussion_r470377742 ## File path: flink-python/pyflink/datastream/tests/test_data_stream.py ## @@ -322,6 +323,86 @@ def test_keyed_stream_partitioning(self): with

[jira] [Updated] (FLINK-18940) Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData"

[ https://issues.apache.org/jira/browse/FLINK-18940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jack sun updated FLINK-18940: - Description: sourcecode is simple like this , there is nothing wrong with kafkaStream, if I replace

[jira] [Updated] (FLINK-18940) Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData"

[ https://issues.apache.org/jira/browse/FLINK-18940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jack sun updated FLINK-18940: - Description: sourcecode is simple like this , there is nothing wrong with kafkaStream, if I replace

[jira] [Closed] (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 ] Hequn Cheng closed FLINK-18878. --- Resolution: Resolved > Support dependency management for Python StreamExecutionEnvironment. >

[jira] [Assigned] (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 ] Hequn Cheng reassigned FLINK-18878: --- Assignee: Shuiqiang Chen > Support dependency management for Python

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

[ https://issues.apache.org/jira/browse/FLINK-18878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177431#comment-17177431 ] Hequn Cheng commented on FLINK-18878: - Resolved in 1.12.0 via 

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

hequn8128 merged pull request #13136: URL: https://github.com/apache/flink/pull/13136 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] zhoulii commented on pull request #12899: [FLINK-16699][k8s] Support accessing secured services via K8s secrets

zhoulii commented on pull request #12899: URL: https://github.com/apache/flink/pull/12899#issuecomment-673845701 Hi @wangyang0918 , I have modified the code and commit message on your advice, and thanks for your time to review this pr.

[GitHub] [flink] zhoulii commented on a change in pull request #12899: [FLINK-16699][k8s] Support accessing secured services via K8s secrets

zhoulii commented on a change in pull request #12899: URL: https://github.com/apache/flink/pull/12899#discussion_r470372722 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java ## @@ -221,6 +221,22 @@ /**

[GitHub] [flink] zhoulii commented on a change in pull request #12899: [FLINK-16699][k8s] Support accessing secured services via K8s secrets

zhoulii commented on a change in pull request #12899: URL: https://github.com/apache/flink/pull/12899#discussion_r470372369 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java ## @@ -221,6 +221,22 @@ /**

[GitHub] [flink] liupc commented on pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

liupc commented on pull request #13141: URL: https://github.com/apache/flink/pull/13141#issuecomment-673843587 cc @wuchong This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-18374) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart produced no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-18374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177428#comment-17177428 ] Dian Fu commented on FLINK-18374: -

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177426#comment-17177426 ] Dian Fu commented on FLINK-16947: -

[jira] [Commented] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

[ https://issues.apache.org/jira/browse/FLINK-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177423#comment-17177423 ] liupengcheng commented on FLINK-7865: - [~xccui] Thanks for your work! I just met this issue when

[jira] [Commented] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)"

[ https://issues.apache.org/jira/browse/FLINK-18807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177419#comment-17177419 ] Xintong Song commented on FLINK-18807: -- Another instance with 

[jira] [Updated] (FLINK-18849) Improve the code tabs of the Flink documents

[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18849: -- Fix Version/s: 1.11.2 1.12.0 > Improve the code tabs of the Flink documents >

[jira] [Closed] (FLINK-18719) Define the interfaces and introduce ActiveResourceManager

[ https://issues.apache.org/jira/browse/FLINK-18719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-18719. Resolution: Done Merged via * master d17993f6a6c37de61e4672a12523ff33d8f51a29 > Define the

[jira] [Closed] (FLINK-18659) FileNotFoundException when writing Hive orc tables

[ https://issues.apache.org/jira/browse/FLINK-18659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-18659. Resolution: Fixed master: 6a7b464c708c64f359b731ae5cee97ebb6c62d07 release-1.11: 

[jira] [Comment Edited] (FLINK-18659) FileNotFoundException when writing Hive orc tables

[ https://issues.apache.org/jira/browse/FLINK-18659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177417#comment-17177417 ] Jingsong Lee edited comment on FLINK-18659 at 8/14/20, 1:55 AM: master: 

[GitHub] [flink] xintongsong closed pull request #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

xintongsong closed pull request #13004: URL: https://github.com/apache/flink/pull/13004 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] JingsongLi merged pull request #13078: [FLINK-18659][hive][orc] Fix streaming write for Hive 1.x Orc table

JingsongLi merged pull request #13078: URL: https://github.com/apache/flink/pull/13078 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] [Updated] (FLINK-18941) There are some typos in "Set up JobManager Memory"

[ https://issues.apache.org/jira/browse/FLINK-18941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng updated FLINK-18941: - Issue Type: Improvement (was: Bug) > There are some typos in "Set up JobManager Memory" >

[jira] [Created] (FLINK-18941) There are some typos in "Set up JobManager Memory"

Peng created FLINK-18941: Summary: There are some typos in "Set up JobManager Memory" Key: FLINK-18941 URL: https://issues.apache.org/jira/browse/FLINK-18941 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-18891) flink job failed but yarn application still running via yarn-per-job mode

[ https://issues.apache.org/jira/browse/FLINK-18891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng closed FLINK-18891. Resolution: Not A Problem > flink job failed but yarn application still running via yarn-per-job mode >

[jira] [Comment Edited] (FLINK-18891) flink job failed but yarn application still running via yarn-per-job mode

[ https://issues.apache.org/jira/browse/FLINK-18891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177372#comment-17177372 ] Peng edited comment on FLINK-18891 at 8/13/20, 11:22 PM: - [~trohrmann] Thanks

[jira] [Commented] (FLINK-18891) flink job failed but yarn application still running via yarn-per-job mode

[ https://issues.apache.org/jira/browse/FLINK-18891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177372#comment-17177372 ] Peng commented on FLINK-18891: -- [~trohrmann] Thanks for your reply. You are right. I double checked my

[GitHub] [flink] flinkbot edited a comment on pull request #13143: [FLINK-18936][docs] Update documentation around aggregate functions

flinkbot edited a comment on pull request #13143: URL: https://github.com/apache/flink/pull/13143#issuecomment-673578366 ## CI report: * e3f355ba1e729543a1b902c6f3fba3c6836f5023 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

flinkbot edited a comment on pull request #13140: URL: https://github.com/apache/flink/pull/13140#issuecomment-673481657 ## CI report: * 95d62f551c4f2215fca8982bddaccde0d0238ef0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13142: [FLINK-18901][table] Use new type inference for aggregate functions in SQL DDL

flinkbot edited a comment on pull request #13142: URL: https://github.com/apache/flink/pull/13142#issuecomment-673556460 ## CI report: * 927b3d91d32cfae261dd8713d9e25f1dcc09b47e Azure:

[jira] [Updated] (FLINK-18898) .flink-runtime.version.properties file does not exist in flink-dist.jar

[ https://issues.apache.org/jira/browse/FLINK-18898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18898: --- Component/s: Build System > .flink-runtime.version.properties file does not exist in

[jira] [Closed] (FLINK-18898) .flink-runtime.version.properties file does not exist in flink-dist.jar

[ https://issues.apache.org/jira/browse/FLINK-18898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-18898. -- Resolution: Invalid Thanks a lot for reporting back. I closed the ticket. >

[jira] [Updated] (FLINK-18899) The property yarn.application-attempts default value is not none

[ https://issues.apache.org/jira/browse/FLINK-18899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18899: --- Component/s: Deployment / YARN > The property yarn.application-attempts default value is

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

[ https://issues.apache.org/jira/browse/FLINK-18933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18933: --- Component/s: Documentation API / Python > Delete the old Python Table API

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

[ https://issues.apache.org/jira/browse/FLINK-18937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18937: --- Component/s: Documentation API / Python > Add a "Environment Setup"

[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] sjwiesman commented on a change in pull request #13143: [FLINK-18936][docs] Update documentation around aggregate functions

sjwiesman commented on a change in pull request #13143: URL: https://github.com/apache/flink/pull/13143#discussion_r470136543 ## File path: docs/dev/table/functions/udfs.md ## @@ -1268,693 +1044,770 @@ class WeightedAvg extends AggregateFunction[JLong, CountAccumulator] {

[GitHub] [flink] flinkbot edited a comment on pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

flinkbot edited a comment on pull request #12966: URL: https://github.com/apache/flink/pull/12966#issuecomment-662861328 ## CI report: * 1790d93b79cfdfc3f65a7805e444699736f80d93 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

flinkbot edited a comment on pull request #13140: URL: https://github.com/apache/flink/pull/13140#issuecomment-673481657 ## CI report: * 0e32abeac5e2b0c6ed09c49c7a1c8fdff944d82b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

flinkbot edited a comment on pull request #13004: URL: https://github.com/apache/flink/pull/13004#issuecomment-664960056 ## CI report: * afc7db9e33b3996dd6b859b1ed1e9c418a7a0ef0 Azure:

[jira] [Commented] (FLINK-18696) Java 14 Records are not recognized as POJOs

[ https://issues.apache.org/jira/browse/FLINK-18696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177190#comment-17177190 ] Michael Gendelman commented on FLINK-18696: --- [~rmetzger] Sorry if I'm way off here. Just

[GitHub] [flink] flinkbot edited a comment on pull request #13111: [FLINK-18220][runtime] Extended OutOfMemoryError message.

flinkbot edited a comment on pull request #13111: URL: https://github.com/apache/flink/pull/13111#issuecomment-671602964 ## CI report: * e575fa045556a0420c79b58f6c0c5fc37b7b937e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

flinkbot edited a comment on pull request #13140: URL: https://github.com/apache/flink/pull/13140#issuecomment-673481657 ## CI report: * 0e32abeac5e2b0c6ed09c49c7a1c8fdff944d82b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13111: [FLINK-18220][runtime] Extended OutOfMemoryError message.

flinkbot edited a comment on pull request #13111: URL: https://github.com/apache/flink/pull/13111#issuecomment-671602964 ## CI report: * 012e50a23dbecc06bc06c537cbabf154eb935236 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13143: [FLINK-18936][docs] Update documentation around aggregate functions

flinkbot edited a comment on pull request #13143: URL: https://github.com/apache/flink/pull/13143#issuecomment-673578366 ## CI report: * e3f355ba1e729543a1b902c6f3fba3c6836f5023 Azure:

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

XComp commented on a change in pull request #13111: URL: https://github.com/apache/flink/pull/13111#discussion_r470083019 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java ## @@ -1046,6 +1047,8 @@ void

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

XComp commented on a change in pull request #13111: URL: https://github.com/apache/flink/pull/13111#discussion_r470082171 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java ## @@ -137,7 +138,12 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

flinkbot edited a comment on pull request #13140: URL: https://github.com/apache/flink/pull/13140#issuecomment-673481657 ## CI report: * 0e32abeac5e2b0c6ed09c49c7a1c8fdff944d82b Azure:

[GitHub] [flink] flinkbot commented on pull request #13143: [FLINK-18936][docs] Update documentation around aggregate functions

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

[GitHub] [flink] flinkbot edited a comment on pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

flinkbot edited a comment on pull request #12966: URL: https://github.com/apache/flink/pull/12966#issuecomment-662861328 ## CI report: * 1790d93b79cfdfc3f65a7805e444699736f80d93 Azure:

[GitHub] [flink] flinkbot commented on pull request #13143: [FLINK-18936][docs] Update documentation around aggregate functions

flinkbot commented on pull request #13143: URL: https://github.com/apache/flink/pull/13143#issuecomment-673566801 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 edited a comment on pull request #13142: [FLINK-18901][table] Use new type inference for aggregate functions in SQL DDL

flinkbot edited a comment on pull request #13142: URL: https://github.com/apache/flink/pull/13142#issuecomment-673556460 ## CI report: * 927b3d91d32cfae261dd8713d9e25f1dcc09b47e Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-18936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18936: --- Labels: pull-request-available (was: ) > Update documentation about user-defined aggregate

[GitHub] [flink] twalthr opened a new pull request #13143: [FLINK-18936][docs] Update documentation around aggregate functions

twalthr opened a new pull request #13143: URL: https://github.com/apache/flink/pull/13143 ## What is the purpose of the change Ensures that all documentation about aggregate functions is correct and consistent. ## Brief change log - Removes mentioning of

[GitHub] [flink] flinkbot commented on pull request #13142: [FLINK-18901][table] Use new type inference for aggregate functions in SQL DDL

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

[GitHub] [flink] flinkbot commented on pull request #13142: [FLINK-18901][table] Use new type inference for aggregate functions in SQL DDL

flinkbot commented on pull request #13142: URL: https://github.com/apache/flink/pull/13142#issuecomment-673546433 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-18901) Use new type inference for SQL DDL of aggregate functions

[ https://issues.apache.org/jira/browse/FLINK-18901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18901: --- Labels: pull-request-available (was: ) > Use new type inference for SQL DDL of aggregate

[GitHub] [flink] twalthr opened a new pull request #13142: [FLINK-18901][table] Use new type inference for aggregate functions in SQL DDL

twalthr opened a new pull request #13142: URL: https://github.com/apache/flink/pull/13142 ## What is the purpose of the change All CREATE FUNCTION statements use the new type inference now. It might require to update existing implementations to the new reflective type extraction

[GitHub] [flink] flinkbot edited a comment on pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

flinkbot edited a comment on pull request #13141: URL: https://github.com/apache/flink/pull/13141#issuecomment-673492124 ## CI report: * ed47271c426abff4426ccf2d0fd5858e6f3d8390 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177070#comment-17177070 ] Kenneth William Krugler commented on FLINK-18934: - Hi [~kien_truong] - I would suggest

[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 *

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177057#comment-17177057 ] Etienne Chauchot commented on FLINK-17073: -- Hi all,  I'll be off for 2 weeks starting tonight,

[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: * ccb177399810fc93aaa9b393e092245deaf6789e 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=17177056#comment-17177056 ] Piotr Nowojski commented on FLINK-18808: Hmmm, you are right. I understand the problem now.

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

echauchot commented on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-673505302 @rkhachatryan I'm leaving on vacation for 2 weeks this evening, so I could update the PR only when I come back. Nevertheless feel free to tell me what you think about my

[GitHub] [flink] flinkbot edited a comment on pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

flinkbot edited a comment on pull request #13141: URL: https://github.com/apache/flink/pull/13141#issuecomment-673492124 ## CI report: * ed47271c426abff4426ccf2d0fd5858e6f3d8390 Azure:

[GitHub] [flink] flinkbot commented on pull request #13141: [FLINK-18852] Fix StreamScan doesn't inherit parallelism from input in legacy planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

flinkbot edited a comment on pull request #13140: URL: https://github.com/apache/flink/pull/13140#issuecomment-673481657 ## CI report: * 0e32abeac5e2b0c6ed09c49c7a1c8fdff944d82b Azure:

[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 #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

flinkbot edited a comment on pull request #13004: URL: https://github.com/apache/flink/pull/13004#issuecomment-664960056 ## CI report: * afc7db9e33b3996dd6b859b1ed1e9c418a7a0ef0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

flinkbot edited a comment on pull request #12966: URL: https://github.com/apache/flink/pull/12966#issuecomment-662861328 ## CI report: * 1790d93b79cfdfc3f65a7805e444699736f80d93 Azure:

[jira] [Commented] (FLINK-18940) Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData"

[ https://issues.apache.org/jira/browse/FLINK-18940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177025#comment-17177025 ] Timo Walther commented on FLINK-18940: -- [~any] Could you explain the query/pipeline and schema that

[jira] [Commented] (FLINK-18704) Support DECIMAL types in datagen Table source connector

[ https://issues.apache.org/jira/browse/FLINK-18704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177020#comment-17177020 ] Fabian Hueske commented on FLINK-18704: --- Thanks for picking this up [~micg]! Since datagen is

[jira] [Resolved] (FLINK-18849) Improve the code tabs of the Flink documents

[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-18849. -- Resolution: Fixed > Improve the code tabs of the Flink documents >

[jira] [Commented] (FLINK-18849) Improve the code tabs of the Flink documents

[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177016#comment-17177016 ] Seth Wiesman commented on FLINK-18849: -- Fixed in master: 2c527fb9c8645b1da4a893577ad2eae3bbab179e

[GitHub] [flink] sjwiesman closed pull request #13085: [FLINK-18849][docs] Improve the code tabs of the Flink documents.

sjwiesman closed pull request #13085: URL: https://github.com/apache/flink/pull/13085 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 commented on pull request #13140: [FLINK-18884][python] Add chaining strategy and slot sharing group in…

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

[GitHub] [flink] flinkbot edited a comment on pull request #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

flinkbot edited a comment on pull request #13004: URL: https://github.com/apache/flink/pull/13004#issuecomment-664960056 ## CI report: * afc7db9e33b3996dd6b859b1ed1e9c418a7a0ef0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

flinkbot edited a comment on pull request #12966: URL: https://github.com/apache/flink/pull/12966#issuecomment-662861328 ## CI report: * 1790d93b79cfdfc3f65a7805e444699736f80d93 Azure:

  1   2   3   >