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

2024-10-10 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36509: -- Assignee: LvYanquan > Fix 'Unsupported bucket mode: GLOBAL_DYNAMIC' error in Paimon Pipeline

Re: [PR] [hotfix] change FileSourceSplit to JdbcSourceSplit [flink-connector-jdbc]

2024-10-10 Thread via GitHub
caicancai commented on PR #145: URL: https://github.com/apache/flink-connector-jdbc/pull/145#issuecomment-2406590520 cc @RocMarshal @1996fanrui -- 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 t

Re: [PR] [BP-1.20][FLINK-36468][parquet] Use Flink Preconditions util instead of Parquet [flink]

2024-10-10 Thread via GitHub
ferenc-csaky commented on PR #25490: URL: https://github.com/apache/flink/pull/25490#issuecomment-2406560135 @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 comme

Re: [PR] [FLINK-30899][connector/filesystem] Fix FileSystemTableSource incorrectly selecting fields on partitioned tables [flink]

2024-10-10 Thread via GitHub
ferenc-csaky commented on PR #25489: URL: https://github.com/apache/flink/pull/25489#issuecomment-2406559216 @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 comme

[PR] Update slack invitation link [flink-web]

2024-10-10 Thread via GitHub
leonardBang opened a new pull request, #756: URL: https://github.com/apache/flink-web/pull/756 Update slack invitation link -- 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.

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

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36476: --- Priority: Blocker (was: Major) > Remove all deprecated methods under public APIs in table modules >

Re: [PR] [hotfix][test] Fix TypeHintITCase if adaptive scheduler enabled [flink]

2024-10-10 Thread via GitHub
flinkbot commented on PR #25493: URL: https://github.com/apache/flink/pull/25493#issuecomment-2406509304 ## CI report: * 5b970b02b4e7d1555733be21e63625baa17722e2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [hotfix][test] Fix TypeHintITCase if adaptive scheduler enabled [flink]

2024-10-10 Thread via GitHub
reswqa opened a new pull request, #25493: URL: https://github.com/apache/flink/pull/25493 ## What is the purpose of the change *Fix TypeHintITCase if adaptive scheduler enabled* ## Verifying this change This change is a trivial rework / code cleanup without any te

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

2024-10-10 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888509#comment-17888509 ] LvYanquan commented on FLINK-36509: --- I've found the resolution and would like to fix i

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

2024-10-10 Thread LvYanquan (Jira)
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

Re: [PR] [hotfix] Fix testfail due to data race with after migration to Fabric8 interceptor [flink-kubernetes-operator]

2024-10-10 Thread via GitHub
SamBarker commented on PR #891: URL: https://github.com/apache/flink-kubernetes-operator/pull/891#issuecomment-2406490221 I've raised https://github.com/apache/flink-kubernetes-operator/pull/896 to actually wait for the metrics to become available. -- This is an automated message from th

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

2024-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36473: --- Labels: pull-request-available (was: ) > Operator metrics tests fail intermittently > -

[PR] [FLINK-36473] Wait for metrics before asserting on them [flink-kubernetes-operator]

2024-10-10 Thread via GitHub
SamBarker opened a new pull request, #896: URL: https://github.com/apache/flink-kubernetes-operator/pull/896 ## What is the purpose of the change Operator metrics are lazily initialised. This PR addresses race conditions in tests trying to assert metrics. An alternative

[jira] [Commented] (FLINK-36167) testSinkDisorderChangeLog failed on AZP

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888505#comment-17888505 ] Weijie Guo commented on FLINK-36167: https://dev.azure.com/apache-flink/apache-flink

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

2024-10-10 Thread xuyang (Jira)
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`

2024-10-10 Thread xuyang (Jira)
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-36505) Remove all deprecated methods in `ImperativeAggregateFunction`

2024-10-10 Thread xuyang (Jira)
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-36504) Remove all deprecated methods `ModuleFactory`

2024-10-10 Thread xuyang (Jira)
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-36507) Remove deprecated method `LogicalTypeParser#parse`

