[GitHub] [flink] flinkbot edited a comment on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * a4a62da3ce0c44afc17969e7e58c73ce227b4358 Azure:

[jira] [Created] (FLINK-19402) Metrics for measuring Flink application deployment latency in Yarn

Yu Yang created FLINK-19402: --- Summary: Metrics for measuring Flink application deployment latency in Yarn Key: FLINK-19402 URL: https://issues.apache.org/jira/browse/FLINK-19402 Project: Flink

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r494507396 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.java ## @@ -0,0 +1,263 @@

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r494509194 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.java ## @@ -0,0 +1,263 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13443: [FLINK-19288] Make the InternalTimeServiceManager an interface

flinkbot edited a comment on pull request #13443: URL: https://github.com/apache/flink/pull/13443#issuecomment-696209532 ## CI report: * 72af10d2bbb3a27c5e737401d217d5b4d5b0b4da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 4a195c669087c56b55b9b43b32e6b6dd7e8bab9a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13471: [FLINK-19124][datastream] Some JobClient methods are not ergonomic, require ClassLoader argument

flinkbot edited a comment on pull request #13471: URL: https://github.com/apache/flink/pull/13471#issuecomment-698161948 ## CI report: * c7a539b5582c927dce191b8f937db1912abcb449 Azure:

[jira] [Commented] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201831#comment-17201831 ] Dian Fu commented on FLINK-19388: - Another instance:

[jira] [Commented] (FLINK-19389) Error determining python major version to start fileserver during e-2-e tests

