[jira] [Created] (FLINK-24584) ClientTest.testRequestUnavailableHost fails on azure

2021-10-18 Thread Xintong Song (Jira)
Xintong Song created FLINK-24584: Summary: ClientTest.testRequestUnavailableHost fails on azure Key: FLINK-24584 URL: https://issues.apache.org/jira/browse/FLINK-24584 Project: Flink Issue

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2021-10-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430321#comment-17430321 ] Xintong Song commented on FLINK-23391: --

[GitHub] [flink] flinkbot edited a comment on pull request #17514: [FLINK-24581][Tests]compatible uname command with multiple OS on ARM …

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17514: URL: https://github.com/apache/flink/pull/17514#issuecomment-946287305 ## CI report: * 3b1673ece4fb4b3071b603a20ad1cc0a38d11d61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17464: [FLINK-24413] Casting to a CHAR() and VARCHAR() doesn't trim the stri…

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17464: URL: https://github.com/apache/flink/pull/17464#issuecomment-942309521 ## CI report: * c27c0bbf796c7d6e92ddef1c893af8d35a18de54 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17464: [FLINK-24413] Casting to a CHAR() and VARCHAR() doesn't trim the stri…

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17464: URL: https://github.com/apache/flink/pull/17464#issuecomment-942309521 ## CI report: * c27c0bbf796c7d6e92ddef1c893af8d35a18de54 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17500: [FLINK-24564][formats] Change the default compression to snappy for parquet, orc, avro in table

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17500: URL: https://github.com/apache/flink/pull/17500#issuecomment-944278328 ## CI report: * f326685880c91dfc439431829658b0eeda7a7bd4 Azure:

[jira] [Created] (FLINK-24583) ElasticsearchWriterITCase.testWriteOnBulkIntervalFlush timeout on azure

2021-10-18 Thread Xintong Song (Jira)
Xintong Song created FLINK-24583: Summary: ElasticsearchWriterITCase.testWriteOnBulkIntervalFlush timeout on azure Key: FLINK-24583 URL: https://issues.apache.org/jira/browse/FLINK-24583 Project:

[jira] [Updated] (FLINK-24583) ElasticsearchWriterITCase.testWriteOnBulkIntervalFlush timeout on azure

2021-10-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24583: - Environment: (was: ElasticsearchWriterITCase) >

[GitHub] [flink] flinkbot edited a comment on pull request #17500: [FLINK-24564][formats] Change the default compression to snappy for parquet, orc, avro in table

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17500: URL: https://github.com/apache/flink/pull/17500#issuecomment-944278328 ## CI report: * f326685880c91dfc439431829658b0eeda7a7bd4 Azure:

[GitHub] [flink] SteNicholas commented on pull request #17500: [FLINK-24564][formats] Change the default compression to snappy for parquet, orc, avro in table

2021-10-18 Thread GitBox
SteNicholas commented on pull request #17500: URL: https://github.com/apache/flink/pull/17500#issuecomment-946324910 @JingsongLi , sorry for missing the update of `ParquetFileSystemITCase`. I have fixed the `testNonPartition` test case of `ParquetFileSystemITCase`. Please help to review

[jira] [Updated] (FLINK-24582) PrometheusReporterEndToEndITCase fails due to timeout

2021-10-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24582: - Fix Version/s: 1.15.0 > PrometheusReporterEndToEndITCase fails due to timeout >

[jira] [Updated] (FLINK-24582) PrometheusReporterEndToEndITCase fails due to timeout

2021-10-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24582: - Affects Version/s: 1.12.5 > PrometheusReporterEndToEndITCase fails due to timeout >

[jira] [Commented] (FLINK-24582) PrometheusReporterEndToEndITCase fails due to timeout

2021-10-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430290#comment-17430290 ] Xintong Song commented on FLINK-24582: --

[GitHub] [flink] wujinhu commented on pull request #7798: [FLINK-11388][fs] Add Aliyun OSS recoverable writer

2021-10-18 Thread GitBox
wujinhu commented on pull request #7798: URL: https://github.com/apache/flink/pull/7798#issuecomment-946322975 @kl0u Can we reopen this PR? Some users depend on this feature and I can keep working on it. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Created] (FLINK-24582) PrometheusReporterEndToEndITCase fails due to timeout

2021-10-18 Thread Xintong Song (Jira)
Xintong Song created FLINK-24582: Summary: PrometheusReporterEndToEndITCase fails due to timeout Key: FLINK-24582 URL: https://issues.apache.org/jira/browse/FLINK-24582 Project: Flink Issue

[GitHub] [flink-web] leonardBang commented on a change in pull request #473: Add Flink 1.13.3 release

