[jira] [Created] (FLINK-36509) Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline Sink.

LvYanquan created FLINK-36509: - Summary: Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline Sink. Key: FLINK-36509 URL: https://issues.apache.org/jira/browse/FLINK-36509 Project: Flink

[jira] [Created] (FLINK-36508) Remove all deprecated methods in `SymbolType `

xuyang created FLINK-36508: -- Summary: Remove all deprecated methods in `SymbolType ` Key: FLINK-36508 URL: https://issues.apache.org/jira/browse/FLINK-36508 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36506) Remove all deprecated methods in `ColumnStats`

xuyang created FLINK-36506: -- Summary: Remove all deprecated methods in `ColumnStats` Key: FLINK-36506 URL: https://issues.apache.org/jira/browse/FLINK-36506 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36507) Remove deprecated method `LogicalTypeParser#parse`

xuyang created FLINK-36507: -- Summary: Remove deprecated method `LogicalTypeParser#parse` Key: FLINK-36507 URL: https://issues.apache.org/jira/browse/FLINK-36507 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction`

xuyang created FLINK-36505: -- Summary: Remove all deprecated methods in `ImperativeAggregateFunction` Key: FLINK-36505 URL: https://issues.apache.org/jira/browse/FLINK-36505 Project: Flink Issue Typ

[jira] [Created] (FLINK-36503) Remove deprecated method `FunctionDefinitionFactory#createFunctionDefinition`

xuyang created FLINK-36503: -- Summary: Remove deprecated method `FunctionDefinitionFactory#createFunctionDefinition` Key: FLINK-36503 URL: https://issues.apache.org/jira/browse/FLINK-36503 Project: Flink

[jira] [Created] (FLINK-36504) Remove all deprecated methods `ModuleFactory`

xuyang created FLINK-36504: -- Summary: Remove all deprecated methods `ModuleFactory` Key: FLINK-36504 URL: https://issues.apache.org/jira/browse/FLINK-36504 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36501) Remove all deprecated methods in `CatalogFactory`

xuyang created FLINK-36501: -- Summary: Remove all deprecated methods in `CatalogFactory` Key: FLINK-36501 URL: https://issues.apache.org/jira/browse/FLINK-36501 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36502) Remove all deprecated methods in `FactoryUtil`

xuyang created FLINK-36502: -- Summary: Remove all deprecated methods in `FactoryUtil` Key: FLINK-36502 URL: https://issues.apache.org/jira/browse/FLINK-36502 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36500) Remove all deprecated methods in `CallExpression`

xuyang created FLINK-36500: -- Summary: Remove all deprecated methods in `CallExpression` Key: FLINK-36500 URL: https://issues.apache.org/jira/browse/FLINK-36500 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36499) Remove deprecated method `SupportsProjectionPushDown#applyProjection`

xuyang created FLINK-36499: -- Summary: Remove deprecated method `SupportsProjectionPushDown#applyProjection` Key: FLINK-36499 URL: https://issues.apache.org/jira/browse/FLINK-36499 Project: Flink Is

[jira] [Created] (FLINK-36497) Remove all deprecated methods in `CatalogTable`

xuyang created FLINK-36497: -- Summary: Remove all deprecated methods in `CatalogTable` Key: FLINK-36497 URL: https://issues.apache.org/jira/browse/FLINK-36497 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36498) Remove deprecated method `ResolvedCatalogBaseTable#getSchema`

xuyang created FLINK-36498: -- Summary: Remove deprecated method `ResolvedCatalogBaseTable#getSchema` Key: FLINK-36498 URL: https://issues.apache.org/jira/browse/FLINK-36498 Project: Flink Issue Type

[jira] [Created] (FLINK-36496) Remove deprecated method `CatalogFunction#isGeneric `

xuyang created FLINK-36496: -- Summary: Remove deprecated method `CatalogFunction#isGeneric ` Key: FLINK-36496 URL: https://issues.apache.org/jira/browse/FLINK-36496 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-36495) Remove deprecated method `CatalogBaseTable#getSchema`

xuyang created FLINK-36495: -- Summary: Remove deprecated method `CatalogBaseTable#getSchema` Key: FLINK-36495 URL: https://issues.apache.org/jira/browse/FLINK-36495 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-36493) Remove all deprecated methods in `MapView`

xuyang created FLINK-36493: -- Summary: Remove all deprecated methods in `MapView` Key: FLINK-36493 URL: https://issues.apache.org/jira/browse/FLINK-36493 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36494) Remove deprecated methods `Catalog#getTableFactory` and `Catalog#supportsManagedTable`

xuyang created FLINK-36494: -- Summary: Remove deprecated methods `Catalog#getTableFactory` and `Catalog#supportsManagedTable` Key: FLINK-36494 URL: https://issues.apache.org/jira/browse/FLINK-36494 Project: F

