[GitHub] [flink] flinkbot edited a comment on pull request #13158: [hotfix] [docs] Fix typo in checkpoint monitoring doc

flinkbot edited a comment on pull request #13158: URL: https://github.com/apache/flink/pull/13158#issuecomment-674472407 ## CI report: * 6117c8b294a5fb0df0ec7fa5e95377890a650754 UNKNOWN * e29749fef5d6062e2a9290890d5863ef73265347 Azure:

[jira] [Updated] (FLINK-18967) Upgrade ORC to 1.5.10 version

[ https://issues.apache.org/jira/browse/FLINK-18967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Dvorzhak updated FLINK-18967: -- Attachment: FLINK-18967.patch > Upgrade ORC to 1.5.10 version > -

[GitHub] [flink] flinkbot edited a comment on pull request #13159: [hotfix] [docs] Fix typo for multiple doc files

flinkbot edited a comment on pull request #13159: URL: https://github.com/apache/flink/pull/13159#issuecomment-674476706 ## CI report: * 1f2668e77f7c46e7e7b5f70a2944f37e27f4d038 Azure:

[GitHub] [flink] flinkbot commented on pull request #13159: [hotfix] [docs] Fix typo for multiple doc files

flinkbot commented on pull request #13159: URL: https://github.com/apache/flink/pull/13159#issuecomment-674476706 ## CI report: * 1f2668e77f7c46e7e7b5f70a2944f37e27f4d038 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-18967) Upgrade ORC to 1.5.10 version

Igor Dvorzhak created FLINK-18967: - Summary: Upgrade ORC to 1.5.10 version Key: FLINK-18967 URL: https://issues.apache.org/jira/browse/FLINK-18967 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-12532) Upgrade Avro to version 1.9.2

[ https://issues.apache.org/jira/browse/FLINK-12532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Dvorzhak updated FLINK-12532: -- Attachment: FLINK-18892.patch > Upgrade Avro to version 1.9.2 > -

[jira] [Updated] (FLINK-12532) Upgrade Avro to version 1.9.2

[ https://issues.apache.org/jira/browse/FLINK-12532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Dvorzhak updated FLINK-12532: -- Attachment: FLINK-12532.patch > Upgrade Avro to version 1.9.2 > -

[jira] [Updated] (FLINK-12532) Upgrade Avro to version 1.9.2

[ https://issues.apache.org/jira/browse/FLINK-12532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igor Dvorzhak updated FLINK-12532: -- Attachment: (was: FLINK-18892.patch) > Upgrade Avro to version 1.9.2 >

[GitHub] [flink] flinkbot commented on pull request #13159: [hotfix] [docs] Fix typo for multiple doc files

flinkbot commented on pull request #13159: URL: https://github.com/apache/flink/pull/13159#issuecomment-674475693 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] brandonJY opened a new pull request #13159: [hotfix] [docs] Fix typo for multiple doc files

brandonJY opened a new pull request #13159: URL: https://github.com/apache/flink/pull/13159 Fix typo for multiple doc files This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #13158: [hotfix] [docs] Fix typo in checkpoint monitoring doc

flinkbot edited a comment on pull request #13158: URL: https://github.com/apache/flink/pull/13158#issuecomment-674472407 ## CI report: * 6117c8b294a5fb0df0ec7fa5e95377890a650754 UNKNOWN * e29749fef5d6062e2a9290890d5863ef73265347 Azure:

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178414#comment-17178414 ] Liu commented on FLINK-18959: - Thank you, [~trohrmann]. I have the same confusion with you. In previous

[GitHub] [flink] flinkbot edited a comment on pull request #13158: [hotfix] [docs] Fix typo in checkpoint monitoring doc

flinkbot edited a comment on pull request #13158: URL: https://github.com/apache/flink/pull/13158#issuecomment-674472407 ## CI report: * 6117c8b294a5fb0df0ec7fa5e95377890a650754 UNKNOWN * e29749fef5d6062e2a9290890d5863ef73265347 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot commented on pull request #13158: [hotfix] [docs] Fix typo in checkpoint monitoring doc

flinkbot commented on pull request #13158: URL: https://github.com/apache/flink/pull/13158#issuecomment-674472407 ## CI report: * 6117c8b294a5fb0df0ec7fa5e95377890a650754 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13158: [hotfix] [docs] Fix typo in checkpoint monitoring doc

flinkbot commented on pull request #13158: URL: https://github.com/apache/flink/pull/13158#issuecomment-674470723 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] brandonJY opened a new pull request #13158: [hotfix] [docs] Fix typo in checkpoint monitoring doc

brandonJY opened a new pull request #13158: URL: https://github.com/apache/flink/pull/13158 fix typo in checkpoint_monitoring doc This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #13157: [FLINK-18900][hive] HiveCatalog should error out when listing partitions with an invalid spec

flinkbot edited a comment on pull request #13157: URL: https://github.com/apache/flink/pull/13157#issuecomment-674410767 ## CI report: * b64a33a3e57e4af2522aeaf274c4711ddb2b00ef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13156: [FLINK-18949][python] Support Streaming File Sink for Python DataStream API

flinkbot edited a comment on pull request #13156: URL: https://github.com/apache/flink/pull/13156#issuecomment-674396240 ## CI report: * 2ee1d96a5033c05e21ddd43004784e63a3fd8c61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13157: [FLINK-18900][hive] HiveCatalog should error out when listing partitions with an invalid spec

flinkbot edited a comment on pull request #13157: URL: https://github.com/apache/flink/pull/13157#issuecomment-674410767 ## CI report: * b64a33a3e57e4af2522aeaf274c4711ddb2b00ef Azure:

[GitHub] [flink] flinkbot commented on pull request #13157: [FLINK-18900][hive] HiveCatalog should error out when listing partitions with an invalid spec

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

[GitHub] [flink] flinkbot commented on pull request #13157: [FLINK-18900][hive] HiveCatalog should error out when listing partitions with an invalid spec

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

[jira] [Updated] (FLINK-18900) HiveCatalog should error out when listing partitions with an invalid spec

[ https://issues.apache.org/jira/browse/FLINK-18900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18900: --- Labels: pull-request-available (was: ) > HiveCatalog should error out when listing

[GitHub] [flink] SteNicholas opened a new pull request #13157: [FLINK-18900][hive] HiveCatalog should error out when listing partitions with an invalid spec

SteNicholas opened a new pull request #13157: URL: https://github.com/apache/flink/pull/13157 ## What is the purpose of the change *Currently `HiveCatalog` could return all partitions of table for `SHOW PARTITIONS` with an invalid spec, which is wrong. `HiveCatalog` should error

[GitHub] [flink] hequn8128 commented on a change in pull request #13155: [FLINK-18947][python] Support partitionCustom() operation for Python …

hequn8128 commented on a change in pull request #13155: URL: https://github.com/apache/flink/pull/13155#discussion_r470989005 ## File path: flink-python/pyflink/datastream/data_stream.py ## @@ -434,6 +434,60 @@ def broadcast(self) -> 'DataStream': """ return

[GitHub] [flink] flinkbot edited a comment on pull request #13154: [FLINK-18704][table] Add DECIMAL type in datagen

flinkbot edited a comment on pull request #13154: URL: https://github.com/apache/flink/pull/13154#issuecomment-674377845 ## CI report: * d8819ee8585dde4ef1da684d8e31f02b964ce6c0 Azure:

[GitHub] [flink] RocMarshal edited a comment on pull request #13059: [hotfix][docs] Update the links' tags in the 'Debugging Windows & Event Time' page of 'Debugging & Monitoring'

RocMarshal edited a comment on pull request #13059: URL: https://github.com/apache/flink/pull/13059#issuecomment-67197 Hi, @rmetzger @alpinegizmo I made a hotfix. Please take a look. Thank you. This is an

[GitHub] [flink] flinkbot edited a comment on pull request #13156: [FLINK-18949][python] Support Streaming File Sink for Python DataStream API

flinkbot edited a comment on pull request #13156: URL: https://github.com/apache/flink/pull/13156#issuecomment-674396240 ## CI report: * 2ee1d96a5033c05e21ddd43004784e63a3fd8c61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13155: [FLINK-18947][python] Support partitionCustom() operation for Python …

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

[GitHub] [flink] flinkbot commented on pull request #13156: [FLINK-18949][python] Support Streaming File Sink for Python DataStream API

flinkbot commented on pull request #13156: URL: https://github.com/apache/flink/pull/13156#issuecomment-674396240 ## CI report: * 2ee1d96a5033c05e21ddd43004784e63a3fd8c61 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13156: [FLINK-18949][python] Support Streaming File Sink for Python DataStream API

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

[jira] [Updated] (FLINK-18949) Support Streaming File Sink for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18949: --- Labels: pull-request-available (was: ) > Support Streaming File Sink for Python DataStream

[GitHub] [flink] hequn8128 opened a new pull request #13156: [FLINK-18949][python] Support Streaming File Sink for Python DataStream API

hequn8128 opened a new pull request #13156: URL: https://github.com/apache/flink/pull/13156 ## What is the purpose of the change This pull request supports StreamingFileSink on Python DataStream API. Row-encoded Formats is only supported in this PR, i.e., Bulk-encoded Formats are

[GitHub] [flink] flinkbot edited a comment on pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

flinkbot edited a comment on pull request #13152: URL: https://github.com/apache/flink/pull/13152#issuecomment-674356260 ## CI report: * fb27e2e5684c59966cc505fbdc7969017ee067c9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13153: [FLINK-18966][python] Support key_by() on ConnectedStreams for Python DataStream API

flinkbot edited a comment on pull request #13153: URL: https://github.com/apache/flink/pull/13153#issuecomment-674367157 ## CI report: * f59963fa5ee56152ca93de32ed73e7fc67eb4250 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13154: [FLINK-18704][table] Add DECIMAL type in datagen

flinkbot edited a comment on pull request #13154: URL: https://github.com/apache/flink/pull/13154#issuecomment-674377845 ## CI report: * d8819ee8585dde4ef1da684d8e31f02b964ce6c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13155: [FLINK-18947][python] Support partitionCustom() operation for Python …

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

[GitHub] [flink] flinkbot commented on pull request #13154: [FLINK-18704][table] Add DECIMAL type in datagen

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

[GitHub] [flink] flinkbot commented on pull request #13155: [FLINK-18947][python] Support partitionCustom() operation for Python …

flinkbot commented on pull request #13155: URL: https://github.com/apache/flink/pull/13155#issuecomment-674377857 ## CI report: * 70aeee4d216b47fe0f118abec2758f0a7f6a1260 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13155: [FLINK-18947][python] Support partitionCustom() operation for Python …

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

[jira] [Updated] (FLINK-18947) Support partitionCustom() operation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18947: --- Labels: pull-request-available (was: ) > Support partitionCustom() operation for Python

[GitHub] [flink] shuiqiangchen opened a new pull request #13155: [FLINK-18947][python] Support partitionCustom() operation for Python …

shuiqiangchen opened a new pull request #13155: URL: https://github.com/apache/flink/pull/13155 ## What is the purpose of the change Add partition_custom() operation for Python DataStream API, so that users can specify custom partitioning. ## Brief change log

[GitHub] [flink] flinkbot commented on pull request #13154: [FLINK-18704][table] Add DECIMAL type in datagen

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

[jira] [Updated] (FLINK-18704) Support DECIMAL types in datagen Table source connector

[ https://issues.apache.org/jira/browse/FLINK-18704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18704: --- Labels: pull-request-available starter (was: starter) > Support DECIMAL types in datagen

[GitHub] [flink] genged opened a new pull request #13154: [FLINK-18704][table] Add DECIMAL type in datagen

genged opened a new pull request #13154: URL: https://github.com/apache/flink/pull/13154 ## What is the purpose of the change This pull request adds DECIMAL type (using BigDecimal) to the datagen Table source connector. ## Brief change log - Added decimalGenerator

[GitHub] [flink] flinkbot edited a comment on pull request #13151: [FLINK-18943][python] Support CoMapFunction for Python DataStream API

flinkbot edited a comment on pull request #13151: URL: https://github.com/apache/flink/pull/13151#issuecomment-674350152 ## CI report: * 85ded7435e39bff6e7a54aa59b6314df8787bc91 Azure:

[jira] [Closed] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink

[ https://issues.apache.org/jira/browse/FLINK-18879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18879. --- Resolution: Resolved > Support Row Serialization and Deserialization schemas for DataStream >

[jira] [Commented] (FLINK-18879) Support Row Serialization and Deserialization schemas for DataStream source/sink

[ https://issues.apache.org/jira/browse/FLINK-18879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178190#comment-17178190 ] Hequn Cheng commented on FLINK-18879: - Resolve in 1.12.0 via 

[GitHub] [flink] hequn8128 merged pull request #13150: [FLINK-18879][python] Support Row Serialization and Deserialization s…

hequn8128 merged pull request #13150: URL: https://github.com/apache/flink/pull/13150 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

[GitHub] [flink] flinkbot edited a comment on pull request #13153: [FLINK-18966][python] Support key_by() on ConnectedStreams for Python DataStream API

flinkbot edited a comment on pull request #13153: URL: https://github.com/apache/flink/pull/13153#issuecomment-674367157 ## CI report: * f59963fa5ee56152ca93de32ed73e7fc67eb4250 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

flinkbot edited a comment on pull request #13152: URL: https://github.com/apache/flink/pull/13152#issuecomment-674356260 ## CI report: * 1cc4bd5d29d7933c190df7d7476ff318c0dab7ee Azure:

[GitHub] [flink] flinkbot commented on pull request #13153: [FLINK-18966][python] Support key_by() on ConnectedStreams for Python DataStream API

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

[GitHub] [flink] flinkbot edited a comment on pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

flinkbot edited a comment on pull request #13152: URL: https://github.com/apache/flink/pull/13152#issuecomment-674356260 ## CI report: * 1cc4bd5d29d7933c190df7d7476ff318c0dab7ee Azure:

[GitHub] [flink] flinkbot commented on pull request #13153: [FLINK-18966][python] Support key_by() on ConnectedStreams for Python DataStream API

flinkbot commented on pull request #13153: URL: https://github.com/apache/flink/pull/13153#issuecomment-674365357 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] hequn8128 commented on pull request #13153: [FLINK-18966][python] Support key_by() on ConnectedStreams for Python DataStream API

hequn8128 commented on pull request #13153: URL: https://github.com/apache/flink/pull/13153#issuecomment-674364816 CC @shuiqiangchen This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-18966) Support key_by() on ConnectedStreams for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18966: --- Labels: pull-request-available (was: ) > Support key_by() on ConnectedStreams for Python

[GitHub] [flink] hequn8128 opened a new pull request #13153: [FLINK-18966][python] Support key_by() on ConnectedStreams for Python DataStream API

hequn8128 opened a new pull request #13153: URL: https://github.com/apache/flink/pull/13153 ## What is the purpose of the change This pull request supports key_by on Python `ConnectedStreams`. ## Brief change log - Add key_by on Python `ConnectedStreams`. -

[GitHub] [flink] flinkbot edited a comment on pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

flinkbot edited a comment on pull request #13152: URL: https://github.com/apache/flink/pull/13152#issuecomment-674356260 ## CI report: * 1cc4bd5d29d7933c190df7d7476ff318c0dab7ee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

flinkbot edited a comment on pull request #13152: URL: https://github.com/apache/flink/pull/13152#issuecomment-674356260 ## CI report: * 1cc4bd5d29d7933c190df7d7476ff318c0dab7ee Azure:

[GitHub] [flink] flinkbot commented on pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

flinkbot commented on pull request #13152: URL: https://github.com/apache/flink/pull/13152#issuecomment-674356260 ## CI report: * 1cc4bd5d29d7933c190df7d7476ff318c0dab7ee UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

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

[jira] [Updated] (FLINK-18945) Support CoFlatMap for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18945: --- Labels: pull-request-available (was: ) > Support CoFlatMap for Python DataStream API >

[GitHub] [flink] hequn8128 opened a new pull request #13152: [FLINK-18945][python] Support CoFlatMap for Python DataStream API

hequn8128 opened a new pull request #13152: URL: https://github.com/apache/flink/pull/13152 ## What is the purpose of the change This pull request adds CoFlatMapFunction for Python DataStream API. ## Brief change log - Add CoFlatMapFunction on DataStream.