[GitHub] [flink] flinkbot edited a comment on pull request #15013: [FLINK-21490][datastream] Make job graph generation deterministic in respect to hashes of input nodes.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15014: [FLINK-21490][datastream] Make job graph generation deterministic in respect to hashes of input nodes. [1.12]

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

[GitHub] [flink] flinkbot edited a comment on pull request #14994: [FLINK-21452][connector/common] Stop snapshotting registered readers in source coordinator.

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

[GitHub] [flink] flinkbot commented on pull request #15018: [FLINK-21460][table api] Use Configuration to create TableEnvironment

flinkbot commented on pull request #15018: URL: https://github.com/apache/flink/pull/15018#issuecomment-785696441 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-21499) maven package hang when using multithread on jdk 11

[ https://issues.apache.org/jira/browse/FLINK-21499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290754#comment-17290754 ] Matthias commented on FLINK-21499: -- Ok, I missed that FLINK-20092 already tackles this

[jira] [Updated] (FLINK-21460) Use Configuration to create TableEnvironment

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

[GitHub] [flink] fsk119 opened a new pull request #15018: [FLINK-21460][table api] Use Configuration to create TableEnvironment

fsk119 opened a new pull request #15018: URL: https://github.com/apache/flink/pull/15018 ## What is the purpose of the change *Allow to create table environment from `Configuration`. However, it's not allowed to modify the planner type or execution mode when table environment

[jira] [Commented] (FLINK-21499) maven package hang when using multithread on jdk 11

[ https://issues.apache.org/jira/browse/FLINK-21499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290751#comment-17290751 ] Matthias commented on FLINK-21499: -- Hi [~Tony Giao], thanks for reporting this issue. C

[jira] [Closed] (FLINK-21499) maven package hang when using multithread on jdk 11

[ https://issues.apache.org/jira/browse/FLINK-21499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21499. Resolution: Duplicate > maven package hang when using multithread on jdk 11 >

[GitHub] [flink] flinkbot edited a comment on pull request #15014: [FLINK-21490][datastream] Make job graph generation deterministic in respect to hashes of input nodes. [1.12]

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

[GitHub] [flink] flinkbot edited a comment on pull request #15013: [FLINK-21490][datastream] Make job graph generation deterministic in respect to hashes of input nodes.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15003: [FLINK-21482][table-planner-blink] Support grouping set syntax for WindowAggregate

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

[GitHub] [flink] flinkbot edited a comment on pull request #14994: [FLINK-21452][connector/common] Stop snapshotting registered readers in source coordinator.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14775: [FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator

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

[jira] [Updated] (FLINK-21499) maven package hang when using multithread on jdk 11

[ https://issues.apache.org/jira/browse/FLINK-21499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21499: - Component/s: Build System > maven package hang when using multithread on jdk 11 > --

[jira] [Commented] (FLINK-21490) UnalignedCheckpointITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290742#comment-17290742 ] Arvid Heise commented on FLINK-21490: - The error is probably test-only: For some rea

[jira] [Commented] (FLINK-21473) Migrate ParquetInputFormat to BulkFormat interface

[ https://issues.apache.org/jira/browse/FLINK-21473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290741#comment-17290741 ] Jingsong Lee commented on FLINK-21473: -- [~ZhenqiuHuang] I think it is good. > Migr

[jira] [Commented] (FLINK-21497) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover fail

[ https://issues.apache.org/jira/browse/FLINK-21497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290738#comment-17290738 ] Matthias commented on FLINK-21497: -- Thanks [~maguowei] for reporting this test instabil

[jira] [Updated] (FLINK-21497) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover fail

[ https://issues.apache.org/jira/browse/FLINK-21497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21497: - Parent: FLINK-21075 Issue Type: Sub-task (was: Bug) > FileSourceTextLinesITCase.testBoundedText

[GitHub] [flink] wuchong commented on a change in pull request #14725: [FLINK-20977] Fix use the "USE DATABASE" command bug

wuchong commented on a change in pull request #14725: URL: https://github.com/apache/flink/pull/14725#discussion_r582595061 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -256,7 +256,7 @@ private static Sq

[jira] [Updated] (FLINK-20977) can not use `use` command to switch database

[ https://issues.apache.org/jira/browse/FLINK-20977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20977: Fix Version/s: 1.12.2 > can not use `use` command to switch database > --

[jira] [Closed] (FLINK-21494) Could not execute statement 'USE `default`' in Flink SQL client

[ https://issues.apache.org/jira/browse/FLINK-21494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21494. --- Fix Version/s: (was: 1.12.2) (was: 1.13.0) Resolution: Duplicate > Could n

[jira] [Commented] (FLINK-21473) Migrate ParquetInputFormat to BulkFormat interface

[ https://issues.apache.org/jira/browse/FLINK-21473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290733#comment-17290733 ] Zhenqiu Huang commented on FLINK-21473: --- [~lzljs3620320] According to existing imp

[GitHub] [flink] flinkbot edited a comment on pull request #15017: [FLINK-12607][rest] Introduce a REST API that returns the maxParallelism

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

[GitHub] [flink] flinkbot edited a comment on pull request #15004: [FLINK-21253][table-planner-blink] Support grouping set syntax for GroupWindowAggregate

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

[GitHub] [flink] flinkbot edited a comment on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

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

[GitHub] [flink] Jiayi-Liao edited a comment on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

Jiayi-Liao edited a comment on pull request #15016: URL: https://github.com/apache/flink/pull/15016#issuecomment-785653274 @carp84 It took me some time to dig how to test this change, but unfortunately there may not be an easy way to achieve this. Take the `TtlListState` as an examp

[GitHub] [flink] docete commented on pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

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

[GitHub] [flink] Jiayi-Liao edited a comment on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

Jiayi-Liao edited a comment on pull request #15016: URL: https://github.com/apache/flink/pull/15016#issuecomment-785653274 @carp84 It took me some time to dig how to test this change, but unfortunately there may not be an easy way to achieve this. Take the `TtlListState` as an examp

[GitHub] [flink] flinkbot commented on pull request #15017: [FLINK-12607][rest] Introduce a REST API that returns the maxParallelism

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

[jira] [Commented] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290724#comment-17290724 ] John Phelan commented on FLINK-12607: - hey [~rmetzger] [~trohrmann] I opened a [gith

[GitHub] [flink] flinkbot edited a comment on pull request #14962: [FLINK-18789][sql-client] Use TableEnvironment#executeSql method to execute insert statement in sql client

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

[jira] [Updated] (FLINK-21460) Use Configuration to create TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-21460: -- Description: We can use new options {{table.planner}}, {{execution.runtime-mode}} to create ta

[GitHub] [flink] flinkbot edited a comment on pull request #14840: [FLINK-21231][sql-client] add "SHOW VIEWS" to SQL client

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

[GitHub] [flink] flinkbot edited a comment on pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

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

[jira] [Updated] (FLINK-21460) Use Configuration to create TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-21460: -- Summary: Use Configuration to create TableEnvironment (was: Introduce option `table.planner`,

[GitHub] [flink] flinkbot commented on pull request #15017: [FLINK-12607][rest] Introduce a REST API that returns the maxParallelism

flinkbot commented on pull request #15017: URL: https://github.com/apache/flink/pull/15017#issuecomment-785658072 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] [Updated] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12607: --- Labels: pull-request-available starter (was: starter) > Introduce a REST API that returns t

[GitHub] [flink] bytesandwich opened a new pull request #15017: [FLINK-12607][rest] Introduce a REST API that returns the maxParallelism

bytesandwich opened a new pull request #15017: URL: https://github.com/apache/flink/pull/15017 ## What is the purpose of the change Add max parallelism for reporting purposes to the REST api. ## Brief change log Add max-parallelism to: - JobVertexDetailsHandler puts m

[GitHub] [flink] Jiayi-Liao edited a comment on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

Jiayi-Liao edited a comment on pull request #15016: URL: https://github.com/apache/flink/pull/15016#issuecomment-785653274 @carp84 It took me some time to dig how to test this change, but unfortunately there may not be an easy way to achieve this. Take the `TtlListState` as an examp

[GitHub] [flink] Jiayi-Liao commented on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

Jiayi-Liao commented on pull request #15016: URL: https://github.com/apache/flink/pull/15016#issuecomment-785653274 @carp84 It took me some time to dig how to test this change, but unfortunately there may not be an easy way to achieve this. Take the `TtlListState` as an example, in

[GitHub] [flink] flinkbot edited a comment on pull request #15015: [FLINK-21479][coordination] Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

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

[GitHub] [flink] flinkbot edited a comment on pull request #14962: [FLINK-18789][sql-client] Use TableEnvironment#executeSql method to execute insert statement in sql client

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

[jira] [Updated] (FLINK-21231) add "SHOW VIEWS" to SQL client

[ https://issues.apache.org/jira/browse/FLINK-21231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21231: Fix Version/s: 1.13.0 > add "SHOW VIEWS" to SQL client > -- > >

[GitHub] [flink] flinkbot edited a comment on pull request #14741: [FLINK-21021][python] Bump Beam to 2.27.0

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

[jira] [Updated] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16441: Parent: FLINK-21454 Issue Type: Sub-task (was: Improvement) > Allow users to override flink-conf

[jira] [Created] (FLINK-21499) maven package hang when using multithread on jdk 11

Zhengqi Zhang created FLINK-21499: - Summary: maven package hang when using multithread on jdk 11 Key: FLINK-21499 URL: https://issues.apache.org/jira/browse/FLINK-21499 Project: Flink Issue T

[jira] [Closed] (FLINK-10229) Support listing of views

[ https://issues.apache.org/jira/browse/FLINK-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-10229. --- Resolution: Duplicate > Support listing of views > > > Key: FLINK-1

[jira] [Closed] (FLINK-21146) 【SQL】Flink SQL Client not support specify the queue to submit the job

[ https://issues.apache.org/jira/browse/FLINK-21146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21146. --- Resolution: Fixed > 【SQL】Flink SQL Client not support specify the queue to submit the job >

[GitHub] [flink] flinkbot commented on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

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

[GitHub] [flink] flinkbot edited a comment on pull request #15015: [FLINK-21479][coordination] Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #14958: [FLINK-18550][sql-client] use TableResult#collect to get select result for sql client

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

[GitHub] [flink] flinkbot edited a comment on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

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

[GitHub] [flink] flinkbot commented on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

flinkbot commented on pull request #15016: URL: https://github.com/apache/flink/pull/15016#issuecomment-785633040 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] [Updated] (FLINK-21413) TtlMapState and TtlListState cannot be clean completely with Filesystem StateBackend

[ https://issues.apache.org/jira/browse/FLINK-21413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21413: --- Labels: pull-request-available (was: ) > TtlMapState and TtlListState cannot be clean compl

[GitHub] [flink] Jiayi-Liao opened a new pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

Jiayi-Liao opened a new pull request #15016: URL: https://github.com/apache/flink/pull/15016 ## What is the purpose of the change Solve the memory leak in #TtlMapState and #TtlListState with #FsStateBackend and incremental cleanup feature. ## Brief change log Changes i

[GitHub] [flink] flinkbot edited a comment on pull request #14958: [FLINK-18550][sql-client] use TableResult#collect to get select result for sql client

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

[jira] [Updated] (FLINK-21498) Avoid copying when converting byte[] to ByteString in StateFun

[ https://issues.apache.org/jira/browse/FLINK-21498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-21498: Issue Type: Task (was: Bug) > Avoid copying when converting byte[] to ByteString

[GitHub] [flink] flinkbot edited a comment on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

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

[jira] [Created] (FLINK-21498) Avoid copying when converting byte[] to ByteString in StateFun

Tzu-Li (Gordon) Tai created FLINK-21498: --- Summary: Avoid copying when converting byte[] to ByteString in StateFun Key: FLINK-21498 URL: https://issues.apache.org/jira/browse/FLINK-21498 Project:

[GitHub] [flink] wuchong commented on a change in pull request #15005: [FLINK-21298][table] Support 'USE MODULES' syntax both in SQL parser, TableEnvironment and SQL CLI

wuchong commented on a change in pull request #15005: URL: https://github.com/apache/flink/pull/15005#discussion_r582530305 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPlannerImpl.scala ## @@ -36,11 +35,11 @@ i

[GitHub] [flink] Thesharing commented on a change in pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

Thesharing commented on a change in pull request #14868: URL: https://github.com/apache/flink/pull/14868#discussion_r582556815 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/EdgeManagerBuildUtil.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to t

[jira] [Assigned] (FLINK-21478) Lookup joins should deal with any intermediate table scans correctly

[ https://issues.apache.org/jira/browse/FLINK-21478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21478: -- Assignee: Caizhi Weng > Lookup joins should deal with any intermediate table scans correctly

[jira] [Assigned] (FLINK-21477) Lookup joins should deal with intermediate table scans containing just the table source correctly

[ https://issues.apache.org/jira/browse/FLINK-21477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21477: -- Assignee: Caizhi Weng > Lookup joins should deal with intermediate table scans containing jus

[jira] [Closed] (FLINK-21495) Flink 1.12.0 execute hive sql GeneratedExpression ERROR

[ https://issues.apache.org/jira/browse/FLINK-21495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiayue.yu closed FLINK-21495. - Resolution: Not A Bug > Flink 1.12.0 execute hive sql GeneratedExpression ERROR > -

[jira] [Closed] (FLINK-21496) Upgrade Testcontainers to 1.15.1 in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-21496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21496. --- Resolution: Fixed flink-statefun/master: ec762a7413c3f94470ee13d57edc47350feb1569 >

[GitHub] [flink] flinkbot edited a comment on pull request #14840: [FLINK-21231][sql-client] add "SHOW VIEWS" to SQL client

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

[GitHub] [flink] flinkbot edited a comment on pull request #15006: [Flink-21485][sql-client] Simplify the ExecutionContext

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

[GitHub] [flink] flinkbot edited a comment on pull request #14840: [FLINK-21231][sql-client] add "SHOW VIEWS" to SQL client

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

[GitHub] [flink] yulei0824 commented on pull request #14840: [FLINK-21231][sql-client] add "SHOW VIEWS" to SQL client

yulei0824 commented on pull request #14840: URL: https://github.com/apache/flink/pull/14840#issuecomment-785598428 Hi @wuchong, I will rebase again. This is an automated message from the Apache Git Service. To respond to

[jira] [Created] (FLINK-21497) FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover fail

Guowei Ma created FLINK-21497: - Summary: FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover fail Key: FLINK-21497 URL: https://issues.apache.org/jira/browse/FLINK-21497 Project: Fli

[GitHub] [flink] flinkbot edited a comment on pull request #15006: [Flink-21485][sql-client] Simplify the ExecutionContext

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

[GitHub] [flink] flinkbot edited a comment on pull request #15015: [FLINK-21479][coordination] Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy

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

[jira] [Closed] (FLINK-18454) Add a code contribution section about how to look for what to contribute

[ https://issues.apache.org/jira/browse/FLINK-18454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-18454. --- Resolution: Done done via: 6c778cb8e85f1ea2b200fec82fa6e7036ef7b947 8f66969d3fcb7c0ee92750c8a6fa068834ca1cfd

[GitHub] [flink] wuchong commented on a change in pull request #14958: [FLINK-18550][sql-client] use TableResult#collect to get select result for sql client

wuchong commented on a change in pull request #14958: URL: https://github.com/apache/flink/pull/14958#discussion_r582523520 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java ## @@ -286,7 +320,7 @@ public vo

[GitHub] [flink] flinkbot commented on pull request #15015: [FLINK-21479][coordination] Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #15006: [Flink-21485][sql-client] Simplify the ExecutionContext

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

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * c7e6b28b249f85cf52740d5201a769e0982a60aa UNKNOWN * bebd298009b12a9d5ac6518902f5534f8e00ff32 UNKNOWN * eb6c10b0d339bfc92a540314e7c58cbf11a7

[jira] [Commented] (FLINK-21495) Flink 1.12.0 execute hive sql GeneratedExpression ERROR

[ https://issues.apache.org/jira/browse/FLINK-21495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290655#comment-17290655 ] jiayue.yu commented on FLINK-21495: --- When  the select case when  contdatins contains o

[GitHub] [flink] wangyang0918 commented on a change in pull request #14629: [FLINK-15656][k8s] Support pod template for native kubernetes integration

wangyang0918 commented on a change in pull request #14629: URL: https://github.com/apache/flink/pull/14629#discussion_r582506793 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java ## @@ -100,6 +104,17 @@ protected void

[GitHub] [flink-web] HuangXingBo opened a new pull request #422: Add xingbo to community page

HuangXingBo opened a new pull request #422: URL: https://github.com/apache/flink-web/pull/422 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

[GitHub] [flink] flinkbot edited a comment on pull request #15003: [FLINK-21482][table-planner-blink] Support grouping set syntax for WindowAggregate

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

[GitHub] [flink] flinkbot commented on pull request #15015: [FLINK-21479][coordination] Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy

flinkbot commented on pull request #15015: URL: https://github.com/apache/flink/pull/15015#issuecomment-785551035 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 edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * c7e6b28b249f85cf52740d5201a769e0982a60aa UNKNOWN * bebd298009b12a9d5ac6518902f5534f8e00ff32 UNKNOWN * eb6c10b0d339bfc92a540314e7c58cbf11a7

[jira] [Created] (FLINK-21496) Upgrade Testcontainers to 1.15.1 in Stateful Functions

Tzu-Li (Gordon) Tai created FLINK-21496: --- Summary: Upgrade Testcontainers to 1.15.1 in Stateful Functions Key: FLINK-21496 URL: https://issues.apache.org/jira/browse/FLINK-21496 Project: Flink

[jira] [Created] (FLINK-21495) Flink 1.12.0 execute hive sql GeneratedExpression ERROR

jiayue.yu created FLINK-21495: - Summary: Flink 1.12.0 execute hive sql GeneratedExpression ERROR Key: FLINK-21495 URL: https://issues.apache.org/jira/browse/FLINK-21495 Project: Flink Issue Type

[jira] [Updated] (FLINK-21479) Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy

[ https://issues.apache.org/jira/browse/FLINK-21479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21479: --- Labels: pull-request-available (was: ) > Provide read-only interface of TaskManagerTracker

[GitHub] [flink] KarmaGYZ commented on pull request #15015: [FLINK-21479][coordination] Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy

KarmaGYZ commented on pull request #15015: URL: https://github.com/apache/flink/pull/15015#issuecomment-785543977 cc @xintongsong This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] KarmaGYZ opened a new pull request #15015: [FLINK-21479][coordination] Provide read-only interface of TaskManagerTracker to ResourceAllocationStrategy

KarmaGYZ opened a new pull request #15015: URL: https://github.com/apache/flink/pull/15015 ## What is the purpose of the change This is a predecessor for optimizing performance of ResourceAllocationStrategy (FLINK-21174). To optimize the performance, we will need to bu

[jira] [Comment Edited] (FLINK-21456) TableResult#print() should correctly stringify values of TIMESTAMP type in SQL format

[ https://issues.apache.org/jira/browse/FLINK-21456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290639#comment-17290639 ] Jark Wu edited comment on FLINK-21456 at 2/25/21, 3:10 AM: --- A

[jira] [Commented] (FLINK-21456) TableResult#print() should correctly stringify values of TIMESTAMP type in SQL format

[ https://issues.apache.org/jira/browse/FLINK-21456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17290639#comment-17290639 ] Jark Wu commented on FLINK-21456: - A simplest to fix all data types can be add a implici

[GitHub] [flink-web] zhuzhurk merged pull request #420: [FLINK-18454] Add Chinese translation for "how to look for what to contribute"

zhuzhurk merged pull request #420: URL: https://github.com/apache/flink-web/pull/420 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink-web] zhuzhurk commented on pull request #420: [FLINK-18454] Add Chinese translation for "how to look for what to contribute"

zhuzhurk commented on pull request #420: URL: https://github.com/apache/flink-web/pull/420#issuecomment-785542493 Thanks for reviewing! @gaoyunhaii Merging. This is an automated message from the Apache Git Service. To res

[GitHub] [flink] flinkbot edited a comment on pull request #15003: [FLINK-21482][table-planner-blink] Support grouping set syntax for WindowAggregate

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

[GitHub] [flink] flinkbot edited a comment on pull request #15004: [FLINK-21253][table-planner-blink] Support grouping set syntax for GroupWindowAggregate

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

[GitHub] [flink] flinkbot edited a comment on pull request #14775: [FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator

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

[jira] [Updated] (FLINK-21494) Could not execute statement 'USE `default`' in Flink SQL client

[ https://issues.apache.org/jira/browse/FLINK-21494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng Hu updated FLINK-21494: - Description: I have two databases in my iceberg catalog,  one is `default`, another one is `test_db`. 

[jira] [Updated] (FLINK-21494) Could not execute statement 'USE `default`' in Flink SQL client

[ https://issues.apache.org/jira/browse/FLINK-21494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zheng Hu updated FLINK-21494: - Description: I have two databases in my iceberg catalog,  one is `default`, another one is `test_db`. 

  1   2   3   4   5   >