2021-10-18 Thread GitBox
leonardBang commented on a change in pull request #473: URL: https://github.com/apache/flink-web/pull/473#discussion_r731454050 ## File path: _posts/2021-10-16-release-1.13.3.md ## @@ -0,0 +1,68 @@ +--- +layout: post +title: "Apache Flink 1.13.3 Released" +date: 2021-10-16

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

2021-10-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430288#comment-17430288 ] Xintong Song commented on FLINK-23944: --

[jira] [Commented] (FLINK-24401) TM cannot exit after Metaspace OOM

2021-10-18 Thread future (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430283#comment-17430283 ] future commented on FLINK-24401: Hi [~pnowojski] , thanks for you reply. I'm sorry, I didn't save the

[jira] [Assigned] (FLINK-24564) Change the default compression to snappy for parquet, orc, avro in table

2021-10-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-24564: Assignee: Nicholas Jiang > Change the default compression to snappy for parquet, orc,

[GitHub] [flink] xintongsong commented on a change in pull request #17496: [FLINK-24562][yarn] YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-18 Thread GitBox
xintongsong commented on a change in pull request #17496: URL: https://github.com/apache/flink/pull/17496#discussion_r731439124 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/TestingContainerStatus.java ## @@ -21,16 +21,23 @@ import

[jira] [Commented] (FLINK-24581) compatible uname command with multiple OS on ARM platform

2021-10-18 Thread zhao bo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430274#comment-17430274 ] zhao bo commented on FLINK-24581: - working on it > compatible uname command with multiple OS on ARM

[GitHub] [flink] flinkbot edited a comment on pull request #17514: [FLINK-24581][Tests]compatible uname command with multiple OS on ARM …

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17514: URL: https://github.com/apache/flink/pull/17514#issuecomment-946287305 ## CI report: * 3b1673ece4fb4b3071b603a20ad1cc0a38d11d61 Azure:

[GitHub] [flink] flinkbot commented on pull request #17514: [FLINK-24581][Tests]compatible uname command with multiple OS on ARM …

2021-10-18 Thread GitBox
flinkbot commented on pull request #17514: URL: https://github.com/apache/flink/pull/17514#issuecomment-946287673 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 #17514: [FLINK-24581][Tests]compatible uname command with multiple OS on ARM …

2021-10-18 Thread GitBox
flinkbot commented on pull request #17514: URL: https://github.com/apache/flink/pull/17514#issuecomment-946287305 ## CI report: * 3b1673ece4fb4b3071b603a20ad1cc0a38d11d61 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-24581) compatible uname command with multiple OS on ARM platform

2021-10-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24581: --- Labels: pull-request-available (was: ) > compatible uname command with multiple OS on ARM

[GitHub] [flink] bzhaoopenstack opened a new pull request #17514: [FLINK-24581][Tests]compatible uname command with multiple OS on ARM …

2021-10-18 Thread GitBox
bzhaoopenstack opened a new pull request #17514: URL: https://github.com/apache/flink/pull/17514 …platfrom exchange `uname -i` to `uname -m` for mac OS, for avoiding problem when we test on ARM Affected JIRA: FLINK-24581 ## What is the purpose of the change

[jira] [Created] (FLINK-24581) compatible uname command with multiple OS on ARM platform

2021-10-18 Thread zhao bo (Jira)
zhao bo created FLINK-24581: --- Summary: compatible uname command with multiple OS on ARM platform Key: FLINK-24581 URL: https://issues.apache.org/jira/browse/FLINK-24581 Project: Flink Issue Type:

[jira] [Created] (FLINK-24580) Kinesis connect time out error is not handled as recoverable

2021-10-18 Thread John Karp (Jira)
John Karp created FLINK-24580: - Summary: Kinesis connect time out error is not handled as recoverable Key: FLINK-24580 URL: https://issues.apache.org/jira/browse/FLINK-24580 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-938816662 ## CI report: * 16b451eba79ef7015e19adf6f0eb7c8b39c70715 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17513: [FLINK-24579][table-api][sql-client] Support toString for arrays as c…

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17513: URL: https://github.com/apache/flink/pull/17513#issuecomment-946022176 ## CI report: * 7ed6fd32b50df2743eb82c9fcc7a0edefc8c11ee Azure:

[jira] [Commented] (FLINK-24516) Modernize Maven Archetype

2021-10-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430205#comment-17430205 ] Martijn Visser commented on FLINK-24516: Definitely we should add a Table API quickstart, but I

[jira] [Commented] (FLINK-24549) FlinkKinesisConsumer does not work with generic types disabled

2021-10-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430203#comment-17430203 ] Martijn Visser commented on FLINK-24549: Would be good if you can pick it up [~dannycranmer].

[GitHub] [flink] flinkbot edited a comment on pull request #17510: [FLINK-24355][runtime] Expose the flag for enabling checkpoints after tasks finish in the Web UI

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17510: URL: https://github.com/apache/flink/pull/17510#issuecomment-945683858 ## CI report: * d2d050bbae90c773386dcfaf77d3b794f8398599 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17441: [FLINK-24461][table] PrintUtils common now accepts only internal data types

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17441: URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036 ## CI report: * e78df5a2a0572a2cfe043bf7737f1e52fe9f89af Azure:

[jira] [Commented] (FLINK-23486) Add metrics for the ChangelogStateBackend

2021-10-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430159#comment-17430159 ] Roman Khachatryan commented on FLINK-23486: --- Sorry [~complone], I don't fully understand your

[GitHub] [flink] flinkbot edited a comment on pull request #17512: [FLINK-24563][table-planner][test]

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17512: URL: https://github.com/apache/flink/pull/17512#issuecomment-945871287 ## CI report: * 596c788e5cc83b2580eb6d338706db135b4ffb1f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17439: [FLINK-23271][table-planner] Disallow cast from decimal numerics to boolean

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17439: URL: https://github.com/apache/flink/pull/17439#issuecomment-938696330 ## CI report: * 57a13401fc3f49a09bc7b5770f1e7aa212a1b6f8 Azure:

[GitHub] [flink] flinkbot commented on pull request #17513: [FLINK-24579][table-api][sql-client] Support toString for arrays as c…

2021-10-18 Thread GitBox
flinkbot commented on pull request #17513: URL: https://github.com/apache/flink/pull/17513#issuecomment-946023939 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 #17513: [FLINK-24579][table-api][sql-client] Support toString for arrays as c…

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17513: URL: https://github.com/apache/flink/pull/17513#issuecomment-946022176 ## CI report: * 7ed6fd32b50df2743eb82c9fcc7a0edefc8c11ee Azure:

[GitHub] [flink] flinkbot commented on pull request #17513: [FLINK-24579][table-api][sql-client] Support toString for arrays as c…

2021-10-18 Thread GitBox
flinkbot commented on pull request #17513: URL: https://github.com/apache/flink/pull/17513#issuecomment-946022176 ## CI report: * 7ed6fd32b50df2743eb82c9fcc7a0edefc8c11ee UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-24579) FlinkSQL does not print correctly content of arrays nested into maps

2021-10-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24579: --- Labels: pull-request-available (was: ) > FlinkSQL does not print correctly content of

[GitHub] [flink] snuyanzin opened a new pull request #17513: [FLINK-24579][table-api][sql-client] Support toString for arrays as c…

2021-10-18 Thread GitBox
snuyanzin opened a new pull request #17513: URL: https://github.com/apache/flink/pull/17513 ## What is the purpose of the change The PRs makes pretty printing of arrays nested into maps . ## Brief change log - *PrintUtils#deepToString* supporting maps -

[GitHub] [flink] flinkbot edited a comment on pull request #17179: [FLINK-24086][checkpoint] Rebuilding the SharedStateRegistry only when the restore method is called for the first time.

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17179: URL: https://github.com/apache/flink/pull/17179#issuecomment-914169535 ## CI report: * 04ae4ec0488291130ddd425c7c71080af698d58a Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #11: [FLINK-5][iteration] Add DraftExecutionEnvironment to support wrapping operators during compile time

2021-10-18 Thread GitBox
gaoyunhaii commented on a change in pull request #11: URL: https://github.com/apache/flink-ml/pull/11#discussion_r731119681 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/compile/translator/BroadcastStateTransformationTranslator.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #17439: [FLINK-23271][table-planner] Disallow cast from decimal numerics to boolean

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17439: URL: https://github.com/apache/flink/pull/17439#issuecomment-938696330 ## CI report: * 5dc78cd2cb8ec6dc971f05c75cbc9b33001e1fe5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * 92b897b4f14d61bf0414fe0d0f95771bdf5f05b5 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #17481: [FLINK-24387][table-planner] Support JSON_STRING.

2021-10-18 Thread GitBox
twalthr commented on a change in pull request #17481: URL: https://github.com/apache/flink/pull/17481#discussion_r731112769 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/DirectConvertRule.java ## @@ -210,6

[GitHub] [flink] flinkbot edited a comment on pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-938816662 ## CI report: * 7d56eb7d002b7bf5c268b98e12a6e4879cd68216 Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #8: [FLINK-4][iteration] Add operator wrapper for all-round iterations.

2021-10-18 Thread GitBox
gaoyunhaii commented on a change in pull request #8: URL: https://github.com/apache/flink-ml/pull/8#discussion_r731110199 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/AbstractWrapperOperator.java ## @@ -0,0 +1,166 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-938816662 ## CI report: * 7d56eb7d002b7bf5c268b98e12a6e4879cd68216 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17441: [FLINK-24461][table] PrintUtils common now accepts only internal data types

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17441: URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036 ## CI report: * 5a10760f62b70db58a953e0d8e304bafa56a053e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17510: [FLINK-24355][runtime] Expose the flag for enabling checkpoints after tasks finish in the Web UI

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17510: URL: https://github.com/apache/flink/pull/17510#issuecomment-945683858 ## CI report: * e5f8ec6be04661593cb2ea715c92bb0e8f75ca69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 279ce6cd083abc97b3be004ec78909783a700664 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17441: [FLINK-24461][table] PrintUtils common now accepts only internal data types

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17441: URL: https://github.com/apache/flink/pull/17441#issuecomment-938905036 ## CI report: * 5a10760f62b70db58a953e0d8e304bafa56a053e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17510: [FLINK-24355][runtime] Expose the flag for enabling checkpoints after tasks finish in the Web UI

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17510: URL: https://github.com/apache/flink/pull/17510#issuecomment-945683858 ## CI report: * e5f8ec6be04661593cb2ea715c92bb0e8f75ca69 Azure:

[jira] [Created] (FLINK-24579) FlinkSQL does not print correctly content of arrays nested into maps

2021-10-18 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-24579: --- Summary: FlinkSQL does not print correctly content of arrays nested into maps Key: FLINK-24579 URL: https://issues.apache.org/jira/browse/FLINK-24579 Project:

[jira] [Created] (FLINK-24578) Unexpected erratic load shape for channel skew load profile

2021-10-18 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24578: - Summary: Unexpected erratic load shape for channel skew load profile Key: FLINK-24578 URL: https://issues.apache.org/jira/browse/FLINK-24578 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17459: [FLINK-24397] Remove TableSchema usages from Flink connectors

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17459: URL: https://github.com/apache/flink/pull/17459#issuecomment-940996979 ## CI report: * 77238fc01c44ecbd5addf1f0dada9baa9366ffc4 Azure:

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17441: [FLINK-24461][table] PrintUtils common now accepts only internal data types

2021-10-18 Thread GitBox
slinkydeveloper commented on a change in pull request #17441: URL: https://github.com/apache/flink/pull/17441#discussion_r731092407 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/CollectDynamicSink.java ## @@ -115,6

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] nicoweidner commented on a change in pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

