[GitHub] [flink] beyond1920 commented on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

beyond1920 commented on pull request #17571: URL: https://github.com/apache/flink/pull/17571#issuecomment-953555889 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif

[jira] [Commented] (FLINK-22793) HybridSource Table Implementation

[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435198#comment-17435198 ] Martijn Visser commented on FLINK-22793: [~nicholasjiang] Are you still working

[GitHub] [flink] flinkbot edited a comment on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

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

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

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435194#comment-17435194 ] JING ZHANG commented on FLINK-24501: [~wenlong.lwl]  > in you case，if the watermark

[jira] [Resolved] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23391. - Fix Version/s: 1.14.1 1.15.0 Assignee: Qingsheng Ren Resolutio

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435192#comment-17435192 ] Arvid Heise commented on FLINK-23391: - Merged into master as c461338d0009a164d9c236a

[GitHub] [flink] AHeise merged pull request #17576: [BP-1.13][FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

AHeise merged pull request #17576: URL: https://github.com/apache/flink/pull/17576 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] AHeise merged pull request #17575: [BP-1.14][FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

AHeise merged pull request #17575: URL: https://github.com/apache/flink/pull/17575 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] AHeise commented on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

AHeise commented on pull request #17516: URL: https://github.com/apache/flink/pull/17516#issuecomment-953546018 Thank you very much for your contribution. I merged. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] AHeise merged pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

AHeise merged pull request #17516: URL: https://github.com/apache/flink/pull/17516 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] AHeise commented on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

AHeise commented on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-953545453 Ah I see that this was already addressed in FLINK-5149. Thanks for the explanation. Can you please check on the test failures? They are directly related to your second com

[GitHub] [flink] flinkbot edited a comment on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

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

[jira] [Updated] (FLINK-24678) Correct the metric name of map state contains latency

[ https://issues.apache.org/jira/browse/FLINK-24678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24678: - Fix Version/s: 1.15.0 > Correct the metric name of map state contains latency >

[jira] [Assigned] (FLINK-24678) Correct the metric name of map state contains latency

[ https://issues.apache.org/jira/browse/FLINK-24678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24678: Assignee: Jinzhong Li (was: Yun Tang) > Correct the metric name of map state contains latency >

[jira] [Updated] (FLINK-24646) Add operator wrapper for all-round iterations

[ https://issues.apache.org/jira/browse/FLINK-24646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24646: --- Labels: pull-request-available (was: ) > Add operator wrapper for all-round iterations > --

[GitHub] [flink-ml] guoweiM commented on a change in pull request #8: [FLINK-24646][iteration] Add operator wrapper for all-round iterations

guoweiM commented on a change in pull request #8: URL: https://github.com/apache/flink-ml/pull/8#discussion_r738060379 ## File path: flink-ml-iteration/pom.xml ## @@ -0,0 +1,115 @@ + + +http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-in

[GitHub] [flink] flinkbot edited a comment on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

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

[GitHub] [flink] AHeise commented on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

AHeise commented on pull request #17374: URL: https://github.com/apache/flink/pull/17374#issuecomment-953543224 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific c

[jira] [Created] (FLINK-24678) Correct the metric name of map state contains latency

Yun Tang created FLINK-24678: Summary: Correct the metric name of map state contains latency Key: FLINK-24678 URL: https://issues.apache.org/jira/browse/FLINK-24678 Project: Flink Issue Type: Bug

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

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

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

JingsongLi commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r738051593 ## File path: flink-formats/flink-avro/pom.xml ## @@ -47,13 +47,11 @@ under the License. - Review comment:

[GitHub] [flink] flinkbot edited a comment on pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

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

[GitHub] [flink] flinkbot edited a comment on pull request #17584: [FLINK-24676][table-planner] Fix schema mismatch exception if explain insert with partial column

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

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435175#comment-17435175 ] Wenlong Lyu commented on FLINK-24501: - [~qingru zhang] in you case，if the watermark

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17562: [FLINK-16206][table-planner] Support JSON_ARRAYAGG

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

[GitHub] [flink] flinkbot edited a comment on pull request #17562: [FLINK-16206][table-planner] Support JSON_ARRAYAGG

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

[GitHub] [flink] Airblader commented on pull request #17562: [FLINK-16206][table-planner] Support JSON_ARRAYAGG

Airblader commented on pull request #17562: URL: https://github.com/apache/flink/pull/17562#issuecomment-953528884 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specifi

[GitHub] [flink] flinkbot edited a comment on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

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

[GitHub] [flink] flinkbot edited a comment on pull request #17585: [hotfix][docs] Modify wrong variable names in doc demo code

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

[GitHub] [flink] flinkbot commented on pull request #17585: [hotfix][docs] Modify wrong variable names in doc demo code

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

[GitHub] [flink] unigeorge opened a new pull request #17585: [hotfix][docs] Modify wrong variable names in doc demo code

unigeorge opened a new pull request #17585: URL: https://github.com/apache/flink/pull/17585 ## What is the purpose of the change This pull request fixes a mistake of variable names in the doc demo code. ## Brief change log - Change the wrong names into corr

[GitHub] [flink] snuyanzin commented on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

snuyanzin commented on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-953512858 LGTM -- 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

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

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435157#comment-17435157 ] JING ZHANG commented on FLINK-24501: [~wenlong.lwl] If we took min watermark of all

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

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

[GitHub] [flink] RocMarshal commented on pull request #17463: [Hotfix] Fix typos.

RocMarshal commented on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-953502947 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif

[jira] [Commented] (FLINK-24408) org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExec

[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435141#comment-17435141 ] Caizhi Weng commented on FLINK-24408: - Hi! Thanks for raising this issue. This is b

[GitHub] [flink] wenlong88 commented on pull request #17584: [FLINK-24676][table-planner] Fix schema mismatch exception if explain insert with partial column

wenlong88 commented on pull request #17584: URL: https://github.com/apache/flink/pull/17584#issuecomment-953477357 LGTM -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17575: [BP-1.14][FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or time

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

[GitHub] [flink] flinkbot edited a comment on pull request #17536: [FLINK-24530][datastream] GlobalCommitter might not commit all records on drain

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

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

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

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

gaoyunhaii commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r737992052 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/OutputOperator.java ## @@ -0,0 +1,53 @@ +/* + * Licensed to the Apache S

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435137#comment-17435137 ] Wenlong Lyu commented on FLINK-24501: - [~qingru zhang] I think watermark should be t

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

gaoyunhaii commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r737990744 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/InputOperator.java ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache So

[GitHub] [flink] flinkbot edited a comment on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

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

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

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435136#comment-17435136 ] JING ZHANG edited comment on FLINK-24501 at 10/28/21, 3:14 AM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435136#comment-17435136 ] JING ZHANG commented on FLINK-24501: [~wenlong.lwl] Thank a lot for your attention t

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

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435136#comment-17435136 ] JING ZHANG edited comment on FLINK-24501 at 10/28/21, 3:13 AM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17576: [BP-1.13][FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or time

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

[GitHub] [flink] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

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

[GitHub] [flink] lincoln-lil commented on a change in pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

lincoln-lil commented on a change in pull request #17570: URL: https://github.com/apache/flink/pull/17570#discussion_r737986937 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/harness/RankHarnessTest.scala ## @@ -0,0 +1,209 @

[GitHub] [flink] flinkbot edited a comment on pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

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

[GitHub] [flink] flinkbot edited a comment on pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

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

[jira] [Created] (FLINK-24677) JdbcBatchingOutputFormat should not generate circulate chaining of exceptions when flushing fails in timer thread

Caizhi Weng created FLINK-24677: --- Summary: JdbcBatchingOutputFormat should not generate circulate chaining of exceptions when flushing fails in timer thread Key: FLINK-24677 URL: https://issues.apache.org/jira/brows

[jira] [Updated] (FLINK-24677) JdbcBatchingOutputFormat should not generate circulate chaining of exceptions when flushing fails in timer thread

[ https://issues.apache.org/jira/browse/FLINK-24677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-24677: Issue Type: Bug (was: Improvement) > JdbcBatchingOutputFormat should not generate circulate chain

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

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r737984130 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/operator/TailOperatorTest.java ## @@ -0,0 +1,104 @@ +/* + * Licensed to the Apache S

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

guoweiM commented on a change in pull request #7: URL: https://github.com/apache/flink-ml/pull/7#discussion_r737983931 ## File path: flink-ml-iteration/src/test/java/org/apache/flink/iteration/operator/OutputOperatorTest.java ## @@ -0,0 +1,54 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

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

[jira] [Updated] (FLINK-24645) Implements the feedback mechanism and the controller operators

[ https://issues.apache.org/jira/browse/FLINK-24645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24645: --- Labels: pull-request-available (was: ) > Implements the feedback mechanism and the controll

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

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

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

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

[GitHub] [flink] beyond1920 commented on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

beyond1920 commented on pull request #17571: URL: https://github.com/apache/flink/pull/17571#issuecomment-953455966 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif

[GitHub] [flink] flinkbot commented on pull request #17584: [FLINK-24676][table-planner] Fix schema mismatch exception if explain insert with partial column

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

[GitHub] [flink] flinkbot edited a comment on pull request #17584: [FLINK-24676][table-planner] Fix schema mismatch exception if explain insert with partial column

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

[GitHub] [flink] flinkbot commented on pull request #17584: [FLINK-24676][table-planner] Fix schema mismatch exception if explain insert with partial column

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

[jira] [Updated] (FLINK-24676) Schema does not match if explain insert statement with partial column

[ https://issues.apache.org/jira/browse/FLINK-24676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24676: --- Labels: pull-request-available (was: ) > Schema does not match if explain insert statement

[GitHub] [flink] godfreyhe opened a new pull request #17584: [FLINK-24676][table-planner] Fix schema mismatch exception if explain insert with partial column

godfreyhe opened a new pull request #17584: URL: https://github.com/apache/flink/pull/17584 ## What is the purpose of the change *Fix schema mismatch exception if explain insert with partial column, please refer to the desc of FLINK-24676 to see the example* ## Brief c

[GitHub] [flink] flinkbot edited a comment on pull request #17575: [BP-1.14][FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or time

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

[GitHub] [flink] flinkbot edited a comment on pull request #17576: [BP-1.13][FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or time

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

[GitHub] [flink] flinkbot edited a comment on pull request #17576: [BP-1.13][FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or time

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

[GitHub] [flink] flinkbot edited a comment on pull request #17575: [BP-1.14][FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or time

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

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

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

[GitHub] [flink] PatrickRen commented on pull request #17576: [BP-1.13][FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

PatrickRen commented on pull request #17576: URL: https://github.com/apache/flink/pull/17576#issuecomment-953450177 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif

[GitHub] [flink] PatrickRen commented on pull request #17575: [BP-1.14][FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

PatrickRen commented on pull request #17575: URL: https://github.com/apache/flink/pull/17575#issuecomment-953449917 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

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

[jira] [Updated] (FLINK-24676) Schema does not match if explain insert statement with partial column

[ https://issues.apache.org/jira/browse/FLINK-24676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24676: --- Fix Version/s: 1.13.4 1.14.1 1.15.0 > Schema does not match if

[jira] [Updated] (FLINK-24676) Schema does not match if explain insert statement with partial column

[ https://issues.apache.org/jira/browse/FLINK-24676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24676: --- Component/s: Table SQL / Planner > Schema does not match if explain insert statement with partial co

[jira] [Updated] (FLINK-24676) Schema does not match if explain insert statement with partial column

[ https://issues.apache.org/jira/browse/FLINK-24676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24676: --- Affects Version/s: 1.15.0 1.13.0 1.14.0 > Schema does

[jira] [Assigned] (FLINK-24676) Schema does not match if explain insert statement with partial column

[ https://issues.apache.org/jira/browse/FLINK-24676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-24676: -- Assignee: godfrey he > Schema does not match if explain insert statement with partial column

[jira] [Created] (FLINK-24676) Schema does not match if explain insert statement with partial column

godfrey he created FLINK-24676: -- Summary: Schema does not match if explain insert statement with partial column Key: FLINK-24676 URL: https://issues.apache.org/jira/browse/FLINK-24676 Project: Flink

[GitHub] [flink] tsreaper commented on a change in pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

tsreaper commented on a change in pull request #17570: URL: https://github.com/apache/flink/pull/17570#discussion_r737970735 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/harness/RankHarnessTest.scala ## @@ -0,0 +1,209 @@ +

[GitHub] [flink] meetjunsu commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

meetjunsu commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r737956485 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java ## @@ -141,6 +163,11 @@ private

[jira] [Created] (FLINK-24675) org.apache.flink.formats.parquet.ParquetMapInputFormat the Constructor has no MessageType will throw an exception.

Hadi created FLINK-24675: Summary: org.apache.flink.formats.parquet.ParquetMapInputFormat the Constructor has no MessageType will throw an exception. Key: FLINK-24675 URL: https://issues.apache.org/jira/

[GitHub] [flink] flinkbot edited a comment on pull request #17579: [FLINK-24454][table-planner][tests] Consolidate cast tests

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

[GitHub] [flink] flinkbot edited a comment on pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

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

[jira] [Commented] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

[ https://issues.apache.org/jira/browse/FLINK-24639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435098#comment-17435098 ] John Karp commented on FLINK-24639: --- Thanks [~dannycranmer], I opened https://github.c

[GitHub] [flink] flinkbot edited a comment on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

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

[GitHub] [flink] flinkbot commented on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

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

[GitHub] [flink] flinkbot commented on pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

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

[jira] [Updated] (FLINK-24639) Improve assignment of Kinesis shards to subtasks

[ https://issues.apache.org/jira/browse/FLINK-24639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24639: --- Labels: pull-request-available (was: ) > Improve assignment of Kinesis shards to subtasks >

[GitHub] [flink] john-karp opened a new pull request #17583: [FLINK-24639][kinesis] Add UniformShardAssigner

john-karp opened a new pull request #17583: URL: https://github.com/apache/flink/pull/17583 ## What is the purpose of the change Add UniformShardAssigner to assign Kinesis shards to subtasks. This algorithm takes advantage of the Kinesis hash-key space that each shard occupies. By d

[jira] [Updated] (FLINK-21747) Encounter an exception that contains "max key length exceeded ..." when reporting metrics to influxdb

[ https://issues.apache.org/jira/browse/FLINK-21747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21747: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

  1   2   3   4   5   >