[jira] [Assigned] (FLINK-36295) AdaptiveSchedulerClusterITCase. testCheckpointStatsPersistedAcrossRescale failed with

[ https://issues.apache.org/jira/browse/FLINK-36295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-36295: - Assignee: Zdenek Tison (was: Matthias Pohl) > AdaptiveSchedulerClusterITC

[jira] [Resolved] (FLINK-36347) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics.

[ https://issues.apache.org/jira/browse/FLINK-36347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongmin Qiao resolved FLINK-36347. --- Resolution: Fixed > Using the offset obtained after a query transaction as a high waterm

[jira] [Commented] (FLINK-36347) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics.

[ https://issues.apache.org/jira/browse/FLINK-36347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883579#comment-17883579 ] Zhongmin Qiao commented on FLINK-36347: --- Assign this pr to me please.  [ h

[jira] [Updated] (FLINK-36347) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics.

[ https://issues.apache.org/jira/browse/FLINK-36347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongmin Qiao updated FLINK-36347: -- Description: !image-2024-09-22-16-51-09-930.png|width=891,height=564! Using the offset

[jira] [Created] (FLINK-36347) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics.

Zhongmin Qiao created FLINK-36347: - Summary: Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics. Key: FLINK-36347 URL: https://issues.apache.org/jira

[jira] [Updated] (FLINK-36346) Remove deprecated API in flink-streaming-java module

[ https://issues.apache.org/jira/browse/FLINK-36346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36346: --- Labels: pull-request-available (was: ) > Remove deprecated API in flink-streaming-j

[jira] [Created] (FLINK-36346) Remove deprecated API in flink-streaming-java module

Weijie Guo created FLINK-36346: -- Summary: Remove deprecated API in flink-streaming-java module Key: FLINK-36346 URL: https://issues.apache.org/jira/browse/FLINK-36346 Project: Flink Issue Type

[jira] [Updated] (FLINK-36293) RocksDBWriteBatchWrapperTest.testAsyncCancellation

[ https://issues.apache.org/jira/browse/FLINK-36293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36293: --- Labels: pull-request-available test-stability (was: test-stability

[jira] [Comment Edited] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883560#comment-17883560 ] Sergey Nuyanzin edited comment on FLINK-34702 at 9/22/24 12:1

[jira] [Comment Edited] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883560#comment-17883560 ] Sergey Nuyanzin edited comment on FLINK-34702 at 9/22/24 12:0

[jira] [Commented] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883560#comment-17883560 ] Sergey Nuyanzin commented on FLINK-34702: - I had a look here a bit. I not

[jira] [Comment Edited] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883560#comment-17883560 ] Sergey Nuyanzin edited comment on FLINK-34702 at 9/22/24 12:0

[jira] [Commented] (FLINK-36292) SplitFetcherManagerTest.testCloseCleansUpPreviouslyClosedFetcher times out

[ https://issues.apache.org/jira/browse/FLINK-36292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883558#comment-17883558 ] Luke Chen commented on FLINK-36292: --- Opened a PR to remove the timeout first: h

[jira] [Updated] (FLINK-36345) [feature][cdc-connector][oracle] Oracle cdc support partition table

[ https://issues.apache.org/jira/browse/FLINK-36345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36345: --- Labels: pull-request-available (was: ) > [feature][cdc-connector][oracle] Oracle

[jira] [Commented] (FLINK-36293) RocksDBWriteBatchWrapperTest.testAsyncCancellation

[ https://issues.apache.org/jira/browse/FLINK-36293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883474#comment-17883474 ] Luke Chen commented on FLINK-36293: --- Investiga

[jira] [Updated] (FLINK-36292) SplitFetcherManagerTest.testCloseCleansUpPreviouslyClosedFetcher times out

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

[jira] [Commented] (FLINK-35260) Translate "Watermark alignment "page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-35260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883467#comment-17883467 ] Yun Tang commented on FLINK-35260: -- [~maomao] already assigned to you. > Tr

[jira] [Assigned] (FLINK-35260) Translate "Watermark alignment "page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-35260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-35260: Assignee: hongxu han > Translate "Watermark alignment "page

[jira] [Updated] (FLINK-36342) Rename misleading BufferDebloater variable 'targetTotalBufferSize'

[ https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-36342: - Summary: Rename misleading BufferDebloater variable 'targetTotalBufferSize' (w

[jira] [Updated] (FLINK-36342) Rename misleading variable names

[ https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-36342: - Fix Version/s: 2.0-preview > Rename misleading variable na

[jira] [Assigned] (FLINK-36342) Rename misleading variable names

[ https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky reassigned FLINK-36342: Assignee: Xu Hao > Rename misleading variable na

[jira] [Updated] (FLINK-36345) [feature][cdc-connector][oracle] Oracle cdc support partition table

[ https://issues.apache.org/jira/browse/FLINK-36345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuxuetong updated FLINK-36345: --- External issue URL: (was: https://github.com/apache/flink-cdc/pull/3593) > [feature][

[jira] [Updated] (FLINK-36345) [feature][cdc-connector][oracle] Oracle cdc support partition table

[ https://issues.apache.org/jira/browse/FLINK-36345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuxuetong updated FLINK-36345: --- External issue URL: https://github.com/apache/flink-cdc/pull/3593 > [feature][cdc-connector][ora

[jira] [Created] (FLINK-36345) [feature][cdc-connector][oracle] Oracle cdc support partition table

zhuxuetong created FLINK-36345: -- Summary: [feature][cdc-connector][oracle] Oracle cdc support partition table Key: FLINK-36345 URL: https://issues.apache.org/jira/browse/FLINK-36345 Project: Flink

[jira] [Assigned] (FLINK-36344) Introduce lastCompletedCheckpointTimestamp metrics

[ https://issues.apache.org/jira/browse/FLINK-36344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-36344: Assignee: Baozhu Zhao > Introduce lastCompletedCheckpointTimestamp metr

[jira] [Commented] (FLINK-36320) Use Protobuf Nested timestamp field as event time column and watermark

[ https://issues.apache.org/jira/browse/FLINK-36320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883445#comment-17883445 ] haiqingchen commented on FLINK-36320: - Hi [~libenchao], may I know if you have

[jira] [Updated] (FLINK-36320) Use Protobuf Nested timestamp field as event time column and watermark

[ https://issues.apache.org/jira/browse/FLINK-36320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] haiqingchen updated FLINK-36320: Priority: Minor (was: Major) > Use Protobuf Nested timestamp field as event time column

[jira] [Created] (FLINK-36344) Introduce lastCompletedCheckpointTimestamp metrics

Yun Tang created FLINK-36344: Summary: Introduce lastCompletedCheckpointTimestamp metrics Key: FLINK-36344 URL: https://issues.apache.org/jira/browse/FLINK-36344 Project: Flink Issue Type

[jira] [Commented] (FLINK-36290) OutOfMemoryError in connect test run

[ https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883431#comment-17883431 ] Luke Chen commented on FLINK-36290: --- I had a look at all the OOM cases, they

[jira] [Created] (FLINK-36343) The description on max-parallelism is misleading and needs to be more specific

Da Huo created FLINK-36343: -- Summary: The description on max-parallelism is misleading and needs to be more specific Key: FLINK-36343 URL: https://issues.apache.org/jira/browse/FLINK-36343 Project: Flink

[jira] [Commented] (FLINK-36343) The description on max-parallelism is misleading and needs to be more specific

[ https://issues.apache.org/jira/browse/FLINK-36343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883423#comment-17883423 ] Da Huo commented on FLINK-36343: I'm happy to help on this ticket as we

[jira] [Resolved] (FLINK-36318) Fail to restore from 1.18 if LAG function is used

[ https://issues.apache.org/jira/browse/FLINK-36318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-36318. - Fix Version/s: 2.0-preview Resolution: Fixed > Fail to restore from 1.18 if

[jira] [Commented] (FLINK-36330) Session Window TVFs with named parameters don't support column expansion

[ https://issues.apache.org/jira/browse/FLINK-36330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883386#comment-17883386 ] Sergey Nuyanzin commented on FLINK-36330: - Merge

[jira] [Resolved] (FLINK-36330) Session Window TVFs with named parameters don't support column expansion

[ https://issues.apache.org/jira/browse/FLINK-36330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-36330. - Fix Version/s: 2.0-preview Resolution: Fixed > Session Window TVFs with na

[jira] [Updated] (FLINK-36342) Rename misleading variable names

[ https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Hao updated FLINK-36342: --- Description: The variable named targetTotalBufferSize appears in class BufferDebloatConfiguration and some

[jira] [Updated] (FLINK-36342) Rename misleading variable names

[ https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Hao updated FLINK-36342: --- Description: The variable named targetTotalBufferSize appears in class BufferDebloatConfiguration and some

[jira] [Updated] (FLINK-36342) Rename misleading variable names

[ https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36342: --- Labels: pull-request-available (was: ) > Rename misleading variable na

[jira] [Created] (FLINK-36342) Rename misleading variable names

Xu Hao created FLINK-36342: -- Summary: Rename misleading variable names Key: FLINK-36342 URL: https://issues.apache.org/jira/browse/FLINK-36342 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36341) Does FlinkSQL have a setting to prohibit CodeGen generation

Wang Qilong created FLINK-36341: --- Summary: Does FlinkSQL have a setting to prohibit CodeGen generation Key: FLINK-36341 URL: https://issues.apache.org/jira/browse/FLINK-36341 Project: Flink

[jira] [Commented] (FLINK-36290) OutOfMemoryError in connect test run

[ https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883247#comment-17883247 ] Matthias Pohl commented on FLINK-36290: --- https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-36290) OutOfMemoryError in connect test run

[ https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883253#comment-17883253 ] Matthias Pohl commented on FLINK-36290: --- https://dev.azure.com/apache-f

[jira] [Comment Edited] (FLINK-36290) OutOfMemoryError in connect test run

[ https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883249#comment-17883249 ] Matthias Pohl edited comment on FLINK-36290 at 9/20/24 12:4

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883252#comment-17883252 ] Matthias Pohl commented on FLINK-17274: --- https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-36290) OutOfMemoryError in connect test run

[ https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883249#comment-17883249 ] Matthias Pohl commented on FLINK-36290: --- https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-36301) TPC-H end-to-end test fails due to TimeoutException

[ https://issues.apache.org/jira/browse/FLINK-36301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883244#comment-17883244 ] Matthias Pohl commented on FLINK-36301: --- https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-33555) LocalRecoveryITCase.testRecoverLocallyFromProcessCrashWithWorkingDirectory:

[ https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883235#comment-17883235 ] Matthias Pohl commented on FLINK-33555: --- https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-36166) testJoinDisorderChangeLog failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883242#comment-17883242 ] Matthias Pohl commented on FLINK-36166: --- https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-36290) OutOfMemoryError in connect test run

[ https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883240#comment-17883240 ] Matthias Pohl commented on FLINK-36290: --- https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-36291) java.lang.IllegalMonitorStateException causing a fatal error on the TaskManager side

[ https://issues.apache.org/jira/browse/FLINK-36291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883239#comment-17883239 ] Matthias Pohl commented on FLINK-36291: --- https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-34273) git fetch fails

[ https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883238#comment-17883238 ] Matthias Pohl commented on FLINK-34273: --- https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-36297) SIGSEGV caused CI failure

[ https://issues.apache.org/jira/browse/FLINK-36297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883237#comment-17883237 ] Matthias Pohl commented on FLINK-36297: --- https://dev.azure.com/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883236#comment-17883236 ] Matthias Pohl commented on FLINK-36167: --- https://dev.azure.com/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36167: -- Labels: test-stability (was: ) > testSinkDisorderChangeLog failed on

[jira] [Comment Edited] (FLINK-36340) Can not stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-36340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883234#comment-17883234 ] chenyuzhi edited comment on FLINK-36340 at 9/20/24 12:2

[jira] [Commented] (FLINK-36340) Can not stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-36340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883234#comment-17883234 ] chenyuzhi commented on FLINK-36340: --- I think the error is caused by h

[jira] [Updated] (FLINK-36340) Can not stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-36340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenyuzhi updated FLINK-36340: -- Description: When stopping flink application  running with kafkaConsumer on k8s operator,    the

[jira] [Created] (FLINK-36340) Can not stop with savepoint

chenyuzhi created FLINK-36340: - Summary: Can not stop with savepoint Key: FLINK-36340 URL: https://issues.apache.org/jira/browse/FLINK-36340 Project: Flink Issue Type: Bug Components

[jira] [Commented] (FLINK-36339) Remove java serialization from SQL serializers

[ https://issues.apache.org/jira/browse/FLINK-36339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883223#comment-17883223 ] david radley commented on FLINK-36339: -- [~dwysakowicz] I think this sounds li

[jira] [Updated] (FLINK-36338) Properly handle KeyContext when using AsyncKeyedStateBackendAdaptor

[ https://issues.apache.org/jira/browse/FLINK-36338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36338: --- Labels: pull-request-available (was: ) > Properly handle KeyContext when us

[jira] [Updated] (FLINK-36338) Properly handle KeyContext when using AsyncKeyedStateBackendAdaptor

[ https://issues.apache.org/jira/browse/FLINK-36338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-36338: Summary: Properly handle KeyContext when using AsyncKeyedStateBackendAdaptor (was: Correct

[jira] [Closed] (FLINK-36284) StreamTableEnvironment#toDataStream(Table table, Class targetClass) is not suitable for setting targetClass as a class generated by Avro.

[ https://issues.apache.org/jira/browse/FLINK-36284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-36284. --- Assignee: xuyang Resolution: Fixed Fixed in master: 1cd9110f858a809ea640a23e872303be02015db9

[jira] [Created] (FLINK-36339) Remove java serialization from SQL serializers

Dawid Wysakowicz created FLINK-36339: Summary: Remove java serialization from SQL serializers Key: FLINK-36339 URL: https://issues.apache.org/jira/browse/FLINK-36339 Project: Flink Issue

[jira] [Created] (FLINK-36338) Correct handle KeyContext when using AsyncKeyedStateBackendAdaptor

Zakelly Lan created FLINK-36338: --- Summary: Correct handle KeyContext when using AsyncKeyedStateBackendAdaptor Key: FLINK-36338 URL: https://issues.apache.org/jira/browse/FLINK-36338 Project: Flink

[jira] [Commented] (FLINK-36292) SplitFetcherManagerTest.testCloseCleansUpPreviouslyClosedFetcher times out

[ https://issues.apache.org/jira/browse/FLINK-36292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883214#comment-17883214 ] Xuannan Su commented on FLINK-36292: https://dev.azure.com/apache-flink/ap

[jira] [Updated] (FLINK-36335) Improving Method Reusability in StreamGraphGenerator with JobVertexBuildContext

[ https://issues.apache.org/jira/browse/FLINK-36335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36335: --- Labels: pull-request-available (was: ) > Improving Method Reusability

[jira] [Assigned] (FLINK-36338) Correct handle KeyContext when using AsyncKeyedStateBackendAdaptor

[ https://issues.apache.org/jira/browse/FLINK-36338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-36338: --- Assignee: Zakelly Lan > Correct handle KeyContext when using AsyncKeyedStateBackendAdap

[jira] [Created] (FLINK-36337) Recursively check if the parent class is org.apache.avro.specific.SpecificRecordBase to confirm whether it is an Avro type

xuyang created FLINK-36337: -- Summary: Recursively check if the parent class is org.apache.avro.specific.SpecificRecordBase to confirm whether it is an Avro type Key: FLINK-36337 URL: https://issues.apache.org/jira

[jira] [Updated] (FLINK-36321) Execute read/write state request in different executor

[ https://issues.apache.org/jira/browse/FLINK-36321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36321: --- Labels: pull-request-available (was: ) > Execute read/write state request in differ

[jira] [Resolved] (FLINK-36314) Support state V1 interface

[ https://issues.apache.org/jira/browse/FLINK-36314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-36314. Assignee: Yanfei Lei Resolution: Resolved > Support state V1 interf

[jira] [Commented] (FLINK-36314) Support state V1 interface

[ https://issues.apache.org/jira/browse/FLINK-36314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883196#comment-17883196 ] Yanfei Lei commented on FLINK-36314: Merged into master via 1ba8900 >

[jira] [Assigned] (FLINK-34342) Address Shard Consistency Issue for DDB Streams Source

[ https://issues.apache.org/jira/browse/FLINK-34342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-34342: --- Assignee: Abhishek Kumar > Address Shard Consistency Issue for DDB Streams Sou

[jira] [Comment Edited] (FLINK-31986) Implement Integration test for FLIP-27 DataStreams API

[ https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883192#comment-17883192 ] Hong Liang Teoh edited comment on FLINK-31986 at 9/20/24 8:4

[jira] [Assigned] (FLINK-31987) Implement KDS Table API support

[ https://issues.apache.org/jira/browse/FLINK-31987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-31987: --- Assignee: Burak Ozakinci > Implement KDS Table API supp

[jira] [Commented] (FLINK-31986) Implement Integration test for FLIP-27 DataStreams API

[ https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883192#comment-17883192 ] Hong Liang Teoh commented on FLINK-31986: - This is blocked by localstack

[jira] [Assigned] (FLINK-31986) Implement Integration test for FLIP-27 DataStreams API

[ https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-31986: --- Assignee: (was: Elphas Toringepi) > Implement Integration test for FLIP

[jira] [Updated] (FLINK-36336) Remove deprecated dataset API

[ https://issues.apache.org/jira/browse/FLINK-36336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36336: --- Labels: pull-request-available (was: ) > Remove deprecated dataset

[jira] [Created] (FLINK-36336) Remove deprecated dataset API

xuhuang created FLINK-36336: --- Summary: Remove deprecated dataset API Key: FLINK-36336 URL: https://issues.apache.org/jira/browse/FLINK-36336 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-36335) Improving Method Reusability in StreamGraphGenerator with JobVertexBuildContext

Lei Yang created FLINK-36335: Summary: Improving Method Reusability in StreamGraphGenerator with JobVertexBuildContext Key: FLINK-36335 URL: https://issues.apache.org/jira/browse/FLINK-36335 Project

[jira] [Updated] (FLINK-36327) Remove the dependencies of the flink-scala and flink-streaming-scala modules from the table module.

[ https://issues.apache.org/jira/browse/FLINK-36327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36327: --- Labels: pull-request-available (was: ) > Remove the dependencies of the flink-scala

[jira] [Updated] (FLINK-36306) Remove deprecated API for 2.0-preview

[ https://issues.apache.org/jira/browse/FLINK-36306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36306: --- Description: ||Module||Contributor||IsDone|| |flink-sql-connector-hive-3.1.3_2.12|[~xuyangzhong

[jira] [Updated] (FLINK-36334) Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses in flink-table-api-scala module

[ https://issues.apache.org/jira/browse/FLINK-36334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36334: --- Summary: Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses

[jira] [Created] (FLINK-36334) Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses that have been moved from the flink-table-api-scala module

: https://issues.apache.org/jira/browse/FLINK-36334 Project: Flink Issue Type: Sub-task Reporter: xuyang Fix For: 2.0.0, 2.0-preview Since there is no 2.0_preview version in FlinkVersion, I am unsure whether to update the reference data for Migration

[jira] [Updated] (FLINK-36332) Allow the Operator http client to be customised

[ https://issues.apache.org/jira/browse/FLINK-36332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36332: --- Labels: pull-request-available (was: ) > Allow the Operator http client to be customi

[jira] [Created] (FLINK-36333) FLIP-475: Support Adaptive Skewed Join Optimization

Lei Yang created FLINK-36333: Summary: FLIP-475: Support Adaptive Skewed Join Optimization Key: FLINK-36333 URL: https://issues.apache.org/jira/browse/FLINK-36333 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-36332) Allow the Operator http client to be customised

[ https://issues.apache.org/jira/browse/FLINK-36332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Barker updated FLINK-36332: --- Description: We are looking to produce a build of the Flink Kubernetes operator however for

[jira] [Updated] (FLINK-36332) Allow the Operator http client to be customised

[ https://issues.apache.org/jira/browse/FLINK-36332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sam Barker updated FLINK-36332: --- Description: We are looking to produce a build of the Flink Kubernetes operator however for

[jira] [Created] (FLINK-36332) Allow the Operator http client to be customised

Sam Barker created FLINK-36332: -- Summary: Allow the Operator http client to be customised Key: FLINK-36332 URL: https://issues.apache.org/jira/browse/FLINK-36332 Project: Flink Issue Type

[jira] [Created] (FLINK-36331) Support multiGet when DB all in local

Yanfei Lei created FLINK-36331: -- Summary: Support multiGet when DB all in local Key: FLINK-36331 URL: https://issues.apache.org/jira/browse/FLINK-36331 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-36293) RocksDBWriteBatchWrapperTest.testAsyncCancellation

[ https://issues.apache.org/jira/browse/FLINK-36293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883097#comment-17883097 ] Arvid Heise commented on FLINK-36293: - Another instance https://dev.azure

[jira] [Resolved] (FLINK-36240) Incorrect Port display in the PrometheusReporter constructor

[ https://issues.apache.org/jira/browse/FLINK-36240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky resolved FLINK-36240. -- Fix Version/s: 2.0-preview Resolution: Fixed [20e9826|https://github.com/apache/flink

[jira] [Resolved] (FLINK-36316) Move PortRange util to flink-core

[ https://issues.apache.org/jira/browse/FLINK-36316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky resolved FLINK-36316. -- Resolution: Fixed [8302e12|https://github.com/apache/flink/commit

[jira] [Assigned] (FLINK-36330) Session Window TVFs with named parameters don't support column expansion

[ https://issues.apache.org/jira/browse/FLINK-36330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-36330: -- Assignee: Jim Hughes > Session Window TVFs with named parameters don't suppor

[jira] [Updated] (FLINK-36330) Session Window TVFs with named parameters don't support column expansion

[ https://issues.apache.org/jira/browse/FLINK-36330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36330: --- Labels: pull-request-available (was: ) > Session Window TVFs with named parameters do

[jira] [Commented] (FLINK-35764) TimerGauge is incorrect when update is called during a measurement

[ https://issues.apache.org/jira/browse/FLINK-35764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883025#comment-17883025 ] Liu Liu commented on FLINK-35764: - [~pnowojski] Hello, I see you edited the TimerG

[jira] [Created] (FLINK-36330) Session Window TVFs with named parameters don't support column expansion

Sergey Nuyanzin created FLINK-36330: --- Summary: Session Window TVFs with named parameters don't support column expansion Key: FLINK-36330 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Commented] (FLINK-30899) FileSystemTableSource with CSV format incorrectly selects fields if filtering for partition

[ https://issues.apache.org/jira/browse/FLINK-30899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883018#comment-17883018 ] Mate Czagany commented on FLINK-30899: -- Hi [~luoyuxia]  Can you please ta

[jira] [Updated] (FLINK-36329) DDB Streams connector not retrying some SDK exceptions

[ https://issues.apache.org/jira/browse/FLINK-36329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36329: --- Labels: pull-request-available (was: ) > DDB Streams connector not retrying some

[jira] [Updated] (FLINK-36329) DDB Streams connector not retrying some SDK exceptions

[ https://issues.apache.org/jira/browse/FLINK-36329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhi Gupta updated FLINK-36329: --- Issue Type: Bug (was: Improvement) > DDB Streams connector not retrying some SDK excepti

[jira] [Resolved] (FLINK-36328) Making the log for child not found as debug

[ https://issues.apache.org/jira/browse/FLINK-36328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-36328. - Resolution: Fixed merged commit [{{3a0e4f5}}|https://github.com/apache/flink-connector

[jira] [Created] (FLINK-36329) DDB Streams connector not retrying some SDK exceptions

Abhi Gupta created FLINK-36329: -- Summary: DDB Streams connector not retrying some SDK exceptions Key: FLINK-36329 URL: https://issues.apache.org/jira/browse/FLINK-36329 Project: Flink Issue

  1   2   3   4   5   6   7   8   9   10   >