[jira] [Created] (FLINK-24094) Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31)

lixu created FLINK-24094: Summary: Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31) Key: FLINK-24094 URL:

[jira] [Created] (FLINK-24093) Supports setting the percentage of kubernetes Request resources

liuzhuo created FLINK-24093: --- Summary: Supports setting the percentage of kubernetes Request resources Key: FLINK-24093 URL: https://issues.apache.org/jira/browse/FLINK-24093 Project: Flink Issue

[jira] [Created] (FLINK-24092) OrcFsStreamingSinkITCase.testPart times out on azure

Xintong Song created FLINK-24092: Summary: OrcFsStreamingSinkITCase.testPart times out on azure Key: FLINK-24092 URL: https://issues.apache.org/jira/browse/FLINK-24092 Project: Flink Issue

[jira] [Created] (FLINK-24091) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure fails on azure

Xintong Song created FLINK-24091: Summary: TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure fails on azure Key: FLINK-24091 URL: https://issues.apache.org/jira/browse/FLINK-24091

[jira] [Created] (FLINK-24090) Document ability to ignore in-flight data on recovery

Joe Moser created FLINK-24090: - Summary: Document ability to ignore in-flight data on recovery Key: FLINK-24090 URL: https://issues.apache.org/jira/browse/FLINK-24090 Project: Flink Issue Type:

Re: [ANNOUNCE] Apache Flink Stateful Functions 3.1.0 released

Congrats on the release! And thank you for driving this release, Igal. Cheers Gordon On Tue, Aug 31, 2021, 23:13 Igal Shilman wrote: > The Apache Flink community is very happy to announce the release of Apache > Flink Stateful Functions (StateFun) 3.1.0. > > StateFun is a cross-platform stack

[jira] [Created] (FLINK-24089) AzureBlobStorageFSFactoryTest and AzureDataLakeStoreGen2FSFactoryTest fail using mvn test

Nicolaus Weidner created FLINK-24089: Summary: AzureBlobStorageFSFactoryTest and AzureDataLakeStoreGen2FSFactoryTest fail using mvn test Key: FLINK-24089 URL: https://issues.apache.org/jira/browse/FLINK-24089

[jira] [Created] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient

Matthias created FLINK-24088: Summary: "Internal server error" when quitting a SELECT query in the SqlClient Key: FLINK-24088 URL: https://issues.apache.org/jira/browse/FLINK-24088 Project: Flink

[ANNOUNCE] Apache Flink Stateful Functions 3.1.0 released

The Apache Flink community is very happy to announce the release of Apache Flink Stateful Functions (StateFun) 3.1.0. StateFun is a cross-platform stack for building Stateful Serverless applications, making it radically simpler to develop scalable, consistent, and elastic distributed

Re: 退订

Hi, Please send email to dev-unsubscr...@flink.apache.org if you want to unsubscribe the mail from dev@flink.apache.org . Please send email to user-unsubscr...@flink.apache.org

[jira] [Created] (FLINK-24087) Kafka connector StartupMode requires a table dependency

Timo Walther created FLINK-24087: Summary: Kafka connector StartupMode requires a table dependency Key: FLINK-24087 URL: https://issues.apache.org/jira/browse/FLINK-24087 Project: Flink

[jira] [Created] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

ming li created FLINK-24086: --- Summary: Do not re-register SharedStateRegistry to reduce the recovery time of the job Key: FLINK-24086 URL: https://issues.apache.org/jira/browse/FLINK-24086 Project: Flink

[jira] [Created] (FLINK-24085) The `versioned table` and `Timezone` pages missed the first class subject

Leonard Xu created FLINK-24085: -- Summary: The `versioned table` and `Timezone` pages missed the first class subject Key: FLINK-24085 URL: https://issues.apache.org/jira/browse/FLINK-24085 Project:

[jira] [Created] (FLINK-24084) The example in sql join document missed primary key

Leonard Xu created FLINK-24084: -- Summary: The example in sql join document missed primary key Key: FLINK-24084 URL: https://issues.apache.org/jira/browse/FLINK-24084 Project: Flink Issue Type:

[jira] [Created] (FLINK-24083) The result isn't as expected when the result type is generator of string for Python UDTF

Dian Fu created FLINK-24083: --- Summary: The result isn't as expected when the result type is generator of string for Python UDTF Key: FLINK-24083 URL: https://issues.apache.org/jira/browse/FLINK-24083

[jira] [Created] (FLINK-24082) Python UDTF throws exception when the result type is generator of Row

Dian Fu created FLINK-24082: --- Summary: Python UDTF throws exception when the result type is generator of Row Key: FLINK-24082 URL: https://issues.apache.org/jira/browse/FLINK-24082 Project: Flink

[jira] [Created] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

Leonard Xu created FLINK-24081: -- Summary: OVER window throws exception when the rowtime is timestamp_ltz type Key: FLINK-24081 URL: https://issues.apache.org/jira/browse/FLINK-24081 Project: Flink

[jira] [Created] (FLINK-24080) taskmanagers leak suspect ChildFirstClassLoader Biggest instances:

leishuiyu created FLINK-24080: - Summary: taskmanagers leak suspect ChildFirstClassLoader Biggest instances: Key: FLINK-24080 URL: https://issues.apache.org/jira/browse/FLINK-24080 Project: Flink

[jira] [Created] (FLINK-24079) BufferedUpsertSinkFunction can loose records during failover

Fabian Paul created FLINK-24079: --- Summary: BufferedUpsertSinkFunction can loose records during failover Key: FLINK-24079 URL: https://issues.apache.org/jira/browse/FLINK-24079 Project: Flink

[jira] [Created] (FLINK-24078) Remove brackets around variables

