[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=17318659#comment-17318659 ] Guowei Ma commented on FLINK-21538: ---

[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

[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

[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=17318658#comment-17318658 ] Guowei Ma commented on FLINK-22085: ---

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

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

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

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

[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:

[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

[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=17318653#comment-17318653 ] Guowei Ma commented on FLINK-22191: ---

[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=17318650#comment-17318650 ] Guowei Ma commented on FLINK-22191: ---

[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=17318649#comment-17318649 ] Guowei Ma commented on FLINK-17510: ---

[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=17318648#comment-17318648 ] Guowei Ma commented on FLINK-22191: --- CC [~dianfu] >

[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

[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=17318643#comment-17318643 ] Guowei Ma commented on FLINK-21659: ---

[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 *

[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=17318641#comment-17318641 ] Guowei Ma commented on FLINK-17274: ---

[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 *

[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=17318632#comment-17318632 ] Kurt Young commented on FLINK-22178: [~hackergin] Thanks! Do you have some thoughts about how to

[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=17318631#comment-17318631 ] Kurt Young commented on FLINK-15165: [~mbalassi] I'm not sure about this since hive ACID table is

[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 @@ +/* + *

[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:

[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:

[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:

[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

[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=17318585#comment-17318585 ] Kezhu Wang edited comment on FLINK-21996 at 4/10/21, 8:11 PM: -- Is there any

[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=17318585#comment-17318585 ] Kezhu Wang commented on FLINK-21996: Is there any design guarantee for no source operator

[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:

[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 *

[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 *

[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:

[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:

[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:

[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

[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

[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:

[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

[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

[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

[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=17318497#comment-17318497 ] Yun Tang commented on FLINK-15146: -- Merged into master: 4dd8c533035b471c2655e6e358cdb75dc57c36c6 >

[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:

[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 *

[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 *

[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,

[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

[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=17318490#comment-17318490 ] Yun Tang commented on FLINK-20816: -- [~AHeise] Thanks for your troubleshooting and sorry for making this

[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,

[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 *

[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 *

[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 >

[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=17318486#comment-17318486 ] Wei Zhong commented on FLINK-21969: --- Merged into master via 5b3a8f3b25dcac71375d1a81fa63d935c8bf3eab

[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,

[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=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:

[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:

[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

[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:

[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:

[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

[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=17318458#comment-17318458 ] jackwangcs commented on FLINK-21699: Hi [~eronwright], [~trohrmann], could you help to review the PR

[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:

[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=17318442#comment-17318442 ] Márton Balassi commented on FLINK-15165: Hi [~phoenixjiangnan], [~ykt836] what is the current

[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 *

[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:

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

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

[jira] [Commented] (FLINK-21891) The .staging_xxx directory isn't deleted after writing data to hive table in batch mode

[ https://issues.apache.org/jira/browse/FLINK-21891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318428#comment-17318428 ] Re0 Beatrice commented on FLINK-21891: -- [~jark], [~lirui] I have opened a pr, can u help to review

[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: * 209f7c6024245762b8bb626ae5c589962fcc2454 Azure:

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

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

[jira] [Updated] (FLINK-21891) The .staging_xxx directory isn't deleted after writing data to hive table in batch mode

[ https://issues.apache.org/jira/browse/FLINK-21891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21891: --- Labels: pull-request-available (was: ) > The .staging_xxx directory isn't deleted after

[GitHub] [flink] itinycheng opened a new pull request #15555: [FLINK-21891][table-runtime-blink] Use FileSystem instance to delete the temporary directory '.staging_xxx'

itinycheng opened a new pull request #1: URL: https://github.com/apache/flink/pull/1 ## What is the purpose of the change This PR fixes the bug that the temporary directory '.staging_xxx' isn't deleted after writing data to hive finished in Flink SQL batch mode. ##

[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: * 209f7c6024245762b8bb626ae5c589962fcc2454 Azure:

[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: * 87b826d246f4e396c92dabfa7510607f1b77e6c4 Azure: