[GitHub] [flink] meetjunsu commented on pull request #16122: [FLINK-21195][Connectors/FileSystem]LimitableBulkFormat is invalid wh…

meetjunsu commented on pull request #16122: URL: https://github.com/apache/flink/pull/16122#issuecomment-861234708 @JingsongLi The code is just to avoid continuing to create the reader after the limit condition has been reached. For the orc format, creating a reader requires pre-reading a

[GitHub] [flink] luoyuxia opened a new pull request #16161: [FLINK-22993][filesystem] Fix the issue that CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId even though the inp

luoyuxia opened a new pull request #16161: URL: https://github.com/apache/flink/pull/16161 ## What is the purpose of the change * This pull request is to fix the issue that CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId even though the inp

[jira] [Updated] (FLINK-22993) CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId

[ https://issues.apache.org/jira/browse/FLINK-22993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22993: --- Labels: pull-request-available (was: ) > CompactFileWriter won't emit EndCheckpoint with Lo

[jira] [Commented] (FLINK-22993) CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId

[ https://issues.apache.org/jira/browse/FLINK-22993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363425#comment-17363425 ] luoyuxia commented on FLINK-22993: -- [~lzljs3620320] Look forward your review :). > Com

[GitHub] [flink] flinkbot edited a comment on pull request #16152: [FLINK-22963][doc][1.12] correct the description of taskmanager.memory.task.heap.size.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16156: [FLINK-22988][tests] Port TestingUtils to java

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

[GitHub] [flink] flinkbot commented on pull request #16157: [FLINK-22989][coordination][tests] Port Tasks to Java

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

[GitHub] [flink] flinkbot commented on pull request #16161: [FLINK-22993][filesystem] Fix the issue that CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId even though the inp

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

[GitHub] [flink] flinkbot commented on pull request #16159: [FLINK-22991][network] Use Optional in NettyBufferPool

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

[GitHub] [flink] flinkbot commented on pull request #16158: [FLINK-22990][tests] Remove unused classes

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

[GitHub] [flink] flinkbot commented on pull request #16160: [FLINK-22992][security] Move SSLUtils#is*Enabled to SecurityOptions

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

[jira] [Comment Edited] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363314#comment-17363314 ] Xintong Song edited comment on FLINK-22963 at 6/15/21, 7:26 AM: --

[GitHub] [flink] xintongsong commented on pull request #16152: [FLINK-22963][doc][1.12] correct the description of taskmanager.memory.task.heap.size.

xintongsong commented on pull request #16152: URL: https://github.com/apache/flink/pull/16152#issuecomment-861254493 7b4d6b8ac06b970667fcea474145dfc22c826c89 -- 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] xintongsong closed pull request #16152: [FLINK-22963][doc][1.12] correct the description of taskmanager.memory.task.heap.size.

xintongsong closed pull request #16152: URL: https://github.com/apache/flink/pull/16152 -- 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. For queries about this service, pl

[jira] [Closed] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-22963. Resolution: Fixed > The description of taskmanager.memory.task.heap.size in the official document

[GitHub] [flink] tony810430 opened a new pull request #16162: [hotfix][docs] fix img links and previous docs link

tony810430 opened a new pull request #16162: URL: https://github.com/apache/flink/pull/16162 ## What is the purpose of the change to fix some issues for docs, such as image link error and missing 1.13 doc link ## Brief change log - fix image link error - add v1.13 do

[jira] [Created] (FLINK-22994) Improve the performance of invoking nesting udf

lynn1.zhang created FLINK-22994: --- Summary: Improve the performance of invoking nesting udf Key: FLINK-22994 URL: https://issues.apache.org/jira/browse/FLINK-22994 Project: Flink Issue Type: Imp

[GitHub] [flink] flinkbot edited a comment on pull request #16128: [FLINK-22957][table-runtime] Rank TTL should use enableTimeToLive of state instead of timer

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

[GitHub] [flink] RocMarshal commented on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

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

[GitHub] [flink] flinkbot commented on pull request #16162: [hotfix][docs] fix img links and previous docs link

flinkbot commented on pull request #16162: URL: https://github.com/apache/flink/pull/16162#issuecomment-861258965 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 #16158: [FLINK-22990][tests] Remove unused classes

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

[jira] [Commented] (FLINK-22984) UnsupportedOperationException when using Python UDF to generate watermark

[ https://issues.apache.org/jira/browse/FLINK-22984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363433#comment-17363433 ] Till Rohrmann commented on FLINK-22984: --- Thanks for reporting this issue [~maver1c

[GitHub] [flink] flinkbot edited a comment on pull request #16160: [FLINK-22992][security] Move SSLUtils#is*Enabled to SecurityOptions

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

[GitHub] [flink] flinkbot edited a comment on pull request #16157: [FLINK-22989][coordination][tests] Port Tasks to Java

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

[GitHub] [flink] flinkbot edited a comment on pull request #16159: [FLINK-22991][network] Use Optional in NettyBufferPool

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

[GitHub] [flink] flinkbot commented on pull request #16161: [FLINK-22993][filesystem] Fix the issue that CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId even though the inp

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

[GitHub] [flink] maver1ck commented on pull request #16154: [FLINK-22982][python] Fix the wrong matching in PythonMapMergeRule

maver1ck commented on pull request #16154: URL: https://github.com/apache/flink/pull/16154#issuecomment-861260416 I was thinking about more high-level test. Like running `SELECT python_udf(CASE WHEN x THEN y ELSE z END)` -- This is an automated message from the Apache Git Service. To res

[GitHub] [flink] zicat opened a new pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

zicat opened a new pull request #16163: URL: https://github.com/apache/flink/pull/16163 … nesting udf ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-t

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22994: --- Labels: pull-request-available (was: ) > Improve the performance of invoking nesting udf >

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround Flink maintain the udf result as binary, like BinaryStringData. When

[GitHub] [flink] flinkbot commented on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot commented on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861263314 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] rkhachatryan merged pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

rkhachatryan merged pull request #16102: URL: https://github.com/apache/flink/pull/16102 -- 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. For queries about this service, p

[GitHub] [flink] rkhachatryan commented on pull request #16102: [FLINK-22818][runtime] IgnoreInFlightDataITCase is blocking the map s…

rkhachatryan commented on pull request #16102: URL: https://github.com/apache/flink/pull/16102#issuecomment-861263684 CI failure unrelated, merging. -- 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

[jira] [Resolved] (FLINK-22818) IgnoreInFlightDataITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-22818. --- Resolution: Fixed Merged into master as 0cfc6451219cb42a77ff57f0aff0215b85d0f4eb. >

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Attachment: image-2021-06-15-15-42-08-065.png > Improve the performance of invoking nesting udf >

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround Flink maintain the udf result as binary, like BinaryStringData. When

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround Flink maintain the udf result as BinaryData, like BinaryStringData. W

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround Flink maintain the udf result as BinaryData, like BinaryStringData. W

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround Flink maintain the udf result as BinaryData, like BinaryStringData. W

[GitHub] [flink] HuangXingBo commented on pull request #16154: [FLINK-22982][python] Fix the wrong matching in PythonMapMergeRule

HuangXingBo commented on pull request #16154: URL: https://github.com/apache/flink/pull/16154#issuecomment-861274984 > I was thinking about more high-level test. Like running `SELECT python_udf(CASE WHEN x THEN y ELSE z END)` You may not understand what I mean. What kind of case is n

[jira] [Commented] (FLINK-22984) UnsupportedOperationException when using Python UDF to generate watermark

[ https://issues.apache.org/jira/browse/FLINK-22984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363451#comment-17363451 ] Maciej Bryński commented on FLINK-22984:   {code:java} from fastavro import pars

[GitHub] [flink] flinkbot edited a comment on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16070: [HOTFIX][docs] Fix typos.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16156: [FLINK-22988][tests] Port TestingUtils to java

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

[GitHub] [flink] flinkbot edited a comment on pull request #16161: [FLINK-22993][filesystem] Fix the issue that CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId even though

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

[GitHub] [flink] flinkbot commented on pull request #16162: [hotfix][docs] fix img links and previous docs link

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

[GitHub] [flink] flinkbot commented on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

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

[jira] [Created] (FLINK-22995) Failed to acquire lease 'ConfigMapLock: .... retrying...

Bhagi created FLINK-22995: - Summary: Failed to acquire lease 'ConfigMapLock: retrying... Key: FLINK-22995 URL: https://issues.apache.org/jira/browse/FLINK-22995 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-22987) Scala suffix check isn't working

[ https://issues.apache.org/jira/browse/FLINK-22987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-22987: Assignee: Chesnay Schepler > Scala suffix check isn't working > -

[GitHub] [flink] flinkbot edited a comment on pull request #16070: [HOTFIX][docs] Fix typos.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16154: [FLINK-22982][python] Fix the wrong matching in PythonMapMergeRule

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

[GitHub] [flink] flinkbot edited a comment on pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

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

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * 742c9aa4fd8fe26d3607cdf389ac8d65a2eb863c UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot edited a comment on pull request #16162: [hotfix][docs] fix img links and previous docs link

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

[jira] [Commented] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363478#comment-17363478 ] Guokuai Huang commented on FLINK-22946: --- Hi [~pnowojski], thanks for your reply. 

[jira] [Comment Edited] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363478#comment-17363478 ] Guokuai Huang edited comment on FLINK-22946 at 6/15/21, 8:38 AM: -

[GitHub] [flink] zentol opened a new pull request #16164: [FLINK-22987][ci] Fix scala suffix check

zentol opened a new pull request #16164: URL: https://github.com/apache/flink/pull/16164 Ports most parts of the scala checker to java and fixes existing issues along the way. We now parse the module name from the dependency-plugin line, and no longer use tee. -- This is an automated me

[jira] [Updated] (FLINK-22987) Scala suffix check isn't working

[ https://issues.apache.org/jira/browse/FLINK-22987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22987: --- Labels: pull-request-available (was: ) > Scala suffix check isn't working > ---

[GitHub] [flink] flinkbot commented on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

flinkbot commented on pull request #16164: URL: https://github.com/apache/flink/pull/16164#issuecomment-861312941 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-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363487#comment-17363487 ] Piotr Nowojski commented on FLINK-22946: Thanks for the explanations. Second so

[GitHub] [flink] flinkbot edited a comment on pull request #16146: [FLINK-22927][python] Fix the bug of JobStatus

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

[jira] [Assigned] (FLINK-22993) CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId

[ https://issues.apache.org/jira/browse/FLINK-22993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22993: Assignee: luoyuxia > CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE check

[GitHub] [flink] RocMarshal removed a comment on pull request #16070: [HOTFIX][docs] Fix typos.

RocMarshal removed a comment on pull request #16070: URL: https://github.com/apache/flink/pull/16070#issuecomment-854873102 @xccui Could you help me to review this PR?Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[jira] [Commented] (FLINK-22978) Flink Maintenance activities Documentation and Testcases for maintainance

[ https://issues.apache.org/jira/browse/FLINK-22978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363493#comment-17363493 ] Till Rohrmann commented on FLINK-22978: --- I am not sure whether I fully understand

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * 742c9aa4fd8fe26d3607cdf389ac8d65a2eb863c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] luoyuxia commented on pull request #16161: [FLINK-22993][filesystem] Fix the issue that CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId even though the inp

luoyuxia commented on pull request #16161: URL: https://github.com/apache/flink/pull/16161#issuecomment-861329655 Sure, I will add test case. -- 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

[GitHub] [flink] JingsongLi commented on pull request #16122: [FLINK-21195][Connectors/FileSystem]LimitableBulkFormat is invalid wh…

JingsongLi commented on pull request #16122: URL: https://github.com/apache/flink/pull/16122#issuecomment-861332673 You can create a UT case for `LimitableBulkFormat`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[jira] [Created] (FLINK-22996) The description about coalesce is wrong

lothar created FLINK-22996: -- Summary: The description about coalesce is wrong Key: FLINK-22996 URL: https://issues.apache.org/jira/browse/FLINK-22996 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363499#comment-17363499 ] Guokuai Huang commented on FLINK-22946: --- Of course, please assign this ticket to m

[GitHub] [flink] xintongsong closed pull request #16155: [hotfix][ci] Make NoticeFileChecker log severe issues at error level.

xintongsong closed pull request #16155: URL: https://github.com/apache/flink/pull/16155 -- 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. For queries about this service, pl

[jira] [Assigned] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-22946: -- Assignee: Guokuai Huang > Network buffer deadlock introduced by unaligned checkpoint

[GitHub] [flink] wenlong88 commented on a change in pull request #16096: [FLINK-22901][table] Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

wenlong88 commented on a change in pull request #16096: URL: https://github.com/apache/flink/pull/16096#discussion_r651616824 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/metadata/FlinkMetadata.java ## @@ -238,4 +239,20

[jira] [Commented] (FLINK-22978) Flink Maintenance activities Documentation and Testcases for maintainance

[ https://issues.apache.org/jira/browse/FLINK-22978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363506#comment-17363506 ] Bhagi commented on FLINK-22978: --- Hi Till, we are going to release Flink 1.13.0 into produ

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363374#comment-17363374 ] Bhagi edited comment on FLINK-22965 at 6/15/21, 9:31 AM: - Hi Til

[GitHub] [flink] flinkbot commented on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

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

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r651630642 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -78,9 +89,14

[GitHub] [flink] flinkbot edited a comment on pull request #14820: [FLINK-21085][runtime][checkpoint] Allows triggering checkpoint for non-source tasks

flinkbot edited a comment on pull request #14820: URL: https://github.com/apache/flink/pull/14820#issuecomment-770327711 ## CI report: * d83bee7799051ef32e0f9ec9e26339b23b7dc057 UNKNOWN * 05c48a82487c41963697e99a31baeab9e3c82240 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround Flink maintain the udf result as BinaryData, like BinaryStringData. W

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r651635234 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,160 @@ +/*

[jira] [Commented] (FLINK-13703) AvroTypeInfo requires objects to be strict POJOs (mutable, with setters)

[ https://issues.apache.org/jira/browse/FLINK-13703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363519#comment-17363519 ] Patrick Lucas commented on FLINK-13703: --- Hit a very similar issue (though didn't t

[GitHub] [flink] flinkbot edited a comment on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

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

[GitHub] [flink] Zakelly commented on a change in pull request #15420: [FLINK-21356] Implement incremental checkpointing and recovery using state changelog

Zakelly commented on a change in pull request #15420: URL: https://github.com/apache/flink/pull/15420#discussion_r651620703 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogReducingState.java ## @@ -65,16 +

[GitHub] [flink] RocMarshal commented on pull request #16070: [HOTFIX][docs] Fix typos.

RocMarshal commented on pull request #16070: URL: https://github.com/apache/flink/pull/16070#issuecomment-861364550 @JingsongLi Could you help me to review the part of Chinese in this PR? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] gaoyunhaii commented on pull request #14820: [FLINK-21085][runtime][checkpoint] Allows triggering checkpoint for non-source tasks

gaoyunhaii commented on pull request #14820: URL: https://github.com/apache/flink/pull/14820#issuecomment-861368486 Hi @dawidwys, I updated the PR according the above discussion. Some points are met during the discussion that might need consideration: 1. For `MultipleInputStreamTask`

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

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

[GitHub] [flink] flinkbot edited a comment on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16164: [FLINK-22987][ci] Fix scala suffix check

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

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * 742c9aa4fd8fe26d3607cdf389ac8d65a2eb863c Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] JingsongLi commented on a change in pull request #16096: [FLINK-22901][table] Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

JingsongLi commented on a change in pull request #16096: URL: https://github.com/apache/flink/pull/16096#discussion_r651656766 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/metadata/FlinkMetadata.java ## @@ -238,4 +239,20

[GitHub] [flink] JingsongLi commented on a change in pull request #16096: [FLINK-22901][table] Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

JingsongLi commented on a change in pull request #16096: URL: https://github.com/apache/flink/pull/16096#discussion_r651657138 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/metadata/FlinkMetadata.java ## @@ -238,4 +239,20

[jira] [Created] (FLINK-22997) Replace AkkaUtils#get*Timeout*

Chesnay Schepler created FLINK-22997: Summary: Replace AkkaUtils#get*Timeout* Key: FLINK-22997 URL: https://issues.apache.org/jira/browse/FLINK-22997 Project: Flink Issue Type: Sub-task

[GitHub] [flink] wenlong88 commented on a change in pull request #16096: [FLINK-22901][table] Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

wenlong88 commented on a change in pull request #16096: URL: https://github.com/apache/flink/pull/16096#discussion_r651666576 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/metadata/FlinkMetadata.java ## @@ -238,4 +239,20

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

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

[jira] [Updated] (FLINK-13150) defaultCatalogName and defaultDatabaseName in TableEnvImpl is not updated after they are updated in TableEnvironment

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

[jira] [Updated] (FLINK-13164) Add a listState#putAndGet benchmark for StateBenchmark

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

[GitHub] [flink] flinkbot edited a comment on pull request #16158: [FLINK-22990][tests] Remove unused classes

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

[jira] [Updated] (FLINK-13050) Counting more checkpoint failure reason in CheckpointFailureManager

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

[jira] [Updated] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

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

[jira] [Updated] (FLINK-12992) All host(s) tried for query failed (tried com.datastax.driver.core.exceptions.TransportException: Error writing...)

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

[GitHub] [flink] flinkbot edited a comment on pull request #16160: [FLINK-22992][security] Move SSLUtils#is*Enabled to SecurityOptions

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

  1   2   3   4   >