2024-10-10 Thread xuyang (Jira)
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] [Updated] (FLINK-36505) Remove all deprecated methods in `ImperativeAggregateFunction`, `ScalarFunction` and `TableFunction`

2024-10-10 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36505: --- Summary: Remove all deprecated methods in `ImperativeAggregateFunction`, `ScalarFunction` and `TableFunction

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

2024-10-10 Thread xuyang (Jira)
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-36501) Remove all deprecated methods in `CatalogFactory`

2024-10-10 Thread xuyang (Jira)
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-36500) Remove all deprecated methods in `CallExpression`

2024-10-10 Thread xuyang (Jira)
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-36502) Remove all deprecated methods in `FactoryUtil`

2024-10-10 Thread xuyang (Jira)
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-36499) Remove deprecated method `SupportsProjectionPushDown#applyProjection`

2024-10-10 Thread xuyang (Jira)
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`

2024-10-10 Thread xuyang (Jira)
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-36496) Remove deprecated method `CatalogFunction#isGeneric `

2024-10-10 Thread xuyang (Jira)
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-36498) Remove deprecated method `ResolvedCatalogBaseTable#getSchema`

2024-10-10 Thread xuyang (Jira)
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] [Commented] (FLINK-36475) YAML Transform supports case-insensitive column names conversion

2024-10-10 Thread JunboWang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888497#comment-17888497 ] JunboWang commented on FLINK-36475: --- Please assign this to me. > YAML Transform suppo

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

2024-10-10 Thread xuyang (Jira)
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-36494) Remove deprecated methods `Catalog#getTableFactory` and `Catalog#supportsManagedTable`

2024-10-10 Thread xuyang (Jira)
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-36493) Remove all deprecated methods in `MapView`

2024-10-10 Thread xuyang (Jira)
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-36492) Remove all deprecated methods in `ListView`

2024-10-10 Thread xuyang (Jira)
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-36490) Remove deprecated method `DataStreamScanProvider#produceDataStream`

2024-10-10 Thread xuyang (Jira)
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-36491) Remove deprecated method `DataStreamSinkProvider#consumeDataStream`

2024-10-10 Thread xuyang (Jira)
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-36489) Remove deprecated method `StreamTableEnvironment#toRetractStream`

2024-10-10 Thread xuyang (Jira)
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-36487) Remove deprecated method `StreamTableEnvironment#createTemporaryView`

2024-10-10 Thread xuyang (Jira)
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-36488) Remove deprecated method `StreamTableEnvironment#toAppendStream`

2024-10-10 Thread xuyang (Jira)
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-36486) Remove deprecated method `StreamTableEnvironment#registerDataStream`

2024-10-10 Thread xuyang (Jira)
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-36485) Remove deprecated method `StreamTableEnvironment#fromDataStream`

2024-10-10 Thread xuyang (Jira)
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-36483) Remove deprecated method `TableResult#getTableSchema`

2024-10-10 Thread xuyang (Jira)
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-36484) Remove deprecated method `StreamTableEnvironment#registerFunction`

2024-10-10 Thread xuyang (Jira)
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`

2024-10-10 Thread xuyang (Jira)
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-36481) Remove deprecated method `TableDescriptor#forManaged`

2024-10-10 Thread xuyang (Jira)
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`

2024-10-10 Thread xuyang (Jira)
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

Re: [PR] [tests] Reorganize test cases to accelerate CI workflow [flink-cdc]

2024-10-10 Thread via GitHub
yuxiqian commented on PR #3587: URL: https://github.com/apache/flink-cdc/pull/3587#issuecomment-2406438647 Closing in favor of #3626 -- 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 c

Re: [PR] [tests] Reorganize test cases to accelerate CI workflow [flink-cdc]

2024-10-10 Thread via GitHub
yuxiqian closed pull request #3587: [tests] Reorganize test cases to accelerate CI workflow URL: https://github.com/apache/flink-cdc/pull/3587 -- 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 spe

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

2024-10-10 Thread xuyang (Jira)
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] [Updated] (FLINK-36478) Remove deprecated methods `EnvironmentSettings#fromConfiguration` and `EnvironmentSettings#toConfiguration`

2024-10-10 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36478: --- Component/s: Table SQL / API > Remove deprecated methods `EnvironmentSettings#fromConfiguration` and > `Env

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

2024-10-10 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36477: --- Component/s: Table SQL / API > Remove deprecated method `BaseExpressions#cast` in table-api-java > -

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

2024-10-10 Thread xuyang (Jira)
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

2024-10-10 Thread xuyang (Jira)
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] [Updated] (FLINK-36476) Remove all deprecated methods under public APIs in table modules

2024-10-10 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36476: --- Description: All methods needed to be removed are: https://docs.google.com/document/d/1bVrmcB9UFOd1-sT7xDRT

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

2024-10-10 Thread xuyang (Jira)
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

2024-10-10 Thread yux (Jira)
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

Re: [PR] [FLINK-36158][runtime] Refactor Job Recovery Process to Use ExecutionPlan Instead of JobGraph. [flink]

2024-10-10 Thread via GitHub
flinkbot commented on PR #25492: URL: https://github.com/apache/flink/pull/25492#issuecomment-2406433950 ## CI report: * 646c8bba28cffe3531976145efa104f422f33bf4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2024-10-10 Thread yux (Jira)
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] [Updated] (FLINK-36158) Refactor Job Recovery Process to Use ExecutionPlan Instead of JobGraph

2024-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36158: --- Labels: pull-request-available (was: ) > Refactor Job Recovery Process to Use ExecutionPlan

[PR] [FLINK-36158][runtime] Refactor Job Recovery Process to Use ExecutionPlan Instead of JobGraph. [flink]

2024-10-10 Thread via GitHub
JunRuiLee opened a new pull request, #25492: URL: https://github.com/apache/flink/pull/25492 ## What is the purpose of the change [FLINK-36158][runtime] Refactor Job Recovery Process to Use ExecutionPlan Instead of JobGraph. ## Brief change log [FLINK-361

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

2024-10-10 Thread Sam Barker (Jira)
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] [Commented] (FLINK-36470) Bump checkstyle to 10+

2024-10-10 Thread Wenjun Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888492#comment-17888492 ] Wenjun Ruan commented on FLINK-36470: - [~Sergey Nuyanzin] Hi, I read the doc from [

[jira] [Resolved] (FLINK-36423) RichMapPartitionFunction does not invoke the open method in the KeyedPartitionWindowedStream

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-36423. Resolution: Fixed master(2.0) via 2949815de621efab4d362bb2ee2c30058c8744a2. > RichMapPartitionFun

[jira] [Updated] (FLINK-36423) RichMapPartitionFunction does not invoke the open method in the KeyedPartitionWindowedStream

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36423: --- Fix Version/s: 2.0.0 > RichMapPartitionFunction does not invoke the open method in the > KeyedParti

[jira] [Assigned] (FLINK-36423) RichMapPartitionFunction does not invoke the open method in the KeyedPartitionWindowedStream

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-36423: -- Assignee: xuhuang > RichMapPartitionFunction does not invoke the open method in the > KeyedP

Re: [PR] [FLINK-36423] Fix RichMapPartitionFunction does not invoke open method in KeyedPartitionWindowedStream [flink]

2024-10-10 Thread via GitHub
reswqa merged PR #25452: URL: https://github.com/apache/flink/pull/25452 -- 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: issues-unsubscr...@flink.apache

Re: [PR] [hotfix] Ingore hadoopInputFormat related test case in adaptive scheduler [flink]

2024-10-10 Thread via GitHub
reswqa merged PR #25482: URL: https://github.com/apache/flink/pull/25482 -- 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: issues-unsubscr...@flink.apache

Re: [PR] [hotfix] Fix CustomSerializationITCase unstable test case [flink]

2024-10-10 Thread via GitHub
codenohup closed pull request #25484: [hotfix] Fix CustomSerializationITCase unstable test case URL: https://github.com/apache/flink/pull/25484 -- 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 sp

[jira] [Updated] (FLINK-26000) Drop Per-Job Mode

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26000: --- Issue Type: Technical Debt (was: Improvement) > Drop Per-Job Mode > - > >

[jira] [Updated] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26541: --- Priority: Blocker (was: Major) > SQL Client should support submitting SQL jobs in application mode

[jira] [Updated] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26541: --- Affects Version/s: 2.0.0 > SQL Client should support submitting SQL jobs in application mode > -

[jira] [Updated] (FLINK-26000) Drop Per-Job Mode

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26000: --- Priority: Blocker (was: Major) > Drop Per-Job Mode > - > > Key: FLI

[jira] [Updated] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26541: --- Fix Version/s: 2.0.0 > SQL Client should support submitting SQL jobs in application mode > -

[jira] [Updated] (FLINK-26000) Drop Per-Job Mode

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26000: --- Affects Version/s: 2.0.0 > Drop Per-Job Mode > - > > Key: FLINK-2600

[jira] [Updated] (FLINK-26000) Drop Per-Job Mode

2024-10-10 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-26000: --- Fix Version/s: 2.0.0 > Drop Per-Job Mode > - > > Key: FLINK-26000 >

Re: [PR] [FLINK-35825][hive] HiveTableSource supports report statistics for text file [flink]

2024-10-10 Thread via GitHub
reswqa commented on PR #25078: URL: https://github.com/apache/flink/pull/25078#issuecomment-2406369128 @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 comment. T

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

2024-10-10 Thread Alan Sheinberg (Jira)
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] [Updated] (FLINK-36472) Correlates with UDTF don't handle right-side projections or empty conditions

