[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-19 Thread GitBox
gaoyunhaii commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r732437805 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastUtils.java ## @@ -0,0 +1,142 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-19 Thread GitBox
gaoyunhaii commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r732431833 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/operator/AbstractBroadcastWrapperOperator.java ## @@ -96,31 +97,36 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17519: [FLINK-24368][testutils] Print logs JobManager and TaskManager on STDOUT in Flink container for redirecting to log4j in tests

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17519: URL: https://github.com/apache/flink/pull/17519#issuecomment-946579332 ## CI report: * 3b693fd284dec0633e572d6e0428bc1153bc0ed9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 3b8fa52e5763fb02a0b786d938f1e478f5a7155e Azure:

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

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

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

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

[jira] [Commented] (FLINK-23169) Support user-level app staging directory when yarn.staging-directory is specified

2021-10-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430878#comment-17430878 ] Xintong Song commented on FLINK-23169: -- hi [~hackergin], I'm trying to understand: # Why is it a

[GitHub] [flink] Myasuka commented on pull request #17482: [FLINK-24546][docs]fix miss Acknowledged description on Monitoring Ch…

2021-10-19 Thread GitBox
Myasuka commented on pull request #17482: URL: https://github.com/apache/flink/pull/17482#issuecomment-947302284 > I have added the description, could you please review it? @wuchong The pull request is [this](https://github.com/apache/flink/pull/17495). @AlstonWilliams , since

[GitHub] [flink] JingsongLi commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-19 Thread GitBox
JingsongLi commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r732391776 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AbstractAvroBulkFormat.java ## @@ -0,0 +1,190 @@ +/* + * Licensed

[GitHub] [flink] JingsongLi commented on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-19 Thread GitBox
JingsongLi commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-947295434 Hi @slinkydeveloper @tsreaper , I think Avro and StreamFormat are in conflict conceptually. In the comments of StreamFormat: > Compared to the {@link BulkFormat}, the

[GitHub] [flink] tsreaper edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-19 Thread GitBox
tsreaper edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-947280429 @slinkydeveloper There are four reasons why I did not choose `StreamFormat`. 1. The biggest concern is that `StreamFormatAdapter.Reader#readBatch` stores all results

[GitHub] [flink] tsreaper edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-19 Thread GitBox
tsreaper edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-947280429 @slinkydeveloper There are four reasons why I did not choose `StreamFormat`. 1. The biggest concern is that `StreamFormatAdapter.Reader#readBatch` stores all results

[GitHub] [flink] tsreaper commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-19 Thread GitBox
tsreaper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r732386149 ## File path: flink-formats/flink-avro/pom.xml ## @@ -47,13 +47,11 @@ under the License. -

[jira] [Updated] (FLINK-24596) Bugs in sink.buffer-flush before upsert-kafka

2021-10-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-24596: - Affects Version/s: 1.14.0 > Bugs in sink.buffer-flush before upsert-kafka >

[jira] [Updated] (FLINK-24596) Bugs in sink.buffer-flush before upsert-kafka

2021-10-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-24596: - Fix Version/s: (was: 1.15.0) > Bugs in sink.buffer-flush before upsert-kafka >

[GitHub] [flink] tsreaper commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-19 Thread GitBox
tsreaper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r732384420 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFileFormatFactory.java ## @@ -20,39 +20,135 @@ import

[jira] [Updated] (FLINK-23849) Support react to the node decommissioning change state on yarn and do graceful restart

2021-10-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23849: - Affects Version/s: (was: 1.13.2) (was: 1.13.1)

[jira] [Commented] (FLINK-24596) Bugs in sink.buffer-flush before upsert-kafka

2021-10-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430850#comment-17430850 ] Jingsong Lee commented on FLINK-24596: -- CC: [~arvid] [~fabian.paul] > Bugs in sink.buffer-flush

[GitHub] [flink] tsreaper commented on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-19 Thread GitBox
tsreaper commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-947280429 @slinkydeveloper There are three reasons why I did not choose `StreamFormat`. 1. The biggest concern is that `StreamFormatAdapter.Reader#readBatch` stores all results in a

[jira] [Created] (FLINK-24596) Bugs in sink.buffer-flush before upsert-kafka

2021-10-19 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-24596: Summary: Bugs in sink.buffer-flush before upsert-kafka Key: FLINK-24596 URL: https://issues.apache.org/jira/browse/FLINK-24596 Project: Flink Issue Type:

[jira] [Updated] (FLINK-24122) Add support to do clean in history server

2021-10-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24122: - Affects Version/s: (was: 1.13.2) (was: 1.12.3) > Add support to

[jira] [Updated] (FLINK-24122) Add support to do clean in history server

2021-10-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24122: - Priority: Major (was: Minor) > Add support to do clean in history server >

[jira] [Updated] (FLINK-24122) Add support to do clean in history server

2021-10-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24122: - Issue Type: Improvement (was: Bug) > Add support to do clean in history server >

[jira] [Updated] (FLINK-24122) Add support to do clean in history server

2021-10-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24122: - Fix Version/s: (was: 1.14.1) 1.15.0 > Add support to do clean in history

[jira] [Closed] (FLINK-24562) YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-24562. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in - master (1.15):

[jira] [Updated] (FLINK-24562) YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24562: - Issue Type: Bug (was: Improvement) > YarnResourceManagerDriverTest should not use

[GitHub] [flink] becketqin merged pull request #17310: [FLINK-24308][docs] Translate Kafka DataStream connector documentation to Chinese

2021-10-19 Thread GitBox
becketqin merged pull request #17310: URL: https://github.com/apache/flink/pull/17310 -- 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] xintongsong closed pull request #17496: [FLINK-24562][yarn] YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-19 Thread GitBox
xintongsong closed pull request #17496: URL: https://github.com/apache/flink/pull/17496 -- 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 #17519: [FLINK-24368][testutils] Print logs JobManager and TaskManager on STDOUT in Flink container for redirecting to log4j in tests

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17519: URL: https://github.com/apache/flink/pull/17519#issuecomment-946579332 ## CI report: * 3b693fd284dec0633e572d6e0428bc1153bc0ed9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17519: [FLINK-24368][testutils] Print logs JobManager and TaskManager on STDOUT in Flink container for redirecting to log4j in tests

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17519: URL: https://github.com/apache/flink/pull/17519#issuecomment-946579332 ## CI report: * 3b693fd284dec0633e572d6e0428bc1153bc0ed9 Azure:

[GitHub] [flink] PatrickRen commented on pull request #17519: [FLINK-24368][testutils] Print logs JobManager and TaskManager on STDOUT in Flink container for redirecting to log4j in tests

2021-10-19 Thread GitBox
PatrickRen commented on pull request #17519: URL: https://github.com/apache/flink/pull/17519#issuecomment-947255847 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 4f842b98d3aaee4d1073a3621aa0f8a125e46528 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17524: Update rabbitmq.md

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17524: URL: https://github.com/apache/flink/pull/17524#issuecomment-947119476 ## CI report: * fbe360124a6e29ed8059246acc6a261f53b5448b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 4f842b98d3aaee4d1073a3621aa0f8a125e46528 Azure:

[GitHub] [flink] baisui1981 commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

2021-10-19 Thread GitBox
baisui1981 commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-947244756 > checkstyle failed. You can run `mvn spotless:apply` to fix it. i have fix it -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-24585) Print the change in the size of the compacted files

2021-10-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-24585. Resolution: Fixed master: 69d5780abc681064f23545f2d4fb4c5ce9ba5403 > Print the change in the

[jira] [Updated] (FLINK-24585) Print the change in the size of the compacted files

2021-10-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-24585: - Fix Version/s: 1.15.0 > Print the change in the size of the compacted files >

[GitHub] [flink] JingsongLi merged pull request #17517: [FLINK-24585][filesystem] Print the change in the size of the compacted files

2021-10-19 Thread GitBox
JingsongLi merged pull request #17517: URL: https://github.com/apache/flink/pull/17517 -- 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:

[jira] [Commented] (FLINK-24562) YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-19 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430830#comment-17430830 ] Feifan Wang commented on FLINK-24562: - Hi [~xtsong], I hive modify the pr follow your comment. >

[GitHub] [flink] tisonkun commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

2021-10-19 Thread GitBox
tisonkun commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-947226017 cc @AHeise from the mailing list discussion. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] tisonkun commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

2021-10-19 Thread GitBox
tisonkun commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-947225450 cc @guoweiM @StephanEwen Also I'd like to know who can be cc to for API/DataStream related changes now? -- This is an automated message from the Apache Git Service.

[GitHub] [flink] tisonkun commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

2021-10-19 Thread GitBox
tisonkun commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-947224927 @baisui1981 checkstyle failed. You can run `mvn spotless:apply` to fix it. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #18: [FLINK-24279] Support withBroadcast in DataStream by caching in static variables

2021-10-19 Thread GitBox
zhipeng93 commented on a change in pull request #18: URL: https://github.com/apache/flink-ml/pull/18#discussion_r730339576 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/broadcast/BroadcastContext.java ## @@ -0,0 +1,123 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17524: Update rabbitmq.md

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17524: URL: https://github.com/apache/flink/pull/17524#issuecomment-947119476 ## CI report: * fbe360124a6e29ed8059246acc6a261f53b5448b Azure:

[GitHub] [flink] flinkbot commented on pull request #17524: Update rabbitmq.md

2021-10-19 Thread GitBox
flinkbot commented on pull request #17524: URL: https://github.com/apache/flink/pull/17524#issuecomment-947120495 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 #17524: Update rabbitmq.md

2021-10-19 Thread GitBox
flinkbot commented on pull request #17524: URL: https://github.com/apache/flink/pull/17524#issuecomment-947119476 ## CI report: * fbe360124a6e29ed8059246acc6a261f53b5448b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] mHz28 opened a new pull request #17524: Update rabbitmq.md

2021-10-19 Thread GitBox
mHz28 opened a new pull request #17524: URL: https://github.com/apache/flink/pull/17524 Might be helpful to set the actual out of box default port value for RabbitMQ. The update code will work with a new installation of RabbitMQ ## What is the purpose of the change

[GitHub] [flink] flinkbot edited a comment on pull request #17496: [FLINK-24562][yarn] YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17496: URL: https://github.com/apache/flink/pull/17496#issuecomment-944116990 ## CI report: * 106c7d11694d96a167cc3a3315ba91fe15d14632 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * 6c6aa3b08eb8bee6f96f27a8b84eaebfba015d7f Azure:

