[jira] [Commented] (FLINK-26595) Improve the PostgresDialect method for getting upsert statements.

[ https://issues.apache.org/jira/browse/FLINK-26595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504861#comment-17504861 ] Martijn Visser commented on FLINK-26595: I would say that means that the current PostgresDialect

[jira] [Updated] (FLINK-26606) CompletedCheckpoints that failed to be discarded are not stored in the CompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-26606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26606: - Component/s: Runtime / Checkpointing > CompletedCheckpoints that failed to be discarded

[jira] [Commented] (FLINK-26388) Release Testing: Repeatable Cleanup (FLINK-25433)

[ https://issues.apache.org/jira/browse/FLINK-26388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504859#comment-17504859 ] Matthias Pohl commented on FLINK-26388: --- Valid point. I created FLINK-26606 to cover this topic

[jira] [Updated] (FLINK-26606) CompletedCheckpoints that failed to be discarded are not stored in the CompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-26606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26606: -- Description: We introduced a repeatable per-job cleanup after the job reached a

[jira] [Updated] (FLINK-26388) Release Testing: Repeatable Cleanup (FLINK-25433)

[ https://issues.apache.org/jira/browse/FLINK-26388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26388: --- Labels: pull-request-available release-testing (was: release-testing) > Release Testing:

[jira] [Comment Edited] (FLINK-26595) Improve the PostgresDialect method for getting upsert statements.

[ https://issues.apache.org/jira/browse/FLINK-26595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504858#comment-17504858 ] wuguihu edited comment on FLINK-26595 at 3/11/22, 10:52 AM: [~jark] Yes,

[jira] [Created] (FLINK-26607) There are multiple MAX_LONG_VALUE value errors in pyflink code

zhangjingcun created FLINK-26607: Summary: There are multiple MAX_LONG_VALUE value errors in pyflink code Key: FLINK-26607 URL: https://issues.apache.org/jira/browse/FLINK-26607 Project: Flink

[GitHub] [flink] XComp opened a new pull request #19058: [FLINK-26388][docs] Adds information about missed out artifacts in repeatable cleanup with a reference to the FLINK issue

XComp opened a new pull request #19058: URL: https://github.com/apache/flink/pull/19058 ## What is the purpose of the change * Adds reference to FLINK-26606 to inform the user on some on-going bug in the cleanup of CompletedCheckpoints that failed to be discarded ## Brief

[jira] [Commented] (FLINK-26595) Improve the PostgresDialect method for getting upsert statements.

[ https://issues.apache.org/jira/browse/FLINK-26595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504858#comment-17504858 ] wuguihu commented on FLINK-26595: - Yes, this is an issue related to matrixDB. In matrixDB, the

[GitHub] [flink] syhily removed a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

syhily removed a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1064993996 @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 #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

flinkbot edited a comment on pull request #19040: URL: https://github.com/apache/flink/pull/19040#issuecomment-1064026493 ## CI report: * c0c7dcadc7b7a8a8999b3689fb0ccae191e2d321 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 753fd989f3f19c6a8cb3a5e9facbc5d8f4a63bc9 Azure:

[jira] [Commented] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504857#comment-17504857 ] Dawid Wysakowicz commented on FLINK-26274: -- Sure! Thanks for taking care of the issue. > Test

[jira] [Updated] (FLINK-26589) Update the logging level of Kinesis Streams and Firehose sinks

[ https://issues.apache.org/jira/browse/FLINK-26589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-26589: -- Fix Version/s: 1.15.0 > Update the logging level of Kinesis Streams and Firehose sinks >

[jira] [Updated] (FLINK-26589) Update the logging level of Kinesis Streams and Firehose sinks

[ https://issues.apache.org/jira/browse/FLINK-26589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-26589: -- Affects Version/s: (was: 1.15.0) > Update the logging level of Kinesis Streams and

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * 82aee14a4ac5874da8d0ab99e8253b2fb59b951a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19055: [hotfix][table-planner] RawToBinaryCastRule can fail

flinkbot edited a comment on pull request #19055: URL: https://github.com/apache/flink/pull/19055#issuecomment-1064872537 ## CI report: * 37a4fde6ae7b5c7f5f04fe3c313365ebe8040fb3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

flinkbot edited a comment on pull request #19040: URL: https://github.com/apache/flink/pull/19040#issuecomment-1064026493 ## CI report: * c0c7dcadc7b7a8a8999b3689fb0ccae191e2d321 Azure:

[GitHub] [flink-docker] knaufk merged pull request #108: Add GPG key for 1.14.4 release

knaufk merged pull request #108: URL: https://github.com/apache/flink-docker/pull/108 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] syhily commented on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

syhily commented on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1064993996 @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

[GitHub] [flink] syhily removed a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

syhily removed a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1064890723 @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 #19055: [hotfix][table-planner] RawToBinaryCastRule can fail

flinkbot edited a comment on pull request #19055: URL: https://github.com/apache/flink/pull/19055#issuecomment-1064872537 ## CI report: * 37a4fde6ae7b5c7f5f04fe3c313365ebe8040fb3 Azure:

[jira] [Created] (FLINK-26606) CompletedCheckpoints that failed to be discarded are not stored in the CompletedCheckpointStore

Matthias Pohl created FLINK-26606: - Summary: CompletedCheckpoints that failed to be discarded are not stored in the CompletedCheckpointStore Key: FLINK-26606 URL: https://issues.apache.org/jira/browse/FLINK-26606

[jira] [Updated] (FLINK-26315) Stream job which have multily region would not recover when connection with zookeeper/hbase lost.

[ https://issues.apache.org/jira/browse/FLINK-26315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26315: --- Labels: failure-recovery restart stale-critical (was: failure-recovery restart) I am the

[jira] [Updated] (FLINK-23210) Running HA per-job cluster (hashmap, sync) end-to-end test failed on azure

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

[jira] [Updated] (FLINK-22343) Running HA per-job cluster (rocks, non-incremental) end-to-end test fails on azure

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

[jira] [Updated] (FLINK-24558) dataStream can not use multiple classloaders

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

[jira] [Updated] (FLINK-24477) Add MongoDB sink

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

[GitHub] [flink] MartijnVisser commented on pull request #19055: [hotfix][table-planner] RawToBinaryCastRule can fail

MartijnVisser commented on pull request #19055: URL: https://github.com/apache/flink/pull/19055#issuecomment-1064989843 @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 #19055: [hotfix][table-planner] RawToBinaryCastRule can fail

flinkbot edited a comment on pull request #19055: URL: https://github.com/apache/flink/pull/19055#issuecomment-1064872537 ## CI report: * 37a4fde6ae7b5c7f5f04fe3c313365ebe8040fb3 Azure:

[jira] [Commented] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504846#comment-17504846 ] Chesnay Schepler commented on FLINK-26274: -- [~dwysakowicz] Can you retry your tests with the

[jira] [Closed] (FLINK-26547) Accepting slots without a matching requirement leads to unfulfillable requirements

[ https://issues.apache.org/jira/browse/FLINK-26547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-26547. Resolution: Fixed master: 3f1a66b9da3e2c9b169ab1a7075468c5f2b559c9 > Accepting slots

[GitHub] [flink] zentol merged pull request #19019: [FLINK-26547][coordination] No requirement adjustments for unmatched slots

zentol merged pull request #19019: URL: https://github.com/apache/flink/pull/19019 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #19057: [FLINK-26589][connectors/kinesis][connectors/firehose] Updating KDS/K…

flinkbot edited a comment on pull request #19057: URL: https://github.com/apache/flink/pull/19057#issuecomment-1064980178 ## CI report: * 09e94fd694202fb0681abd6a1498591c1d7b7a69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19020: [FLINK-26551][table] Flip legacy casting to disable by default

flinkbot edited a comment on pull request #19020: URL: https://github.com/apache/flink/pull/19020#issuecomment-1062833750 ## CI report: * ac7bb9bc4f9d49db28df7ebb1a9de59aab7e0baa Azure:

[GitHub] [flink] flinkbot commented on pull request #19057: [FLINK-26589][connectors/kinesis][connectors/firehose] Updating KDS/K…

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

[GitHub] [flink] flinkbot edited a comment on pull request #19050: [FLINK-26592][state/changelog] Schedule uploads outside synchronized block

flinkbot edited a comment on pull request #19050: URL: https://github.com/apache/flink/pull/19050#issuecomment-1064564761 ## CI report: * d1ed0624f5f4f60391369862791123a61c1becd6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * ce5259932767032a24e15f5475f31ff336d40a48 Azure:

[GitHub] [flink] hehuiyuan commented on pull request #19036: [FLINK-26498][table-runtime] The window result may not have been emit…

hehuiyuan commented on pull request #19036: URL: https://github.com/apache/flink/pull/19036#issuecomment-1064979355 There is no late for ’processint time‘. The window cleanup time equals window.MaxTimestamp, which will definitely be emitted. -- This is an automated message from the

[jira] [Closed] (FLINK-25069) YARNHighAvailabilityITCase.testJobRecoversAfterKillingTaskManager failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-25069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-25069. - Resolution: Cannot Reproduce It looks like the

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 0ee22778504c1bf11c25b5e9df0a8b5fc88a83cc Azure:

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19045: [FLINK-26194][table-api] Deprecate unused options from TableConfig.

slinkydeveloper commented on a change in pull request #19045: URL: https://github.com/apache/flink/pull/19045#discussion_r824578111 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala ## @@ -477,40 +477,26 @@

[jira] [Updated] (FLINK-26589) Update the logging level of Kinesis Streams and Firehose sinks

[ https://issues.apache.org/jira/browse/FLINK-26589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26589: --- Labels: pull-request-available (was: ) > Update the logging level of Kinesis Streams and

[GitHub] [flink-docker] knaufk merged pull request #109: Update Dockerfiles for 1.14.4 release

knaufk merged pull request #109: URL: https://github.com/apache/flink-docker/pull/109 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] CrynetLogistics opened a new pull request #19057: [FLINK-26589][connectors/kinesis][connectors/firehose] Updating KDS/K…

CrynetLogistics opened a new pull request #19057: URL: https://github.com/apache/flink/pull/19057 …DF logging level from warn to debug on failure and from trace to NONE on write ## What is the purpose of the change To reduce the level of logging in KDS/KDF sink

[GitHub] [flink] matriv commented on a change in pull request #19045: [FLINK-26194][table-api] Deprecate unused options from TableConfig.

matriv commented on a change in pull request #19045: URL: https://github.com/apache/flink/pull/19045#discussion_r824576629 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala ## @@ -477,40 +477,26 @@ object

[GitHub] [flink] matriv commented on a change in pull request #19045: [FLINK-26194][table-api] Deprecate unused options from TableConfig.

matriv commented on a change in pull request #19045: URL: https://github.com/apache/flink/pull/19045#discussion_r824576629 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala ## @@ -477,40 +477,26 @@ object

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19039: [FLINK-26582][table] Convert table modules assertions to AssertJ

slinkydeveloper commented on a change in pull request #19039: URL: https://github.com/apache/flink/pull/19039#discussion_r824576002 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/FunctionITCase.java ## @@ -127,7

[GitHub] [flink] matriv commented on a change in pull request #19045: [FLINK-26194][table-api] Deprecate unused options from TableConfig.

matriv commented on a change in pull request #19045: URL: https://github.com/apache/flink/pull/19045#discussion_r824575713 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ExprCodeGenerator.scala ## @@ -215,7 +209,7 @@ class

[GitHub] [flink] matriv commented on a change in pull request #19045: [FLINK-26194][table-api] Deprecate unused options from TableConfig.

matriv commented on a change in pull request #19045: URL: https://github.com/apache/flink/pull/19045#discussion_r824572926 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/TableConfigUtils.java ## @@ -90,6 +94,35 @@ public

[jira] [Updated] (FLINK-18235) Improve the checkpoint strategy for Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-18235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18235: Fix Version/s: (was: 1.15.0) > Improve the checkpoint strategy for Python UDF execution >

[GitHub] [flink] flinkbot edited a comment on pull request #18949: [FLINK-25235][tests] re-enable zookeeper test

flinkbot edited a comment on pull request #18949: URL: https://github.com/apache/flink/pull/18949#issuecomment-1055620167 ## CI report: * b6c65b276e7f0609112c937afc5f63af15361d5c Azure:

[jira] [Created] (FLINK-26605) JobManagerDeploymentStatus.READY does not correctly reflect the real Flink cluster status

Yang Wang created FLINK-26605: - Summary: JobManagerDeploymentStatus.READY does not correctly reflect the real Flink cluster status Key: FLINK-26605 URL: https://issues.apache.org/jira/browse/FLINK-26605

[GitHub] [flink] flinkbot edited a comment on pull request #18949: [FLINK-25235][tests] re-enable zookeeper test

flinkbot edited a comment on pull request #18949: URL: https://github.com/apache/flink/pull/18949#issuecomment-1055620167 ## CI report: * b6c65b276e7f0609112c937afc5f63af15361d5c Azure:

[GitHub] [flink] metaswirl commented on a change in pull request #18949: [FLINK-25235][tests] re-enable zookeeper test

metaswirl commented on a change in pull request #18949: URL: https://github.com/apache/flink/pull/18949#discussion_r824567042 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java ## @@ -571,6 +585,10 @@ protected

[GitHub] [flink] flinkbot edited a comment on pull request #19054: [FLINK-26482][python] Support WindowedStream.reduce in Python DataStream API

flinkbot edited a comment on pull request #19054: URL: https://github.com/apache/flink/pull/19054#issuecomment-1064837015 ## CI report: * 5c14b7fc09537f4959b8dccc25722140ad2e24ba Azure:

[jira] [Updated] (FLINK-26589) Update the logging level of Kinesis Streams and Firehose sinks

[ https://issues.apache.org/jira/browse/FLINK-26589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-26589: --- Description: h2. Motivation During the normal course of the KDS and KDF's sink's operation, we

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19039: [FLINK-26582][table] Convert table modules assertions to AssertJ

slinkydeveloper commented on a change in pull request #19039: URL: https://github.com/apache/flink/pull/19039#discussion_r824552089 ## File path: flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/sort/SortUtilTest.java ## @@ -124,7 +125,7

[jira] [Updated] (FLINK-26603) [Umbrella] Decouple Hive with Flink itself

[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26603: - Description: To support Hive dialect with Flink, we have implemented FLIP-123, FLIP-152. But it also

[jira] [Updated] (FLINK-26603) [Umbrella] Decouple Hive with Flink itself

[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26603: - Description: To support Hive dialect with Flink, we have implemented FLIP-123, FLIP-152. But it also

[jira] [Updated] (FLINK-26603) [Umbrella] Decouple Hive with Flink itself

[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26603: - Description: To support Hive dialect with Flink, we have implemented [link

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19039: [FLINK-26582][table] Convert table modules assertions to AssertJ

slinkydeveloper commented on a change in pull request #19039: URL: https://github.com/apache/flink/pull/19039#discussion_r824550910 ## File path: flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/sort/BufferedKVExternalSorterTest.java ##

[jira] [Updated] (FLINK-26603) [Umbrella] Decouple Hive with Flink itself

[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26603: - Description: To support Hive dialect with Flink, we have implemented

[jira] [Updated] (FLINK-26603) [Umbrella] Decouple Hive with Flink itself

[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26603: - Description: To support Hive dialect with Flink, we have implemented

[jira] [Updated] (FLINK-26603) [Umbrella] Decouple Hive with Flink itself

[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26603: - Description: To support Hive dialect with Flink, we have implemented

[jira] [Updated] (FLINK-26603) [Umbrella] Decouple Hive with Flink itself

[ https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26603: - Description: To support Hive dialect with Flink, we have implemented

[jira] [Updated] (FLINK-26604) update AvroParquet format user-facing document

[ https://issues.apache.org/jira/browse/FLINK-26604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26604: Affects Version/s: 1.15.0 > update AvroParquet format user-facing document >

[jira] [Updated] (FLINK-26604) update AvroParquet format user-facing document

[ https://issues.apache.org/jira/browse/FLINK-26604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26604: Fix Version/s: 1.15.0 > update AvroParquet format user-facing document >

[GitHub] [flink] flinkbot edited a comment on pull request #19041: [FLINK-24538][runtime][tests] Fix race condition when offering information to leader event queue in TestingRetrievalBase

flinkbot edited a comment on pull request #19041: URL: https://github.com/apache/flink/pull/19041#issuecomment-1064048402 ## CI report: * e2dfa45e08c28547666ad03c5a402e83b5e74f0a Azure:

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19039: [FLINK-26582][table] Convert table modules assertions to AssertJ

slinkydeveloper commented on a change in pull request #19039: URL: https://github.com/apache/flink/pull/19039#discussion_r824540352 ## File path: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableDescriptorTest.java ## @@ -99,9 +97,9 @@ public

[GitHub] [flink-statefun] FilKarnicki commented on a change in pull request #307: [FLINK-26537][statefun] Allow disabling StatefulFunctionsConfigValida…

FilKarnicki commented on a change in pull request #307: URL: https://github.com/apache/flink-statefun/pull/307#discussion_r824543145 ## File path: statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsJob.java ## @@ -36,18

[jira] [Commented] (FLINK-26388) Release Testing: Repeatable Cleanup (FLINK-25433)

[ https://issues.apache.org/jira/browse/FLINK-26388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504827#comment-17504827 ] Dawid Wysakowicz commented on FLINK-26388: -- No, I meant checkpoints that failed to be

[jira] [Created] (FLINK-26604) update AvroParquet format user-facing document

Jing Ge created FLINK-26604: --- Summary: update AvroParquet format user-facing document Key: FLINK-26604 URL: https://issues.apache.org/jira/browse/FLINK-26604 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15550: - Fix Version/s: 1.14.5 (was: 1.14.3) >

[GitHub] [flink] flinkbot edited a comment on pull request #19041: [FLINK-24538][runtime][tests] Fix race condition when offering information to leader event queue in TestingRetrievalBase

flinkbot edited a comment on pull request #19041: URL: https://github.com/apache/flink/pull/19041#issuecomment-1064048402 ## CI report: * e2dfa45e08c28547666ad03c5a402e83b5e74f0a Azure:

[jira] [Updated] (FLINK-26049) The tolerable-failed-checkpoints logic is invalid when checkpoint trigger failed

[ https://issues.apache.org/jira/browse/FLINK-26049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26049: - Fix Version/s: 1.14.5 (was: 1.14.4) > The

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19039: [FLINK-26582][table] Convert table modules assertions to AssertJ

slinkydeveloper commented on a change in pull request #19039: URL: https://github.com/apache/flink/pull/19039#discussion_r824540352 ## File path: flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableDescriptorTest.java ## @@ -99,9 +97,9 @@ public

[jira] [Updated] (FLINK-26223) Making ZK-related logs available in tests

[ https://issues.apache.org/jira/browse/FLINK-26223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26223: - Fix Version/s: 1.14.5 (was: 1.14.4) > Making ZK-related logs

[jira] [Updated] (FLINK-26285) ZooKeeperStateHandleStore does not handle not existing nodes properly in getAllAndLock

[ https://issues.apache.org/jira/browse/FLINK-26285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26285: - Fix Version/s: 1.14.5 (was: 1.14.4) > ZooKeeperStateHandleStore

[GitHub] [flink] autophagy commented on a change in pull request #19041: [FLINK-24538][runtime][tests] Fix race condition when offering information to leader event queue in TestingRetrievalBase

autophagy commented on a change in pull request #19041: URL: https://github.com/apache/flink/pull/19041#discussion_r824537699 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderretrieval/SettableLeaderRetrievalServiceTest.java ## @@ -32,6 +32,7 @@

[jira] [Commented] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504825#comment-17504825 ] Jark Wu commented on FLINK-26565: - What's the problem with current implementation? Could you give an

[GitHub] [flink] autophagy commented on pull request #19041: [FLINK-24538][runtime][tests] Fix race condition when offering information to leader event queue in TestingRetrievalBase

autophagy commented on pull request #19041: URL: https://github.com/apache/flink/pull/19041#issuecomment-1064930550 @XComp I did check that one - I don't believe that a check is strictly necessary for `testKubernetesLeaderRetrievalOnModifiedWithEmpty`, but I will add a

[jira] [Created] (FLINK-26603) [Umbrella] Decouple Hive with Flink itself

luoyuxia created FLINK-26603: Summary: [Umbrella] Decouple Hive with Flink itself Key: FLINK-26603 URL: https://issues.apache.org/jira/browse/FLINK-26603 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 0ee22778504c1bf11c25b5e9df0a8b5fc88a83cc Azure:

[jira] [Commented] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504822#comment-17504822 ] Jark Wu commented on FLINK-26565: - Is this a duplicate of FLINK-26498? > Use lateTrigger when the

[jira] [Updated] (FLINK-26602) The Rocksdb task failed savepoint, and then checkpoint failed several times

[ https://issues.apache.org/jira/browse/FLINK-26602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuchenhong updated FLINK-26602: Attachment: wx20220311-172...@2x.png wx20220311-172...@2x.png > The Rocksdb task

[jira] [Commented] (FLINK-26388) Release Testing: Repeatable Cleanup (FLINK-25433)

[ https://issues.apache.org/jira/browse/FLINK-26388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504819#comment-17504819 ] Matthias Pohl commented on FLINK-26388: --- I can do that. You're talking about checkpoints that

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 0ee22778504c1bf11c25b5e9df0a8b5fc88a83cc Azure:

[GitHub] [flink] autophagy commented on a change in pull request #19041: [FLINK-24538][runtime][tests] Fix race condition when offering information to leader event queue in TestingRetrievalBase

autophagy commented on a change in pull request #19041: URL: https://github.com/apache/flink/pull/19041#discussion_r824528488 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderretrieval/SettableLeaderRetrievalServiceTest.java ## @@ -32,6 +32,7 @@

[GitHub] [flink] MartijnVisser merged pull request #19044: [hotfix][doc] Chinese translation of "Running in an IDE"

MartijnVisser merged pull request #19044: URL: https://github.com/apache/flink/pull/19044 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #18974: Flink 26028 sink documentation 2

flinkbot edited a comment on pull request #18974: URL: https://github.com/apache/flink/pull/18974#issuecomment-1058728223 ## CI report: * ae4f76521d0913f4188740ee552dfc3802401c2d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 0ee22778504c1bf11c25b5e9df0a8b5fc88a83cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18776: [FLINK-26151][streaming]Avoid inprogressfileRecoverable not be clean up after restoring the bucket

flinkbot edited a comment on pull request #18776: URL: https://github.com/apache/flink/pull/18776#issuecomment-1040098864 ## CI report: * e7a42620acc196ee86d7d9b29cc53dbb5ae521c2 Azure:

[jira] [Created] (FLINK-26602) The Rocksdb task failed savepoint, and then checkpoint failed several times

liuchenhong created FLINK-26602: --- Summary: The Rocksdb task failed savepoint, and then checkpoint failed several times Key: FLINK-26602 URL: https://issues.apache.org/jira/browse/FLINK-26602 Project:

[GitHub] [flink] Myasuka commented on a change in pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

Myasuka commented on a change in pull request #19033: URL: https://github.com/apache/flink/pull/19033#discussion_r824522047 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java ## @@ -861,6 +1010,16 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 0ee22778504c1bf11c25b5e9df0a8b5fc88a83cc Azure:

[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test

[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26524: --- Fix Version/s: (was: 1.14.5) > Elasticsearch (v5.3.3) sink end-to-end test >

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504810#comment-17504810 ] Jark Wu commented on FLINK-26498: - [~hehuiyuan], [~paul8263], the current behavior works as expect with

[GitHub] [flink] flinkbot edited a comment on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

flinkbot edited a comment on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1064910556 ## CI report: * da5db0e1f7f7d0534b6637352eee8b9e8884b2a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 0ee22778504c1bf11c25b5e9df0a8b5fc88a83cc Azure:

<    1   2   3   4   5   6   >