2024-10-10 Thread Alan Sheinberg (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Sheinberg updated FLINK-36472: --- Summary: Correlates with UDTF don't handle right-side projections or empty conditions (was:

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

2024-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36471: --- Labels: pull-request-available (was: ) > Flink Operator uses out of date Docker actions. >

[PR] [FLINK-36471] Update docker build actions to current versions. [flink-kubernetes-operator]

2024-10-10 Thread via GitHub
SamBarker opened a new pull request, #895: URL: https://github.com/apache/flink-kubernetes-operator/pull/895 ## What is the purpose of the change Upgrade to the current versions of the docker actions to avoid NodeJS 12 deprecation ## Brief change log Upgrade to t

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

2024-10-10 Thread Sam Barker (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Barker updated FLINK-36471: --- Description: The operator test suite if full of warnings about using out of date github actions bas

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

2024-10-10 Thread Sam Barker (Jira)
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

Re: [PR] [FLINK-36470][build] Bump checkstyle to 10+ [flink]

2024-10-10 Thread via GitHub
flinkbot commented on PR #25491: URL: https://github.com/apache/flink/pull/25491#issuecomment-2406038716 ## CI report: * 35e45e6ef24b0d734a46a08702364f304e04681a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [BP-1.18][FLINK-36421] [fs] [checkpoint] Sync outputStream before returning handle in FsCheckpointStreamFactory [flink]

2024-10-10 Thread via GitHub
gaborgsomogyi commented on PR #25479: URL: https://github.com/apache/flink/pull/25479#issuecomment-2406031612 @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 comm

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

2024-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36470: --- Labels: pull-request-available (was: ) > Bump checkstyle to 10+ > -- >

[PR] [FLINK-36470][build] Bump checkstyle to 10+ [flink]

2024-10-10 Thread via GitHub
snuyanzin opened a new pull request, #25491: URL: https://github.com/apache/flink/pull/25491 ## What is the purpose of the change Bumping checkstyle to 10+ ## Verifying this change This change is a trivial rework / code cleanup without any test coverag

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

2024-10-10 Thread Sergey Nuyanzin (Jira)
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

Re: [PR] [BP-1.20][FLINK-36468][parquet] Use Flink Preconditions util instead of Parquet [flink]

2024-10-10 Thread via GitHub
flinkbot commented on PR #25490: URL: https://github.com/apache/flink/pull/25490#issuecomment-2405992448 ## CI report: * 7d72aaea7f1f9e95fcd9428142905118abde6cbb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [hotfix] Add maven wrapper [flink-connector-kafka]

2024-10-10 Thread via GitHub
AHeise commented on PR #127: URL: https://github.com/apache/flink-connector-kafka/pull/127#issuecomment-2405985352 Welp didn't squash... -- 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 speci

Re: [PR] [hotfix] Add maven wrapper [flink-connector-kafka]

2024-10-10 Thread via GitHub
AHeise merged PR #127: URL: https://github.com/apache/flink-connector-kafka/pull/127 -- 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: issues-unsubscr...@

[PR] [BP-1.20][FLINK-36468][parquet] Use Flink Preconditions util instead of Parquet [flink]

2024-10-10 Thread via GitHub
ferenc-csaky opened a new pull request, #25490: URL: https://github.com/apache/flink/pull/25490 1.20 Backport of https://github.com/apache/flink/pull/25488 ## What is the purpose of the change Use Flink Preconditions util instead of Parquet ## Brief change log `org

[PR] [FLINK-36469] Bump commons-io from 2.11.0 to 2.17.0 [flink-kubernetes-operator]

2024-10-10 Thread via GitHub
r-sidd opened a new pull request, #894: URL: https://github.com/apache/flink-kubernetes-operator/pull/894 ## What is the purpose of the change Bump commons-io from 2.11.0 to 2.17.0 ## Brief change log Commons-io version 2.11.0 has a direct vulnerability and bumping it

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

2024-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36469: --- Labels: pull-request-available (was: ) > Bump commons-io from 2.11.0 to 2.17.0 > --

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

2024-10-10 Thread Siddharth R (Jira)
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] [Closed] (FLINK-29797) can't run a job on yarn, if set fs.default-scheme

2024-10-10 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky closed FLINK-29797. Resolution: Fixed [{{6422142}}|https://github.com/apache/flink/commit/6422142369b280fc24d790c3eaf4

Re: [PR] [FLINK-29797][flink-yarn][backport] Fix fs.default-scheme will accidentally cau… [flink]

2024-10-10 Thread via GitHub
ferenc-csaky merged PR #25485: URL: https://github.com/apache/flink/pull/25485 -- 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: issues-unsubscr...@flink.

Re: [PR] [FLINK-29797][flink-yarn] Fix fs.default-scheme will accidentally cau… [flink]

2024-10-10 Thread via GitHub
ferenc-csaky merged PR #24733: URL: https://github.com/apache/flink/pull/24733 -- 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: issues-unsubscr...@flink.

[jira] [Updated] (FLINK-29797) can't run a job on yarn, if set fs.default-scheme

2024-10-10 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-29797: - Fix Version/s: 2.0-preview (was: 2.0.0) > can't run a job on yarn, if set

Re: [PR] [FLINK-30899][connector/filesystem] Fix FileSystemTableSource incorrectly selecting fields on partitioned tables [flink]

2024-10-10 Thread via GitHub
flinkbot commented on PR #25489: URL: https://github.com/apache/flink/pull/25489#issuecomment-2405695523 ## CI report: * 51b7d2279e6ba19657ea9d31376c60e12ba2bf13 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Resolved] (FLINK-25546) [JUnit5 Migration] Module: flink-connector-base

2024-10-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-25546. - Fix Version/s: 2.0-preview Resolution: Fixed > [JUnit5 Migration] Module: flink-c

[jira] [Commented] (FLINK-25546) [JUnit5 Migration] Module: flink-connector-base

2024-10-10 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888378#comment-17888378 ] Sergey Nuyanzin commented on FLINK-25546: - Merged as [653c0fff7001350a107450910

  1   2   3   >