[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=17363420#comment-17363420 ] luoyuxia commented on FLINK-22993: -- I'd like to fix it. > CompactFileWriter won't emit

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

luoyuxia created FLINK-22993: Summary: CompactFileWriter won't emit EndCheckpoint with Long.MAX_VALUE checkpointId Key: FLINK-22993 URL: https://issues.apache.org/jira/browse/FLINK-22993 Project: Flink

[jira] [Closed] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-22986. Resolution: Duplicate True, this is a duplication of FLINK-22980. Thanks for pointing it out, [~f

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363419#comment-17363419 ] Yun Gao commented on FLINK-22085: - [~xintongsong] OK, I'll have a look~ > KafkaSourceLe

[jira] [Commented] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363413#comment-17363413 ] luoyuxia commented on FLINK-22073: -- [~lzljs3620320] I see  setParallelism(3) for the Da

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363414#comment-17363414 ] Xintong Song commented on FLINK-22085: -- [~gaoyunhaii], could you help take a look a

[jira] [Commented] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363411#comment-17363411 ] Fabian Paul commented on FLINK-22986: - [~xintongsong] I think this is a duplicate of

[jira] [Assigned] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-22980: --- Assignee: Fabian Paul > FileExecutionGraphInfoStoreTest hangs on azure > --

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363410#comment-17363410 ] Xintong Song commented on FLINK-20329: -- https://dev.azure.com/apache-flink/apache-f

[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-861219826 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-22992) Move SSLUtils#is*Enabled to SecurityOptions

[ https://issues.apache.org/jira/browse/FLINK-22992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22992: --- Labels: pull-request-available (was: ) > Move SSLUtils#is*Enabled to SecurityOptions >

[GitHub] [flink] zentol opened a new pull request #16160: [FLINK-22992][security] Move SSLUtils#is*Enabled to SecurityOptions

zentol opened a new pull request #16160: URL: https://github.com/apache/flink/pull/16160 The SSLUtils contain a few methods that check whether certain SSL options are enabled while honoring a fallback "security.ssl.enabled" option. These are required by RPC, network and REST components.

[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-861218202 Hi, @maver1ck, Thanks for the advice. The rule of `PythonMapMergeRule` is used to deals with the scenario of map operation, but some other calculations are incorrectly judge

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

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

[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: * 9c8edc81b9f24d2657e7c8d8c07744e928954716 Azure: [FAILURE](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: * 05049a69c6d046c3aaf5d47c1f99011e3f1c4ff7 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-22992) Move SSLUtils#is*Enabled to SecurityOptions

Chesnay Schepler created FLINK-22992: Summary: Move SSLUtils#is*Enabled to SecurityOptions Key: FLINK-22992 URL: https://issues.apache.org/jira/browse/FLINK-22992 Project: Flink Issue Typ

[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-861214607 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 #16158: [FLINK-22990][tests] Remove unused classes

flinkbot commented on pull request #16158: URL: https://github.com/apache/flink/pull/16158#issuecomment-861213265 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-22991) Use Optional in NettyBufferPool

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

[GitHub] [flink] zentol opened a new pull request #16159: [FLINK-22991][network] Use Optional in NettyBufferPool

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

[jira] [Updated] (FLINK-22991) Use Optional in NettyBufferPool

[ https://issues.apache.org/jira/browse/FLINK-22991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22991: - Summary: Use Optional in NettyBufferPool (was: Use Optional in NetworkBufferPool) > Us

[jira] [Updated] (FLINK-22990) Remove unused ScalaUtils/TestingMessages

[ https://issues.apache.org/jira/browse/FLINK-22990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22990: --- Labels: pull-request-available (was: ) > Remove unused ScalaUtils/TestingMessages > ---

[jira] [Created] (FLINK-22991) Use Optional in NetworkBufferPool

Chesnay Schepler created FLINK-22991: Summary: Use Optional in NetworkBufferPool Key: FLINK-22991 URL: https://issues.apache.org/jira/browse/FLINK-22991 Project: Flink Issue Type: Sub-tas

[GitHub] [flink] zentol opened a new pull request #16158: [FLINK-22990][tests] Remove unused classes

zentol opened a new pull request #16158: URL: https://github.com/apache/flink/pull/16158 -- 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] flinkbot commented on pull request #16156: [FLINK-22988][tests] Port TestingUtils to java

flinkbot commented on pull request #16156: URL: https://github.com/apache/flink/pull/16156#issuecomment-861210646 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 #16157: [FLINK-22989][coordination][tests] Port Tasks to Java

flinkbot commented on pull request #16157: URL: https://github.com/apache/flink/pull/16157#issuecomment-861210621 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] [Created] (FLINK-22990) Remove unused ScalaUtils/TestingMessages

Chesnay Schepler created FLINK-22990: Summary: Remove unused ScalaUtils/TestingMessages Key: FLINK-22990 URL: https://issues.apache.org/jira/browse/FLINK-22990 Project: Flink Issue Type:

[jira] [Updated] (FLINK-22989) Port Tasks to Java

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

[GitHub] [flink] zentol opened a new pull request #16157: [FLINK-22989][coordination][tests] Port Tasks to Java

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

[jira] [Created] (FLINK-22989) Port Tasks to Java

Chesnay Schepler created FLINK-22989: Summary: Port Tasks to Java Key: FLINK-22989 URL: https://issues.apache.org/jira/browse/FLINK-22989 Project: Flink Issue Type: Sub-task Com

[jira] [Updated] (FLINK-22988) Port TestingUtils to Java

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

[GitHub] [flink] zentol opened a new pull request #16156: [FLINK-22988][tests] Port TestingUtils to java

zentol opened a new pull request #16156: URL: https://github.com/apache/flink/pull/16156 - removes unused stuff - ports remaining stuff to java - adjusts package name to comply with checkstyle -- This is an automated message from the Apache Git Service. To respond to the message, pl

[jira] [Created] (FLINK-22988) Port TestingUtils to Java

Chesnay Schepler created FLINK-22988: Summary: Port TestingUtils to Java Key: FLINK-22988 URL: https://issues.apache.org/jira/browse/FLINK-22988 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-14105) Make flink-runtime scala-free

[ https://issues.apache.org/jira/browse/FLINK-14105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-14105: Assignee: Chesnay Schepler > Make flink-runtime scala-free >

[GitHub] [flink] flinkbot edited a comment on pull request #16155: [hotfix][ci] Make NoticeFileChecker log severe issues at error level.

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

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

Chesnay Schepler created FLINK-22987: Summary: Scala suffix check isn't working Key: FLINK-22987 URL: https://issues.apache.org/jira/browse/FLINK-22987 Project: Flink Issue Type: Bug

[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-861201083 @meetjunsu Thanks for the contribution, can you add a case for this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Closed] (FLINK-20318) Fix cast question for properies() method in kafka ConnectorDescriptor

[ https://issues.apache.org/jira/browse/FLINK-20318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20318. Resolution: Fixed Fixed via: master: df92fa95ad28206df1dcb434df2c76b563c5ed4a > Fix cast questio

[GitHub] [flink] JingsongLi merged pull request #15250: [FLINK-20318][Connector/kafka]Fix cast question for properies() method in kafka ConnectorDescriptor

JingsongLi merged pull request #15250: URL: https://github.com/apache/flink/pull/15250 -- 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, ple

[jira] [Commented] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input

[ https://issues.apache.org/jira/browse/FLINK-21389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363389#comment-17363389 ] Arvid Heise commented on FLINK-21389: - Merged into 1.13 as 4780b5d98e53c7a1cbabf2092

[jira] [Closed] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input

[ https://issues.apache.org/jira/browse/FLINK-21389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-21389. --- Fix Version/s: 1.13.2 Resolution: Resolved > ParquetInputFormat should not need parquet schem

[GitHub] [flink] AHeise merged pull request #15725: [FLINK-21389] determine parquet schema from file instead of taking it from user

AHeise merged pull request #15725: URL: https://github.com/apache/flink/pull/15725 -- 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, please

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

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

[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: * 9c8edc81b9f24d2657e7c8d8c07744e928954716 Azure: [FAILURE](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: * 9c2560bd72ef6f598231c30468ef0d33c0036b51 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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-861178781 @HuangXingBo Don't we want any test for the case from Jira ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[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: [PENDING](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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 08ffe3adfa0399106c7a7e82e682323adf4e4519 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 9c8edc81b9f24d2657e7c8d8c07744e928954716 Azure: [FAILURE](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: * 9c2560bd72ef6f598231c30468ef0d33c0036b51 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot commented on pull request #16155: URL: https://github.com/apache/flink/pull/16155#issuecomment-861174618 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] xintongsong commented on pull request #16155: [hotfix][ci] Make NoticeFileChecker log severe issues at error level.

xintongsong commented on pull request #16155: URL: https://github.com/apache/flink/pull/16155#issuecomment-861168367 cc @rmetzger -- 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 co

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

xintongsong opened a new pull request #16155: URL: https://github.com/apache/flink/pull/16155 This PR upgrades logging level of severe issues in NoticeFileChecker from WARN to ERROR Currently, it's a bit confusing which issue is causing the check failure when there are multiple warn

[jira] [Commented] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363378#comment-17363378 ] Jingsong Lee commented on FLINK-22073: -- [~luoyuxia] Maybe we have set parallelism p

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

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

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

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

[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: * 08ffe3adfa0399106c7a7e82e682323adf4e4519 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 9c8edc81b9f24d2657e7c8d8c07744e928954716 Azure: [FAILURE](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: * 9c2560bd72ef6f598231c30468ef0d33c0036b51 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (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 commented on FLINK-22965: --- waiting for your response. > Association with remote sys

[jira] [Comment Edited] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363368#comment-17363368 ] luoyuxia edited comment on FLINK-22073 at 6/15/21, 4:20 AM:

[jira] [Comment Edited] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363368#comment-17363368 ] luoyuxia edited comment on FLINK-22073 at 6/15/21, 4:19 AM:

[jira] [Comment Edited] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363368#comment-17363368 ] luoyuxia edited comment on FLINK-22073 at 6/15/21, 4:19 AM:

[jira] [Comment Edited] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363368#comment-17363368 ] luoyuxia edited comment on FLINK-22073 at 6/15/21, 4:18 AM:

[jira] [Commented] (FLINK-22073) ParquetFileCompactionITCase fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363368#comment-17363368 ] luoyuxia commented on FLINK-22073: -- >From the detail log, there are three streaming-wri

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

flinkbot commented on pull request #16154: URL: https://github.com/apache/flink/pull/16154#issuecomment-861153559 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 #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

flinkbot commented on pull request #16153: URL: https://github.com/apache/flink/pull/16153#issuecomment-861152936 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] xintongsong commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-861150767 Thanks for updating the PR, @galenwarren. - The Azure build has been triggered, on your latest commit (e751250). It's probably not very timely. - It's good to hear

[jira] [Updated] (FLINK-22982) java.lang.ClassCastException when using Python UDF

[ https://issues.apache.org/jira/browse/FLINK-22982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22982: --- Labels: pull-request-available (was: ) > java.lang.ClassCastException when using Python UDF

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

HuangXingBo opened a new pull request #16154: URL: https://github.com/apache/flink/pull/16154 ## What is the purpose of the change *This pull request makes will fix the wrong matching in PythonMapMergeRule* ## Brief change log - *Fix the wrong matching in PythonMap

[jira] [Commented] (FLINK-22983) Support lazy evaluation in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363362#comment-17363362 ] Jingsong Lee commented on FLINK-22983: -- Hi [~maver1ck], can you check the generated

[jira] [Updated] (FLINK-22678) Hide ChangelogStateBackend From Users

[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22678: --- Labels: pull-request-available (was: ) > Hide ChangelogStateBackend From Users > -

[GitHub] [flink] Zakelly opened a new pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

Zakelly opened a new pull request #16153: URL: https://github.com/apache/flink/pull/16153 ## What is the purpose of the change This change provides configurations as well as APIs to configure ChangelogStateBackend. Base on the discussion before (https://lists.apache.org/thread.html/

[jira] [Commented] (FLINK-21736) Introduce latency tracking state

[ https://issues.apache.org/jira/browse/FLINK-21736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363360#comment-17363360 ] Yun Tang commented on FLINK-21736: -- [~trohrmann], sure. https://issues.apache.org/jira/

[jira] [Assigned] (FLINK-22528) Document latency tracking metrics for state accesses

[ https://issues.apache.org/jira/browse/FLINK-22528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-22528: Assignee: Yun Tang > Document latency tracking metrics for state accesses > -

[jira] [Updated] (FLINK-22985) NullPointerException when cast string literal to date or time

[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-22985: - Summary: NullPointerException when cast string literal to date or time (was: sql syntax, NullPo

[jira] [Commented] (FLINK-22985) sql syntax, NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363357#comment-17363357 ] Jingsong Lee commented on FLINK-22985: -- There is bug in {{ScalarOperatorGens.genera

[jira] [Comment Edited] (FLINK-22985) sql syntax, NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363357#comment-17363357 ] Jingsong Lee edited comment on FLINK-22985 at 6/15/21, 3:46 AM: --

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * c1496ae5f3e3f74ac121791bdf3b1f82bede643a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363353#comment-17363353 ] Anton Kalashnikov commented on FLINK-20495: --- https://dev.azure.com/apache-flin

[GitHub] [flink] zuston edited a comment on pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

zuston edited a comment on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-859462105 @lirui-apache Updated. The ci failure looks unrelated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-22386) Introduce cache for docker images

[ https://issues.apache.org/jira/browse/FLINK-22386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22386: - Labels: (was: stale-major) > Introduce cache for docker images > -

[jira] [Updated] (FLINK-22386) Introduce cache for docker images

[ https://issues.apache.org/jira/browse/FLINK-22386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22386: - Priority: Critical (was: Major) > Introduce cache for docker images > -

[jira] [Updated] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22986: - Affects Version/s: 1.13.1 > FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown

[jira] [Commented] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363348#comment-17363348 ] Xintong Song commented on FLINK-22986: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363347#comment-17363347 ] Xintong Song commented on FLINK-22702: -- https://dev.azure.com/apache-flink/apache-f

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

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

[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: * c1496ae5f3e3f74ac121791bdf3b1f82bede643a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363345#comment-17363345 ] Xintong Song commented on FLINK-22068: -- Hi [~dannycranmer], would you mind help tak

[jira] [Commented] (FLINK-22985) sql syntax, NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363344#comment-17363344 ] Jark Wu commented on FLINK-22985: - [~simen] looks like a bug in code generation. Could y

[jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22068: - Priority: Major (was: Minor) > FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure >

[jira] [Commented] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363340#comment-17363340 ] Xintong Song commented on FLINK-22068: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22068: - Labels: test-stability (was: auto-deprioritized-major test-stability) > FlinkKinesisConsumerTes

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363339#comment-17363339 ] Xintong Song commented on FLINK-22387: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363338#comment-17363338 ] Xintong Song commented on FLINK-22986: -- cc [~chesnay] Could this be related to the

[jira] [Created] (FLINK-22986) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure

Xintong Song created FLINK-22986: Summary: FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown hangs on azure Key: FLINK-22986 URL: https://issues.apache.org/jira/browse/FLINK-22986

[jira] [Commented] (FLINK-22985) sql syntax, NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-22985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363335#comment-17363335 ] simenliuxing commented on FLINK-22985: -- [~jark] hello jark , Is my grammar wrong？

  1   2   3   4   >