[jira] [Commented] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000)

[ https://issues.apache.org/jira/browse/FLINK-24586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17431015#comment-17431015 ] liwei li commented on FLINK-24586: -- I'm interested in changing the return of JSON funct

[GitHub] [flink] dawidwys closed pull request #17447: [hotfix] Update release notes with changes to StreamStatus

dawidwys closed pull request #17447: URL: https://github.com/apache/flink/pull/17447 -- 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: issues-unsubs

[GitHub] [flink] flinkbot edited a comment on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

flinkbot edited a comment on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380227 ## CI report: * bf7f144b587313f1ab5cd706c52a25587151b923 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

flinkbot commented on pull request #17525: URL: https://github.com/apache/flink/pull/17525#issuecomment-947380401 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 pro

[GitHub] [flink] flinkbot commented on pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

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

[GitHub] [flink-ml] guoweiM commented on a change in pull request #6: [FLINK-2][iteration] Add broadcast output to broadcast events to all the downstream tasks

guoweiM commented on a change in pull request #6: URL: https://github.com/apache/flink-ml/pull/6#discussion_r732456097 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/broadcast/ChainingBroadcastOutput.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to the A

[jira] [Updated] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24597: --- Labels: pull-request-available (was: ) > RocksdbStateBackend getKeysAndNamespaces would ret

[GitHub] [flink] mayuehappy opened a new pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

mayuehappy opened a new pull request #17525: URL: https://github.com/apache/flink/pull/17525 …terator would return duplicate data ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through

[jira] [Updated] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24597: - Attachment: (was: image-2021-10-20-14-23-20-333.png) > RocksdbStateBackend getKeysAn

[GitHub] [flink] RocMarshal commented on a change in pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

RocMarshal commented on a change in pull request #17508: URL: https://github.com/apache/flink/pull/17508#discussion_r732397717 ## File path: docs/data/sql_functions_zh.yml ## @@ -742,9 +740,9 @@ json: - sql: JSON_EXISTS(jsonValue, path [ { TRUE | FALSE | UNKNOWN | ERROR } ON

[jira] [Created] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

Yue Ma created FLINK-24597: -- Summary: RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState Key: FLINK-24597 URL: https://issues.apache.org/jira/browse/FLINK-24597 Project

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

flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * def050276334d930dec36d5cffe52a47c1bf039d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * def050276334d930dec36d5cffe52a47c1bf039d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ https://issues.apache.org/jira/browse/FLINK-24596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17430999#comment-17430999 ] Fabian Paul commented on FLINK-24596: - I can take it. > Bugs in sink.buffer-flush b

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

[ https://issues.apache.org/jira/browse/FLINK-24596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-24596: --- Assignee: Fabian Paul > Bugs in sink.buffer-flush before upsert-kafka > ---

[jira] [Resolved] (FLINK-24546) Acknowledged description miss on Monitoring Checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-24546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24546. -- Fix Version/s: 1.15.0 Resolution: Fixed merged in master: 6b405f6318b82d759fbd93f9a6af213cda723

[jira] [Commented] (FLINK-24546) Acknowledged description miss on Monitoring Checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-24546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17430987#comment-17430987 ] Yun Tang commented on FLINK-24546: -- [~Alston Williams], thanks for your enthusiasm! As

[jira] [Assigned] (FLINK-24546) Acknowledged description miss on Monitoring Checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-24546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24546: Assignee: camilesing > Acknowledged description miss on Monitoring Checkpointing page > -

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

Myasuka closed pull request #17482: URL: https://github.com/apache/flink/pull/17482 -- 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: issues-unsubsc

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

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 Sof

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

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

flinkbot edited a comment on pull request #17519: URL: https://github.com/apache/flink/pull/17519#issuecomment-946579332 ## CI report: * 3b693fd284dec0633e572d6e0428bc1153bc0ed9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 3b8fa52e5763fb02a0b786d938f1e478f5a7155e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 594c229d544573b2697781bc2ef1e53baaccba5a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 594c229d544573b2697781bc2ef1e53baaccba5a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ https://issues.apache.org/jira/browse/FLINK-23169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17430878#comment-17430878 ] Xintong Song commented on FLINK-23169: -- hi [~hackergin], I'm trying to understand:

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

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 camile

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

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 t

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

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 st

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

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 i

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

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 i

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

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

[ 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

[ 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

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 org.apac

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-24596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17430850#comment-17430850 ] Jingsong Lee commented on FLINK-24596: -- CC: [~arvid] [~fabian.paul] > Bugs in sink

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

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 ba

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

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: Bug

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

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

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

[ 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

[ 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

[ 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

[ 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): a08e7c6577557dce874b30df9

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

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

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

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: issues-unsub

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

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: issues-uns

[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

flinkbot edited a comment on pull request #17519: URL: https://github.com/apache/flink/pull/17519#issuecomment-946579332 ## CI report: * 3b693fd284dec0633e572d6e0428bc1153bc0ed9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

flinkbot edited a comment on pull request #17519: URL: https://github.com/apache/flink/pull/17519#issuecomment-946579332 ## CI report: * 3b693fd284dec0633e572d6e0428bc1153bc0ed9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

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 specif

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

flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 4f842b98d3aaee4d1073a3621aa0f8a125e46528 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17524: URL: https://github.com/apache/flink/pull/17524#issuecomment-947119476 ## CI report: * fbe360124a6e29ed8059246acc6a261f53b5448b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 4f842b98d3aaee4d1073a3621aa0f8a125e46528 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 message,

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

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

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

[ 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

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: issues-unsu

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

[ https://issues.apache.org/jira/browse/FLINK-24562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17430830#comment-17430830 ] Feifan Wang commented on FLINK-24562: - Hi [~xtsong], I hive modify the pr follow you

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

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 ab

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

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. T

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

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 o

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

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 So

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

flinkbot edited a comment on pull request #17524: URL: https://github.com/apache/flink/pull/17524#issuecomment-947119476 ## CI report: * fbe360124a6e29ed8059246acc6a261f53b5448b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 pro

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

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 r

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

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 *(F

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

flinkbot edited a comment on pull request #17496: URL: https://github.com/apache/flink/pull/17496#issuecomment-944116990 ## CI report: * 106c7d11694d96a167cc3a3315ba91fe15d14632 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17459: URL: https://github.com/apache/flink/pull/17459#issuecomment-940996979 ## CI report: * 0a7a93b33cebac710002818515ba9cec493c6dc2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * 6c6aa3b08eb8bee6f96f27a8b84eaebfba015d7f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-938816662 ## CI report: * 658994fafd3947a2a9a49fa91d3c7e4fce3e52b5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

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

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 fol

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

flinkbot edited a comment on pull request #17439: URL: https://github.com/apache/flink/pull/17439#issuecomment-938696330 ## CI report: * 711c3b24a34da8fbc1065487b3815599a7c25af7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 specif

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

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 org.apache.hadoop.yarn.api.rec

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

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 org.apache.hadoop.yarn.api.rec

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

flinkbot edited a comment on pull request #17458: URL: https://github.com/apache/flink/pull/17458#issuecomment-940890804 ## CI report: * 2a955c618facf78f9953cb6159f201c2262a78eb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

[ https://issues.apache.org/jira/browse/FLINK-24384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17430664#comment-17430664 ] Feifan Wang commented on FLINK-24384: - Hi [~pnowojski], I test the pr of FLINK-24344

[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

flinkbot edited a comment on pull request #17523: URL: https://github.com/apache/flink/pull/17523#issuecomment-946841463 ## CI report: * cd03025238198ad4fdd48009e412f3594ca613ac Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * def050276334d930dec36d5cffe52a47c1bf039d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17439: URL: https://github.com/apache/flink/pull/17439#issuecomment-938696330 ## CI report: * 5af68936a0eec1623b38a5f73ba5f5e9d62e387a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #17458: URL: https://github.com/apache/flink/pull/17458#issuecomment-940890804 ## CI report: * 2c0a31553ff573e2ac794d0dc5f11c33144c24c8 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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

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

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

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

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

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

flinkbot edited a comment on pull request #17512: URL: https://github.com/apache/flink/pull/17512#issuecomment-945871287 ## CI report: * 6c70fbff77debc375858f142cb325f6c0942d978 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ 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) > Config

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

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 @@ +/* + * L

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

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 @@ +/* + * L

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

flinkbot edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-946651087 ## CI report: * 4f842b98d3aaee4d1073a3621aa0f8a125e46528 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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…

flinkbot edited a comment on pull request #17482: URL: https://github.com/apache/flink/pull/17482#issuecomment-943277366 ## CI report: * 5adaf0c3a0a2d0d6a98f0e095603aea1a87e91e0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #17458: URL: https://github.com/apache/flink/pull/17458#issuecomment-940890804 ## CI report: * 1527085f5c1365c300b47c783f655cb8494a92f5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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: issues-unsubs

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

flinkbot edited a comment on pull request #17458: URL: https://github.com/apache/flink/pull/17458#issuecomment-940890804 ## CI report: * 1527085f5c1365c300b47c783f655cb8494a92f5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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

flinkbot edited a comment on pull request #17523: URL: https://github.com/apache/flink/pull/17523#issuecomment-946841463 ## CI report: * cd03025238198ad4fdd48009e412f3594ca613ac Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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 r

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

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

[ https://issues.apache.org/jira/browse/FLINK-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17430609#comment-17430609 ] Chesnay Schepler commented on FLINK-14954: -- flink-shaded-swagger added to flink

  1   2   3   4   >