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

[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

[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

[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=17435157#comment-17435157 ] JING ZHANG commented on FLINK-24501: [~wenlong.lwl] If we took min watermark of all subtask as new

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

[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

[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=17435141#comment-17435141 ] Caizhi Weng commented on FLINK-24408: - Hi! Thanks for raising this issue. This is because Java code

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

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

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

[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

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

[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=17435137#comment-17435137 ] Wenlong Lyu commented on FLINK-24501: - [~qingru zhang] I think watermark should be the min of all

[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

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

[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=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=17435136#comment-17435136 ] JING ZHANG commented on FLINK-24501: [~wenlong.lwl] Thank a lot for your attention to this issue. > 

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

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

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

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

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

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

[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

[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

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

[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

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

[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

[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

[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

[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

[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

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

[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

[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

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

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

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

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

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

[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

[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

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

[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

[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

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

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

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

[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=17435098#comment-17435098 ] John Karp commented on FLINK-24639: --- Thanks [~dannycranmer], I opened

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

[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

[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

[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

[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

[jira] [Updated] (FLINK-21652) Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because of throwing SocketTimeoutException during the closing stage.

[ https://issues.apache.org/jira/browse/FLINK-21652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21652: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-10740) FLIP-27: Refactor Source Interface

[ https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10740: --- Labels: auto-unassigned pull-request-available stale-major usability (was: auto-unassigned

[jira] [Updated] (FLINK-21677) org.apache.flink.test.state.operator.restore.unkeyed.ChainBreakTest hangs

[ https://issues.apache.org/jira/browse/FLINK-21677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21677: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21792) Add a PythonFunctionRunnerDescriptor and unify the creation of all the PythonFunctionRunner

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

[jira] [Updated] (FLINK-21806) ContinuousEventTimeTrigger should register its first timer base on current watermark

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

[jira] [Updated] (FLINK-21763) Extend Data Stream's batch mode to handle partitioning/grouping/ordering

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

[jira] [Updated] (FLINK-21832) Avro Confluent Schema Registry nightly end-to-end fail

[ https://issues.apache.org/jira/browse/FLINK-21832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21832: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21752) NullPointerException on restore in PojoSerializer

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

[jira] [Updated] (FLINK-21782) Lookup Table based on rowkey ranges

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

[jira] [Updated] (FLINK-21807) Make ApplicationDeployer interface public

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

[jira] [Updated] (FLINK-21854) WebUI show incorrect value

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

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * a20fe2427c03ceb71b8d4b5f30bdc282aba530fe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-953241058 ## CI report: * 99fa2e362ef929e2549e5aa76ef2c11b7b39891d Azure:

[jira] [Comment Edited] (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=17435061#comment-17435061 ] Danny Cranmer edited comment on FLINK-24639 at 10/27/21, 9:16 PM: --

[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=17435061#comment-17435061 ] Danny Cranmer commented on FLINK-24639: --- Thanks [~jkarp], your analysis is great! I have been

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

[GitHub] [flink] flinkbot edited a comment on pull request #17573: [FLINK-24190][runtime] Forbid to split the first record in the buffer if it physically fit it.

flinkbot edited a comment on pull request #17573: URL: https://github.com/apache/flink/pull/17573#issuecomment-952043255 ## CI report: * 3444ac297d6efb06fa2565e51fb64075aee43201 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 93b95b3918ab5f6f64180398d3dd38a4f27e0793 Azure:

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

[GitHub] [flink] matriv commented on pull request #17579: [FLINK-24454][table-planner][tests] Consolidate cast tests

matriv commented on pull request #17579: URL: https://github.com/apache/flink/pull/17579#issuecomment-953300504 @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

[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: * 31d1980cca148d082862449c468f1813b5d6b534 Azure:

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

flinkbot edited a comment on pull request #17522: URL: https://github.com/apache/flink/pull/17522#issuecomment-94673 ## CI report: * 87d6ba91b3b6a734f8875b8b6ec93bad513ee805 Azure:

[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: * 31d1980cca148d082862449c468f1813b5d6b534 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17581: [FLINK-24552][tests] Moved randomization of buffer debloat from Strea…

flinkbot edited a comment on pull request #17581: URL: https://github.com/apache/flink/pull/17581#issuecomment-953068068 ## CI report: * dfba64bd7737705235c2fa279a31fb8ba951aa13 Azure:

[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: * 4fbfa27d34f86479d352240fe8a16c07f338aedb Azure:

[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: * 4fbfa27d34f86479d352240fe8a16c07f338aedb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17574: [FLINK-24665] Update Presto Hadoop dependency to latest version

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

[GitHub] [flink] flinkbot edited a comment on pull request #17578: [FLINK-24208][rest] Support user-supplied Savepoint triggerId

flinkbot edited a comment on pull request #17578: URL: https://github.com/apache/flink/pull/17578#issuecomment-952731483 ## CI report: * 639b420be63844073345b89063cba258cc652f23 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-953241058 ## CI report: * 99fa2e362ef929e2549e5aa76ef2c11b7b39891d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17573: [FLINK-24190][runtime] Forbid to split the first record in the buffer if it physically fit it.

flinkbot edited a comment on pull request #17573: URL: https://github.com/apache/flink/pull/17573#issuecomment-952043255 ## CI report: * 0413fd1ea88d920c106fa783b9e2061ce735228c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17574: [FLINK-24665] Update Presto Hadoop dependency to latest version

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

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

[jira] [Assigned] (FLINK-24667) Channel state writer would fail the task directly if meeting exception previously

[ https://issues.apache.org/jira/browse/FLINK-24667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-24667: - Assignee: Roman Khachatryan > Channel state writer would fail the task

  1   2   3   4   5   >