[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-19 Thread GitBox
flinkbot edited a comment on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-938816662 ## CI report: * 658994fafd3947a2a9a49fa91d3c7e4fce3e52b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17496: [FLINK-24562][yarn] YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17496: URL: https://github.com/apache/flink/pull/17496#issuecomment-944116990 ## CI report: * Unknown: [CANCELED](TBD) * 106c7d11694d96a167cc3a3315ba91fe15d14632 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17496: [FLINK-24562][yarn] YarnResourceManagerDriverTest should not use ContainerStatusPBImpl.newInstance

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17496: URL: https://github.com/apache/flink/pull/17496#issuecomment-944116990 ## CI report: * Unknown: [CANCELED](TBD) * 106c7d11694d96a167cc3a3315ba91fe15d14632 UNKNOWN Bot commands The @flinkbot bot supports the

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

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

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

2021-10-19 Thread GitBox
zoltar9264 commented on pull request #17496: URL: https://github.com/apache/flink/pull/17496#issuecomment-946961163 @flinkbot run azure -- 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

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17458: URL: https://github.com/apache/flink/pull/17458#issuecomment-940890804 ## CI report: * 2a955c618facf78f9953cb6159f201c2262a78eb Azure:

[jira] [Created] (FLINK-24595) Programmatic configuration of S3 doesn't pass parameters to Hadoop FS

2021-10-19 Thread Pavel Penkov (Jira)
Pavel Penkov created FLINK-24595: Summary: Programmatic configuration of S3 doesn't pass parameters to Hadoop FS Key: FLINK-24595 URL: https://issues.apache.org/jira/browse/FLINK-24595 Project: Flink

[jira] [Commented] (FLINK-24384) Count checkpoints failed in trigger phase into numberOfFailedCheckpoints

2021-10-19 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430664#comment-17430664 ] Feifan Wang commented on FLINK-24384: - Hi [~pnowojski], I test the pr of FLINK-24344 just now. It

[GitHub] [flink] flinkbot edited a comment on pull request #17523: [FLINK-21407] Update formats in connectors doc for Flink 1.13 for DataSet and DataStream APIs

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17523: URL: https://github.com/apache/flink/pull/17523#issuecomment-946841463 ## CI report: * cd03025238198ad4fdd48009e412f3594ca613ac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * def050276334d930dec36d5cffe52a47c1bf039d Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17458: URL: https://github.com/apache/flink/pull/17458#issuecomment-940890804 ## CI report: * 2c0a31553ff573e2ac794d0dc5f11c33144c24c8 Azure:

[jira] [Closed] (FLINK-24355) Expose the flag for enabling checkpoints after tasks finish in the Web UI

2021-10-19 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24355. Resolution: Implemented Implemented in: * master **

[jira] [Closed] (FLINK-24487) Add DELETE endpoint for operation results

2021-10-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24487. Fix Version/s: (was: 1.15.0) Resolution: Later May add this later. The

[jira] [Closed] (FLINK-24484) Support manual cleanup of async operation results

2021-10-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24484. Fix Version/s: (was: 1.15.0) Resolution: Later > Support manual cleanup of

[GitHub] [flink] flinkbot edited a comment on pull request #17512: [FLINK-24563][table-planner][test] Re-enable tests for invalid strings->timestamp_tz cast

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

[jira] [Updated] (FLINK-24486) Configurable async operation result cache timeout

2021-10-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24486: - Parent: (was: FLINK-24484) Issue Type: Improvement (was: Sub-task) >

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-19 Thread GitBox
slinkydeveloper commented on a change in pull request #17522: URL: https://github.com/apache/flink/pull/17522#discussion_r732012043 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/data/casting/CastRulesTest.java ## @@ -0,0 +1,165 @@ +/* + *

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-19 Thread GitBox
slinkydeveloper commented on a change in pull request #17522: URL: https://github.com/apache/flink/pull/17522#discussion_r732007560 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/data/casting/CastExpression.java ## @@ -0,0 +1,56 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 4f842b98d3aaee4d1073a3621aa0f8a125e46528 Azure:

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-19 Thread GitBox
slinkydeveloper commented on a change in pull request #17522: URL: https://github.com/apache/flink/pull/17522#discussion_r732007179 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/data/casting/CastRuleProvider.java ## @@ -0,0 +1,155 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #17482: [FLINK-24546][docs]fix miss Acknowledged description on Monitoring Ch…

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17482: URL: https://github.com/apache/flink/pull/17482#issuecomment-943277366 ## CI report: * 5adaf0c3a0a2d0d6a98f0e095603aea1a87e91e0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17458: [hotfix][docs] add more information about how to speed up maven build.

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17458: URL: https://github.com/apache/flink/pull/17458#issuecomment-940890804 ## CI report: * 1527085f5c1365c300b47c783f655cb8494a92f5 Azure:

[GitHub] [flink] dawidwys merged pull request #17510: [FLINK-24355][runtime] Expose the flag for enabling checkpoints after tasks finish in the Web UI

2021-10-19 Thread GitBox
dawidwys merged pull request #17510: URL: https://github.com/apache/flink/pull/17510 -- 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 #17458: [hotfix][docs] add more information about how to speed up maven build.

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17458: URL: https://github.com/apache/flink/pull/17458#issuecomment-940890804 ## CI report: * 1527085f5c1365c300b47c783f655cb8494a92f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17523: [FLINK-21407] Update formats in connectors doc for Flink 1.13 for DataSet and DataStream APIs

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17523: URL: https://github.com/apache/flink/pull/17523#issuecomment-946841463 ## CI report: * cd03025238198ad4fdd48009e412f3594ca613ac Azure:

[GitHub] [flink] flinkbot commented on pull request #17523: [FLINK-21407] Update formats in connectors doc for Flink 1.13 for DataSet and DataStream APIs

2021-10-19 Thread GitBox
flinkbot commented on pull request #17523: URL: https://github.com/apache/flink/pull/17523#issuecomment-946841463 ## CI report: * cd03025238198ad4fdd48009e412f3594ca613ac UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] echauchot commented on pull request #17523: [FLINK-21407] Update formats in connectors doc for Flink 1.13 for DataSet and DataStream APIs

2021-10-19 Thread GitBox
echauchot commented on pull request #17523: URL: https://github.com/apache/flink/pull/17523#issuecomment-946841301 R: @zentol CC: @AHeise Thanks guys, feel free to point me to another committer if you lack time to review that. -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-14954) Publish OpenAPI specification of REST Monitoring API

2021-10-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430609#comment-17430609 ] Chesnay Schepler commented on FLINK-14954: -- flink-shaded-swagger added to flink-shaded master

[jira] [Updated] (FLINK-14954) Publish OpenAPI specification of REST Monitoring API

2021-10-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14954: - Fix Version/s: shaded-15.0 > Publish OpenAPI specification of REST Monitoring API >

[GitHub] [flink-shaded] zentol merged pull request #102: [FLINK-14954] Add flink-shaded-swagger

2021-10-19 Thread GitBox
zentol merged pull request #102: URL: https://github.com/apache/flink-shaded/pull/102 -- 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 commented on pull request #17523: [FLINK-21407] Update formats in connectors doc for Flink 1.13 for DataSet and DataStream APIs

2021-10-19 Thread GitBox
flinkbot commented on pull request #17523: URL: https://github.com/apache/flink/pull/17523#issuecomment-946839843 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-21407) Clarify which sources and APIs support which formats

2021-10-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21407: --- Labels: auto-deprioritized-major pull-request-available (was: auto-deprioritized-major) >

[GitHub] [flink] echauchot opened a new pull request #17523: [FLINK-21407] Update formats in connectors doc for Flink 1.13 for DataSet and DataStream APIs

2021-10-19 Thread GitBox
echauchot opened a new pull request #17523: URL: https://github.com/apache/flink/pull/17523 This PR updates undocumented existing features. As they were removed in 1.14 I update the 1.13 branch. AFAICT the formats work also for DataStream API so I added also the pages to DataStream

[jira] [Commented] (FLINK-20195) Jobs endpoint returns duplicated jobs

2021-10-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430598#comment-17430598 ] Chesnay Schepler commented on FLINK-20195: -- Maybe not in 1.11, but definitely in more recent

[GitHub] [flink] flinkbot edited a comment on pull request #17482: [FLINK-24546][docs]fix miss Acknowledged description on Monitoring Ch…

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17482: URL: https://github.com/apache/flink/pull/17482#issuecomment-943277366 ## CI report: * 85bb1d38daa1f28fdfb0c59125d4e4a1fd36d1f7 Azure:

[jira] [Closed] (FLINK-24594) /jobs endpoint returns same job id twice (suspended and running) until stopped

2021-10-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24594. Resolution: Duplicate > /jobs endpoint returns same job id twice (suspended and running)

[jira] [Updated] (FLINK-24594) /jobs endpoint returns same job id twice (suspended and running) until stopped

2021-10-19 Thread Azocan Kara (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Azocan Kara updated FLINK-24594: Description: We observe this behavior since our migration to flink 1.13.2.  /jobs GET endpoint

[jira] [Updated] (FLINK-24594) /jobs endpoint returns same job id twice (suspended and running) until stopped

2021-10-19 Thread Azocan Kara (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Azocan Kara updated FLINK-24594: Description: We observe this behavior since our migration to flink 1.13.2.  /jobs GET endpoint

[jira] [Created] (FLINK-24594) /jobs endpoint returns same job id twice (suspended and running) until stopped

2021-10-19 Thread Azocan Kara (Jira)
Azocan Kara created FLINK-24594: --- Summary: /jobs endpoint returns same job id twice (suspended and running) until stopped Key: FLINK-24594 URL: https://issues.apache.org/jira/browse/FLINK-24594

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * 328757a3ccd17d2594bf2bfca945ce07f7c9d012 Azure:

[GitHub] [flink] matriv commented on a change in pull request #17522: [FLINK-24462][table] Introduce CastRule interface to reorganize casting code

2021-10-19 Thread GitBox
matriv commented on a change in pull request #17522: URL: https://github.com/apache/flink/pull/17522#discussion_r731901591 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/data/casting/CastRuleProvider.java ## @@ -0,0 +1,155 @@ +/* + *

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

2021-10-19 Thread GitBox
flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * 328757a3ccd17d2594bf2bfca945ce07f7c9d012 Azure:

[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-19 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] zentol commented on a change in pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

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

[jira] [Resolved] (FLINK-21336) Activate bloom filter in RocksDB State Backend via Flink configuration

2021-10-19 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-21336. - Resolution: Duplicate > Activate bloom filter in RocksDB State Backend via Flink configuration

  1   2   3   4   >