[jira] [Commented] (FLINK-21728) DegreesWithExceptionITCase crash

[ https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302264#comment-17302264 ] Dawid Wysakowicz commented on FLINK-21728: -- https://dev.azure.com/apache-flink/

[GitHub] [flink] wsry commented on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

wsry commented on pull request #15193: URL: https://github.com/apache/flink/pull/15193#issuecomment-88510 @zhuzhurk Thanks for the review and suggestion. I have added some more explanation in the commit message and updated the PR. --

[GitHub] [flink] fsk119 commented on a change in pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

fsk119 commented on a change in pull request #15197: URL: https://github.com/apache/flink/pull/15197#discussion_r594905557 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/SqlClientOptions.java ## @@ -0,0 +1,42 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302268#comment-17302268 ] Dawid Wysakowicz commented on FLINK-12030: -- https://dev.azure.com/apache-flink/

[GitHub] [flink] zjuwangg commented on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

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

[jira] [Created] (FLINK-21809) PyFlink end-to-end test fail

Guowei Ma created FLINK-21809: - Summary: PyFlink end-to-end test fail Key: FLINK-21809 URL: https://issues.apache.org/jira/browse/FLINK-21809 Project: Flink Issue Type: Bug Components:

[GitHub] [flink] lindong28 removed a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

lindong28 removed a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-799917097 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Updated] (FLINK-21809) PyFlink end-to-end test fail