2021-10-18 Thread GitBox
nicoweidner commented on a change in pull request #17472: URL: https://github.com/apache/flink/pull/17472#discussion_r731087092 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/async/CompletedOperationCacheTest.java ## @@ -107,4 +109,53 @@

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17441: [FLINK-24461][table] PrintUtils common now accepts only internal data types

2021-10-18 Thread GitBox
slinkydeveloper commented on a change in pull request #17441: URL: https://github.com/apache/flink/pull/17441#discussion_r731087036 ## File path: flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/PrintUtilsTest.java ## @@ -437,10 +463,28 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[jira] [Closed] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

2021-10-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24480. Fix Version/s: 1.14.1 1.15.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] flinkbot edited a comment on pull request #17493: [FLINK-24019][build][dist] Package Scala APIs separately

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17493: URL: https://github.com/apache/flink/pull/17493#issuecomment-944057092 ## CI report: * 138a13cae9d3fe5b8003f0a50e70cfcb4ee03d6c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] twalthr closed pull request #17499: [FLINK-24480][table-planner] Reduce number of fields in test

2021-10-18 Thread GitBox
twalthr closed pull request #17499: URL: https://github.com/apache/flink/pull/17499 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #17441: [FLINK-24461][table] PrintUtils common now accepts only internal data types

