[GitHub] [flink] zentol commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

zentol commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803465610 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -273,6 +274,8 @@ public void setupYarnClient() { }

[GitHub] [flink] vahmed-hamdy commented on a change in pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

vahmed-hamdy commented on a change in pull request #18669: URL: https://github.com/apache/flink/pull/18669#discussion_r803465710 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

zentol commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803465610 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -273,6 +274,8 @@ public void setupYarnClient() { }

[GitHub] [flink] gaoyunhaii commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

gaoyunhaii commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r803265948 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

flinkbot edited a comment on pull request #18689: URL: https://github.com/apache/flink/pull/18689#issuecomment-1033918208 ## CI report: * fa6bf00fd239c64c44c03447fc4f5a1b1bcbc314 Azure:

[jira] [Comment Edited] (FLINK-25985) e2e test covering the main functionality of the JobResultStore

[ https://issues.apache.org/jira/browse/FLINK-25985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490055#comment-17490055 ] Matthias Pohl edited comment on FLINK-25985 at 2/10/22, 9:21 AM: - *

[GitHub] [flink] MrWhiteSike commented on pull request #18698: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chinese.

MrWhiteSike commented on pull request #18698: URL: https://github.com/apache/flink/pull/18698#issuecomment-1034681531 [@flinkbot ](https://github.com/flinkbot) run Azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

flinkbot edited a comment on pull request #18672: URL: https://github.com/apache/flink/pull/18672#issuecomment-1033272608 ## CI report: * e88e25f069efe98417e027028d3fdf202379dd92 Azure:

[jira] [Commented] (FLINK-25985) e2e test covering the main functionality of the JobResultStore

[ https://issues.apache.org/jira/browse/FLINK-25985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490055#comment-17490055 ] Matthias Pohl commented on FLINK-25985: --- * cancelling a cleanuprunner > e2e test covering the

[jira] [Commented] (FLINK-25985) e2e test covering the main functionality of the JobResultStore

[ https://issues.apache.org/jira/browse/FLINK-25985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490054#comment-17490054 ] Matthias Pohl commented on FLINK-25985: --- {quote} * leadership lost: concurrent cleanup * retry

[GitHub] [flink] dmvk commented on pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

dmvk commented on pull request #18699: URL: https://github.com/apache/flink/pull/18699#issuecomment-1034678046 Sounds like a right place to me  -- 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

[GitHub] [flink] XComp commented on pull request #18692: [FLINK-26015] Fixes object store bug

XComp commented on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034676861 The license checker failed because of the `curator-test` dependency being added. That introduces a new transitive dependency for guava. I excluded that dependency from

[GitHub] [flink] flinkbot edited a comment on pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18698: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chinese.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

flinkbot edited a comment on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1034510296 ## CI report: * 34a2b1811fd7bc75e2c1e9c8462ab9573d506559 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

flinkbot edited a comment on pull request #18689: URL: https://github.com/apache/flink/pull/18689#issuecomment-1033918208 ## CI report: * fa6bf00fd239c64c44c03447fc4f5a1b1bcbc314 Azure:

[GitHub] [flink] pltbkd commented on pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

pltbkd commented on pull request #18699: URL: https://github.com/apache/flink/pull/18699#issuecomment-1034673667 @dmvk Sure. I have added a test to verify this. The case will fail if I revert the change of this PR. But I am not sure if it's at the right place. Since no

[GitHub] [flink] metaswirl commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

metaswirl commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803453533 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public

[jira] [Updated] (FLINK-25862) Refactor SharedStateRegistry to not limit StreamStateHandle to register/unregister

[ https://issues.apache.org/jira/browse/FLINK-25862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25862: -- Fix Version/s: 1.16.0 > Refactor SharedStateRegistry to not limit StreamStateHandle

[GitHub] [flink] flinkbot edited a comment on pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

flinkbot edited a comment on pull request #18624: URL: https://github.com/apache/flink/pull/18624#issuecomment-1029176049 ## CI report: * 861fa3fa04ca63de1ce8cfc9b057699ebc0e2002 Azure:

[GitHub] [flink] zentol commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

zentol commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803453042 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh ## @@ -225,4 +225,9 @@ function get_host_machine_address { fi } +function

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

flinkbot edited a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1018078894 ## CI report: * 6408af3118bf294fdb704e36af7568756f3bd1c5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

flinkbot edited a comment on pull request #18624: URL: https://github.com/apache/flink/pull/18624#issuecomment-1029176049 ## CI report: * 861fa3fa04ca63de1ce8cfc9b057699ebc0e2002 Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

dannycranmer commented on a change in pull request #18669: URL: https://github.com/apache/flink/pull/18669#discussion_r803439459 ## File path:

[GitHub] [flink] dmvk commented on a change in pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

dmvk commented on a change in pull request #18651: URL: https://github.com/apache/flink/pull/18651#discussion_r803439528 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -267,18 +267,31 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18700: [FLINK-26070][Python] Update dependency numpy to >=1.21.0,<1.22

flinkbot edited a comment on pull request #18700: URL: https://github.com/apache/flink/pull/18700#issuecomment-1034649114 ## CI report: * a03576e0a414443a0174b4f3240aedb5520fe3b5 Azure:

[GitHub] [flink] matriv commented on a change in pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

matriv commented on a change in pull request #18624: URL: https://github.com/apache/flink/pull/18624#discussion_r803434975 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecPythonCalc.java ## @@ -39,6

[GitHub] [flink] matriv commented on a change in pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

matriv commented on a change in pull request #18624: URL: https://github.com/apache/flink/pull/18624#discussion_r803434013 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMatch.java ## @@ -92,6 +92,11

[jira] [Assigned] (FLINK-25640) Enhance the document for blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-25640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao reassigned FLINK-25640: --- Assignee: Yingjie Cao > Enhance the document for blocking shuffle >

[GitHub] [flink] flinkbot commented on pull request #18700: [FLINK-26070][Python] Update dependency numpy to >=1.21.0,<1.22

flinkbot commented on pull request #18700: URL: https://github.com/apache/flink/pull/18700#issuecomment-1034649779 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 #18700: [FLINK-26070][Python] Update dependency numpy to >=1.21.0,<1.22

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

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * 6d3fd5e55dcb2402ffc49ca7fbf8854c8090b854 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 42bf48fdbba63580ec0d5418579e2e65c413cf38 Azure:

[jira] [Commented] (FLINK-25992) JobDispatcherITCase.testRecoverFromCheckpointAfterLosingAndRegainingLeadership fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490043#comment-17490043 ] Roman Khachatryan commented on FLINK-25992: --- Thanks for looking into it [~Jiangang]. The

[jira] [Updated] (FLINK-26070) Update dependency numpy to >=1.21.0,<1.22

[ https://issues.apache.org/jira/browse/FLINK-26070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26070: --- Labels: pull-request-available (was: ) > Update dependency numpy to >=1.21.0,<1.22 >

[GitHub] [flink] MartijnVisser opened a new pull request #18700: [FLINK-26070][Python] Update dependency numpy to >=1.21.0,<1.22

MartijnVisser opened a new pull request #18700: URL: https://github.com/apache/flink/pull/18700 ## What is the purpose of the change * Update numpy to the latest version 1.22 ## Brief change log * Updated all version references to numpy to 1.22 ## Verifying this

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * 6d3fd5e55dcb2402ffc49ca7fbf8854c8090b854 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18676: [FLINK-26035][build][planner] Add table-planner-loader-helper module

flinkbot edited a comment on pull request #18676: URL: https://github.com/apache/flink/pull/18676#issuecomment-1033442314 ## CI report: * 51f70c89ee9e6ab9964793a032653fc027e498d0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18648: [FLINK-25845][table] Introduce EXECUTE PLAN

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

[GitHub] [flink] flinkbot edited a comment on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

flinkbot edited a comment on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1022021934 ## CI report: * 42bf48fdbba63580ec0d5418579e2e65c413cf38 Azure:

[jira] [Assigned] (FLINK-26070) Update dependency numpy to >=1.21.0,<1.22

[ https://issues.apache.org/jira/browse/FLINK-26070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-26070: -- Assignee: Martijn Visser > Update dependency numpy to >=1.21.0,<1.22 >

[GitHub] [flink] ruanhang1993 commented on pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

ruanhang1993 commented on pull request #18516: URL: https://github.com/apache/flink/pull/18516#issuecomment-1034640876 @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] [Created] (FLINK-26070) Update dependency numpy to >=1.21.0,<1.22

Martijn Visser created FLINK-26070: -- Summary: Update dependency numpy to >=1.21.0,<1.22 Key: FLINK-26070 URL: https://issues.apache.org/jira/browse/FLINK-26070 Project: Flink Issue Type:

[GitHub] [flink] dmvk commented on a change in pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

dmvk commented on a change in pull request #18686: URL: https://github.com/apache/flink/pull/18686#discussion_r803419819 ## File path: flink-connectors/flink-connector-aws-kinesis-data-streams/src/test/java/org/apache/flink/connectors/kinesis/testutils/KinesaliteContainer.java

[GitHub] [flink] flinkbot edited a comment on pull request #18676: [FLINK-26035][build][planner] Add table-planner-loader-helper module

flinkbot edited a comment on pull request #18676: URL: https://github.com/apache/flink/pull/18676#issuecomment-1033442314 ## CI report: * 51f70c89ee9e6ab9964793a032653fc027e498d0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18648: [FLINK-25845][table] Introduce EXECUTE PLAN

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

[GitHub] [flink] flinkbot edited a comment on pull request #18649: [FLINK-25844][table-api-java] Introduce StatementSet#compilePlan

flinkbot edited a comment on pull request #18649: URL: https://github.com/apache/flink/pull/18649#issuecomment-1031570072 ## CI report: * 7abbdf54df75a8e9e0041e908ab61d785d800410 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18649: [FLINK-25844][table-api-java] Introduce StatementSet#compilePlan

flinkbot edited a comment on pull request #18649: URL: https://github.com/apache/flink/pull/18649#issuecomment-1031570072 ## CI report: * 7abbdf54df75a8e9e0041e908ab61d785d800410 Azure:

[GitHub] [flink] slinkydeveloper commented on pull request #18648: [FLINK-25845][table] Introduce EXECUTE PLAN

slinkydeveloper commented on pull request #18648: URL: https://github.com/apache/flink/pull/18648#issuecomment-1034627356 @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-20195) Jobs endpoint returns duplicated jobs

[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490036#comment-17490036 ] Guillaume Vauvert commented on FLINK-20195: --- Please note that this fix triggers

[jira] [Updated] (FLINK-25995) Make implicit assumption of SQL local hash explicit

[ https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-25995: Summary: Make implicit assumption of SQL local hash explicit (was: Make implicit assumption of SQL local

[jira] [Updated] (FLINK-25995) Make implicit assumption of SQL local hash explicit

[ https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-25995: Description: If there are multiple consecutive and the same hash shuffles, SQL planner will change them

[jira] [Updated] (FLINK-25992) JobDispatcherITCase.testRecoverFromCheckpointAfterLosingAndRegainingLeadership fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25992: -- Component/s: Runtime / Coordination >

[GitHub] [flink] slinkydeveloper commented on pull request #18649: [FLINK-25844][table-api-java] Introduce StatementSet#compilePlan

slinkydeveloper commented on pull request #18649: URL: https://github.com/apache/flink/pull/18649#issuecomment-1034627012 @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] slinkydeveloper edited a comment on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

slinkydeveloper edited a comment on pull request #18657: URL: https://github.com/apache/flink/pull/18657#issuecomment-1034623498 Hi @JingsongLi @tsreaper, I have a question about this PR. I stumbled upon this and, without Avro knowledge, I thought it was wrong as I initially thought

[GitHub] [flink] flinkbot edited a comment on pull request #18693: [FLINK-25987][state/changelog] Make lastAppendedSqn optional

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

[GitHub] [flink] flinkbot edited a comment on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

flinkbot edited a comment on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561 ## CI report: * ce93ea4f52aad9d4d7adfaecdb470f25fdf86689 Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid confi

dannycranmer commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803412486 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[GitHub] [flink] slinkydeveloper commented on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

slinkydeveloper commented on pull request #18657: URL: https://github.com/apache/flink/pull/18657#issuecomment-1034623498 Hi @JingsongLi @tsreaper, I have a question about this PR. I stumbled upon this and, without Avro knowledge, I thought it was wrong as I initially thought the

[GitHub] [flink] flinkbot edited a comment on pull request #18693: [FLINK-25987][state/changelog] Make lastAppendedSqn optional

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

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * fbdf72f62409be6aa9d7ff9663029a90bc38585b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * b8a5ce340b7a1c8e1e4bfb5e0b215dc7bfe0 Azure:

[GitHub] [flink] dmvk commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

dmvk commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803408662 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[GitHub] [flink] flinkbot edited a comment on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

flinkbot edited a comment on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561 ## CI report: * ce93ea4f52aad9d4d7adfaecdb470f25fdf86689 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 83d261d7dfaa98ed991d32f2600ce9d9acc181e2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18641: [FLINK-25761] [docs] Translate Avro format page into Chinese.

flinkbot edited a comment on pull request #18641: URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534 ## CI report: * 60ff1ee473b47a6fad8440dd6b9cc635633c56b8 Azure:

[GitHub] [flink-benchmarks] wsry commented on pull request #49: [FLINK-25959] Add micro-benchmarks for the sort-based blocking shuffle

wsry commented on pull request #49: URL: https://github.com/apache/flink-benchmarks/pull/49#issuecomment-1034619286 @pnowojski As discussed in FLINK-25704, I add a micro-benchmark for the sort-based blocking shuffle, please take a look when you have time. -- This is an automated message

[GitHub] [flink] dannycranmer commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid confi

dannycranmer commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803407497 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[GitHub] [flink] dmvk commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

dmvk commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803406852 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * fbdf72f62409be6aa9d7ff9663029a90bc38585b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * b8a5ce340b7a1c8e1e4bfb5e0b215dc7bfe0 Azure:

[jira] [Updated] (FLINK-25959) Add a micro-benchmark for the sort-based blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-25959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25959: --- Labels: pull-request-available (was: ) > Add a micro-benchmark for the sort-based blocking

[GitHub] [flink] flinkbot edited a comment on pull request #18641: [FLINK-25761] [docs] Translate Avro format page into Chinese.

flinkbot edited a comment on pull request #18641: URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534 ## CI report: * 60ff1ee473b47a6fad8440dd6b9cc635633c56b8 Azure:

[GitHub] [flink-benchmarks] wsry opened a new pull request #49: [FLINK-25959] Add micro-benchmarks for the sort-based blocking shuffle

wsry opened a new pull request #49: URL: https://github.com/apache/flink-benchmarks/pull/49 This patch adds micro-benchmarks for the sort-based blocking shuffle. -- 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] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 83d261d7dfaa98ed991d32f2600ce9d9acc181e2 Azure:

[jira] [Updated] (FLINK-25725) Agile configurable modules in web ui

[ https://issues.apache.org/jira/browse/FLINK-25725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junhan Yang updated FLINK-25725: Summary: Agile configurable modules in web ui (was: Refactor web-dashboard's folder structure

[jira] [Updated] (FLINK-25725) Agile configurable modules in web ui

[ https://issues.apache.org/jira/browse/FLINK-25725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junhan Yang updated FLINK-25725: Description: For modules like task-manager and job-manager, use an injection token to allow a

[GitHub] [flink] autophagy commented on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

autophagy commented on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1034614935 @dmvk Thanks! I've removed it, squashed the commits and force pushed up. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

slinkydeveloper commented on a change in pull request #18653: URL: https://github.com/apache/flink/pull/18653#discussion_r803396778 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java ## @@

[GitHub] [flink] dannycranmer commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

dannycranmer commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1034613000 @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] dannycranmer commented on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

dannycranmer commented on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1034613077 @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] MrWhiteSike commented on pull request #18641: [FLINK-25761] [docs] Translate Avro format page into Chinese.

MrWhiteSike commented on pull request #18641: URL: https://github.com/apache/flink/pull/18641#issuecomment-1034612417 [@flinkbot ](https://github.com/flinkbot) run Azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] wanglijie95 commented on a change in pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

wanglijie95 commented on a change in pull request #18673: URL: https://github.com/apache/flink/pull/18673#discussion_r803401510 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/ForwardForLocalKeyByPartitioner.java ## @@ -0,0

[jira] [Commented] (FLINK-26062) [Changelog] Non-deterministic recovery of PriorityQueue states

[ https://issues.apache.org/jira/browse/FLINK-26062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490020#comment-17490020 ] Roman Khachatryan commented on FLINK-26062: --- Good point, yes, peek() is also affected.

[GitHub] [flink] dmvk commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

dmvk commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803400739 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -273,6 +274,8 @@ public void setupYarnClient() { }

[jira] [Assigned] (FLINK-26065) org.apache.flink.table.api.PlanReference$ContentPlanReference $FilePlanReference $ResourcePlanReference violation the api rules

[ https://issues.apache.org/jira/browse/FLINK-26065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-26065: --- Assignee: Francesco Guardiani >

[GitHub] [flink] flinkbot edited a comment on pull request #18505: [FLINK-25796][network] Avoid record copy for result partition of sort-shuffle if there are enough buffers for better performance

flinkbot edited a comment on pull request #18505: URL: https://github.com/apache/flink/pull/18505#issuecomment-1021169033 ## CI report: * 6216fd083e98baa0408e7884b9129afd8c135973 Azure:

[GitHub] [flink] zhuzhurk commented on a change in pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

zhuzhurk commented on a change in pull request #18673: URL: https://github.com/apache/flink/pull/18673#discussion_r803389214 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/ForwardForConsecutiveHashPartitioner.java ## @@ -0,0

<    6   7   8   9   10   11