[jira] [Created] (FLINK-25475) When windowAgg and groupAgg are included at the same time, there is no assigner generated but MiniBatch optimization is still used.

ChangjiGuo created FLINK-25475: -- Summary: When windowAgg and groupAgg are included at the same time, there is no assigner generated but MiniBatch optimization is still used. Key: FLINK-25475 URL: https://issues.apach

[jira] [Created] (FLINK-25476) CharType lost in the creation of MaxAggFunction & MinAggFunction

zoucao created FLINK-25476: -- Summary: CharType lost in the creation of MaxAggFunction & MinAggFunction Key: FLINK-25476 URL: https://issues.apache.org/jira/browse/FLINK-25476 Project: Flink Issue T

[GitHub] [flink] tillrohrmann closed pull request #18222: [FLINK-25468] Copy SST files if they cannot be hard linked in RocksDBHandle.restoreInstanceDirectoryFromPath

tillrohrmann closed pull request #18222: URL: https://github.com/apache/flink/pull/18222 -- 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-un

[jira] [Commented] (FLINK-25475) When windowAgg and groupAgg are included at the same time, there is no assigner generated but MiniBatch optimization is still used.

[ https://issues.apache.org/jira/browse/FLINK-25475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466345#comment-17466345 ] ChangjiGuo commented on FLINK-25475: Hello [~jark], Can you help me review this issu

[jira] [Updated] (FLINK-25475) When windowAgg and groupAgg are included at the same time, there is no assigner generated but MiniBatch optimization is still used.

[ https://issues.apache.org/jira/browse/FLINK-25475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-25475: --- Affects Version/s: (was: 1.14.0) > When windowAgg and groupAgg are included at the same time, th

[GitHub] [flink] RyanSkraba commented on pull request #18133: [FLINK-24718][avro] update AVRO dependency to latest version

RyanSkraba commented on pull request #18133: URL: https://github.com/apache/flink/pull/18133#issuecomment-1002455465 @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 speci

[GitHub] [flink] flinkbot edited a comment on pull request #18133: [FLINK-24718][avro] update AVRO dependency to latest version

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

[jira] [Closed] (FLINK-25468) Local recovery fails if local state storage and RocksDB working directory are not on the same volume

[ https://issues.apache.org/jira/browse/FLINK-25468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25468. - Resolution: Fixed Fixed via 1.15.0: 6bab695f85f8c9b1fec926880480c4ffb414a44b 1.14.3: f851f583e0

[GitHub] [flink] tillrohrmann commented on a change in pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

tillrohrmann commented on a change in pull request #18158: URL: https://github.com/apache/flink/pull/18158#discussion_r776206917 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -137,6 +137,15 @@ .noDefault

[GitHub] [flink] flinkbot edited a comment on pull request #18133: [FLINK-24718][avro] update AVRO dependency to latest version

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

[GitHub] [flink] flinkbot edited a comment on pull request #18218: [FLINK-18295] Rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer

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

[GitHub] [flink] flinkbot edited a comment on pull request #18218: [FLINK-18295] Rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer

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

[GitHub] [flink] MartijnVisser opened a new pull request #18228: [FLINK-25472][core] Update to Log4j 2.17.1

MartijnVisser opened a new pull request #18228: URL: https://github.com/apache/flink/pull/18228 ## What is the purpose of the change * Update Log4j dependency to 2.17.1 to address CVE-2021-44832 ## Brief change log * Updated POM file * Updated NOTICE license files

[jira] [Updated] (FLINK-25472) Update to Log4j 2.17.1

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

[GitHub] [flink] sky-walking opened a new pull request #18229: [hotfix] Fix typo my_stram -> my_stream

sky-walking opened a new pull request #18229: URL: https://github.com/apache/flink/pull/18229 [hotfix] Fix typo my_stram -> my_stream -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] flinkbot edited a comment on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

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

[GitHub] [flink] flinkbot commented on pull request #18228: [FLINK-25472][core] Update to Log4j 2.17.1

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

[GitHub] [flink] flinkbot commented on pull request #18228: [FLINK-25472][core] Update to Log4j 2.17.1

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

[GitHub] [flink] MartijnVisser opened a new pull request #18230: [FLINK-25472][BP 1.14][core] Update to Log4j 2.17.1

MartijnVisser opened a new pull request #18230: URL: https://github.com/apache/flink/pull/18230 Backport of https://github.com/apache/flink/pull/18228 -- 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 g

[GitHub] [flink] sky-walking opened a new pull request #18231: [hotfix] Fix typo DataStram -> DataStream

sky-walking opened a new pull request #18231: URL: https://github.com/apache/flink/pull/18231 [hotfix] Fix typo DataStram -> DataStream -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif

[GitHub] [flink] flinkbot commented on pull request #18229: [hotfix] Fix typo my_stram -> my_stream

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

[GitHub] [flink] MartijnVisser opened a new pull request #18232: [FLINK-25472][BP 1-1.3][core] Update to Log4j 2.17.1

MartijnVisser opened a new pull request #18232: URL: https://github.com/apache/flink/pull/18232 Backport of https://github.com/apache/flink/pull/18228 -- 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 g

[GitHub] [flink] flinkbot edited a comment on pull request #18228: [FLINK-25472][core] Update to Log4j 2.17.1

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

[GitHub] [flink] flinkbot commented on pull request #18229: [hotfix] Fix typo my_stram -> my_stream

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

[GitHub] [flink] flinkbot commented on pull request #18230: [FLINK-25472][BP 1.14][core] Update to Log4j 2.17.1

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

[GitHub] [flink] zuston commented on a change in pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

zuston commented on a change in pull request #18158: URL: https://github.com/apache/flink/pull/18158#discussion_r776217830 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -137,6 +137,15 @@ .noDefaultValue(

[GitHub] [flink] MartijnVisser opened a new pull request #18233: [FLINK-25472][BP 1.12][core] Update to Log4j 2.17.1

MartijnVisser opened a new pull request #18233: URL: https://github.com/apache/flink/pull/18233 Backport of https://github.com/apache/flink/pull/18228 -- 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 g

[jira] [Commented] (FLINK-25463) Set is not supported in User Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-25463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466356#comment-17466356 ] Wenlong Lyu commented on FLINK-25463: - hi, [~surendra.lalwani], As I known, there is

[GitHub] [flink] flinkbot commented on pull request #18231: [hotfix] Fix typo DataStram -> DataStream

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

[GitHub] [flink] flinkbot commented on pull request #18230: [FLINK-25472][BP 1.14][core] Update to Log4j 2.17.1

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

[jira] [Created] (FLINK-25477) The directory structure of the State Backends document is not standardized

Hangxiang Yu created FLINK-25477: Summary: The directory structure of the State Backends document is not standardized Key: FLINK-25477 URL: https://issues.apache.org/jira/browse/FLINK-25477 Project: F

[GitHub] [flink] flinkbot edited a comment on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

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

[GitHub] [flink] flinkbot edited a comment on pull request #18230: [FLINK-25472][BP 1.14][core] Update to Log4j 2.17.1

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

[GitHub] [flink] flinkbot edited a comment on pull request #18229: [hotfix] Fix typo my_stram -> my_stream

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

[GitHub] [flink] flinkbot commented on pull request #18231: [hotfix] Fix typo DataStram -> DataStream

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

[GitHub] [flink] flinkbot commented on pull request #18232: [FLINK-25472][BP 1-1.3][core] Update to Log4j 2.17.1

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

[GitHub] [flink] flinkbot commented on pull request #18233: [FLINK-25472][BP 1.12][core] Update to Log4j 2.17.1

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

[GitHub] [flink] flinkbot commented on pull request #18233: [FLINK-25472][BP 1.12][core] Update to Log4j 2.17.1

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

[GitHub] [flink] flinkbot commented on pull request #18232: [FLINK-25472][BP 1-1.3][core] Update to Log4j 2.17.1

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

[GitHub] [flink] zuston commented on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

zuston commented on pull request #18158: URL: https://github.com/apache/flink/pull/18158#issuecomment-1002471449 @tillrohrmann Thanks again for your kind and patience. By the way, could you help review #18157 ? -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

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

[GitHub] [flink] flinkbot edited a comment on pull request #18233: [FLINK-25472][BP 1.12][core] Update to Log4j 2.17.1

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

[GitHub] [flink] flinkbot edited a comment on pull request #18232: [FLINK-25472][BP 1-1.3][core] Update to Log4j 2.17.1

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

[GitHub] [flink] flinkbot edited a comment on pull request #18231: [hotfix] Fix typo DataStram -> DataStream

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

[jira] [Updated] (FLINK-25471) wrong result if table transfrom to DataStream then keyby sum in Batch Mode

[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangzh updated FLINK-25471: Summary: wrong result if table transfrom to DataStream then keyby sum in Batch Mode (was: wrong result i

[jira] [Commented] (FLINK-25474) Idea Scala plugin can not compile RexExplainUtil

[ https://issues.apache.org/jira/browse/FLINK-25474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466365#comment-17466365 ] Martijn Visser commented on FLINK-25474: [~godfreyhe] Flink 1.15 doesn't support

[GitHub] [flink] beyond1920 merged pull request #17684: [FLINK-23999][table-planner] Support evaluating individual window table-valued function in planner

beyond1920 merged pull request #17684: URL: https://github.com/apache/flink/pull/17684 -- 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-unsu

[jira] [Commented] (FLINK-23999) Support evaluating individual window table-valued function in planner

[ https://issues.apache.org/jira/browse/FLINK-23999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466368#comment-17466368 ] Jing Zhang commented on FLINK-23999: Fixed in master: https://github.com/apache/fli

[jira] [Resolved] (FLINK-23999) Support evaluating individual window table-valued function in planner

[ https://issues.apache.org/jira/browse/FLINK-23999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang resolved FLINK-23999. Resolution: Fixed > Support evaluating individual window table-valued function in planner > --

[jira] [Comment Edited] (FLINK-23999) Support evaluating individual window table-valued function in planner

[ https://issues.apache.org/jira/browse/FLINK-23999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466368#comment-17466368 ] Jing Zhang edited comment on FLINK-23999 at 12/29/21, 9:18 AM: ---

[jira] [Closed] (FLINK-23999) Support evaluating individual window table-valued function in planner

[ https://issues.apache.org/jira/browse/FLINK-23999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang closed FLINK-23999. -- > Support evaluating individual window table-valued function in planner >

[GitHub] [flink] echauchot commented on pull request #18211: [FLINK-25415] implement retrial on connections to Cassandra container

echauchot commented on pull request #18211: URL: https://github.com/apache/flink/pull/18211#issuecomment-1002480108 @tillrohrmann CI is green, can we merge the PR ? As usual we will monitor for flakiness for a week or two and see if the PR solves the problem. -- This is an automated mess

[GitHub] [flink] shouweikun commented on a change in pull request #18199: [FLINK-25183] Optimize changelog normalize for the managed table upse…

shouweikun commented on a change in pull request #18199: URL: https://github.com/apache/flink/pull/18199#discussion_r776232478 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesManagedTableFactory.java ## @@ -0,0 +1,

[GitHub] [flink] shouweikun commented on a change in pull request #18199: [FLINK-25183] Optimize changelog normalize for the managed table upse…

shouweikun commented on a change in pull request #18199: URL: https://github.com/apache/flink/pull/18199#discussion_r776232478 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesManagedTableFactory.java ## @@ -0,0 +1,

[GitHub] [flink] flinkbot edited a comment on pull request #18227: [hotfix] Fix typo hasAggreateExprs -> hasAggregateExprs in HiveParser…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18226: [FLINK-25474][table-planner] Fix Idea Scala plugin can not compile RexExplainUtil

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

[GitHub] [flink] flinkbot edited a comment on pull request #18133: [FLINK-24718][avro] update AVRO dependency to latest version

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

[GitHub] [flink] flinkbot edited a comment on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

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

[GitHub] [flink] pnowojski commented on a change in pull request #18210: [FLINK-25454][runtime] Pause and resume time for throughput calculator only from one thread.

pnowojski commented on a change in pull request #18210: URL: https://github.com/apache/flink/pull/18210#discussion_r776249889 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java ## @@ -717,14 +717,11 @@ public S

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

RocMarshal commented on a change in pull request #15140: URL: https://github.com/apache/flink/pull/15140#discussion_r776250487 ## File path: flink-connectors/flink-connector-rabbitmq2/src/main/java/org/apache/flink/connector/rabbitmq2/common/RabbitMQConnectionConfig.java ## @@

[jira] [Commented] (FLINK-25469) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466390#comment-17466390 ] Martijn Visser commented on FLINK-25469: cc [~fpaul] :) > FlinkKafkaProducerITC

[jira] [Updated] (FLINK-21186) RecordWriterOutput swallows interrupt state when interrupted.

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

[jira] [Updated] (FLINK-9620) Add an alternative option to choose when deal with eventtime cep

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

[jira] [Updated] (FLINK-15476) Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy

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

[jira] [Updated] (FLINK-20823) Update documentation to mention Table/SQL API doesn't provide cross-major-version state compatibility

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

[jira] [Updated] (FLINK-9607) Support ParquetTableSink

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

[jira] [Updated] (FLINK-9617) Provide alias for whole records in Table API

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

[jira] [Updated] (FLINK-22072) Rethink UnfulfillableSlotRequestException class hierarchy

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

[jira] [Updated] (FLINK-9657) Suspicious output from Bucketing sink E2E test on travis

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

[jira] [Updated] (FLINK-20760) Broken doc link in Apache Flink Code Style and Quality Guide

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

[jira] [Updated] (FLINK-9605) Support KafkaProtoBufTableSink

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

[jira] [Updated] (FLINK-10031) Support handling late events in Table API & SQL

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

[jira] [Updated] (FLINK-9604) Support KafkaProtoBufTableSource

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

[jira] [Updated] (FLINK-7765) Enable dependency convergence

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

[jira] [Updated] (FLINK-20569) testKafkaSourceSinkWithMetadata hangs

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

[jira] [Updated] (FLINK-7916) Remove NetworkStackThroughputITCase

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

[jira] [Updated] (FLINK-11007) Update documentation to describe new checkpoint metadata file behavior

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

[jira] [Updated] (FLINK-11658) Implement HadoopMapreduceITCase for new Hadoop API

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

[jira] [Updated] (FLINK-10947) Document handling of null keys in the data types documentation

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

[jira] [Updated] (FLINK-11323) Upgrade KryoSerializer snapshot to implement new TypeSerializerSnapshot interface

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

[jira] [Updated] (FLINK-9523) Add Kafka examples for Flink Table/SQL API

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

[jira] [Updated] (FLINK-25306) Flink CLI end-to-end test timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25306: --- Labels: stale-critical test-stability (was: test-stability) I am the [Flink Jira Bot|https:

[jira] [Updated] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

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

[GitHub] [flink] flinkbot edited a comment on pull request #18208: [FLINK-25335][Runtime/Coordination, Connectors/Hive] Improvement of task deployment by enable source split asynchronous enumerate

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

[jira] [Closed] (FLINK-25417) Too many connections for TM

[ https://issues.apache.org/jira/browse/FLINK-25417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25417. -- Resolution: Duplicate > Too many connections for TM > --- > >

[GitHub] [flink] MartijnVisser opened a new pull request #18234: [hotfix][docs] Fixing multiple 404 links in docs

MartijnVisser opened a new pull request #18234: URL: https://github.com/apache/flink/pull/18234 ## What is the purpose of the change * Addressing multiple 404s ## Brief change log * Updated references to documentation in various places ## Verifying this change

[jira] [Commented] (FLINK-22643) Too many TCP connections among TaskManagers for large scale jobs

[ https://issues.apache.org/jira/browse/FLINK-22643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466423#comment-17466423 ] Piotr Nowojski commented on FLINK-22643: Currently it looks like nobody is worki

[GitHub] [flink] flinkbot commented on pull request #18234: [hotfix][docs] Fixing multiple 404 links in docs

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

[GitHub] [flink] flinkbot commented on pull request #18234: [hotfix][docs] Fixing multiple 404 links in docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #18234: [hotfix][docs] Fixing multiple 404 links in docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #18218: [FLINK-18295] Rework IntermediateDataSet and IntermediateResultPartition to explicitly have one consumer

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

[GitHub] [flink] flinkbot edited a comment on pull request #18229: [hotfix] Fix typo my_stram -> my_stream

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

[GitHub] [flink-web] zhipeng93 commented on a change in pull request #493: Add flink-ml 2.0.0

zhipeng93 commented on a change in pull request #493: URL: https://github.com/apache/flink-web/pull/493#discussion_r776283257 ## File path: downloads.md ## @@ -200,6 +200,24 @@ You can add the following dependencies to your `pom.xml` to include Apache Flink The `statefun-sdk`

[GitHub] [flink-web] zhipeng93 commented on a change in pull request #493: Add flink-ml 2.0.0

zhipeng93 commented on a change in pull request #493: URL: https://github.com/apache/flink-web/pull/493#discussion_r776283257 ## File path: downloads.md ## @@ -200,6 +200,24 @@ You can add the following dependencies to your `pom.xml` to include Apache Flink The `statefun-sdk`

[GitHub] [flink-web] zhipeng93 commented on a change in pull request #493: Add flink-ml 2.0.0

zhipeng93 commented on a change in pull request #493: URL: https://github.com/apache/flink-web/pull/493#discussion_r776283257 ## File path: downloads.md ## @@ -200,6 +200,24 @@ You can add the following dependencies to your `pom.xml` to include Apache Flink The `statefun-sdk`

[GitHub] [flink] rmetzger commented on a change in pull request #17996: [FLINK-23230] Fix protoc dependency for Apple Silicon / m1 support

rmetzger commented on a change in pull request #17996: URL: https://github.com/apache/flink/pull/17996#discussion_r776289081 ## File path: flink-formats/flink-parquet/pom.xml ## @@ -131,8 +131,17 @@ under the License. org.apache.hadoop

[GitHub] [flink] rmetzger commented on a change in pull request #17996: [FLINK-23230] Fix protoc dependency for Apple Silicon / m1 support

rmetzger commented on a change in pull request #17996: URL: https://github.com/apache/flink/pull/17996#discussion_r776291237 ## File path: flink-formats/flink-parquet/pom.xml ## @@ -131,8 +131,17 @@ under the License. org.apache.hadoop

[GitHub] [flink] rmetzger commented on pull request #17996: [FLINK-23230] Fix protoc dependency for Apple Silicon / m1 support

rmetzger commented on pull request #17996: URL: https://github.com/apache/flink/pull/17996#issuecomment-1002560301 @AHeise / @fapaul I've manually tested the Parquet Format support with this change, and it works. -- This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] flinkbot edited a comment on pull request #18158: [FLINK-25398] Show complete stacktrace when requesting thread dump

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

  1   2   3   4   5   >