[jira] [Commented] (FLINK-23062) FLIP-129: Register sources/sinks in Table API

2021-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431431#comment-17431431 ] Martijn Visser commented on FLINK-23062: [~airblader] Should this ticket be closed? >

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-20 Thread GitBox
flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * d45a1f76630a03ec6a0efd3d38044ab925ab7533 Azure:

[jira] [Assigned] (FLINK-24331) PartiallyFinishedSourcesITCase fails with "No downstream received 0 from xxx;"

2021-10-20 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-24331: - Assignee: Anton Kalashnikov > PartiallyFinishedSourcesITCase fails with "No

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-20 Thread GitBox
flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 3d03869b64cad0b1051bd0c07427a5a158320668 Azure:

[jira] [Commented] (FLINK-20578) Cannot create empty array using ARRAY[]

2021-10-20 Thread Saad Ur Rahman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431414#comment-17431414 ] Saad Ur Rahman commented on FLINK-20578: Hello, I would like to try and resolve this issue. I am

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

[GitHub] [flink] twalthr closed pull request #17530: [FLINK-24604] Remove tests which use decimal -> boolean cast

2021-10-20 Thread GitBox
twalthr closed pull request #17530: URL: https://github.com/apache/flink/pull/17530 -- 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] [Closed] (FLINK-24604) Failing tests for casting decimals to boolean

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17529: [FLINK-24563][table-planner] Fix NullPointerException when comparing timestamp_ltz with random string

2021-10-20 Thread GitBox
flinkbot edited a comment on pull request #17529: URL: https://github.com/apache/flink/pull/17529#issuecomment-947630768 ## CI report: * f1a2a94b889d9645505ec351d434c0c9b7e095f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-20 Thread GitBox
flinkbot edited a comment on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-926627700 ## CI report: * 3d03869b64cad0b1051bd0c07427a5a158320668 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17518: [FLINK-24018][build] Remove Scala dependencies from Java APIs

2021-10-20 Thread GitBox
flinkbot edited a comment on pull request #17518: URL: https://github.com/apache/flink/pull/17518#issuecomment-946526433 ## CI report: * a177b8b7a724a0de1c4f76326c55753eabcc417b Azure:

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

2021-10-20 Thread GitBox
RocMarshal commented on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-948196371 @MonsterChenzhuo Maybe you should rebase from latest master branch for your branch and resolve the conflicting file before next review . -- This is an automated message

[GitHub] [flink] cshuo opened a new pull request #17531: [FLINK-24598][table-runtime] Fix test problem that the current IT cas…

2021-10-20 Thread GitBox
cshuo opened a new pull request #17531: URL: https://github.com/apache/flink/pull/17531 …e do not cover fallback path for hash aggregate ## What is the purpose of the change Test data in AggregateITCaseBase#testBigData is not big enough to trigger hash agg to sort and

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

2021-10-20 Thread GitBox
RocMarshal edited a comment on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-948196371 @MonsterChenzhuo Thanks for the update. Maybe you should rebase from latest master branch for your branch and resolve the conflicting file before next review . --

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

2021-10-20 Thread vmaster.cc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432172#comment-17432172 ] vmaster.cc commented on FLINK-24539: [~pnowojski] Thank you very much, i have subscribed the user

[GitHub] [flink] flinkbot edited a comment on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-10-20 Thread GitBox
flinkbot edited a comment on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-948251540 ## CI report: * dd8d7b161f71cef2099c746f4e54cb62d4b881dd Azure:

[jira] [Created] (FLINK-24605) org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined offset with no reset policy for partitions

2021-10-20 Thread Abhijit Talukdar (Jira)
Abhijit Talukdar created FLINK-24605: Summary: org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined offset with no reset policy for partitions Key: FLINK-24605

[jira] [Updated] (FLINK-23997) Improvement for SQL windowing table-valued function

2021-10-20 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-23997: --- Fix Version/s: 1.15.0 > Improvement for SQL windowing table-valued function >