[jira] [Created] (FLINK-36492) Remove all deprecated methods in `ListView`

xuyang created FLINK-36492: -- Summary: Remove all deprecated methods in `ListView` Key: FLINK-36492 URL: https://issues.apache.org/jira/browse/FLINK-36492 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36489) Remove deprecated method `StreamTableEnvironment#toRetractStream`

xuyang created FLINK-36489: -- Summary: Remove deprecated method `StreamTableEnvironment#toRetractStream` Key: FLINK-36489 URL: https://issues.apache.org/jira/browse/FLINK-36489 Project: Flink Issue

[jira] [Created] (FLINK-36491) Remove deprecated method `DataStreamSinkProvider#consumeDataStream`

xuyang created FLINK-36491: -- Summary: Remove deprecated method `DataStreamSinkProvider#consumeDataStream` Key: FLINK-36491 URL: https://issues.apache.org/jira/browse/FLINK-36491 Project: Flink Issu

[jira] [Created] (FLINK-36490) Remove deprecated method `DataStreamScanProvider#produceDataStream`

xuyang created FLINK-36490: -- Summary: Remove deprecated method `DataStreamScanProvider#produceDataStream` Key: FLINK-36490 URL: https://issues.apache.org/jira/browse/FLINK-36490 Project: Flink Issu

[jira] [Created] (FLINK-36486) Remove deprecated method `StreamTableEnvironment#registerDataStream`

xuyang created FLINK-36486: -- Summary: Remove deprecated method `StreamTableEnvironment#registerDataStream` Key: FLINK-36486 URL: https://issues.apache.org/jira/browse/FLINK-36486 Project: Flink Iss