Chesnay Schepler created FLINK-24078: Summary: Remove brackets around variables Key: FLINK-24078 URL: https://issues.apache.org/jira/browse/FLINK-24078 Project: Flink Issue Type:

flink-runtime-web build failing locally

Hi devs, A couple of people encountered recently a master build failure when building `flink-runtime-web`: TypeError: Cannot read property 'resolve' of undefined (and some node/npm stack trace) What solved the problem for me and a couple of other persons: 1. update npm/node > brew upgrade

[jira] [Created] (FLINK-24077) HBaseConnectorITCase.testTableSink

Xintong Song created FLINK-24077: Summary: HBaseConnectorITCase.testTableSink Key: FLINK-24077 URL: https://issues.apache.org/jira/browse/FLINK-24077 Project: Flink Issue Type: Bug

Re: Flink 1.14 Weekly 2021-08-31

Small correction: They should /only/ be tagged as fixes for 1.14.0. https://cwiki.apache.org/confluence/display/FLINK/Flink+Jira+Process#FlinkJiraProcess-FixVersion/s: On 31/08/2021 11:21, Johannes Moser wrote: Dear Apache Flink community, Today was another update and more and more features

Flink 1.14 Weekly 2021-08-31

Dear Apache Flink community, Today was another update and more and more features are moving into the glorious state of “done done”. *RC0* Xintong did a great job in cutting of the 1.14 branch and releasing the first release candidate that is available [1][2][3][3]. So from now on bug fixes

[jira] [Created] (FLINK-24076) Implement Table API walkthrough in flink-playground

Matthias created FLINK-24076: Summary: Implement Table API walkthrough in flink-playground Key: FLINK-24076 URL: https://issues.apache.org/jira/browse/FLINK-24076 Project: Flink Issue Type:

[jira] [Created] (FLINK-24075) Apache Flink 1.13.1 Docker images are published for linux/arm

Matthias created FLINK-24075: Summary: Apache Flink 1.13.1 Docker images are published for linux/arm Key: FLINK-24075 URL: https://issues.apache.org/jira/browse/FLINK-24075 Project: Flink Issue

[jira] [Created] (FLINK-24074) Check 1.14 licensing

Xintong Song created FLINK-24074: Summary: Check 1.14 licensing Key: FLINK-24074 URL: https://issues.apache.org/jira/browse/FLINK-24074 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-24073) Statefun 2.2 documentation build fails on buildbot

Chesnay Schepler created FLINK-24073: Summary: Statefun 2.2 documentation build fails on buildbot Key: FLINK-24073 URL: https://issues.apache.org/jira/browse/FLINK-24073 Project: Flink

[jira] [Created] (FLINK-24072) Add support for setting default headers in elasticsearch connector

jinfeng created FLINK-24072: --- Summary: Add support for setting default headers in elasticsearch connector Key: FLINK-24072 URL: https://issues.apache.org/jira/browse/FLINK-24072 Project: Flink

[jira] [Created] (FLINK-24071) Flink 1.12 HDFS sink have a problem,reported as OOM

zhuzhengjun created FLINK-24071: --- Summary: Flink 1.12 HDFS sink have a problem,reported as OOM Key: FLINK-24071 URL: https://issues.apache.org/jira/browse/FLINK-24071 Project: Flink Issue

[jira] [Created] (FLINK-24070) Support different over window aggregates in streaming queries

zl created FLINK-24070: -- Summary: Support different over window aggregates in streaming queries Key: FLINK-24070 URL: https://issues.apache.org/jira/browse/FLINK-24070 Project: Flink Issue Type:

[jira] [Created] (FLINK-24069) IgnoreInFlightDataITCase.testIgnoreInFlightDataDuringRecovery hangs on azure

Xintong Song created FLINK-24069: Summary: IgnoreInFlightDataITCase.testIgnoreInFlightDataDuringRecovery hangs on azure Key: FLINK-24069 URL: https://issues.apache.org/jira/browse/FLINK-24069

[jira] [Created] (FLINK-24068) CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint

Yun Gao created FLINK-24068: --- Summary: CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint Key: FLINK-24068 URL: https://issues.apache.org/jira/browse/FLINK-24068

[jira] [Created] (FLINK-24067) CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint

Yun Gao created FLINK-24067: --- Summary: CheckpointBarrierHandler may skip the markAlignmentStart for alignment -with-timeout checkpoint Key: FLINK-24067 URL: https://issues.apache.org/jira/browse/FLINK-24067

[jira] [Created] (FLINK-24066) Provides a new stop entry for Kubernetes session mode

liuzhuo created FLINK-24066: --- Summary: Provides a new stop entry for Kubernetes session mode Key: FLINK-24066 URL: https://issues.apache.org/jira/browse/FLINK-24066 Project: Flink Issue Type:

[jira] [Created] (FLINK-24065) Upgrade the TwoPhaseCommitSink to support empty transaction after finished

Yun Gao created FLINK-24065: --- Summary: Upgrade the TwoPhaseCommitSink to support empty transaction after finished Key: FLINK-24065 URL: https://issues.apache.org/jira/browse/FLINK-24065 Project: Flink

[jira] [Created] (FLINK-24064) HybridSource recovery from savepoint fails

Thomas Weise created FLINK-24064: Summary: HybridSource recovery from savepoint fails Key: FLINK-24064 URL: https://issues.apache.org/jira/browse/FLINK-24064 Project: Flink Issue Type: Bug

Re: Support decimal types with larger precisions

Hi Jark and Jingsong, Thanks for your reply! Since modifying the SQL type system needs a lot of work, I agree that we should postpone this until we get more requests from users. For my own case, according to the domain knowledge, I think a precision of 38 would be enough (though the fields were