[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[jira] [Updated] (FLINK-24397) Reduce legacy in Table API connectors

[ https://issues.apache.org/jira/browse/FLINK-24397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24397: - Summary: Reduce legacy in Table API connectors (was: Reduce TableSchema usage in Table API

[jira] [Updated] (FLINK-24397) Reduce legacy in Table API connectors

[ https://issues.apache.org/jira/browse/FLINK-24397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24397: - Description: The TableSchema class is now deprecated for a while but a lot of connectors still

[GitHub] [flink] twalthr closed pull request #17459: [FLINK-24397] Remove TableSchema usages from Flink connectors

twalthr closed pull request #17459: URL: https://github.com/apache/flink/pull/17459 -- 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 #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink-ml] guoweiM commented on a change in pull request #7: [FLINK-3][iteration] Implements the feedback mechanism and the controller operators.

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r732474603 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationRecord.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to the Apache Software

[jira] [Comment Edited] (FLINK-24477) Add MongoDB sink

[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431044#comment-17431044 ] ZhuoYu Chen edited comment on FLINK-24477 at 10/20/21, 8:11 AM:

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

slinkydeveloper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r732519455 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AbstractAvroBulkFormat.java ## @@ -0,0 +1,190 @@ +/* + *

[jira] [Commented] (FLINK-24477) Add MongoDB sink

[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431044#comment-17431044 ] ZhuoYu Chen commented on FLINK-24477: - [~fabian.paul] [~nir.tsruya] , I am very interested in

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

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink] JingGe commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

JingGe commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r732516736 ## File path: flink-formats/flink-avro/pom.xml ## @@ -26,7 +26,7 @@ under the License. org.apache.flink flink-formats

[GitHub] [flink] JingGe commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

JingGe commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r732516736 ## File path: flink-formats/flink-avro/pom.xml ## @@ -26,7 +26,7 @@ under the License. org.apache.flink flink-formats

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

[jira] [Closed] (FLINK-23271) RuntimeException: while resolving method 'booleanValue' in class class java.math.BigDecimal

[ https://issues.apache.org/jira/browse/FLINK-23271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-23271. Fix Version/s: 1.15.0 Release Note: Casting to BOOLEAN is not allowed from decimal numeric

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink] twalthr closed pull request #17439: [FLINK-23271][table-planner] Disallow cast from decimal numerics to boolean

twalthr closed pull request #17439: URL: https://github.com/apache/flink/pull/17439 -- 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] [Created] (FLINK-24600) job checkpoint page has two p99 which is duplicated

donglei created FLINK-24600: --- Summary: job checkpoint page has two p99 which is duplicated Key: FLINK-24600 URL: https://issues.apache.org/jira/browse/FLINK-24600 Project: Flink Issue Type: New

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431038#comment-17431038 ] ZhuoYu Chen commented on FLINK-24456: - Hi [~MartijnVisser] , I am very interested in this，and I want

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink] xuyangzhong commented on a change in pull request #17436: [FLINK-15987][tabel-planner]SELECT 1.0e0 / 0.0e0 throws NumberFormatException

xuyangzhong commented on a change in pull request #17436: URL: https://github.com/apache/flink/pull/17436#discussion_r732509497 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/TemporalTypesTest.scala ## @@ -1116,6

[GitHub] [flink] JingGe commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

JingGe commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r732509201 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/reader/RecordFormat.java ## @@ -0,0 +1,130 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[jira] [Updated] (FLINK-24397) Reduce TableSchema usage in Table API connectors

[ https://issues.apache.org/jira/browse/FLINK-24397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24397: Affects Version/s: (was: 1.14.0) > Reduce TableSchema usage in Table API connectors >

[jira] [Assigned] (FLINK-24599) Make checking for type root and family less verbose

[ https://issues.apache.org/jira/browse/FLINK-24599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas reassigned FLINK-24599: --- Assignee: Marios Trivyzas > Make checking for type root and family less verbose >

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17483: [FLINK-24547][Table SQL / Planner]A function named row_kind() can get…

flinkbot edited a comment on pull request #17483: URL: https://github.com/apache/flink/pull/17483#issuecomment-943310958 ## CI report: * 6a9d4e076ea0891039ee1cac272292049b1fdc3a Azure:

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

slinkydeveloper commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-947418884 > The biggest concern is that StreamFormatAdapter.Reader#readBatch stores all results in a batch in heap memory. This is bad because avro is a format which supports

[GitHub] [flink] JingGe commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

JingGe commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r732506246 ## File path: flink-formats/flink-avro/pom.xml ## @@ -26,7 +26,7 @@ under the License. org.apache.flink flink-formats

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17483: [FLINK-24547][Table SQL / Planner]A function named row_kind() can get…

flinkbot edited a comment on pull request #17483: URL: https://github.com/apache/flink/pull/17483#issuecomment-943310958 ## CI report: * 6a9d4e076ea0891039ee1cac272292049b1fdc3a Azure:

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

MonsterChenzhuo commented on a change in pull request #17508: URL: https://github.com/apache/flink/pull/17508#discussion_r732504022 ## File path: docs/data/sql_functions_zh.yml ## @@ -707,11 +707,9 @@ json: - sql: IS JSON [ { VALUE | SCALAR | ARRAY | OBJECT } ] table:

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[jira] [Created] (FLINK-24599) Make checking for type root and family less verbose

Timo Walther created FLINK-24599: Summary: Make checking for type root and family less verbose Key: FLINK-24599 URL: https://issues.apache.org/jira/browse/FLINK-24599 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

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

MonsterChenzhuo commented on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-947412864 > > > Thanks for the contribution. And I left some comments. Please let me know what do you think about . > Thank you for taking the time to correct it

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

MonsterChenzhuo commented on a change in pull request #17508: URL: https://github.com/apache/flink/pull/17508#discussion_r732498100 ## File path: docs/data/sql_functions_zh.yml ## @@ -850,16 +841,13 @@ json: - sql: JSON_OBJECT([[KEY] key VALUE value]* [ { NULL | ABSENT } ON

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[jira] [Commented] (FLINK-21200) User defined functions refuse to accept multi-set arguments without type hints

[ https://issues.apache.org/jira/browse/FLINK-21200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431027#comment-17431027 ] Timo Walther commented on FLINK-21200: -- Another incident:

[jira] [Commented] (FLINK-17321) Support for casting collection types.

[ https://issues.apache.org/jira/browse/FLINK-17321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431026#comment-17431026 ] Timo Walther commented on FLINK-17321: -- Another incident:

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

MonsterChenzhuo commented on a change in pull request #17508: URL: https://github.com/apache/flink/pull/17508#discussion_r732491168 ## File path: docs/data/sql_functions_zh.yml ## @@ -887,15 +875,11 @@ json: - sql: JSON_ARRAY([value]* [ { NULL | ABSENT } ON NULL ])

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[jira] [Created] (FLINK-24598) Current IT case do not cover fallback path for hash aggregate

Shuo Cheng created FLINK-24598: -- Summary: Current IT case do not cover fallback path for hash aggregate Key: FLINK-24598 URL: https://issues.apache.org/jira/browse/FLINK-24598 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[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_r732453723 ## File path: docs/data/sql_functions_zh.yml ## @@ -850,16 +841,13 @@ json: - sql: JSON_OBJECT([[KEY] key VALUE value]* [ { NULL | ABSENT } ON NULL

[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_r732457358 ## File path: docs/data/sql_functions_zh.yml ## @@ -887,15 +875,11 @@ json: - sql: JSON_ARRAY([value]* [ { NULL | ABSENT } ON NULL ]) table:

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[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=17431022#comment-17431022 ] jinfeng commented on FLINK-23169: - Hi [~xtsong]  1.    Putting them together doesn't seem to be a big

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

flinkbot edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-945469753 ## CI report: * 70d401d08d97bb9481281caf4aa25a1b2b30384a Azure:

[jira] [Assigned] (FLINK-24318) Casting a number to boolean has different results between 'select' fields and 'where' condition

[ https://issues.apache.org/jira/browse/FLINK-24318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-24318: -- Assignee: xuyangzhong > Casting a number to boolean has different results between 'select'

[GitHub] [flink] dawidwys commented on a change in pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

dawidwys commented on a change in pull request #17440: URL: https://github.com/apache/flink/pull/17440#discussion_r732474755 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyPartitionRequestClient.java ## @@ -195,22 +195,26 @@ public

[GitHub] [flink] dawidwys commented on a change in pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

dawidwys commented on a change in pull request #17440: URL: https://github.com/apache/flink/pull/17440#discussion_r732472566 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyPartitionRequestClient.java ## @@ -240,4 +244,57 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #17292: [FLINK-24274][docs] Wrong parameter order in documentation of State Processor API

flinkbot edited a comment on pull request #17292: URL: https://github.com/apache/flink/pull/17292#issuecomment-920217923 ## CI report: * 5cb9c76088321a3c1e367961d64980a01e031afd Azure:

[GitHub] [flink] godfreyhe closed pull request #17311: [FLINK-24318][table-planner]Casting a number to boolean has different results between 'select' fields and 'where' condition

godfreyhe closed pull request #17311: URL: https://github.com/apache/flink/pull/17311 -- 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 #17292: [FLINK-24274][docs] Wrong parameter order in documentation of State Processor API

flinkbot edited a comment on pull request #17292: URL: https://github.com/apache/flink/pull/17292#issuecomment-920217923 ## CI report: * 5cb9c76088321a3c1e367961d64980a01e031afd Azure:

[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=17431015#comment-17431015 ] liwei li commented on FLINK-24586: -- I'm interested in changing the return of JSON functions, can I have

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

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

[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

[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

[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

[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

[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

[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

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

[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

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

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

[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=17430999#comment-17430999 ] Fabian Paul commented on FLINK-24596: - I can take it. > Bugs in sink.buffer-flush before

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

[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=17430987#comment-17430987 ] Yun Tang commented on FLINK-24546: -- [~Alston Williams], thanks for your enthusiasm! As I wrote in

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

<    1   2   3   4