[GitHub] [flink] flinkbot commented on pull request #17531: [FLINK-24598][table-runtime] Fix test problem that the current IT cas…

2021-10-20 Thread GitBox
flinkbot commented on pull request #17531: URL: https://github.com/apache/flink/pull/17531#issuecomment-948196975 ## CI report: * 4de4de84a971dbba3b6701922d083359a732b4f2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2021-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24598: --- Labels: pull-request-available (was: ) > Current IT case do not cover fallback path for

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

2021-10-20 Thread vmaster.cc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432171#comment-17432171 ] vmaster.cc commented on FLINK-24539: [~twalthr] Yeah, there is no partitioned, because the source

[GitHub] [flink] flinkbot edited a comment on pull request #17436: [FLINK-15987][tabel-planner]SELECT 1.0e0 / 0.0e0 throws NumberFormatException

2021-10-20 Thread GitBox
flinkbot edited a comment on pull request #17436: URL: https://github.com/apache/flink/pull/17436#issuecomment-938641830 ## CI report: * 8e7cadf33f0414a07b1496cabe0c8d7088f870c2 Azure:

[GitHub] [flink] godfreyhe commented on a change in pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

2021-10-20 Thread GitBox
godfreyhe commented on a change in pull request #17344: URL: https://github.com/apache/flink/pull/17344#discussion_r732918626 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -867,27

[jira] [Created] (FLINK-24606) AvroDeserializationSchema buffer is not clean

2021-10-20 Thread heyu dou (Jira)
heyu dou created FLINK-24606: Summary: AvroDeserializationSchema buffer is not clean Key: FLINK-24606 URL: https://issues.apache.org/jira/browse/FLINK-24606 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24501) Unexpected behavior of cumulate window aggregate for late event after recover from sp/cp

2021-10-20 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432190#comment-17432190 ] Wenlong Lyu commented on FLINK-24501: - I think it may be better to make sure that watermark would

[GitHub] [flink] TanYuxin-tyx opened a new pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-10-20 Thread GitBox
TanYuxin-tyx opened a new pull request #17532: URL: https://github.com/apache/flink/pull/17532 ## What is the purpose of the change Fix port conflict in `ServerTransportErrorHandlingTest#testRemoteClose`. In the test case, a `BindException` may be thrown when init

[GitHub] [flink] flinkbot commented on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

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

[jira] [Updated] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

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

[GitHub] [flink] godfreyhe commented on a change in pull request #17344: [FLINK-20895] [flink-table-planner] support local aggregate push down in table planner

2021-10-20 Thread GitBox
godfreyhe commented on a change in pull request #17344: URL: https://github.com/apache/flink/pull/17344#discussion_r732920524 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java ## @@ -867,27

[GitHub] [flink] flinkbot commented on pull request #17531: [FLINK-24598][table-runtime] Fix test problem that the current IT cas…

2021-10-20 Thread GitBox
flinkbot commented on pull request #17531: URL: https://github.com/apache/flink/pull/17531#issuecomment-948198035 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] [Commented] (FLINK-21068) Add new timeout options for Elasticsearch connector

2021-10-20 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432192#comment-17432192 ] Yangze Guo commented on FLINK-21068: I think it is a valid improvement. However, it seems the

[jira] [Commented] (FLINK-22096) ServerTransportErrorHandlingTest.testRemoteClose fail

2021-10-20 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432202#comment-17432202 ] Yuxin Tan commented on FLINK-22096: --- In the test case, a `{{BindException`}} may be thrown when

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

2021-10-20 Thread GitBox
tsreaper commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948202218 @JingGe > For point 1, the uncompressed data size should be controlled by `StreamFormat.FETCH_IO_SIZE`. It might not be very precise to control the heap size, since

[GitHub] [flink] fsk119 commented on pull request #14444: [FLINK-20091][avro] add ignore-parse-error for avro formats

