[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17467835#comment-17467835 ] Martijn Visser commented on FLINK-18356: [~gaoyunhaii] [~trohrmann] I've underst

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 611af0ce8e2999f7896a259edab03b8d1103eb1c UNKNOWN * b0da7ee5efc7652b302161d8eab7989a29e5160c Azure: [FAILURE](https://dev.azure.com/apache-f

[jira] [Closed] (FLINK-25502) eval method of Flink ScalerFunction only run one time

[ https://issues.apache.org/jira/browse/FLINK-25502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25502. Resolution: Invalid Please take a look at: https://nightlies.apache.org/flink/flink-docs-master/d

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 611af0ce8e2999f7896a259edab03b8d1103eb1c UNKNOWN * b0da7ee5efc7652b302161d8eab7989a29e5160c Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 611af0ce8e2999f7896a259edab03b8d1103eb1c UNKNOWN * b0da7ee5efc7652b302161d8eab7989a29e5160c Azure: [FAILURE](https://dev.azure.com/apache-f

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

MartijnVisser commented on pull request #18225: URL: https://github.com/apache/flink/pull/18225#issuecomment-1003916601 @chenxyz707 Thanks for that. Can you squash the commits on your end? -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 611af0ce8e2999f7896a259edab03b8d1103eb1c UNKNOWN * b0da7ee5efc7652b302161d8eab7989a29e5160c Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 611af0ce8e2999f7896a259edab03b8d1103eb1c UNKNOWN * b0da7ee5efc7652b302161d8eab7989a29e5160c Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 611af0ce8e2999f7896a259edab03b8d1103eb1c UNKNOWN * b0da7ee5efc7652b302161d8eab7989a29e5160c Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] MartijnVisser commented on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

MartijnVisser commented on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-1003912467 @leonardBang Will you do a review for this one? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink] MartijnVisser commented on pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

MartijnVisser commented on pull request #17332: URL: https://github.com/apache/flink/pull/17332#issuecomment-1003912249 @cuibo01 Is there any progress to report from your end? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [flink] flinkbot edited a comment on pull request #18253: FLINK-24900

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

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

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

[jira] [Commented] (FLINK-9966) Add a ORC table factory

[ https://issues.apache.org/jira/browse/FLINK-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17467821#comment-17467821 ] Martijn Visser commented on FLINK-9966: --- [~lzljs3620320] Do you think we can close

[jira] [Resolved] (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 ] Martijn Visser resolved FLINK-20823. Resolution: Fixed This has been resolved, see https://nightlies.apache.org/flink/flink-do

[GitHub] [flink] flinkbot edited a comment on pull request #18253: FLINK-24900

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

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

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

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

[ https://issues.apache.org/jira/browse/FLINK-20569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-20569. -- Resolution: Fixed Closing this ticket because no new issues have been reported in a long time

[jira] [Assigned] (FLINK-25491) Code generation: init method exceeds 64 KB when there is a large IN filter with Table API

[ https://issues.apache.org/jira/browse/FLINK-25491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25491: -- Assignee: Caizhi Weng > Code generation: init method exceeds 64 KB when there is a la

[jira] [Resolved] (FLINK-8474) Add documentation for HBaseTableSource

[ https://issues.apache.org/jira/browse/FLINK-8474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser resolved FLINK-8474. --- Resolution: Fixed This has been resolved in the meantime > Add documentation for HBaseTableS

[jira] [Commented] (FLINK-18717) reuse MiniCluster in table integration test class ?

[ https://issues.apache.org/jira/browse/FLINK-18717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17467810#comment-17467810 ] Martijn Visser commented on FLINK-18717: [~godfreyhe] Is still is a valid issue?

[GitHub] [flink] MartijnVisser commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

MartijnVisser commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1003904759 @galenwarren Thanks for this. It does seem like there are still some license issues because the build failed. Could you look into those or do you need some help with that

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

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

[GitHub] [flink] flinkbot edited a comment on pull request #18254: [hotfix][tools] Extract duplicate code in JarFileChecker

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

[GitHub] [flink] flinkbot edited a comment on pull request #18254: [hotfix][tools] Extract duplicate code in JarFileChecker

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

[GitHub] [flink] flinkbot commented on pull request #18254: [hotfix][tools] Extract duplicate code in JarFileChecker

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

[GitHub] [flink] flinkbot commented on pull request #18254: [hotfix][tools] Extract duplicate code in JarFileChecker

flinkbot commented on pull request #18254: URL: https://github.com/apache/flink/pull/18254#issuecomment-1003884979 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] ruanwenjun opened a new pull request #18254: [hotfix][tools] Extract duplicate code in JarFileChecker

ruanwenjun opened a new pull request #18254: URL: https://github.com/apache/flink/pull/18254 ## What is the purpose of the change * This pull request aim to extract some duplicate code in JarFileChecker. ## Brief change log - Optimize the code in JarFileChecker.

[GitHub] [flink] xuzifu666 commented on pull request #18243: [hotfix] remove unused LOG reference

xuzifu666 commented on pull request #18243: URL: https://github.com/apache/flink/pull/18243#issuecomment-1003880081 @dianfu hi, please have a review, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[GitHub] [flink] flinkbot edited a comment on pull request #18253: FLINK-24900

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

[GitHub] [flink] flinkbot commented on pull request #18253: FLINK-24900

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

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

[jira] [Updated] (FLINK-24900) Support to run multiple shuffle plugins in one session cluster

[ https://issues.apache.org/jira/browse/FLINK-24900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24900: --- Labels: pull-request-available (was: ) > Support to run multiple shuffle plugins in one ses

[GitHub] [flink] wsry opened a new pull request #18253: FLINK-24900

wsry opened a new pull request #18253: URL: https://github.com/apache/flink/pull/18253 ## What is the purpose of the change This is a draft PR for stability test of FLINK-24900. -- This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

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

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

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

[jira] [Comment Edited] (FLINK-25499) Column 'window_start' is ambiguous

[ https://issues.apache.org/jira/browse/FLINK-25499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17467739#comment-17467739 ] Jing Zhang edited comment on FLINK-25499 at 1/3/22, 12:52 AM:

[jira] [Commented] (FLINK-25499) Column 'window_start' is ambiguous

[ https://issues.apache.org/jira/browse/FLINK-25499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17467739#comment-17467739 ] Jing Zhang commented on FLINK-25499: [~zhitom], Thanks for reporting the bug. This i

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

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

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

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

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

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

[jira] [Updated] (FLINK-6605) Allow users to specify a default name for processing time in Table API

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

[jira] [Updated] (FLINK-6446) Various improvements to the Web Frontend

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

[jira] [Updated] (FLINK-6713) Document how to allow multiple Kafka consumers / producers to authenticate using different credentials

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

[jira] [Updated] (FLINK-6771) Create committer guide

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

[jira] [Updated] (FLINK-6370) FileAlreadyExistsException on startup

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

[jira] [Updated] (FLINK-6363) Document precedence rules of Kryo serializer registrations

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

[jira] [Updated] (FLINK-6424) Add basic helper functions for map type

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

[jira] [Updated] (FLINK-6477) The first time to click Taskmanager cannot get the actual data

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

[jira] [Updated] (FLINK-6761) Limitation for maximum state size per key in RocksDB backend

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

[jira] [Updated] (FLINK-6767) Cannot load user class on local environment

[ https://issues.apache.org/jira/browse/FLINK-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6767: -- Labels: CollocatedComputation Flink Ignite LocalEvironment auto-deprioritized-critical auto-d

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 611af0ce8e2999f7896a259edab03b8d1103eb1c UNKNOWN * b0da7ee5efc7652b302161d8eab7989a29e5160c Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18203: [FLINK-25460][core] Update slf4j-api dependency to 1.7.32

flinkbot edited a comment on pull request #18203: URL: https://github.com/apache/flink/pull/18203#issuecomment-1001460756 ## CI report: * 766445d2c9108cc2cca0b2a0231b172eb76a7b62 UNKNOWN * 333b991392c6834570ee50189b6e687bcd07f4c9 Azure: [SUCCESS](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

flinkbot edited a comment on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1001578474 ## CI report: * 611af0ce8e2999f7896a259edab03b8d1103eb1c UNKNOWN * b0da7ee5efc7652b302161d8eab7989a29e5160c Azure: [PENDING](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18203: [FLINK-25460][core] Update slf4j-api dependency to 1.7.32

flinkbot edited a comment on pull request #18203: URL: https://github.com/apache/flink/pull/18203#issuecomment-1001460756 ## CI report: * 766445d2c9108cc2cca0b2a0231b172eb76a7b62 UNKNOWN * 333b991392c6834570ee50189b6e687bcd07f4c9 Azure: [PENDING](https://dev.azure.com/apache-f

[GitHub] [flink] MartijnVisser commented on pull request #18203: [FLINK-25460][core] Update slf4j-api dependency to 1.7.32

MartijnVisser commented on pull request #18203: URL: https://github.com/apache/flink/pull/18203#issuecomment-1003773372 @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 sp

[GitHub] [flink] MartijnVisser commented on pull request #18209: [FLINK-25461][python] Update net.sf.py4j:py4j dependency to 0.10.9.3

MartijnVisser commented on pull request #18209: URL: https://github.com/apache/flink/pull/18209#issuecomment-1003773308 @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 sp

[GitHub] [flink] flinkbot edited a comment on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

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

[GitHub] [flink] flinkbot edited a comment on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

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

[GitHub] [flink] flinkbot edited a comment on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

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

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

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

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

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

[GitHub] [flink] flinkbot edited a comment on pull request #18235: Test change default batch configuration

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

[GitHub] [flink] gaoyunhaii commented on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

gaoyunhaii commented on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-1003721880 Very thanks @pnowojski for the review! I'll merge the PR now~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [flink] flinkbot edited a comment on pull request #18243: [hotfix] remove unused LOG reference

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

[jira] [Closed] (FLINK-25414) Provide metrics to measure how long task has been blocked

[ https://issues.apache.org/jira/browse/FLINK-25414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-25414. -- Fix Version/s: 1.15.0 Resolution: Fixed Merged to master as bc22d2b90cb..1166d11f61a >

[GitHub] [flink] pnowojski merged pull request #18181: [FLINK-25414][metrics] Provide metrics to measure how long task has been blocked

pnowojski merged pull request #18181: URL: https://github.com/apache/flink/pull/18181 -- 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-unsub

[GitHub] [flink] flinkbot edited a comment on pull request #18023: [FLINK-25032] Allow to create execution vertices and execution edges lazily

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

[jira] [Commented] (FLINK-25483) When FlinkSQL writes ES, it will not write and update the null value field

[ https://issues.apache.org/jira/browse/FLINK-25483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17467621#comment-17467621 ] 陈磊 commented on FLINK-25483: Hi, [~MartijnVisser] .Glad you can reply to my question. In the

[jira] [Updated] (FLINK-12097) Flink SQL hangs in StreamTableEnvironment.sqlUpdate, keeps executing and seems never stop, finally lead to java.lang.OutOfMemoryError: GC overhead limit exceeded

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

[jira] [Updated] (FLINK-6800) PojoSerializer ignores added pojo fields

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

[jira] [Updated] (FLINK-24349) Support customized Calalogs via JDBC

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

[jira] [Updated] (FLINK-20696) Yarn Session Blob Directory is not deleted.

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

[jira] [Updated] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails

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

[jira] [Updated] (FLINK-6969) Add support for deferred computation for group window aggregates

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

[jira] [Updated] (FLINK-21153) yarn-per-job deployment target ignores yarn options

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

[jira] [Updated] (FLINK-22551) checkpoints: strange behaviour

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

[jira] [Updated] (FLINK-22075) Incorrect null outputs in left join

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

[jira] [Updated] (FLINK-18717) reuse MiniCluster in table integration test class ?

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

[jira] [Updated] (FLINK-16320) Can not use sub-queries in the VALUES clause

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

[jira] [Updated] (FLINK-22004) Translate Flink Roadmap to Chinese.

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

[jira] [Updated] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

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

[jira] [Updated] (FLINK-14297) Temporal Table Function Build Side does not accept a constant key

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

[jira] [Updated] (FLINK-15826) Add renameFunction() to Catalog

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

[jira] [Updated] (FLINK-22517) Fix pickle compatibility problem in different Python versions

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

[jira] [Updated] (FLINK-22190) no guarantee on Flink exactly_once sink to Kafka

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

[jira] [Updated] (FLINK-21877) Add E2E test for upsert-kafka connector

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

[jira] [Updated] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

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

[jira] [Updated] (FLINK-6931) Support custom compression formats for checkpoints (+Upgrade/Compatibility)

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

[jira] [Updated] (FLINK-22128) Window aggregation should have unique keys

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

[jira] [Updated] (FLINK-24731) Add a blank space for TransitiveClosureNaive

[ https://issues.apache.org/jira/browse/FLINK-24731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24731: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-24745) Add support for Oracle OGG json parser in flink-json module

[ https://issues.apache.org/jira/browse/FLINK-24745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24745: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-17378) KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator unstable

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

[jira] [Updated] (FLINK-21716)  Support higher precision for Data Type TIME(p)

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

[jira] [Updated] (FLINK-24320) Show in the Job / Checkpoints / Configuration if checkpoints are incremental

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

[jira] [Updated] (FLINK-21583) Allow comments in CSV format without having to ignore parse errors

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

[jira] [Updated] (FLINK-22705) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to fail to download the tar

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

[jira] [Updated] (FLINK-25483) When FlinkSQL writes ES, it will not write and update the null value field

[ https://issues.apache.org/jira/browse/FLINK-25483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈磊 updated FLINK-25483: --- Issue Type: New Feature (was: Improvement) > When FlinkSQL writes ES, it will not write and update the null value f

[jira] [Created] (FLINK-25502) eval method of Flink ScalerFunction only run one time

Spongebob created FLINK-25502: - Summary: eval method of Flink ScalerFunction only run one time Key: FLINK-25502 URL: https://issues.apache.org/jira/browse/FLINK-25502 Project: Flink Issue Type: B

[GitHub] [flink] flinkbot edited a comment on pull request #18243: [hotfix] remove unused LOG reference

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

  1   2   >