[jira] [Created] (FLINK-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang.

Guowei Ma created FLINK-22198: - Summary: org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang. Key: FLINK-22198 URL: https://issues.apache.org/jira/browse/FLINK-22198 Project: Flink

[jira] [Updated] (FLINK-22198) org.apache.flink.streaming.connectors.kafka.table.KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22198: -- Description: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16287&view=logs&j=

[jira] [Commented] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318664#comment-17318664 ] Lsw_aka_laplace commented on FLINK-22196: - cc [~jark] cc [~godfreyhe]   > Fli

[jira] [Commented] (FLINK-22181) SourceNAryInputChainingITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318663#comment-17318663 ] Guowei Ma commented on FLINK-22181: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Updated] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-22196: Description: Well since we have supported project push-down, some primary-key in original

[jira] [Created] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

Guowei Ma created FLINK-22197: - Summary: UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException Key: FLINK-22197 URL: https://issues.apache.org/jira/browse/FLINK-22197

[jira] [Updated] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist in current row schema

[ https://issues.apache.org/jira/browse/FLINK-22196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-22196: Component/s: Table SQL / Planner Affects Version/s: 1.12.2 Summary:

[jira] [Commented] (FLINK-22129) OrcFileSystemITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318662#comment-17318662 ] Guowei Ma commented on FLINK-22129: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-22196) FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist

Lsw_aka_laplace created FLINK-22196: --- Summary: FlinkRelMdUniqueKeys#getTableUniqueKeys should filter out the column indices which the does not exist Key: FLINK-22196 URL: https://issues.apache.org/jira/browse/F

[jira] [Commented] (FLINK-21608) YARNHighAvailabilityITCase.testClusterClientRetrieval fails with "There is at least one application..."

[ https://issues.apache.org/jira/browse/FLINK-21608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318661#comment-17318661 ] Guowei Ma commented on FLINK-21608: --- testKillYarnSessionClusterEntrypoint(org.apache.f

[jira] [Created] (FLINK-22195) YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException

Guowei Ma created FLINK-22195: - Summary: YARNHighAvailabilityITCase.testClusterClientRetrieval because of TestTimedOutException Key: FLINK-22195 URL: https://issues.apache.org/jira/browse/FLINK-22195 Proj

[jira] [Commented] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318659#comment-17318659 ] Guowei Ma commented on FLINK-21538: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Updated] (FLINK-21538) Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting job

[ https://issues.apache.org/jira/browse/FLINK-21538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21538: -- Affects Version/s: 1.13.0 > Elasticsearch6DynamicSinkITCase.testWritingDocuments fails when submitting

[jira] [Created] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

Guowei Ma created FLINK-22194: - Summary: KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout Key: FLINK-22194 URL: https://issues.apache.org/jira/browse/FLINK-22194 Pro

[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=17318658#comment-17318658 ] Guowei Ma commented on FLINK-22085: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22193) HiveTableSinkITCase.testNonPartStreamingMrWrite fail

[ https://issues.apache.org/jira/browse/FLINK-22193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318657#comment-17318657 ] Guowei Ma commented on FLINK-22193: --- cc [~lzljs3620320] > HiveTableSinkITCase.testNon

[jira] [Commented] (FLINK-22192) HiveTableSinkITCase.testDefaultSerPartStreamingWrite fail

[ https://issues.apache.org/jira/browse/FLINK-22192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318656#comment-17318656 ] Guowei Ma commented on FLINK-22192: --- cc [~lzljs3620320] > HiveTableSinkITCase.testDef

[jira] [Created] (FLINK-22193) HiveTableSinkITCase.testNonPartStreamingMrWrite fail

Guowei Ma created FLINK-22193: - Summary: HiveTableSinkITCase.testNonPartStreamingMrWrite fail Key: FLINK-22193 URL: https://issues.apache.org/jira/browse/FLINK-22193 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-22192) HiveTableSinkITCase.testDefaultSerPartStreamingWrite fail

Guowei Ma created FLINK-22192: - Summary: HiveTableSinkITCase.testDefaultSerPartStreamingWrite fail Key: FLINK-22192 URL: https://issues.apache.org/jira/browse/FLINK-22192 Project: Flink Issue Typ

[jira] [Commented] (FLINK-22191) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE

[ https://issues.apache.org/jira/browse/FLINK-22191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318653#comment-17318653 ] Guowei Ma commented on FLINK-22191: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22191) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE

[ https://issues.apache.org/jira/browse/FLINK-22191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318650#comment-17318650 ] Guowei Ma commented on FLINK-22191: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318649#comment-17318649 ] Guowei Ma commented on FLINK-17510: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22191) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE

[ https://issues.apache.org/jira/browse/FLINK-22191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318648#comment-17318648 ] Guowei Ma commented on FLINK-22191: --- CC [~dianfu] > PyFlinkStreamUserDefinedFunctionT

[jira] [Created] (FLINK-22191) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE

Guowei Ma created FLINK-22191: - Summary: PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition_2 fail due to NPE Key: FLINK-22191 URL: https://issues.apache.org/jira/browse/FLINK-22191 Project

[jira] [Commented] (FLINK-21659) Running HA per-job cluster (rocks, incremental) end-to-end test fails

[ https://issues.apache.org/jira/browse/FLINK-21659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318643#comment-17318643 ] Guowei Ma commented on FLINK-21659: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * bd27dabd13c11fd65b98423595e9d9323453

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318641#comment-17318641 ] Guowei Ma commented on FLINK-17274: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 248aaeec8b1c42ca82610eebe34e2321d95f

[jira] [Assigned] (FLINK-22178) Support ignore-first-line option in new csv format

[ https://issues.apache.org/jira/browse/FLINK-22178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-22178: -- Assignee: jinfeng > Support ignore-first-line option in new csv format >

[jira] [Commented] (FLINK-22178) Support ignore-first-line option in new csv format

[ https://issues.apache.org/jira/browse/FLINK-22178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318632#comment-17318632 ] Kurt Young commented on FLINK-22178: [~hackergin] Thanks! Do you have some thoughts

[jira] [Commented] (FLINK-15165) support upsert (Hive ACID) in Hive sink

[ https://issues.apache.org/jira/browse/FLINK-15165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318631#comment-17318631 ] Kurt Young commented on FLINK-15165: [~mbalassi] I'm not sure about this since hive

[GitHub] [flink] maosuhan commented on a change in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r611124468 ## File path: flink-formats/flink-protobuf/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory ## @@ -0,0 +1,18 @@ +/* + * Lic

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

Spongebob created FLINK-22190: - Summary: no guarantee on Flink exactly_once sink to Kafka Key: FLINK-22190 URL: https://issues.apache.org/jira/browse/FLINK-22190 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-22189) Flink SQL Client Hudi batch write crashes JobManager

[ https://issues.apache.org/jira/browse/FLINK-22189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Phil Chen updated FLINK-22189: -- Priority: Blocker (was: Major) > Flink SQL Client Hudi batch write crashes JobManager > -

[jira] [Created] (FLINK-22189) Flink SQL Client Hudi batch write crashes JobManager

Phil Chen created FLINK-22189: - Summary: Flink SQL Client Hudi batch write crashes JobManager Key: FLINK-22189 URL: https://issues.apache.org/jira/browse/FLINK-22189 Project: Flink Issue Type: Bu

[jira] [Closed] (FLINK-22188) Flink SQL Client Error running SQL job

[ https://issues.apache.org/jira/browse/FLINK-22188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22188. --- Resolution: Not A Problem >From the exception stack, the root cause is reported "Caused by: >java.lang.Clas

[GitHub] [flink] flinkbot edited a comment on pull request #15523: [FLINK-22109][table-planner-blink] Resolve misleading exception message in invalid nested function

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

[jira] [Created] (FLINK-22188) Flink SQL Client Error running SQL job

Phil Chen created FLINK-22188: - Summary: Flink SQL Client Error running SQL job Key: FLINK-22188 URL: https://issues.apache.org/jira/browse/FLINK-22188 Project: Flink Issue Type: Bug Co

[GitHub] [flink] xmarker commented on pull request #15523: [FLINK-22109][table-planner-blink] Resolve misleading exception message in invalid nested function

xmarker commented on pull request #15523: URL: https://github.com/apache/flink/pull/15523#issuecomment-817237466 @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 specific

[jira] [Comment Edited] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss

[ https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318585#comment-17318585 ] Kezhu Wang edited comment on FLINK-21996 at 4/10/21, 8:11 PM:

[jira] [Commented] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss

[ https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318585#comment-17318585 ] Kezhu Wang commented on FLINK-21996: Is there any design guarantee for no source ope

[GitHub] [flink] flinkbot edited a comment on pull request #15555: [FLINK-21891][table-runtime-blink] Use FileSystem instance to delete the temporary directory '.staging_xxx'

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

[GitHub] [flink] flinkbot edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

flinkbot edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550 ## CI report: * 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN * f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN * a3341911ab289f00a4aa50b99c8b90980f5f

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[GitHub] [flink] flinkbot edited a comment on pull request #15556: [FLINK-22187][docs] Remove description of sync checkpoint mode of HashMapStateBackend

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

[GitHub] [flink] flinkbot edited a comment on pull request #15531: [FLINK-22147][connector/kafka] Refactor partition discovery logic in Kafka source enumerator

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

[GitHub] [flink] flinkbot edited a comment on pull request #15556: [FLINK-22187][docs] Remove description of sync checkpoint mode of HashMapStateBackend

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

[GitHub] [flink] flinkbot commented on pull request #15556: [FLINK-22187][docs] Remove description of sync checkpoint mode of HashMapStateBackend

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

[GitHub] [flink] laughingman7743 commented on a change in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

laughingman7743 commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r611049891 ## File path: flink-formats/flink-protobuf/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory ## @@ -0,0 +1,18 @@ +/*

[GitHub] [flink] flinkbot commented on pull request #15556: [FLINK-22187][docs] Remove description of sync checkpoint mode of HashMapStateBackend

flinkbot commented on pull request #15556: URL: https://github.com/apache/flink/pull/15556#issuecomment-817142930 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 #15555: [FLINK-21891][table-runtime-blink] Use FileSystem instance to delete the temporary directory '.staging_xxx'

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

[jira] [Updated] (FLINK-22187) Remove description of sync checkpoint mode of HashMapStateBackend

[ https://issues.apache.org/jira/browse/FLINK-22187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22187: --- Labels: pull-request-available (was: ) > Remove description of sync checkpoint mode of Hash

[GitHub] [flink] Myasuka opened a new pull request #15556: [FLINK-22187][docs] Remove description of sync checkpoint mode of HashMapStateBackend

Myasuka opened a new pull request #15556: URL: https://github.com/apache/flink/pull/15556 ## What is the purpose of the change Remove description of sync checkpoint mode of HashMapStateBackend as the constructor has been removed. ## Verifying this change This ch

[jira] [Updated] (FLINK-22187) Remove description of sync checkpoint mode of HashMapStateBackend

[ https://issues.apache.org/jira/browse/FLINK-22187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22187: - Component/s: Documentation > Remove description of sync checkpoint mode of HashMapStateBackend > ---

[jira] [Created] (FLINK-22187) Remove description of sync checkpoint mode of HashMapStateBackend

Yun Tang created FLINK-22187: Summary: Remove description of sync checkpoint mode of HashMapStateBackend Key: FLINK-22187 URL: https://issues.apache.org/jira/browse/FLINK-22187 Project: Flink Is

[jira] [Resolved] (FLINK-15146) Fix check that incremental cleanup size must be greater than zero

[ https://issues.apache.org/jira/browse/FLINK-15146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-15146. -- Resolution: Fixed > Fix check that incremental cleanup size must be greater than zero > -

[jira] [Commented] (FLINK-15146) Fix check that incremental cleanup size must be greater than zero

[ https://issues.apache.org/jira/browse/FLINK-15146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318497#comment-17318497 ] Yun Tang commented on FLINK-15146: -- Merged into master: 4dd8c533035b471c2655e6e358cdb75

[GitHub] [flink] flinkbot edited a comment on pull request #15555: [FLINK-21891][table-runtime-blink] Use FileSystem instance to delete the temporary directory '.staging_xxx'

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

[GitHub] [flink] flinkbot edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

flinkbot edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550 ## CI report: * 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN * f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN * a3341911ab289f00a4aa50b99c8b90980f5f

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[jira] [Closed] (FLINK-22120) Remove duplicate code in generated code for map get

[ https://issues.apache.org/jira/browse/FLINK-22120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22120. --- Fix Version/s: 1.13.0 Resolution: Fixed Fixed in master: 7581a62e07cd60941d94cf5c7cc6f4facf3510a6 >

[GitHub] [flink] wuchong merged pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get

wuchong merged pull request #15519: URL: https://github.com/apache/flink/pull/15519 -- 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] wuchong commented on pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get

wuchong commented on pull request #15519: URL: https://github.com/apache/flink/pull/15519#issuecomment-817137387 The failed test case is not related to this PR. Will merge this. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318490#comment-17318490 ] Yun Tang commented on FLINK-20816: -- [~AHeise] Thanks for your troubleshooting and sorry

[GitHub] [flink] Myasuka merged pull request #15395: [FLINK-15146][core][ttl] Fix check that incremental cleanup size must be greater than zero

Myasuka merged pull request #15395: URL: https://github.com/apache/flink/pull/15395 -- 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 edited a comment on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

flinkbot edited a comment on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-803592550 ## CI report: * 2ef40343abecf693b39b7b7fcb9f6d0d26bf82cd UNKNOWN * f7dde849a55b4aad1044ac200b390a604029c710 UNKNOWN * a3341911ab289f00a4aa50b99c8b90980f5f

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[jira] [Closed] (FLINK-21969) PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data

[ https://issues.apache.org/jira/browse/FLINK-21969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21969. - Fix Version/s: 1.12.3 1.13.0 Resolution: Fixed > PythonTimestampsAndWatermarks

[jira] [Commented] (FLINK-21969) PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data

[ https://issues.apache.org/jira/browse/FLINK-21969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318486#comment-17318486 ] Wei Zhong commented on FLINK-21969: --- Merged into master via 5b3a8f3b25dcac71375d1a81fa

[GitHub] [flink] WeiZhong94 merged pull request #15451: [FLINK-21969][python] Invoke finish bundle method before emitting the max timestamp watermark in PythonTimestampsAndWatermarksOperator

WeiZhong94 merged pull request #15451: URL: https://github.com/apache/flink/pull/15451 -- 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-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318485#comment-17318485 ] Arvid Heise commented on FLINK-20816: - Downgraded to Major as it's a test-only issue

[jira] [Updated] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20816: Priority: Major (was: Critical) > NotifyCheckpointAbortedITCase failed due to timeout > -

[GitHub] [flink] flinkbot edited a comment on pull request #15531: [FLINK-22147][connector/kafka] Refactor partition discovery logic in Kafka source enumerator

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

[GitHub] [flink] flinkbot edited a comment on pull request #15531: [FLINK-22147][connector/kafka] Refactor partition discovery logic in Kafka source enumerator

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

[GitHub] [flink] PatrickRen commented on pull request #15531: [FLINK-22147][connector/kafka] Refactor partition discovery logic in Kafka source enumerator

PatrickRen commented on pull request #15531: URL: https://github.com/apache/flink/pull/15531#issuecomment-817120042 @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 edited a comment on pull request #15555: [FLINK-21891][table-runtime-blink] Use FileSystem instance to delete the temporary directory '.staging_xxx'

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

[GitHub] [flink] flinkbot edited a comment on pull request #15451: [FLINK-21969][python] Invoke finish bundle method before emitting the max timestamp watermark in PythonTimestampsAndWatermarksOperato

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

[GitHub] [flink] YuvalItzchakov commented on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

YuvalItzchakov commented on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-817113249 @godfreyhe @fsk119 Would appreciate your feedbacks so we can push this through 🙏 -- This is an automated message from the Apache Git Service. To respond to the message

[jira] [Commented] (FLINK-21699) SecurityUtils JaasModule make JVM dirty

[ https://issues.apache.org/jira/browse/FLINK-21699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318458#comment-17318458 ] jackwangcs commented on FLINK-21699: Hi [~eronwright], [~trohrmann], could you help

[GitHub] [flink] flinkbot edited a comment on pull request #15499: [FLINK-22127][network] Enrich error message of read buffer request timeout to tell the user how to solve the problem when using sort-

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

[jira] [Commented] (FLINK-15165) support upsert (Hive ACID) in Hive sink

[ https://issues.apache.org/jira/browse/FLINK-15165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318442#comment-17318442 ] Márton Balassi commented on FLINK-15165: Hi [~phoenixjiangnan], [~ykt836] what i

[jira] [Created] (FLINK-22186) Standalone webUI Internal server error flink.client.program.PackagedProgram.close()V

刘虎 created FLINK-22186: -- Summary: Standalone webUI Internal server error flink.client.program.PackagedProgram.close()V Key: FLINK-22186 URL: https://issues.apache.org/jira/browse/FLINK-22186 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[GitHub] [flink] flinkbot edited a comment on pull request #15555: [FLINK-21891][table-runtime-blink] Use FileSystem instance to delete the temporary directory '.staging_xxx'

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