2021-10-18 Thread GitBox
twalthr commented on a change in pull request #17441: URL: https://github.com/apache/flink/pull/17441#discussion_r731066521 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/CollectDynamicSink.java ## @@ -115,6 +105,9 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17511: [FLINK-24122][history] Add support to do clean in history server

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17511: URL: https://github.com/apache/flink/pull/17511#issuecomment-945683958 ## CI report: * e1142a17f72fc01067ec2582c71b2887795e82bb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[jira] [Commented] (FLINK-21884) Reduce TaskManager failure detection time

2021-10-18 Thread ZhuoYu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430068#comment-17430068 ] ZhuoYu Chen commented on FLINK-21884: - Hi [~rmetzger] , I am very interested in this,and I want do

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #8: [FLINK-4][iteration] Add operator wrapper for all-round iterations.

2021-10-18 Thread GitBox
gaoyunhaii commented on a change in pull request #8: URL: https://github.com/apache/flink-ml/pull/8#discussion_r731047886 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/AbstractWrapperOperator.java ## @@ -0,0 +1,166 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17510: [FLINK-24355][runtime] Expose the flag for enabling checkpoints after tasks finish in the Web UI

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17510: URL: https://github.com/apache/flink/pull/17510#issuecomment-945683858 ## CI report: * e5f8ec6be04661593cb2ea715c92bb0e8f75ca69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * e55e39b5d853dca996b59212c2c8d9899a9b5a81 Azure:

[GitHub] [flink] twalthr closed pull request #17343: [hotfix][docs] Various doc enhancements around filesystem table connector and json

2021-10-18 Thread GitBox
twalthr closed pull request #17343: URL: https://github.com/apache/flink/pull/17343 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #8: [FLINK-4][iteration] Add operator wrapper for all-round iterations.

2021-10-18 Thread GitBox
gaoyunhaii commented on a change in pull request #8: URL: https://github.com/apache/flink-ml/pull/8#discussion_r731033300 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/proxy/ProxyOutput.java ## @@ -0,0 +1,105 @@ +/* + * Licensed to the Apache

[jira] [Comment Edited] (FLINK-24539) ChangelogNormalize operator tooks too long time to INITIALIZING until failed

2021-10-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430063#comment-17430063 ] Timo Walther edited comment on FLINK-24539 at 10/18/21, 3:12 PM: -

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 9b955f3b9d31e3cfc411bd763ace3a0fb916b3c4 Azure:

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #8: [FLINK-4][iteration] Add operator wrapper for all-round iterations.

2021-10-18 Thread GitBox
gaoyunhaii commented on a change in pull request #8: URL: https://github.com/apache/flink-ml/pull/8#discussion_r731032333 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/progresstrack/ProgressTracker.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-24539) ChangelogNormalize operator tooks too long time to INITIALIZING until failed

2021-10-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430063#comment-17430063 ] Timo Walther commented on FLINK-24539: -- [~vmaster] {{ChangelogNormalize}} stores the entire input

[GitHub] [flink] fapaul commented on a change in pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-10-18 Thread GitBox
fapaul commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r731023148 ## File path: flink-connectors/flink-connector-aws/src/test/java/org/apache/flink/streaming/connectors/kinesis/async/testutils/KinesaliteContainer.java

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #8: [FLINK-4][iteration] Add operator wrapper for all-round iterations.

2021-10-18 Thread GitBox
gaoyunhaii commented on a change in pull request #8: URL: https://github.com/apache/flink-ml/pull/8#discussion_r731030286 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/EpochWatermarkAware.java ## @@ -0,0 +1,30 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17512: [FLINK-24563][table-planner][test]

2021-10-18 Thread GitBox
flinkbot edited a comment on pull request #17512: URL: https://github.com/apache/flink/pull/17512#issuecomment-945871287 ## CI report: * 596c788e5cc83b2580eb6d338706db135b4ffb1f Azure:

[jira] [Updated] (FLINK-24454) Consolidate all CAST related test into the new CastFunctionITCase class

2021-10-18 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas updated FLINK-24454: Description: Check and possibly move all related CAST tests into one place, i.e.:

[GitHub] [flink] flinkbot commented on pull request #17512: [FLINK-24563][table-planner][test]

2021-10-18 Thread GitBox
flinkbot commented on pull request #17512: URL: https://github.com/apache/flink/pull/17512#issuecomment-945872777 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-ml] gaoyunhaii commented on a change in pull request #8: [FLINK-4][iteration] Add operator wrapper for all-round iterations.

2021-10-18 Thread GitBox
gaoyunhaii commented on a change in pull request #8: URL: https://github.com/apache/flink-ml/pull/8#discussion_r731026886 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/ml/iteration/operator/allround/MultipleInputAllRoundWrapperOperator.java ## @@ -0,0 +1,116

[GitHub] [flink] flinkbot commented on pull request #17512: [FLINK-24563][table-planner][test]

2021-10-18 Thread GitBox
flinkbot commented on pull request #17512: URL: https://github.com/apache/flink/pull/17512#issuecomment-945871287 ## CI report: * 596c788e5cc83b2580eb6d338706db135b4ffb1f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

  1   2   3   4   >