2021-10-20 Thread GitBox
fsk119 commented on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-948210311 I am recently busy working in the inner branch. I think I have no time to finish this PR -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] RocMarshal commented on pull request #17352: [FLINK-10230][table] Support 'SHOW CREATE VIEW' syntax to print the query of a view

2021-10-20 Thread GitBox
RocMarshal commented on pull request #17352: URL: https://github.com/apache/flink/pull/17352#issuecomment-948195266 @wuchong I really appreciate it. I make some change based on your suggestions. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #17436: [FLINK-15987][tabel-planner]SELECT 1.0e0 / 0.0e0 throws NumberFormatException

2021-10-20 Thread GitBox
flinkbot edited a comment on pull request #17436: URL: https://github.com/apache/flink/pull/17436#issuecomment-938641830 ## CI report: * 8e7cadf33f0414a07b1496cabe0c8d7088f870c2 Azure:

[jira] [Updated] (FLINK-24606) AvroDeserializationSchema buffer is not clean

2021-10-20 Thread heyu dou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] heyu dou updated FLINK-24606: - Description:  org.apache.flink.formats.avro.AvroDeserializationSchema Decoder want reuse 

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

2021-10-20 Thread GitBox
tsreaper edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-948202218 @JingGe > For point 1, the uncompressed data size should be controlled by `StreamFormat.FETCH_IO_SIZE`. It might not be very precise to control the heap size,

[jira] [Created] (FLINK-24607) SourceCoordinator may miss to close SplitEnumerator when failover frequently

2021-10-20 Thread Jark Wu (Jira)
Jark Wu created FLINK-24607: --- Summary: SourceCoordinator may miss to close SplitEnumerator when failover frequently Key: FLINK-24607 URL: https://issues.apache.org/jira/browse/FLINK-24607 Project: Flink

[jira] [Closed] (FLINK-23062) FLIP-129: Register sources/sinks in Table API

2021-10-20 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk closed FLINK-23062. - Fix Version/s: 1.14.0 Resolution: Fixed > FLIP-129: Register sources/sinks in Table API >

[jira] [Commented] (FLINK-23062) FLIP-129: Register sources/sinks in Table API

2021-10-20 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432204#comment-17432204 ] Ingo Bürk commented on FLINK-23062: --- Yes, sorry. Will close it and move the FLIP. > FLIP-129:

[GitHub] [flink] flinkbot edited a comment on pull request #17531: [FLINK-24598][table-runtime] Fix test problem that the current IT cas…

2021-10-20 Thread GitBox
flinkbot edited a comment on pull request #17531: URL: https://github.com/apache/flink/pull/17531#issuecomment-948196975 ## CI report: * 4de4de84a971dbba3b6701922d083359a732b4f2 Azure:

[jira] [Commented] (FLINK-24072) Add support for setting default headers in elasticsearch connector

2021-10-20 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432186#comment-17432186 ] Yangze Guo commented on FLINK-24072: [~hackergin] I'm not an expert on Elasticsearch. May I ask two

[GitHub] [flink] flinkbot commented on pull request #17532: [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose

2021-10-20 Thread GitBox
flinkbot commented on pull request #17532: URL: https://github.com/apache/flink/pull/17532#issuecomment-948252161 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #17531: [FLINK-24598][table-runtime] Fix test problem that the current IT cas…

2021-10-20 Thread GitBox
flinkbot edited a comment on pull request #17531: URL: https://github.com/apache/flink/pull/17531#issuecomment-948196975 ## CI report: * 4de4de84a971dbba3b6701922d083359a732b4f2 Azure:

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

2021-10-20 Thread Yue Ma (Jira)
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] RocMarshal commented on a change in pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2021-10-20 Thread GitBox
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 }