[ https://issues.apache.org/jira/browse/FLINK-19389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201868#comment-17201868 ] Di Xu commented on FLINK-19389: --- [~fly_in_gis] would you mind help to confirm and assign it to me? >

[GitHub] [flink] flinkbot edited a comment on pull request #13475: [FLINK-19372][python] Support Pandas Batch Over Window Aggregation

flinkbot edited a comment on pull request #13475: URL: https://github.com/apache/flink/pull/13475#issuecomment-698240452 ## CI report: * e1098322eb0d29b6bd1cf47bbafdfe179c948e7a Azure:

[GitHub] [flink] flinkbot commented on pull request #13477: [FLINK-19406][table-planner-blink] Casting row time to timestamp lose…

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

[jira] [Assigned] (FLINK-19403) Support Pandas Stream Group Window Aggregation

[ https://issues.apache.org/jira/browse/FLINK-19403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19403: --- Assignee: Huang Xingbo > Support Pandas Stream Group Window Aggregation >

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

flinkbot edited a comment on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354 ## CI report: * 28d25983818d7805f6708b36125a65a493d03aa9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF.

flinkbot edited a comment on pull request #13462: URL: https://github.com/apache/flink/pull/13462#issuecomment-697272556 ## CI report: * f043157df80e534f25f07f8346c902b0032fca26 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

flinkbot edited a comment on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354 ## CI report: * 28d25983818d7805f6708b36125a65a493d03aa9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13419: [FLINK-18842][e2e] Added 10min timeout to building the container.

flinkbot edited a comment on pull request #13419: URL: https://github.com/apache/flink/pull/13419#issuecomment-694745717 ## CI report: * bf0418c1332c5371f14820d80af9ceea7507bedc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

flinkbot edited a comment on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836 ## CI report: * 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN * ef7c9791b678f3cc6b524a3d5d0b7b9f0f0402f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13471: [FLINK-19124][datastream] Some JobClient methods are not ergonomic, require ClassLoader argument

flinkbot edited a comment on pull request #13471: URL: https://github.com/apache/flink/pull/13471#issuecomment-698161948 ## CI report: * c7a539b5582c927dce191b8f937db1912abcb449 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

flinkbot edited a comment on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836 ## CI report: * 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN * 62fcbeb58996533fa63df6f83e35efb34898e811 Azure:

[jira] [Updated] (FLINK-19398) Hive connector fails with IllegalAccessError if submitted as usercode

[ https://issues.apache.org/jira/browse/FLINK-19398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19398: - Priority: Critical (was: Major) > Hive connector fails with IllegalAccessError if submitted as

[jira] [Updated] (FLINK-19398) Hive connector fails with IllegalAccessError if submitted as usercode

[ https://issues.apache.org/jira/browse/FLINK-19398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19398: - Fix Version/s: 1.11.3 > Hive connector fails with IllegalAccessError if submitted as usercode >

[jira] [Closed] (FLINK-19323) Small optimization of network layer record serialization

[ https://issues.apache.org/jira/browse/FLINK-19323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-19323. --- Resolution: Fixed > Small optimization of network layer record serialization >

[jira] [Closed] (FLINK-19320) Remove RecordWriter#clearBuffers

[ https://issues.apache.org/jira/browse/FLINK-19320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-19320. --- Resolution: Fixed > Remove RecordWriter#clearBuffers > > >

[jira] [Closed] (FLINK-19312) Introduce BufferWritingResultPartition which wraps the logic of writing buffers to ResultSubpartition

[ https://issues.apache.org/jira/browse/FLINK-19312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-19312. --- Resolution: Fixed > Introduce BufferWritingResultPartition which wraps the logic of writing >

[jira] [Closed] (FLINK-19302) Flushing of BoundedBlockingResultPartition should finish current BufferBuilder

[ https://issues.apache.org/jira/browse/FLINK-19302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-19302. --- Resolution: Fixed > Flushing of BoundedBlockingResultPartition should finish current BufferBuilder

[jira] [Commented] (FLINK-19320) Remove RecordWriter#clearBuffers

[ https://issues.apache.org/jira/browse/FLINK-19320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201858#comment-17201858 ] Yingjie Cao commented on FLINK-19320: - Merged into master via 

[jira] [Commented] (FLINK-19323) Small optimization of network layer record serialization

[ https://issues.apache.org/jira/browse/FLINK-19323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201859#comment-17201859 ] Yingjie Cao commented on FLINK-19323: - Merged into master via 

[jira] [Commented] (FLINK-19297) Make ResultPartitionWriter record-oriented

[ https://issues.apache.org/jira/browse/FLINK-19297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201853#comment-17201853 ] Yingjie Cao commented on FLINK-19297: - Merged into master via 

[jira] [Commented] (FLINK-19302) Flushing of BoundedBlockingResultPartition should finish current BufferBuilder

[ https://issues.apache.org/jira/browse/FLINK-19302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201854#comment-17201854 ] Yingjie Cao commented on FLINK-19302: - Merged into master via 

[jira] [Commented] (FLINK-19312) Introduce BufferWritingResultPartition which wraps the logic of writing buffers to ResultSubpartition

[ https://issues.apache.org/jira/browse/FLINK-19312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201856#comment-17201856 ] Yingjie Cao commented on FLINK-19312: - Merged into master via 

[jira] [Commented] (FLINK-19405) Translate "DataSet Connectors" page of "Connectors" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201879#comment-17201879 ] Jark Wu commented on FLINK-19405: - DataSet is going to be removed in the future. I would suggest to put

[GitHub] [flink] WeiZhong94 commented on a change in pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python

WeiZhong94 commented on a change in pull request #13462: URL: https://github.com/apache/flink/pull/13462#discussion_r494722379 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ArrowUtils.java ## @@ -749,7 +749,7 @@ private static boolean

[GitHub] [flink] dianfu commented on a change in pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF

dianfu commented on a change in pull request #13462: URL: https://github.com/apache/flink/pull/13462#discussion_r494728861 ## File path: flink-python/pyflink/fn_execution/beam/beam_coder_impl_slow.py ## @@ -46,8 +46,7 @@ def __init__(self, field_coders):

[GitHub] [flink] dianfu commented on a change in pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF

dianfu commented on a change in pull request #13462: URL: https://github.com/apache/flink/pull/13462#discussion_r494728861 ## File path: flink-python/pyflink/fn_execution/beam/beam_coder_impl_slow.py ## @@ -46,8 +46,7 @@ def __init__(self, field_coders):

[jira] [Assigned] (FLINK-19404) Support Pandas Stream Over Window Aggregation

[ https://issues.apache.org/jira/browse/FLINK-19404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19404: --- Assignee: Huang Xingbo > Support Pandas Stream Over Window Aggregation >

[GitHub] [flink] flinkbot edited a comment on pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF.

flinkbot edited a comment on pull request #13462: URL: https://github.com/apache/flink/pull/13462#issuecomment-697272556 ## CI report: * f043157df80e534f25f07f8346c902b0032fca26 Azure:

[GitHub] [flink] fsk119 commented on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

fsk119 commented on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-698710664 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

flinkbot edited a comment on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354 ## CI report: * 28d25983818d7805f6708b36125a65a493d03aa9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF.

flinkbot edited a comment on pull request #13462: URL: https://github.com/apache/flink/pull/13462#issuecomment-697272556 ## CI report: * d7401ae9d8da75274c3ba6a2fb04f4639409b59d Azure:

[jira] [Comment Edited] (FLINK-17613) Run K8s related e2e tests with multiple K8s versions

[ https://issues.apache.org/jira/browse/FLINK-17613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201894#comment-17201894 ] Di Xu edited comment on FLINK-17613 at 9/25/20, 4:59 AM: - [~rmetzger] and

[GitHub] [flink] flinkbot edited a comment on pull request #13471: [FLINK-19124][datastream] Some JobClient methods are not ergonomic, require ClassLoader argument

flinkbot edited a comment on pull request #13471: URL: https://github.com/apache/flink/pull/13471#issuecomment-698161948 ## CI report: * 56ba62dd0ca89a5037144d5401d9aee23a7caed2 Azure:

[GitHub] [flink] PoojaChandak removed a comment on pull request #13391: Update README.md

PoojaChandak removed a comment on pull request #13391: URL: https://github.com/apache/flink/pull/13391#issuecomment-693400261 Let me know if any other changes required or it is good to merge. Thanks This is an automated

[GitHub] [flink] PoojaChandak commented on pull request #13391: Update README.md

PoojaChandak commented on pull request #13391: URL: https://github.com/apache/flink/pull/13391#issuecomment-698724331 Hi, Let me know if any changes are required or the pull request is good to be merged. Thanks. This

[GitHub] [flink] rkhachatryan commented on a change in pull request #13351: [FLINK-18990][task] Read channel state sequentially

rkhachatryan commented on a change in pull request #13351: URL: https://github.com/apache/flink/pull/13351#discussion_r494523777 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/SequentialChannelStateReaderImpl.java ## @@ -0,0 +1,263 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13128: [FLINK-18795][hbase] Support for HBase 2

flinkbot edited a comment on pull request #13128: URL: https://github.com/apache/flink/pull/13128#issuecomment-672766836 ## CI report: * 313b80f4474455d7013b0852929b5a8458f391a1 UNKNOWN * 62fcbeb58996533fa63df6f83e35efb34898e811 Azure:

[jira] [Created] (FLINK-19404) Support Pandas Stream Over Window Aggregation

Huang Xingbo created FLINK-19404: Summary: Support Pandas Stream Over Window Aggregation Key: FLINK-19404 URL: https://issues.apache.org/jira/browse/FLINK-19404 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #13475: [FLINK-19372][python] Support Pandas Batch Over Window Aggregation

flinkbot edited a comment on pull request #13475: URL: https://github.com/apache/flink/pull/13475#issuecomment-698240452 ## CI report: * e1098322eb0d29b6bd1cf47bbafdfe179c948e7a Azure:

[jira] [Created] (FLINK-19403) Support Pandas Stream Group Window Aggregation

Huang Xingbo created FLINK-19403: Summary: Support Pandas Stream Group Window Aggregation Key: FLINK-19403 URL: https://issues.apache.org/jira/browse/FLINK-19403 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #13475: [FLINK-19372][python] Support Pandas Batch Over Window Aggregation

flinkbot edited a comment on pull request #13475: URL: https://github.com/apache/flink/pull/13475#issuecomment-698240452 ## CI report: * e1098322eb0d29b6bd1cf47bbafdfe179c948e7a Azure:

[GitHub] [flink] xintongsong edited a comment on pull request #13464: [FLINK-19307][coordination] Add ResourceTracker

xintongsong edited a comment on pull request #13464: URL: https://github.com/apache/flink/pull/13464#issuecomment-698301073 I can see how the mapping simplifies things. My concern is whether this simplification hurts not only optimal but also the correctness. Not entirely sure about this.

[jira] [Assigned] (FLINK-19297) Make ResultPartitionWriter record-oriented

[ https://issues.apache.org/jira/browse/FLINK-19297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-19297: Assignee: Yingjie Cao > Make ResultPartitionWriter record-oriented >

[jira] [Issue Comment Deleted] (FLINK-19389) Error determining python major version to start fileserver during e-2-e tests

[ https://issues.apache.org/jira/browse/FLINK-19389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Xu updated FLINK-19389: -- Comment: was deleted (was: I can help to fix it, if this is a confirmed issue.) > Error determining python

[jira] [Updated] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19388: Component/s: (was: Tests) > Streaming bucketing end-to-end test failed with "Number of running task

[jira] [Commented] (FLINK-19405) Translate "DataSet Connectors" page of "Connectors" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201867#comment-17201867 ] weizheng commented on FLINK-19405: -- Hi [~jark], Could you please assign it to me > Translate "DataSet

[jira] [Updated] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19388: Component/s: Runtime / Coordination > Streaming bucketing end-to-end test failed with "Number of running

[jira] [Created] (FLINK-19405) Translate "DataSet Connectors" page of "Connectors" into Chinese

weizheng created FLINK-19405: Summary: Translate "DataSet Connectors" page of "Connectors" into Chinese Key: FLINK-19405 URL: https://issues.apache.org/jira/browse/FLINK-19405 Project: Flink

[jira] [Comment Edited] (FLINK-18851) Add checkpoint type to checkpoint history entries in Web UI

[ https://issues.apache.org/jira/browse/FLINK-18851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201866#comment-17201866 ] goutham edited comment on FLINK-18851 at 9/25/20, 2:31 AM: --- [~mapohl] Thanks

[jira] [Commented] (FLINK-18851) Add checkpoint type to checkpoint history entries in Web UI

[ https://issues.apache.org/jira/browse/FLINK-18851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201866#comment-17201866 ] goutham commented on FLINK-18851: - [~mapohl] Thanks, Also can you provide access to Jira to assign

[GitHub] [flink] xintongsong commented on pull request #13464: [FLINK-19307][coordination] Add ResourceTracker

xintongsong commented on pull request #13464: URL: https://github.com/apache/flink/pull/13464#issuecomment-698685698 Sorry for the typo. Just corrected. Having heuristics for triggering re-assignment on both JM/RM sides sounds promising to me. Just to add another idea, we may also

[GitHub] [flink] xintongsong edited a comment on pull request #13464: [FLINK-19307][coordination] Add ResourceTracker

xintongsong edited a comment on pull request #13464: URL: https://github.com/apache/flink/pull/13464#issuecomment-698685698 Sorry for the typo. Just corrected. Having heuristics for triggering re-assignment on both JM/RM sides sounds promising to me. Just to add another idea, we may

[jira] [Comment Edited] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201864#comment-17201864 ] Dian Fu edited comment on FLINK-19388 at 9/25/20, 2:34 AM: --- cc [~azagrebin]

[GitHub] [flink] HsbcJone commented on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

HsbcJone commented on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-698688361 @caozhen1937  this is the record by confluent

[GitHub] [flink] flinkbot edited a comment on pull request #13475: [FLINK-19372][python] Support Pandas Batch Over Window Aggregation

flinkbot edited a comment on pull request #13475: URL: https://github.com/apache/flink/pull/13475#issuecomment-698240452 ## CI report: * e1098322eb0d29b6bd1cf47bbafdfe179c948e7a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * a0ecc93483203cb019f279955cc466d2a6944fc3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13303: [FLINK-19098][format] Make row data converters public

flinkbot edited a comment on pull request #13303: URL: https://github.com/apache/flink/pull/13303#issuecomment-685551684 ## CI report: * d1b9c21ec9330791b02f6836fed0b36c4d62a253 Azure:

[jira] [Comment Edited] (FLINK-17613) Run K8s related e2e tests with multiple K8s versions

[ https://issues.apache.org/jira/browse/FLINK-17613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201894#comment-17201894 ] Di Xu edited comment on FLINK-17613 at 9/25/20, 4:22 AM: - [~rmetzger] and

[GitHub] [flink] rkhachatryan commented on a change in pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

rkhachatryan commented on a change in pull request #13040: URL: https://github.com/apache/flink/pull/13040#discussion_r494742471 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreITCase.java ## @@ -283,6 +286,54 @@

[GitHub] [flink] dianfu commented on a change in pull request #13475: [FLINK-19372][python] Support Pandas Batch Over Window Aggregation

dianfu commented on a change in pull request #13475: URL: https://github.com/apache/flink/pull/13475#discussion_r494733674 ## File path: flink-python/pyflink/fn_execution/beam/beam_coder_impl_slow.py ## @@ -560,23 +560,52 @@ def encode_to_stream(self, iter_cols, out_stream,

[GitHub] [flink] flinkbot edited a comment on pull request #13475: [FLINK-19372][python] Support Pandas Batch Over Window Aggregation

flinkbot edited a comment on pull request #13475: URL: https://github.com/apache/flink/pull/13475#issuecomment-698240452 ## CI report: * 76736cc092aa256ff4680e54613e8c17cf45b596 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13419: [FLINK-18842][e2e] Added 10min timeout to building the container.

flinkbot edited a comment on pull request #13419: URL: https://github.com/apache/flink/pull/13419#issuecomment-694745717 ## CI report: * bf0418c1332c5371f14820d80af9ceea7507bedc Azure:

[jira] [Comment Edited] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201864#comment-17201864 ] Dian Fu edited comment on FLINK-19388 at 9/25/20, 2:28 AM: --- cc [~azagrebin]

[GitHub] [flink] HsbcJone edited a comment on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

HsbcJone edited a comment on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-698684598 @caozhen1937 hi i fork ur code for test debezium-avro-confluent . i debug the source code .but its do not work . @wuchong here is the exception;

[GitHub] [flink] gm7y8 commented on a change in pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

gm7y8 commented on a change in pull request #13458: URL: https://github.com/apache/flink/pull/13458#discussion_r494527680 ## File path: flink-runtime-web/src/test/resources/rest_api_v1.snapshot ## @@ -1254,6 +1263,9 @@ "num_acknowledged_subtasks" : { "type"

[jira] [Comment Edited] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201864#comment-17201864 ] Dian Fu edited comment on FLINK-19388 at 9/25/20, 2:28 AM: --- cc [~azagrebin]

[jira] [Created] (FLINK-19406) Casting row time to timestamp loses nullability info

Rui Li created FLINK-19406: -- Summary: Casting row time to timestamp loses nullability info Key: FLINK-19406 URL: https://issues.apache.org/jira/browse/FLINK-19406 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #13303: [FLINK-19098][format] Make row data converters public

flinkbot edited a comment on pull request #13303: URL: https://github.com/apache/flink/pull/13303#issuecomment-685551684 ## CI report: * d1b9c21ec9330791b02f6836fed0b36c4d62a253 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

flinkbot edited a comment on pull request #13449: URL: https://github.com/apache/flink/pull/13449#issuecomment-696509354 ## CI report: * 3925844a1496578ba81e55f1969729c2ddca31c8 Azure:

[GitHub] [flink] V1ncentzzZ commented on pull request #13472: [FLINK-19291][Formats] Fix `SchemaParseException` when use `AvroSchemaConverter` converts flink logical type

V1ncentzzZ commented on pull request #13472: URL: https://github.com/apache/flink/pull/13472#issuecomment-698705423 Hi @danny0405 @wuchong , would you help review this PR? Thank you very much. This is an automated message

[jira] [Commented] (FLINK-19407) Translate "Elasticsearch Connector" page of "Connectors" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201890#comment-17201890 ] 魏旭斌 commented on FLINK-19407: - Hi [~jark] ,I would like to translate this page . Could you please assign it

[jira] [Created] (FLINK-19407) Translate "Elasticsearch Connector" page of "Connectors" into Chinese

魏旭斌 created FLINK-19407: --- Summary: Translate "Elasticsearch Connector" page of "Connectors" into Chinese Key: FLINK-19407 URL: https://issues.apache.org/jira/browse/FLINK-19407 Project: Flink Issue

[jira] [Commented] (FLINK-17613) Run K8s related e2e tests with multiple K8s versions

[ https://issues.apache.org/jira/browse/FLINK-17613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201894#comment-17201894 ] Di Xu commented on FLINK-17613: --- [~rmetzger] and [~fly_in_gis] I would like to take this ticket. Here is

[GitHub] [flink] dianfu commented on a change in pull request #13475: [FLINK-19372][python] Support Pandas Batch Over Window Aggregation

dianfu commented on a change in pull request #13475: URL: https://github.com/apache/flink/pull/13475#discussion_r494761634 ## File path: flink-python/pyflink/fn_execution/beam/beam_operations_fast.pyx ## @@ -192,6 +194,108 @@ cdef class

[jira] [Closed] (FLINK-19297) Make ResultPartitionWriter record-oriented

[ https://issues.apache.org/jira/browse/FLINK-19297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-19297. --- Resolution: Fixed > Make ResultPartitionWriter record-oriented >

[jira] [Updated] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19388: Priority: Blocker (was: Critical) > Streaming bucketing end-to-end test failed with "Number of running

[jira] [Commented] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201863#comment-17201863 ] Dian Fu commented on FLINK-19388: - Upgrade it to "Blocker"! > Streaming bucketing end-to-end test

[GitHub] [flink] HsbcJone commented on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

HsbcJone commented on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-698684598 @caozhen1937 hi i fork ur code for test debezium-avro-confluent . i debug the source code .but its do not work . @wuchong here is the exception; ![Uploading

[jira] [Commented] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201864#comment-17201864 ] Dian Fu commented on FLINK-19388: - cc [~azagrebin] Could you help to take a look at this issue? The

[jira] [Commented] (FLINK-19388) Streaming bucketing end-to-end test failed with "Number of running task managers has not reached 4 within a timeout of 40 sec"

[ https://issues.apache.org/jira/browse/FLINK-19388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201862#comment-17201862 ] Dian Fu commented on FLINK-19388: - I found the following exception in the log: {code} 2020-09-24

[GitHub] [flink] WeiZhong94 commented on a change in pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python

WeiZhong94 commented on a change in pull request #13462: URL: https://github.com/apache/flink/pull/13462#discussion_r494714656 ## File path: flink-python/pyflink/fn_execution/beam/beam_coder_impl_slow.py ## @@ -46,8 +46,7 @@ def __init__(self, field_coders):

[jira] [Assigned] (FLINK-19180) Make RocksDB respect the calculated managed memory fraction

[ https://issues.apache.org/jira/browse/FLINK-19180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-19180: Assignee: Xintong Song > Make RocksDB respect the calculated managed memory fraction >

[jira] [Assigned] (FLINK-19181) Make python processes respect the calculated managed memory fraction

[ https://issues.apache.org/jira/browse/FLINK-19181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19181: --- Assignee: Dian Fu > Make python processes respect the calculated managed memory fraction >

[jira] [Commented] (FLINK-19405) Translate "DataSet Connectors" page of "Connectors" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-19405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201884#comment-17201884 ] weizheng commented on FLINK-19405: -- ok thanks > Translate "DataSet Connectors" page of "Connectors"

[GitHub] [flink] flinkbot commented on pull request #13477: [FLINK-19406][table-planner-blink] Casting row time to timestamp lose…

flinkbot commented on pull request #13477: URL: https://github.com/apache/flink/pull/13477#issuecomment-698699571 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] lirui-apache opened a new pull request #13477: [FLINK-19406][table-planner-blink] Casting row time to timestamp lose…

lirui-apache opened a new pull request #13477: URL: https://github.com/apache/flink/pull/13477 …s nullability info ## What is the purpose of the change We lose nullability info when casting row time to timestamp. If the timestamp is passed to a function that takes not

[jira] [Updated] (FLINK-19406) Casting row time to timestamp loses nullability info

[ https://issues.apache.org/jira/browse/FLINK-19406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19406: --- Labels: pull-request-available (was: ) > Casting row time to timestamp loses nullability

[GitHub] [flink] flinkbot edited a comment on pull request #13477: [FLINK-19406][table-planner-blink] Casting row time to timestamp lose…

flinkbot edited a comment on pull request #13477: URL: https://github.com/apache/flink/pull/13477#issuecomment-698702956 ## CI report: * 3c9bb3850b73a0499bd2eb99ee0a738cbee63789 Azure:

[GitHub] [flink] WeiZhong94 commented on pull request #13462: [FLINK-19229][python] Introduces rules and python side implementation to ensure the basic functionality of the general Python UDAF.

WeiZhong94 commented on pull request #13462: URL: https://github.com/apache/flink/pull/13462#issuecomment-698721421 @dianfu @HuangXingBo Thanks for your comments! I have updated this PR. This is an automated message from the

[GitHub] [flink-statefun] tzulitai commented on pull request #162: [FLINK-19399][doc][py] Document AsyncRequestHandler

tzulitai commented on pull request #162: URL: https://github.com/apache/flink-statefun/pull/162#issuecomment-698736864 Merging ... This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #13474: [FLINK-19391][network] Moved notification during subpartition request to the requester.

flinkbot edited a comment on pull request #13474: URL: https://github.com/apache/flink/pull/13474#issuecomment-698204591 ## CI report: * db8764396df2141143c989f2138dbbc5f43ac63a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 43dc692c9d9fedfbe139f3c376486071980551d1 Azure:

  1   2   3   4   5   >