[ https://issues.apache.org/jira/browse/FLINK-21809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21809: -- Labels: test-stability (was: ) > PyFlink end-to-end test fail > > >

[jira] [Updated] (FLINK-21809) PyFlink end-to-end test fails

[ https://issues.apache.org/jira/browse/FLINK-21809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21809: -- Summary: PyFlink end-to-end test fails (was: PyFlink end-to-end test fail) > PyFlink end-to-end test

[jira] [Created] (FLINK-21810) PyFlink end-to-end fails with "sorted[*]: unbound variable"

Dawid Wysakowicz created FLINK-21810: Summary: PyFlink end-to-end fails with "sorted[*]: unbound variable" Key: FLINK-21810 URL: https://issues.apache.org/jira/browse/FLINK-21810 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

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

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

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

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

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

[jira] [Commented] (FLINK-21809) PyFlink end-to-end test fails

[ https://issues.apache.org/jira/browse/FLINK-21809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302273#comment-17302273 ] Dawid Wysakowicz commented on FLINK-21809: -- The build runs for a PR against the

[GitHub] [flink] flinkbot edited a comment on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

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

[GitHub] [flink] flinkbot edited a comment on pull request #15200: [FLINK-21355] Send changes to the state changelog

flinkbot edited a comment on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-798902665 ## CI report: * 5e1342d9916f5c4356c622a40bc27bcbdacde9d7 UNKNOWN * ece208b9da559a725362de3d5c4e39e05de5d35e Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

flinkbot edited a comment on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-798871985 ## CI report: * 546bb52a009fee535df450c4ce569f1d8019ff6a UNKNOWN * afa8be823a70be47cabce1f91eb0e8f24e60be35 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15205: [FLINK-21649] Refactor CopyOnWrite state classes

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

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 8a320ad9b0780b4b18c23c68314ffd2b750f259c UNKNOWN * 625559cda6f8fc99ad0722e716a063e3482a80e1 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #15220: [FLINK-21744][table-planner-blink]Support StreamExecDeduplicate json serialization/deserialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

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

[GitHub] [flink] flinkbot edited a comment on pull request #15228: [hotfix][resourceManager] fix the check that whether JobLeaderIdServi…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

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

[GitHub] [flink] rmetzger commented on a change in pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

rmetzger commented on a change in pull request #14948: URL: https://github.com/apache/flink/pull/14948#discussion_r594912420 ## File path: flink-tests/src/test/java/org/apache/flink/test/scheduling/AdaptiveSchedulerITCase.java ## @@ -88,6 +123,189 @@ public void testGlobalFail

[jira] [Created] (FLINK-21811) Support StreamExecJoin json serialization/deserialization

Terry Wang created FLINK-21811: -- Summary: Support StreamExecJoin json serialization/deserialization Key: FLINK-21811 URL: https://issues.apache.org/jira/browse/FLINK-21811 Project: Flink Issue T

[GitHub] [flink] AHeise commented on pull request #14054: [FLINK-20130][core] Add ZStandard to FileInputFormat

AHeise commented on pull request #14054: URL: https://github.com/apache/flink/pull/14054#issuecomment-800020809 Sorry for this oversight. @xintongsong reverted it in f220277c907852c028150a26fb5aff55dcff9d57. @eskabetxe can you please check and create a new PR? ---

[jira] [Updated] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-21685: -- Attachment: jstack.jm.1 > Flink JobManager failed to restart from checkpoint in kubernetes HA setup >

[GitHub] [flink] PatrickRen commented on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

PatrickRen commented on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-800034523 Finally we have a successfully run Azure build. @becketqin @lindong28 Could you please have a review on this PR? Thanks~ ---

[GitHub] [flink] flinkbot edited a comment on pull request #14916: [FLINK-21345][Table SQL / Planner] Fix BUG of Union All join Temporal…

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

[GitHub] [flink] rmetzger commented on a change in pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

rmetzger commented on a change in pull request #14948: URL: https://github.com/apache/flink/pull/14948#discussion_r594927028 ## File path: flink-tests/src/test/java/org/apache/flink/test/scheduling/AdaptiveSchedulerITCase.java ## @@ -88,6 +123,189 @@ public void testGlobalFail

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

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

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

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

[GitHub] [flink] flinkbot edited a comment on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

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

[jira] [Commented] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302297#comment-17302297 ] Yang Wang commented on FLINK-21685: --- I have attached a jstack of JobManager process. I

[GitHub] [flink] flinkbot edited a comment on pull request #15205: [FLINK-21649] Refactor CopyOnWrite state classes

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

[GitHub] [flink] flinkbot edited a comment on pull request #15215: [FLINK-21785][blink-table-planner] Support json ser/de for StreamExecCorrelate

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

[GitHub] [flink] flinkbot edited a comment on pull request #15220: [FLINK-21744][table-planner-blink]Support StreamExecDeduplicate json serialization/deserialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 8a320ad9b0780b4b18c23c68314ffd2b750f259c UNKNOWN * 625559cda6f8fc99ad0722e716a063e3482a80e1 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] rmetzger commented on a change in pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

rmetzger commented on a change in pull request #15064: URL: https://github.com/apache/flink/pull/15064#discussion_r594930351 ## File path: docs/content/docs/deployment/elastic_scaling.md ## @@ -0,0 +1,107 @@ +--- +title: Elastic Scaling +weight: 5 +type: docs + +--- + + +# Elas

[GitHub] [flink] rmetzger commented on a change in pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

rmetzger commented on a change in pull request #15064: URL: https://github.com/apache/flink/pull/15064#discussion_r594931481 ## File path: docs/content/docs/deployment/elastic_scaling.md ## @@ -0,0 +1,107 @@ +--- +title: Elastic Scaling +weight: 5 +type: docs + +--- + + +# Elas

[jira] [Created] (FLINK-21812) How to read data from kafka and sink to Postgresql Database

Bhagi created FLINK-21812: - Summary: How to read data from kafka and sink to Postgresql Database Key: FLINK-21812 URL: https://issues.apache.org/jira/browse/FLINK-21812 Project: Flink Issue Type: Ta

[jira] [Updated] (FLINK-21808) Support DQL/DML in HiveParser

[ https://issues.apache.org/jira/browse/FLINK-21808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-21808: --- Summary: Support DQL/DML in HiveParser (was: Support DQL in HiveParser) > Support DQL/DML in HiveParser > -

[jira] [Updated] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit and StreamExecLimit Json ser/de

[ https://issues.apache.org/jira/browse/FLINK-21805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-21805: Summary: Support StreamExecRank and StreamExecSortLimit and StreamExecLimit Json ser/de (was: Sup

[jira] [Updated] (FLINK-21812) How to read data from kafka and sink to Postgresql Database

[ https://issues.apache.org/jira/browse/FLINK-21812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-21812: -- Issue Type: Bug (was: Task) > How to read data from kafka and sink to Postgresql Database > -

[jira] [Created] (FLINK-21813) Support StreamExecOverAggregate json ser/de

Wenlong Lyu created FLINK-21813: --- Summary: Support StreamExecOverAggregate json ser/de Key: FLINK-21813 URL: https://issues.apache.org/jira/browse/FLINK-21813 Project: Flink Issue Type: Sub-tas

[jira] [Commented] (FLINK-21786) sample Job execution failed

[ https://issues.apache.org/jira/browse/FLINK-21786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302312#comment-17302312 ] Matthias commented on FLINK-21786: -- Ok, my bad. The file needs to be accessible from wi

[GitHub] [flink] LadyForest opened a new pull request #15230: [FLINK-21300][docs] Update module-related documentation

LadyForest opened a new pull request #15230: URL: https://github.com/apache/flink/pull/15230 ## What is the purpose of the change This pull request is a subtask of FLINK-21045 to update the docs on module-related changes. ## Brief change log - Update the `overview

[jira] [Updated] (FLINK-21300) Update module documentation

[ https://issues.apache.org/jira/browse/FLINK-21300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21300: --- Labels: pull-request-available (was: ) > Update module documentation >

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

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

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

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

[GitHub] [flink] flinkbot edited a comment on pull request #15215: [FLINK-21785][blink-table-planner] Support json ser/de for StreamExecCorrelate

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

[jira] [Commented] (FLINK-21774) Do not display column names when return set is emtpy in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-21774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302313#comment-17302313 ] Jane Chan commented on FLINK-21774: --- Hi [~nicholasjiang], please also update the docs

[jira] [Created] (FLINK-21814) flink CollectSink error info unfriendly

Peihui He created FLINK-21814: - Summary: flink CollectSink error info unfriendly Key: FLINK-21814 URL: https://issues.apache.org/jira/browse/FLINK-21814 Project: Flink Issue Type: Improvement

[GitHub] [flink] westphal-jan commented on a change in pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

westphal-jan commented on a change in pull request #15140: URL: https://github.com/apache/flink/pull/15140#discussion_r594939796 ## File path: flink-connectors/flink-connector-rabbitmq2/src/test/java/org/apache/flink/connector/rabbitmq2/common/RabbitMQBaseTest.java ## @@ -0,0

[GitHub] [flink] flinkbot commented on pull request #15230: [FLINK-21300][docs] Update module-related documentation

flinkbot commented on pull request #15230: URL: https://github.com/apache/flink/pull/15230#issuecomment-800048489 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] rmetzger commented on a change in pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

rmetzger commented on a change in pull request #15064: URL: https://github.com/apache/flink/pull/15064#discussion_r594942821 ## File path: docs/content/docs/deployment/elastic_scaling.md ## @@ -0,0 +1,107 @@ +--- +title: Elastic Scaling +weight: 5 +type: docs + +--- + + +# Elas

[GitHub] [flink] rmetzger commented on a change in pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

rmetzger commented on a change in pull request #15064: URL: https://github.com/apache/flink/pull/15064#discussion_r594946177 ## File path: docs/content/docs/deployment/elastic_scaling.md ## @@ -0,0 +1,107 @@ +--- +title: Elastic Scaling +weight: 5 +type: docs + +--- + + +# Elas

[GitHub] [flink] rmetzger commented on a change in pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

rmetzger commented on a change in pull request #15064: URL: https://github.com/apache/flink/pull/15064#discussion_r594946630 ## File path: docs/content/docs/deployment/elastic_scaling.md ## @@ -0,0 +1,91 @@ +--- +title: Elastic Scaling +weight: 5 +type: docs + +--- + + +# Elast

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302315#comment-17302315 ] Till Rohrmann commented on FLINK-12030: --- Should we reopen this issue [~dwysakowicz

[GitHub] [flink] wenlong88 opened a new pull request #15231: [FLINK-21805][table-planner-blink] Support json ser/de for StreamExecRank, StreamExecLimit and StreamExecSortLimit

wenlong88 opened a new pull request #15231: URL: https://github.com/apache/flink/pull/15231 ## What is the purpose of the change Support json ser/de for StreamExecRank, StreamExecLimit and StreamExecSortLimit ## Brief change log Support json ser/de for StreamExecRank, StreamExe

[jira] [Updated] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit and StreamExecLimit Json ser/de

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

[GitHub] [flink] flinkbot commented on pull request #15231: [FLINK-21805][table-planner-blink] Support json ser/de for StreamExecRank, StreamExecLimit and StreamExecSortLimit

flinkbot commented on pull request #15231: URL: https://github.com/apache/flink/pull/15231#issuecomment-800057751 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] LadyForest commented on pull request #15230: [FLINK-21300][docs] Update module-related documentation

LadyForest commented on pull request #15230: URL: https://github.com/apache/flink/pull/15230#issuecomment-800058099 I'm also fine with updating myself if https://github.com/apache/flink/pull/15213 gets merged firstly. This i

[GitHub] [flink] rmetzger commented on pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

rmetzger commented on pull request #15064: URL: https://github.com/apache/flink/pull/15064#issuecomment-800058252 @xintongsong: Thanks for your comment! I left this PR stale for some days because I was focused on other work. I was aware of your comment, but didn't react to it! --

[GitHub] [flink] rmetzger commented on a change in pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

rmetzger commented on a change in pull request #15064: URL: https://github.com/apache/flink/pull/15064#discussion_r594950216 ## File path: docs/content/docs/deployment/elastic_scaling.md ## @@ -0,0 +1,107 @@ +--- +title: Elastic Scaling +weight: 5 +type: docs + +--- + + +# Elas

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

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

[GitHub] [flink] flinkbot edited a comment on pull request #15200: [FLINK-21355] Send changes to the state changelog

flinkbot edited a comment on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-798902665 ## CI report: * 5e1342d9916f5c4356c622a40bc27bcbdacde9d7 UNKNOWN * ece208b9da559a725362de3d5c4e39e05de5d35e Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

flinkbot edited a comment on pull request #15197: URL: https://github.com/apache/flink/pull/15197#issuecomment-798871985 ## CI report: * 546bb52a009fee535df450c4ce569f1d8019ff6a UNKNOWN * afa8be823a70be47cabce1f91eb0e8f24e60be35 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] eskabetxe opened a new pull request #15232: [FLINK-20130][core] Add ZStandard to FileInputFormat

eskabetxe opened a new pull request #15232: URL: https://github.com/apache/flink/pull/15232 What is the purpose of the change Allow FileInputFormat to read files compressed in ZStandard format Brief change log Added ZStandard as stream input Verifying this change T

[GitHub] [flink] flinkbot commented on pull request #15230: [FLINK-21300][docs] Update module-related documentation

flinkbot commented on pull request #15230: URL: https://github.com/apache/flink/pull/15230#issuecomment-800060276 ## CI report: * 569104dd1bb31158bf920f832d87b7d9d76513ac UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] eskabetxe commented on pull request #14054: [FLINK-20130][core] Add ZStandard to FileInputFormat

eskabetxe commented on pull request #14054: URL: https://github.com/apache/flink/pull/14054#issuecomment-800060570 @AHeise new PR here: https://github.com/apache/flink/pull/15232 This is an automated message from the Apache G

[GitHub] [flink] eskabetxe commented on pull request #15232: [FLINK-20130][core] Add ZStandard to FileInputFormat

eskabetxe commented on pull request #15232: URL: https://github.com/apache/flink/pull/15232#issuecomment-800061188 @AHeise could you check I have to add a new dependency for the test work correctly com.github.luben zstd-jni 1.4.9-1 test --

[jira] [Closed] (FLINK-21812) How to read data from kafka and sink to Postgresql Database

[ https://issues.apache.org/jira/browse/FLINK-21812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias closed FLINK-21812. Resolution: Won't Fix Hi Bhagi, have you had a look at [Apache Flink Kafka Connector docs|https://ci.apac

[GitHub] [flink] eskabetxe edited a comment on pull request #15232: [FLINK-20130][core] Add ZStandard to FileInputFormat

eskabetxe edited a comment on pull request #15232: URL: https://github.com/apache/flink/pull/15232#issuecomment-800061188 @AHeise could you check I have to add a new dependency for the test work correctly ` com.github.luben zstd-jni 1.4.9-1 test `

[jira] [Created] (FLINK-21815) Support StreamExecUnion json ser/de

Wenlong Lyu created FLINK-21815: --- Summary: Support StreamExecUnion json ser/de Key: FLINK-21815 URL: https://issues.apache.org/jira/browse/FLINK-21815 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302321#comment-17302321 ] Dawid Wysakowicz commented on FLINK-12030: -- Not sure, If I understood the discu

[jira] [Comment Edited] (FLINK-21812) How to read data from kafka and sink to Postgresql Database

[ https://issues.apache.org/jira/browse/FLINK-21812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302319#comment-17302319 ] Matthias edited comment on FLINK-21812 at 3/16/21, 8:30 AM:

[jira] [Commented] (FLINK-21532) Make CatalogTableImpl#toProperties and CatalogTableImpl#fromProperties case sensitive

[ https://issues.apache.org/jira/browse/FLINK-21532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302322#comment-17302322 ] Lsw_aka_laplace commented on FLINK-21532: - [~jark] Would u mind assigning it to

[jira] [Commented] (FLINK-21812) How to read data from kafka and sink to Postgresql Database

[ https://issues.apache.org/jira/browse/FLINK-21812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302329#comment-17302329 ] Bhagi commented on FLINK-21812: --- Thanks Matthias > How to read data from kafka and sink

[jira] [Assigned] (FLINK-21532) Make CatalogTableImpl#toProperties and CatalogTableImpl#fromProperties case sensitive

[ https://issues.apache.org/jira/browse/FLINK-21532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21532: --- Assignee: Lsw_aka_laplace > Make CatalogTableImpl#toProperties and CatalogTableImpl#fromProperties

[GitHub] [flink] Airblader commented on a change in pull request #15217: [FLINK-21396][table-planner-blink] Use ResolvedCatalogTable within the planner

Airblader commented on a change in pull request #15217: URL: https://github.com/apache/flink/pull/15217#discussion_r594961650 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPropertiesUtil.java ## @@ -74,7 +74,10 @@

[GitHub] [flink] flinkbot commented on pull request #15232: [FLINK-20130][core] Add ZStandard to FileInputFormat

flinkbot commented on pull request #15232: URL: https://github.com/apache/flink/pull/15232#issuecomment-800072547 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] zhuzhurk commented on a change in pull request #15192: [FLINK-21777][network] Replace the 4M data writing cache of sort-merge shuffle with writev system call

zhuzhurk commented on a change in pull request #15192: URL: https://github.com/apache/flink/pull/15192#discussion_r594963510 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PartitionedFileWriter.java ## @@ -202,26 +190,51 @@ private void

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15192: [FLINK-21777][network] Replace the 4M data writing cache of sort-merge shuffle with writev system call

gaoyunhaii commented on a change in pull request #15192: URL: https://github.com/apache/flink/pull/15192#discussion_r594938336 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -70,15 +81,18 @@ /**

[GitHub] [flink] flinkbot edited a comment on pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #15086: [FLINK-21561] Predownload/Cache large E2E test artifacts

flinkbot edited a comment on pull request #15086: URL: https://github.com/apache/flink/pull/15086#issuecomment-790506153 ## CI report: * 3f85a1bad5fb751a05590c7acfaae898549f9a21 UNKNOWN * 2394febfc54a6db9e1c5aac8896cc2b508c227dc UNKNOWN * 02b045262d72baf8304b8592ccb3b7b95a69

[GitHub] [flink] wenlong88 opened a new pull request #15233: [FLINK-21815][table-planner-blink] Support json ser/de for StreamExecUnion

wenlong88 opened a new pull request #15233: URL: https://github.com/apache/flink/pull/15233 ## What is the purpose of the change Support json ser/de for StreamExecUnion ## Brief change log Support json ser/de for StreamExecUnion ## Verifying this change This ch

[jira] [Commented] (FLINK-21728) DegreesWithExceptionITCase crash

[ https://issues.apache.org/jira/browse/FLINK-21728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302339#comment-17302339 ] Dawid Wysakowicz commented on FLINK-21728: -- Isn't it the case that we may run i

[GitHub] [flink] flinkbot edited a comment on pull request #15230: [FLINK-21300][docs] Update module-related documentation

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

rkhachatryan commented on a change in pull request #15119: URL: https://github.com/apache/flink/pull/15119#discussion_r594929467 ## File path: flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java ## @@ -26,42 +26,9 @@ public class CheckpointingOpt

[GitHub] [flink] flinkbot commented on pull request #15231: [FLINK-21805][table-planner-blink] Support json ser/de for StreamExecRank, StreamExecLimit and StreamExecSortLimit

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

[GitHub] [flink] flinkbot commented on pull request #15232: [FLINK-20130][core] Add ZStandard to FileInputFormat

flinkbot commented on pull request #15232: URL: https://github.com/apache/flink/pull/15232#issuecomment-800077162 ## CI report: * 8d7443192137a84f84445d3d8e759bc25c37dc31 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-21815) Support StreamExecUnion json ser/de

[ https://issues.apache.org/jira/browse/FLINK-21815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21815: --- Labels: pull-request-available (was: ) > Support StreamExecUnion json ser/de >

[jira] [Commented] (FLINK-21588) unable to create catalogs for postgresql

[ https://issues.apache.org/jira/browse/FLINK-21588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302340#comment-17302340 ] Bhagi commented on FLINK-21588: --- No,still issue is there > unable to create catalogs for

[GitHub] [flink] flinkbot commented on pull request #15233: [FLINK-21815][table-planner-blink] Support json ser/de for StreamExecUnion

flinkbot commented on pull request #15233: URL: https://github.com/apache/flink/pull/15233#issuecomment-800078415 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] AHeise commented on a change in pull request #15109: [FLINK-20955][connectors/hbase] HBase connector using new connector API

AHeise commented on a change in pull request #15109: URL: https://github.com/apache/flink/pull/15109#discussion_r594972495 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/reader/HBaseSourceDeserializer.java ## @@ -0,0

[jira] [Commented] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302342#comment-17302342 ] Peng Zhang commented on FLINK-21685: [~fly_in_gis] I confirm that increasing cluster

[jira] [Commented] (FLINK-21786) sample Job execution failed

[ https://issues.apache.org/jira/browse/FLINK-21786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302343#comment-17302343 ] Bhagi commented on FLINK-21786: --- Matthias, even tasks manager has access to file.. its fa

[jira] [Updated] (FLINK-21786) sample Job execution failed

[ https://issues.apache.org/jira/browse/FLINK-21786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-21786: -- Attachment: job logs.txt > sample Job execution failed > --- > > Key:

  1   2   3   4   5   6   7   >