[jira] [Created] (FLINK-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream`

xuyang created FLINK-36488: -- Summary: Remove deprecated method `StreamTableEnvironment#toAppendStream` Key: FLINK-36488 URL: https://issues.apache.org/jira/browse/FLINK-36488 Project: Flink Issue T

[jira] [Created] (FLINK-36485) Remove deprecated method `StreamTableEnvironment#fromDataStream`

xuyang created FLINK-36485: -- Summary: Remove deprecated method `StreamTableEnvironment#fromDataStream` Key: FLINK-36485 URL: https://issues.apache.org/jira/browse/FLINK-36485 Project: Flink Issue T

[jira] [Created] (FLINK-36487) Remove deprecated method `StreamTableEnvironment#createTemporaryView`

xuyang created FLINK-36487: -- Summary: Remove deprecated method `StreamTableEnvironment#createTemporaryView` Key: FLINK-36487 URL: https://issues.apache.org/jira/browse/FLINK-36487 Project: Flink Is

[jira] [Created] (FLINK-36484) Remove deprecated method `StreamTableEnvironment#registerFunction`

xuyang created FLINK-36484: -- Summary: Remove deprecated method `StreamTableEnvironment#registerFunction` Key: FLINK-36484 URL: https://issues.apache.org/jira/browse/FLINK-36484 Project: Flink Issue

[jira] [Created] (FLINK-36482) Remove all deprecated methods in `TableEnvironment`

xuyang created FLINK-36482: -- Summary: Remove all deprecated methods in `TableEnvironment` Key: FLINK-36482 URL: https://issues.apache.org/jira/browse/FLINK-36482 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36483) Remove deprecated method `TableResult#getTableSchema`

xuyang created FLINK-36483: -- Summary: Remove deprecated method `TableResult#getTableSchema` Key: FLINK-36483 URL: https://issues.apache.org/jira/browse/FLINK-36483 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-36481) Remove deprecated method `TableDescriptor#forManaged`

xuyang created FLINK-36481: -- Summary: Remove deprecated method `TableDescriptor#forManaged` Key: FLINK-36481 URL: https://issues.apache.org/jira/browse/FLINK-36481 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-36480) Remove all deprecated methods in `TableConfig`

xuyang created FLINK-36480: -- Summary: Remove all deprecated methods in `TableConfig` Key: FLINK-36480 URL: https://issues.apache.org/jira/browse/FLINK-36480 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36479) Remove deprecated methods `Table#getSchema` and `Table#as`

xuyang created FLINK-36479: -- Summary: Remove deprecated methods `Table#getSchema` and `Table#as` Key: FLINK-36479 URL: https://issues.apache.org/jira/browse/FLINK-36479 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-36478) Remove deprecated methods `EnvironmentSettings#fromConfiguration` and `EnvironmentSettings#toConfiguration`

xuyang created FLINK-36478: -- Summary: Remove deprecated methods `EnvironmentSettings#fromConfiguration` and `EnvironmentSettings#toConfiguration` Key: FLINK-36478 URL: https://issues.apache.org/jira/browse/FLINK-36478

[jira] [Created] (FLINK-36477) Remove deprecated method `BaseExpressions#cast` in table-api-java

xuyang created FLINK-36477: -- Summary: Remove deprecated method `BaseExpressions#cast` in table-api-java Key: FLINK-36477 URL: https://issues.apache.org/jira/browse/FLINK-36477 Project: Flink Issue

[jira] [Created] (FLINK-36476) Remove all deprecated methods under public APIs in table modules

xuyang created FLINK-36476: -- Summary: Remove all deprecated methods under public APIs in table modules Key: FLINK-36476 URL: https://issues.apache.org/jira/browse/FLINK-36476 Project: Flink Issue T

[jira] [Created] (FLINK-36475) YAML Transform supports case-insensitive column names conversion

yux created FLINK-36475: --- Summary: YAML Transform supports case-insensitive column names conversion Key: FLINK-36475 URL: https://issues.apache.org/jira/browse/FLINK-36475 Project: Flink Issue Type: I

[jira] [Created] (FLINK-36474) YAML Table-merging route should accept more type widening cases

yux created FLINK-36474: --- Summary: YAML Table-merging route should accept more type widening cases Key: FLINK-36474 URL: https://issues.apache.org/jira/browse/FLINK-36474 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-36473) Operator metrics tests fail intermittently

Sam Barker created FLINK-36473: -- Summary: Operator metrics tests fail intermittently Key: FLINK-36473 URL: https://issues.apache.org/jira/browse/FLINK-36473 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36472) Correlates with UDTF don't handle right-side conditions or projections

Alan Sheinberg created FLINK-36472: -- Summary: Correlates with UDTF don't handle right-side conditions or projections Key: FLINK-36472 URL: https://issues.apache.org/jira/browse/FLINK-36472 Project: F

[jira] [Created] (FLINK-36471) Flink Operator uses out of date Docker actions.

Sam Barker created FLINK-36471: -- Summary: Flink Operator uses out of date Docker actions. Key: FLINK-36471 URL: https://issues.apache.org/jira/browse/FLINK-36471 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-36470) Bump checkstyle to 10+

Sergey Nuyanzin created FLINK-36470: --- Summary: Bump checkstyle to 10+ Key: FLINK-36470 URL: https://issues.apache.org/jira/browse/FLINK-36470 Project: Flink Issue Type: Technical Debt

Resource limits for the k8s

Hi I'm really struggling to find out, how I can manage resource limits for k8s deployment. We experiencing lots of cputhrotling alerts and would like to adjust resource limits but I can't find out how. Will appreciate any help you can provide. Regards, Maksym Serhieiev

[jira] [Created] (FLINK-36469) Bump commons-io from 2.11.0 to 2.17.0

Siddharth R created FLINK-36469: --- Summary: Bump commons-io from 2.11.0 to 2.17.0 Key: FLINK-36469 URL: https://issues.apache.org/jira/browse/FLINK-36469 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36468) Use Flink Precondition utils instead of Parquet

Ferenc Csaky created FLINK-36468: Summary: Use Flink Precondition utils instead of Parquet Key: FLINK-36468 URL: https://issues.apache.org/jira/browse/FLINK-36468 Project: Flink Issue Type: T

[jira] [Created] (FLINK-36467) Bump google-java-format and spotless

Mate Czagany created FLINK-36467: Summary: Bump google-java-format and spotless Key: FLINK-36467 URL: https://issues.apache.org/jira/browse/FLINK-36467 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36466) Change default value of execution.runtime-mode from STREAMING to AUTOMATIC

Wenjun Ruan created FLINK-36466: --- Summary: Change default value of execution.runtime-mode from STREAMING to AUTOMATIC Key: FLINK-36466 URL: https://issues.apache.org/jira/browse/FLINK-36466 Project: Fl

Re: Consequences of removing per-job mode in Flink 2.0

Hello Weijie, Shengkai, Thank you for your response! The suggested plan by reverting the commit for the 2.0-preview sounds good to me! I also hope AM support for SQL jobs can be delivered for 2.0.0, and we can remove the long-time deprecated per-job mode and simplify both the deployment model and

[jira] [Created] (FLINK-36465) Bump okhttp from 3.14.9 to 4.12.0

Siddharth R created FLINK-36465: --- Summary: Bump okhttp from 3.14.9 to 4.12.0 Key: FLINK-36465 URL: https://issues.apache.org/jira/browse/FLINK-36465 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36464) Local artifact fetcher should not require base directory

Fabian Paul created FLINK-36464: --- Summary: Local artifact fetcher should not require base directory Key: FLINK-36464 URL: https://issues.apache.org/jira/browse/FLINK-36464 Project: Flink Issue