[jira] [Commented] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462436#comment-17462436 ] RocMarshal commented on FLINK-25380: Hi, [~arvid] May I have a try on the ticket ? B

[jira] [Updated] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25380: --- Description: This feature should be arranged after  # FLINK-21373 # FLINK-20628 was:This  > I

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

ruanhang1993 commented on a change in pull request #18137: URL: https://github.com/apache/flink/pull/18137#discussion_r772143083 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/testutils/KafkaSourceExternalContext.java ###

[GitHub] [flink] flinkbot edited a comment on pull request #18152: [FLINK-25364][python][table-planner] Remove dependency on planner internal code generation

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

[GitHub] [flink] MartijnVisser commented on pull request #18149: Update log4j to 2.17 to address CVE-2021-45105.

MartijnVisser commented on pull request #18149: URL: https://github.com/apache/flink/pull/18149#issuecomment-997676826 @theArtechnology Any idea when you'll be able to update the PR? There's a Flink ticket created for this too https://issues.apache.org/jira/browse/FLINK-25375 and I do thin

[jira] [Commented] (FLINK-25375) Update Log4j to 2.17.0

[ https://issues.apache.org/jira/browse/FLINK-25375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462433#comment-17462433 ] Martijn Visser commented on FLINK-25375: Thanks for noticing that [~Sergey Nuyan

[jira] [Updated] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25380: --- Description: This  > Introduce DynamicTableSink & DynamicTableSource for RabbitMQ >

[jira] [Updated] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25380: --- Issue Type: New Feature (was: Improvement) > Introduce DynamicTableSink & DynamicTableSource for Ra

[GitHub] [flink] slinkydeveloper commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

slinkydeveloper commented on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-997676689 @MartijnVisser this PR adds support for the limit keyword, that is instead of defining `number-of-rows` per doc, you can also omit that option and instead per query set

[GitHub] [flink] flinkbot commented on pull request #18152: [FLINK-25364][python][table-planner] Remove dependency on planner internal code generation

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

[jira] [Commented] (FLINK-25379) Support limit push down in DATAGEN connector.

[ https://issues.apache.org/jira/browse/FLINK-25379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462432#comment-17462432 ] Martijn Visser commented on FLINK-25379: You can already specify the number of r

[GitHub] [flink] flinkbot commented on pull request #18152: [FLINK-25364][python][table-planner] Remove dependency on planner internal code generation

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

[jira] [Created] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

RocMarshal created FLINK-25380: -- Summary: Introduce DynamicTableSink & DynamicTableSource for RabbitMQ Key: FLINK-25380 URL: https://issues.apache.org/jira/browse/FLINK-25380 Project: Flink Iss

[jira] [Updated] (FLINK-25364) Don't generate code in open() methods of Python operators

[ https://issues.apache.org/jira/browse/FLINK-25364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25364: --- Labels: pull-request-available (was: ) > Don't generate code in open() methods of Python op

[GitHub] [flink] slinkydeveloper opened a new pull request #18152: [FLINK-25364][python][table-planner] Remove dependency on planner internal code generation

slinkydeveloper opened a new pull request #18152: URL: https://github.com/apache/flink/pull/18152 Signed-off-by: slinkydeveloper ## What is the purpose of the change Remove dependency on planner internal code generation. ## Brief change log * Remove depen

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462425#comment-17462425 ] zhenlong dong commented on FLINK-24456: --- [~monster#12]  That,s enough for test. In

[jira] [Commented] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462424#comment-17462424 ] zhenlong dong commented on FLINK-24456: --- [~monster#12] That,s enough for test. In

[jira] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456 ] zhenlong dong deleted comment on FLINK-24456: --- was (Author: dragonpic): [~monster#12] That,s enough for test. In that way, SQL api and streaming api are different in use. Will it confuse u

[GitHub] [flink] wuchong commented on pull request #18056: [FLINK-25074][streaming] Simplify name of WindowOperator

wuchong commented on pull request #18056: URL: https://github.com/apache/flink/pull/18056#issuecomment-997662274 @godfreyhe do you want to merge it? -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] YuvalItzchakov commented on a change in pull request #17845: [FLINK-24352] [flink-table-planner] Add null check for temporal table check on SqlSnapshot

YuvalItzchakov commented on a change in pull request #17845: URL: https://github.com/apache/flink/pull/17845#discussion_r772127406 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/validate/SqlValidatorImpl.java ## @@ -4711,6 +4711,11 @@ privat

[GitHub] [flink] ZhangChaoming commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

ZhangChaoming commented on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-997659985 @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 spe

[GitHub] [flink] flinkbot commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink] flinkbot commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

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

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

gaoyunhaii commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772109840 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/Graph.java ## @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Software Foundation (

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #20: [FLINK-23959][FLIP-175] Compose Estimator/Model/AlgoOperator from DAG of Estimator/Model/AlgoOperator

gaoyunhaii commented on a change in pull request #20: URL: https://github.com/apache/flink-ml/pull/20#discussion_r772116079 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/builder/GraphExecutionHelper.java ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache Softw

[jira] [Updated] (FLINK-25379) Support limit push down in DATAGEN connector.

[ https://issues.apache.org/jira/browse/FLINK-25379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25379: --- Labels: pull-request-available (was: ) > Support limit push down in DATAGEN connector. > --

[GitHub] [flink] ZhangChaoming opened a new pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

ZhangChaoming opened a new pull request #18151: URL: https://github.com/apache/flink/pull/18151 ## What is the purpose of the change Support limit push down in DATAGEN connector. ## Brief change log - Support limit push down in DATAGEN connector. ##

[jira] [Closed] (FLINK-25373) task manager can not free memory when jobs are finished

[ https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob closed FLINK-25373. - Resolution: Not A Problem > task manager can not free memory when jobs are finished > --

[jira] [Commented] (FLINK-25373) task manager can not free memory when jobs are finished

[ https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462420#comment-17462420 ] Spongebob commented on FLINK-25373: --- Hi Xintong, Thanks for your kind explanatory, no

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

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

[jira] [Created] (FLINK-25379) Support limit push down in DATAGEN connector.

Moses created FLINK-25379: - Summary: Support limit push down in DATAGEN connector. Key: FLINK-25379 URL: https://issues.apache.org/jira/browse/FLINK-25379 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[jira] [Updated] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database

[ https://issues.apache.org/jira/browse/FLINK-25369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25369: - Summary: CatalogManager provide wrong tables or views in given catalog database (was: CatalogManager pr

[GitHub] [flink] imaffe commented on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

imaffe commented on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-997651179 @PatrickRen Updated ~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specifi

[GitHub] [flink] flinkbot edited a comment on pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] liyubin117 removed a comment on pull request #18146: [FLINK-25369][table] CatalogManager provide right tables or views in given catalog database name

liyubin117 removed a comment on pull request #18146: URL: https://github.com/apache/flink/pull/18146#issuecomment-997646918 @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 th

[jira] [Commented] (FLINK-25373) task manager can not free memory when jobs are finished

[ https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462412#comment-17462412 ] Xintong Song commented on FLINK-25373: -- [~SpongebobZ], I think the behavior you ob

[GitHub] [flink] liyubin117 commented on pull request #18146: [FLINK-25369][table] CatalogManager provide right tables or views in given catalog database name

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

[GitHub] [flink] flinkbot edited a comment on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #18150: [docs] Fix typo

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

[GitHub] [flink] flinkbot edited a comment on pull request #17953: [FLINK-24481][docs] Translate buffer debloat documenation to chinese

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

[GitHub] [flink] flinkbot commented on pull request #18150: [docs] Fix typo

flinkbot commented on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-997636482 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] Myracle commented on pull request #17953: [FLINK-24481][docs] Translate buffer debloat documenation to chinese

Myracle commented on pull request #17953: URL: https://github.com/apache/flink/pull/17953#issuecomment-997636373 @xintongsong Thank you for the review. I have modified the code. Please review again. -- This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink] flinkbot commented on pull request #18150: [docs] Fix typo

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

[GitHub] [flink] flinkbot edited a comment on pull request #17953: [FLINK-24481][docs] Translate buffer debloat documenation to chinese

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

[GitHub] [flink] aihai opened a new pull request #18150: [docs] Fix typo

aihai opened a new pull request #18150: URL: https://github.com/apache/flink/pull/18150 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on e

[jira] [Commented] (FLINK-25373) task manager can not free memory when jobs are finished

[ https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462403#comment-17462403 ] Spongebob commented on FLINK-25373: --- Hi Xintong, # I have checked the memory usage of

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] flinkbot edited a comment on pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

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

[GitHub] [flink] zjureel commented on a change in pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

zjureel commented on a change in pull request #18007: URL: https://github.com/apache/flink/pull/18007#discussion_r772091393 ## File path: flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/FencedRpcEndpoint.java ## @@ -56,10 +56,12 @@ protected FencedRpcEndpoi

[jira] [Commented] (FLINK-25328) Improvement of reuse segments for join/agg/sort operators in TaskManager for flink olap queries

[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462390#comment-17462390 ] Xintong Song commented on FLINK-25328: -- [~zjureel], Making segment reusing feature

[jira] [Updated] (FLINK-25328) Improvement of reuse segments for join/agg/sort operators in TaskManager for flink olap queries

[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-25328: Summary: Improvement of reuse segments for join/agg/sort operators in TaskManager for flink olap queries

[jira] [Commented] (FLINK-25328) Improvement of share memory manager between jobs if they use the same slot in TaskManager for flink olap queries

[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462382#comment-17462382 ] Shammon commented on FLINK-25328: - [~xtsong] I think you raise an important difference b

[GitHub] [flink] flinkbot edited a comment on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

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

[GitHub] [flink] flinkbot edited a comment on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

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

[GitHub] [flink] X-czh commented on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager

X-czh commented on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997590285 @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 co

[jira] [Created] (FLINK-25378) kubernetes's request/limit resource can been seperated?

jeff-zou created FLINK-25378: Summary: kubernetes's request/limit resource can been seperated? Key: FLINK-25378 URL: https://issues.apache.org/jira/browse/FLINK-25378 Project: Flink Issue Type: N

[jira] [Created] (FLINK-25377) kubernetes's request/limit resource can been seperated?

jeff-zou created FLINK-25377: Summary: kubernetes's request/limit resource can been seperated? Key: FLINK-25377 URL: https://issues.apache.org/jira/browse/FLINK-25377 Project: Flink Issue Type: N

[jira] [Comment Edited] (FLINK-25373) task manager can not free memory when jobs are finished

[ https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462378#comment-17462378 ] Xintong Song edited comment on FLINK-25373 at 12/20/21, 3:56 AM: -

[jira] [Commented] (FLINK-25373) task manager can not free memory when jobs are finished

[ https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462378#comment-17462378 ] Xintong Song commented on FLINK-25373: -- Hi [~SpongebobZ], I think these threads ar

[GitHub] [flink-ml] gaoyunhaii closed pull request #24: [FLINK-24557] Add Estimator and Transformer for K-nearest neighbor

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

[jira] [Created] (FLINK-25376) Too many JM logs in flink session cluster for olap queries

Shammon created FLINK-25376: --- Summary: Too many JM logs in flink session cluster for olap queries Key: FLINK-25376 URL: https://issues.apache.org/jira/browse/FLINK-25376 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

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

[jira] [Commented] (FLINK-25176) Introduce "ALTER TABLE ... COMPACT" SQL

[ https://issues.apache.org/jira/browse/FLINK-25176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462374#comment-17462374 ] Jingsong Lee commented on FLINK-25176: -- [~qingyue] Thanks! Assigned to u~ > Introd

[jira] [Assigned] (FLINK-25176) Introduce "ALTER TABLE ... COMPACT" SQL

[ https://issues.apache.org/jira/browse/FLINK-25176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-25176: Assignee: Jane Chan > Introduce "ALTER TABLE ... COMPACT" SQL > -

[GitHub] [flink] flinkbot edited a comment on pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

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

[GitHub] [flink] zuston commented on pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

zuston commented on pull request #18087: URL: https://github.com/apache/flink/pull/18087#issuecomment-997564732 All done @KarmaGYZ Thanks. -- 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 spe

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [FLINK-24557] Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r772060051 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModelData.java ## @@ -0,0 +1,117 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink] flinkbot edited a comment on pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

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

[jira] [Commented] (FLINK-25176) Introduce "ALTER TABLE ... COMPACT" SQL

[ https://issues.apache.org/jira/browse/FLINK-25176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462368#comment-17462368 ] Jane Chan commented on FLINK-25176: --- Hi, [~lzljs3620320], I'm interested in this subta

[GitHub] [flink] imaffe commented on pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

imaffe commented on pull request #18125: URL: https://github.com/apache/flink/pull/18125#issuecomment-997551112 @zentol Yes ~ I'll rebase once FLINK-25340 is resolved ~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[jira] [Commented] (FLINK-24556) Support Logistic Regression in FlinkML

[ https://issues.apache.org/jira/browse/FLINK-24556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462364#comment-17462364 ] Yun Gao commented on FLINK-24556: - Merge on master via 0f20eeb72a46e8dc1995a1c806c676b9

[jira] [Closed] (FLINK-24556) Support Logistic Regression in FlinkML

[ https://issues.apache.org/jira/browse/FLINK-24556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24556. --- Fix Version/s: ml-0.1.0 Assignee: Zhipeng Zhang Resolution: Fixed > Support Logistic Regress

[GitHub] [flink-ml] gaoyunhaii closed pull request #28: [FLINK-24556] Add Estimator and Transformer for logistic regression

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

[jira] [Commented] (FLINK-25372) Add thread dump feature for jobmanager

[ https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462363#comment-17462363 ] Xintong Song commented on FLINK-25372: -- Thanks [~Zhanghao Chen]. I think this is a

[jira] [Assigned] (FLINK-25372) Add thread dump feature for jobmanager

[ https://issues.apache.org/jira/browse/FLINK-25372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-25372: Assignee: Zhanghao Chen > Add thread dump feature for jobmanager > --

[GitHub] [flink] flinkbot edited a comment on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

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

[GitHub] [flink] KarmaGYZ commented on a change in pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

KarmaGYZ commented on a change in pull request #18087: URL: https://github.com/apache/flink/pull/18087#discussion_r772045629 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/ContainerRequestReflectorTest.java ## @@ -0,0 +1,171 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink] flinkbot edited a comment on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

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

[jira] [Closed] (FLINK-25310) Fix the incorrect description for output network buffers in buffer debloat documenation

[ https://issues.apache.org/jira/browse/FLINK-25310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu closed FLINK-25310. --- Resolution: Fixed > Fix the incorrect description for output network buffers in buffer debloat > documenation > --

[GitHub] [flink] RocMarshal commented on pull request #18056: [FLINK-25074][streaming] Simplify name of WindowOperator

RocMarshal commented on pull request #18056: URL: https://github.com/apache/flink/pull/18056#issuecomment-997530116 @wenlong88 There's nothing better. LGTM+1. Ping @wuchong @xintongsong . -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] wenlong88 commented on pull request #18056: [FLINK-25074][streaming] Simplify name of WindowOperator

wenlong88 commented on pull request #18056: URL: https://github.com/apache/flink/pull/18056#issuecomment-997521544 hi, @RocMarshal thanks for the review, there is no much value on such refactoring IMO, the code is similar but not the same, the difference is to ignore evictor when it is nu

[jira] [Commented] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462349#comment-17462349 ] Wenlong Lyu commented on FLINK-25330: - Hi, Maybe we could support customized Deseria

[GitHub] [flink] flinkbot edited a comment on pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

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

[jira] [Updated] (FLINK-10007) Security vulnerability in website build infrastructure

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

[jira] [Updated] (FLINK-9794) JDBCOutputFormat does not consider idle connection and multithreads synchronization

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

[jira] [Updated] (FLINK-10146) numBuffersOut not updated properly

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

[jira] [Updated] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

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

[jira] [Updated] (FLINK-10002) WebUI shows logs unfriendly, especially when the amount of logs is large

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

[jira] [Updated] (FLINK-10119) JsonRowDeserializationSchema deserialize kafka message

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

  1   2   >