[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

2021-10-20 Thread GitBox
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

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

2021-10-20 Thread GitBox
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] RocMarshal commented on a change in pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2021-10-20 Thread GitBox
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] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2021-10-20 Thread GitBox
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 a change in pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2021-10-20 Thread GitBox
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] JingGe commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-10-20 Thread GitBox
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] twalthr closed pull request #17459: [FLINK-24397] Remove TableSchema usages from Flink connectors

2021-10-20 Thread GitBox
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] RocMarshal commented on a change in pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

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

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

2021-10-20 Thread GitBox
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:

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

2021-10-20 Thread Dawid Wysakowicz (Jira)
[ 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

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

2021-10-20 Thread ASF GitHub Bot (Jira)
[ 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] dawidwys commented on a change in pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

2021-10-20 Thread GitBox
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] dawidwys commented on a change in pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

2021-10-20 Thread GitBox
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] flinkbot edited a comment on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2021-10-20 Thread GitBox
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

2021-10-20 Thread GitBox
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] MonsterChenzhuo commented on a change in pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2021-10-20 Thread GitBox
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 ])

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

2021-10-20 Thread Timo Walther (Jira)
[ 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:

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

2021-10-20 Thread Timo Walther (Jira)
[ 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:

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

2021-10-20 Thread GitBox
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

2021-10-20 Thread Fabian Paul (Jira)
[ 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 >

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

2021-10-20 Thread GitBox
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] slinkydeveloper commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-20 Thread GitBox
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] [Comment Edited] (FLINK-24477) Add MongoDB sink

2021-10-20 Thread ZhuoYu Chen (Jira)
[ 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:

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

2021-10-20 Thread ZhuoYu Chen (Jira)
[ 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 #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2021-10-20 Thread GitBox
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 #17523: [FLINK-21407] Update formats in connectors doc for Flink 1.13 for DataSet and DataStream APIs

2021-10-20 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] slinkydeveloper commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

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

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

2021-10-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24397. Fix Version/s: 1.15.0 Release Note: The old JDBC connector (indicated by

[jira] [Commented] (FLINK-24577) Support cast from BINARY/VARBINARY/BYTES to of RAW()

2021-10-20 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17431047#comment-17431047 ] liwei li commented on FLINK-24577: -- Create a position-based RAW with the length of 1 and the field type

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

2021-10-20 Thread GitBox
RocMarshal commented on a change in pull request #17508: URL: https://github.com/apache/flink/pull/17508#discussion_r732452207 ## File path: docs/data/sql_functions_zh.yml ## @@ -799,22 +792,20 @@ json: DEFAULT FALSE ON ERROR) -- 0.998D -

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

2021-10-20 Thread Yun Tang (Jira)
[ 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] [Assigned] (FLINK-24596) Bugs in sink.buffer-flush before upsert-kafka

2021-10-20 Thread Fabian Paul (Jira)
[ 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] [Commented] (FLINK-24596) Bugs in sink.buffer-flush before upsert-kafka

2021-10-20 Thread Fabian Paul (Jira)
[ 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

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

2021-10-20 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] mayuehappy opened a new pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-10-20 Thread GitBox
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

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

2021-10-20 Thread GitBox
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

2021-10-20 Thread GitBox
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

2021-10-20 Thread godfrey he (Jira)
[ 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'

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

2021-10-20 Thread jinfeng (Jira)
[ 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

2021-10-20 Thread GitBox
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-24599) Make checking for type root and family less verbose

2021-10-20 Thread Marios Trivyzas (Jira)
[ 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] slinkydeveloper commented on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-10-20 Thread GitBox
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] flinkbot edited a comment on pull request #17483: [FLINK-24547][Table SQL / Planner]A function named row_kind() can get…

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

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

2021-10-20 Thread GitBox
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

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

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

2021-10-20 Thread Timo Walther (Jira)
[ 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] JingGe commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-10-20 Thread GitBox
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

2021-10-20 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 #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

2021-10-20 Thread GitBox
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

2021-10-20 Thread GitBox
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

2021-10-20 Thread Timo Walther (Jira)
[ 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

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

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

  1   2   3   4   >