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

[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_r776194977 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -137,6 +137,15 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18225: [hotfix] [javadocs] Fix typo in org.apache.flink.sql.parser.ddl.SqlCr…

flinkbot edited a comment on pull request #18225: URL: https://github.com/apache/flink/pull/18225#issuecomment-1002403111 ## CI report: * 0b3ca1d8af0f84c0e6c4d3e7e23a88d4d933dea0 Azure:

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

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

tillrohrmann commented on pull request #18222: URL: https://github.com/apache/flink/pull/18222#issuecomment-1002443184 Thanks a lot for the review @Myasuka and @SteNicholas. I will resolve your comment and then merge the PR. -- This is an automated message from the Apache Git Service.

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

tillrohrmann commented on a change in pull request #18222: URL: https://github.com/apache/flink/pull/18222#discussion_r776193369 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBHandle.java ##

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

tillrohrmann commented on a change in pull request #18222: URL: https://github.com/apache/flink/pull/18222#discussion_r776193021 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBHandle.java ##

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

tillrohrmann commented on a change in pull request #18222: URL: https://github.com/apache/flink/pull/18222#discussion_r776192813 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBHandle.java ##

[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_r776192128 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -137,6 +137,15 @@

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

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

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

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

flinkbot commented on pull request #18227: URL: https://github.com/apache/flink/pull/18227#issuecomment-1002440201 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 #18227: [hotfix] Fix typo hasAggreateExprs -> hasAggregateExprs in HiveParser…

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

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

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

[jira] [Updated] (FLINK-25473) Azure pipeline failed due to stopped hearing from agent Azure Pipelines 11

[ https://issues.apache.org/jira/browse/FLINK-25473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25473: -- Priority: Critical (was: Major) > Azure pipeline failed due to stopped hearing from agent

[jira] [Updated] (FLINK-25473) Azure pipeline failed due to stopped hearing from agent Azure Pipelines 11

[ https://issues.apache.org/jira/browse/FLINK-25473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25473: -- Fix Version/s: 1.15.0 > Azure pipeline failed due to stopped hearing from agent Azure

[GitHub] [flink] sky-walking opened a new pull request #18227: [hotfix] Fix typo hasAggreateExprs -> hasAggregateExprs in HiveParser…

sky-walking opened a new pull request #18227: URL: https://github.com/apache/flink/pull/18227 [hotfix] Fix typo hasAggreateExprs -> hasAggregateExprs in HiveParserQBSubQuery.java -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

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

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

flinkbot edited a comment on pull request #18224: URL: https://github.com/apache/flink/pull/18224#issuecomment-1002391830 ## CI report: * 231c43147b7e31805dec744a8aa7caf14d57c6ab Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-25474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25474: --- Labels: pull-request-available (was: ) > Idea Scala plugin can not compile RexExplainUtil

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

[GitHub] [flink] godfreyhe opened a new pull request #18226: [FLINK-25474][table-planner] Fix Idea Scala plugin can not compile RexExplainUtil

godfreyhe opened a new pull request #18226: URL: https://github.com/apache/flink/pull/18226 ## What is the purpose of the change *Fix Idea Scala plugin can not compile RexExplainUtil, see the description in FLINK-25474* ## Brief change log - *Use Multiline

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-25474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25474: -- Assignee: godfrey he > Idea Scala plugin can not compile RexExplainUtil >

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

godfrey he created FLINK-25474: -- Summary: Idea Scala plugin can not compile RexExplainUtil Key: FLINK-25474 URL: https://issues.apache.org/jira/browse/FLINK-25474 Project: Flink Issue Type:

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

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

[GitHub] [flink] flinkbot edited a comment on pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

flinkbot edited a comment on pull request #18215: URL: https://github.com/apache/flink/pull/18215#issuecomment-1001883080 ## CI report: * bf622cc8bec7b7d00a94bb48ff09cbe8e93c23df Azure:

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

[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: * 6f8364dcd45ee44369137a7de06922f8f08e667d Azure:

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

[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: * 6f8364dcd45ee44369137a7de06922f8f08e667d Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

JingsongLi commented on a change in pull request #18219: URL: https://github.com/apache/flink/pull/18219#discussion_r776175705 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala ## @@ -533,4 +536,44 @@

[GitHub] [flink] JingsongLi commented on a change in pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

JingsongLi commented on a change in pull request #18219: URL: https://github.com/apache/flink/pull/18219#discussion_r776175449 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala ## @@ -370,6 +371,7 @@

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

[jira] [Commented] (FLINK-25426) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP because it cannot allocate enough network buffers

[ https://issues.apache.org/jira/browse/FLINK-25426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466322#comment-17466322 ] Jing Zhang commented on FLINK-25426: Another instance:

[GitHub] [flink] JingsongLi commented on a change in pull request #18219: [FLINK-25178][table] Throw exception when managed table sink needs checkpointing

JingsongLi commented on a change in pull request #18219: URL: https://github.com/apache/flink/pull/18219#discussion_r776173479 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala ## @@ -533,4 +536,44 @@

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

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

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

JingsongLi commented on a change in pull request #18199: URL: https://github.com/apache/flink/pull/18199#discussion_r776172010 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdHandlerTestBase.scala ## @@

[jira] [Created] (FLINK-25473) Azure pipeline failed due to stopped hearing from agent Azure Pipelines 11

Yun Gao created FLINK-25473: --- Summary: Azure pipeline failed due to stopped hearing from agent Azure Pipelines 11 Key: FLINK-25473 URL: https://issues.apache.org/jira/browse/FLINK-25473 Project: Flink

[jira] [Commented] (FLINK-24216) org.apache.flink.test.scheduling.AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond blocked on azure

[ https://issues.apache.org/jira/browse/FLINK-24216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466318#comment-17466318 ] Yun Gao commented on FLINK-24216: -

[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 ] Martijn Visser updated FLINK-25472: --- Affects Version/s: 1.15.0 1.12.8 1.13.6

[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 ] Martijn Visser updated FLINK-25472: --- Fix Version/s: 1.12.8 > Update to Log4j 2.17.1 > -- > >

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

Martijn Visser created FLINK-25472: -- Summary: Update to Log4j 2.17.1 Key: FLINK-25472 URL: https://issues.apache.org/jira/browse/FLINK-25472 Project: Flink Issue Type: Technical Debt

[GitHub] [flink] MartijnVisser commented on pull request #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.

MartijnVisser commented on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-1002412629 Thanks @leonardBang -- 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] [Updated] (FLINK-25471) wrong result if table transfrom to DataStream then keyey 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: Description: I have a dataStream with 6 lines datas like this: Row.of("Alice"), Row.of("alice"),

[jira] [Updated] (FLINK-25471) wrong result if table transfrom to DataStream then keyey 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: Description: I have a dataStream with 6 lines datas like this: Row.of("Alice"), Row.of("alice"),

[jira] [Updated] (FLINK-25471) wrong result if table transfrom to DataStream then keyey 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: Environment: mac book pro m1  jdk 8  scala 2.11 flink 1.14.2 idea 2020 was: mac book pro m1  jdk

[jira] [Updated] (FLINK-25471) wrong result if table transfrom to DataStream then keyey 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 keyey sum in Batch Mode (was: wrong result

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey 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: Description: I have a dataStream with 6 lines datas like this: Row.of("Alice"), Row.of("alice"),

[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: * 05a6a104d89ec0adc15fb4724f87ced5f33378ba Azure:

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey 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: Component/s: Table SQL / Runtime Description: I have a dataStream with 6 lines datas like this:

[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: * 05a6a104d89ec0adc15fb4724f87ced5f33378ba Azure:

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey 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: Attachment: (was: TableToDataStreamBatchWordCount.scala) > wrong result if table toDataStream then

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey 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: Description: I have a dataStream with 6 lines datas like this: Row.of("Alice"), Row.of("alice"),

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey 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: Attachment: TableToDataStreamBatchWordCount-1.scala > wrong result if table toDataStream then keyey sum

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey 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 toDataStream then keyey sum in Batch Mode (was: wrong result if table

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey by 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: Description: I have a dataStream with 6 lines datas like this: Row.of("Alice"), Row.of("alice"),

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey by 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: Attachment: TableToDataStreamBatchWordCount.scala > wrong result if table toDataStream then keyey by sum

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey by 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: Description: I have a dataStream with 6 lines datas like this: Row.of("Alice"), Row.of("alice"),

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey by 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: Attachment: pom.xml > wrong result if table toDataStream then keyey by sum in Batch Mode >

[GitHub] [flink] flinkbot edited a comment on pull request #18225: [hotfix] [javadocs] Fix typo in org.apache.flink.sql.parser.ddl.SqlCr…

flinkbot edited a comment on pull request #18225: URL: https://github.com/apache/flink/pull/18225#issuecomment-1002403111 ## CI report: * 0b3ca1d8af0f84c0e6c4d3e7e23a88d4d933dea0 Azure:

[GitHub] [flink] flinkbot commented on pull request #18225: [hotfix] [javadocs] Fix typo in org.apache.flink.sql.parser.ddl.SqlCr…

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

[GitHub] [flink] flinkbot commented on pull request #18225: [hotfix] [javadocs] Fix typo in org.apache.flink.sql.parser.ddl.SqlCr…

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

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey by 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: Description: I have 6 lines like this: Row.of("Alice"), Row.of("alice"), Row.of("Bob"), Row.of("lily"),

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey by 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: Description: I have 6 lines like this: Row.of("Alice"), Row.of("alice"), Row.of("Bob"), Row.of("lily"),

[GitHub] [flink] chenxyz707 opened a new pull request #18225: [hotfix] [javadocs] Fix typo in org.apache.flink.sql.parser.ddl.SqlCr…

chenxyz707 opened a new pull request #18225: URL: https://github.com/apache/flink/pull/18225 ## What is the purpose of the change Fix typo in org.apache.flink.sql.parser.ddl.SqlCreateTable and add override annotation for methods ## Brief change log *(for

[jira] [Updated] (FLINK-25471) wrong result if table toDataStream then keyey by 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 toDataStream then keyey by sum in Batch Mode (was: wrong result if table

[jira] [Created] (FLINK-25471) wrong result if table toDataStream then keyey by sum

zhangzh created FLINK-25471: --- Summary: wrong result if table toDataStream then keyey by sum Key: FLINK-25471 URL: https://issues.apache.org/jira/browse/FLINK-25471 Project: Flink Issue Type: Bug

[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=17466307#comment-17466307 ] Surendra Lalwani commented on FLINK-25463: -- So I am using a UDF which extends

[jira] [Comment Edited] (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=17466307#comment-17466307 ] Surendra Lalwani edited comment on FLINK-25463 at 12/29/21, 5:13 AM: -

[jira] [Updated] (FLINK-25470) Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization size

[ https://issues.apache.org/jira/browse/FLINK-25470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-25470: - Attachment: Screen Shot 2021-12-29 at 1.09.48 PM.png > Add/Expose/Differentiate metrics of checkpoint

[jira] [Updated] (FLINK-25470) Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization size

[ https://issues.apache.org/jira/browse/FLINK-25470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-25470: - Description: Right now, the checkpoint size includes both changelog size + materialization size We

[jira] [Updated] (FLINK-25470) Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization size

[ https://issues.apache.org/jira/browse/FLINK-25470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-25470: - Summary: Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization

[jira] [Created] (FLINK-25470) Add/Expose/differentiate metrics of checkpoint size between changelog size vs materialization size

Yuan Mei created FLINK-25470: Summary: Add/Expose/differentiate metrics of checkpoint size between changelog size vs materialization size Key: FLINK-25470 URL: https://issues.apache.org/jira/browse/FLINK-25470

[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: * 6f8364dcd45ee44369137a7de06922f8f08e667d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

flinkbot edited a comment on pull request #18224: URL: https://github.com/apache/flink/pull/18224#issuecomment-1002391830 ## CI report: * 231c43147b7e31805dec744a8aa7caf14d57c6ab Azure:

[GitHub] [flink] flinkbot commented on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

flinkbot commented on pull request #18224: URL: https://github.com/apache/flink/pull/18224#issuecomment-1002392284 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 #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[jira] [Updated] (FLINK-25143) Add ITCase for periodic materialization

[ https://issues.apache.org/jira/browse/FLINK-25143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25143: --- Labels: pull-request-available (was: ) > Add ITCase for periodic materialization >

[GitHub] [flink] masteryhx opened a new pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

masteryhx opened a new pull request #18224: URL: https://github.com/apache/flink/pull/18224 ## What is the purpose of the change Add ITCase for periodic materialization in Changelog state backend. This verifies that checkpointing works correctly for Changelog state backend

[GitHub] [flink] chenxyz707 closed pull request #16225: [hotfix] [javadocs] Fix typo in SqlCreateTable

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

[GitHub] [flink] curcur commented on a change in pull request #18217: [FLINK-25466][state] Enable state descriptor to handle StateTtlConfig#DISABLED

curcur commented on a change in pull request #18217: URL: https://github.com/apache/flink/pull/18217#discussion_r776145663 ## File path: flink-core/src/test/java/org/apache/flink/api/common/state/StateDescriptorTest.java ## @@ -251,6 +253,15 @@ public void go() {

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

[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: * 640a09dcb49c9d2d8eeb3a2ce7a884f837b99cdf Azure:

[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_r776139112 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfoTest.java ## @@ -20,13 +20,27 @@ import

[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: * 6f8364dcd45ee44369137a7de06922f8f08e667d Azure:

[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: * 6f8364dcd45ee44369137a7de06922f8f08e667d Azure:

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

beyond1920 commented on pull request #17684: URL: https://github.com/apache/flink/pull/17684#issuecomment-1002376334 @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-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466297#comment-17466297 ] Yuan Mei commented on FLINK-25423: -- Thanks [~sjwiesman] ! I will! > Enable loading state backend via

[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: * 16807de0cdce89f9739ee854c4542c53294d1299 Azure:

[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: * 16807de0cdce89f9739ee854c4542c53294d1299 Azure:

  1   2   3   4   5   >