[jira] [Updated] (FLINK-23147) ThreadPools can be poisoned by context class loaders

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23147: Fix Version/s: (was: 1.19.0) > ThreadPools can be poisoned by context class loaders >

[jira] [Updated] (FLINK-32079) Read/write checkpoint metadata of merged files

2024-03-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32079: --- Labels: pull-request-available (was: ) > Read/write checkpoint metadata of merged files > -

[jira] [Updated] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34380: Fix Version/s: (was: 1.19.0) > Strange RowKind and records about intermediate output when usin

[jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-19722: Fix Version/s: (was: 1.19.0) > Pushdown Watermark to SourceProvider (new Source) > ---

[jira] [Updated] (FLINK-24849) Only return stacktrace if RestHandlerException has a cause

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-24849: Fix Version/s: (was: 1.19.0) > Only return stacktrace if RestHandlerException has a cause > --

[jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-20091: Fix Version/s: (was: 1.19.0) > Introduce avro.ignore-parse-errors for AvroRowDataDeserializat

[jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16023: Fix Version/s: (was: 1.19.0) > jdbc connector's 'connector.table' property should be optional

[jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-13735: Fix Version/s: (was: 1.19.0) > Support session window with blink planner in batch mode > -

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21876: Fix Version/s: (was: 1.19.0) > Handle it properly when the returned value of Python UDF doesn'

[jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18592: Fix Version/s: (was: 1.19.0) > StreamingFileSink fails due to truncating HDFS file failure > -

[jira] [Updated] (FLINK-16701) Elasticsearch sink support alias for indices.

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-16701: Fix Version/s: (was: 1.19.0) > Elasticsearch sink support alias for indices. > ---

[jira] [Updated] (FLINK-28830) new stack udtf doesn't support atomic type

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28830: Fix Version/s: (was: 1.19.0) > new stack udtf doesn't support atomic type > -

[jira] [Updated] (FLINK-27364) Support DESC EXTENDED partition statement for partitioned table

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-27364: Fix Version/s: (was: 1.19.0) > Support DESC EXTENDED partition statement for partitioned table

[jira] [Commented] (FLINK-23545) Use new schema in SqlCreateTableConverter

2024-03-11 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825298#comment-17825298 ] Feng Jin commented on FLINK-23545: -- https://issues.apache.org/jira/browse/FLINK-25347 a

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825303#comment-17825303 ] lincoln lee commented on FLINK-31472: - [~chalixar] I'm going to change this issue to

[jira] [Updated] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31472: Fix Version/s: 1.20.0 (was: 1.19.0) > AsyncSinkWriterThrottlingTest failed

Re: [PR] [FLINK-32079][checkpoint] Support to read/write checkpoint metadata of merged files [flink]

2024-03-11 Thread via GitHub
flinkbot commented on PR #24480: URL: https://github.com/apache/flink/pull/24480#issuecomment-1988423052 ## CI report: * 6e25a394027c9f1572a84324a9a99961ae618f7a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33705) Upgrade flink-shaded to 18.0

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33705: Fix Version/s: 1.20.0 (was: 1.19.0) > Upgrade flink-shaded to 18.0 > --

[jira] [Updated] (FLINK-33696) FLIP-385: Add OpenTelemetryTraceReporter and OpenTelemetryMetricReporter

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33696: Fix Version/s: 1.20.0 (was: 1.19.0) > FLIP-385: Add OpenTelemetryTraceRepor

[jira] [Updated] (FLINK-33064) Improve the error message when the lookup source is used as the scan source

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33064: Fix Version/s: 1.20.0 (was: 1.19.0) > Improve the error message when the lo

[jira] [Updated] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30629: Fix Version/s: 1.20.0 (was: 1.19.0) > ClientHeartbeatTest.testJobRunningIfC

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28440: Fix Version/s: 1.20.0 (was: 1.19.0) > EventTimeWindowCheckpointingITCase fa

[PR] [FLINK-32079][checkpoint] Support to read/write checkpoint metadata of merged files [flink]

2024-03-11 Thread via GitHub
masteryhx opened a new pull request, #24480: URL: https://github.com/apache/flink/pull/24480 ## What is the purpose of the change Support to read/write checkpoint metadata of merged files ## Brief change log - serialize and deserialize SegmentFileStateHandle in

[jira] [Updated] (FLINK-18742) Some configuration args do not take effect at client

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-18742: Fix Version/s: 1.12.0 (was: 1.19.0) > Some configuration args do not take e

[jira] [Closed] (FLINK-18742) Some configuration args do not take effect at client

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-18742. --- Resolution: Fixed > Some configuration args do not take effect at client > -

[jira] [Updated] (FLINK-30166) Refactor tests that use the deprecated StreamingFileSink instead of FileSink

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30166: Fix Version/s: 1.20.0 (was: 1.19.0) > Refactor tests that use the deprecate

[jira] [Updated] (FLINK-31951) Mix schema record source creates corrupt record

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-31951: Fix Version/s: 1.20.0 (was: 1.19.0) > Mix schema record source creates corr

[jira] [Updated] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22826: Fix Version/s: 1.20.0 (was: 1.19.0) > flink sql1.13.1 causes data loss base

[jira] [Updated] (FLINK-21302) Fix NPE when use row_number() in over agg

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-21302: Fix Version/s: 1.14.0 1.13.0 (was: 1.19.0) > Fix NPE whe

[jira] [Commented] (FLINK-18742) Some configuration args do not take effect at client

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825305#comment-17825305 ] lincoln lee commented on FLINK-18742: - [~wangm92] thanks for your updates. Closing t

[jira] [Updated] (FLINK-22484) Built-in functions for collections

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-22484: Fix Version/s: 1.20.0 (was: 1.19.0) > Built-in functions for collections >

Re: [PR] [FLINK-32513][core] Add predecessor caching [flink]

2024-03-11 Thread via GitHub
zhuzhurk commented on code in PR #24475: URL: https://github.com/apache/flink/pull/24475#discussion_r1519708804 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/AbstractMultipleInputTransformation.java: ## @@ -76,7 +76,7 @@ public StreamOperat

[jira] [Closed] (FLINK-21302) Fix NPE when use row_number() in over agg

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-21302. --- Resolution: Fixed close this becase already fixed in both 1.13.0 & 1.14.0 > Fix NPE when use row_nu

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2024-03-11 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825309#comment-17825309 ] Ahmed Hamdy commented on FLINK-31472: - [~lincoln.86xy] yes, I will publish fixes for

[jira] [Updated] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28897: Fix Version/s: 1.20.0 (was: 1.19.0) > Fail to use udf in added jar when ena

[jira] [Updated] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

2024-03-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34639: --- Labels: pull-request-available (was: ) > Flink CDC: Support DebeziumDeserializationSchema i

[jira] [Commented] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825310#comment-17825310 ] lincoln lee commented on FLINK-28897: - [~lsy] Any new thoughts on this issue? > Fai

[PR] [FLINK-31472] Remove external timer service reference from AsyncSinkThrottling Test [flink]

2024-03-11 Thread via GitHub
vahmed-hamdy opened a new pull request, #24481: URL: https://github.com/apache/flink/pull/24481 ## What is the purpose of the change Refactor `AsyncSinkWriterThrottlingTest` to flush when reaching batch sizes without changing processing time. The changes of processing

[jira] [Commented] (FLINK-23545) Use new schema in SqlCreateTableConverter

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825311#comment-17825311 ] lincoln lee commented on FLINK-23545: - [~hackergin] Thanks, closing. > Use new sche

[jira] [Updated] (FLINK-23545) Use new schema in SqlCreateTableConverter

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-23545: Fix Version/s: (was: 1.20.0) > Use new schema in SqlCreateTableConverter > ---

[jira] [Closed] (FLINK-23545) Use new schema in SqlCreateTableConverter

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-23545. --- Resolution: Duplicate > Use new schema in SqlCreateTableConverter >

Re: [PR] [FLINK-31472] Remove external timer service reference from AsyncSinkThrottling Test [flink]

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

[jira] [Commented] (FLINK-34570) JoinITCase.testLeftJoinWithEqualPk times out

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825318#comment-17825318 ] Matthias Pohl commented on FLINK-34570: --- Looks like it's the same issue as FLINK-3

[jira] [Closed] (FLINK-34570) JoinITCase.testLeftJoinWithEqualPk times out

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-34570. - Resolution: Duplicate > JoinITCase.testLeftJoinWithEqualPk times out > -

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825319#comment-17825319 ] Matthias Pohl commented on FLINK-34227: --- Transferred over from FLINK-34570 (JoinIT

[PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]

2024-03-11 Thread via GitHub
anupamaggarwal opened a new pull request, #24482: URL: https://github.com/apache/flink/pull/24482 ## What is the purpose of the change Support Debezium Protobuf Confluent Format ## Brief change log - Add support for protobuf-confluent format ## Verifyi

[jira] [Updated] (FLINK-34440) Support Debezium Protobuf Confluent Format

2024-03-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34440: --- Labels: pull-request-available (was: ) > Support Debezium Protobuf Confluent Format > -

Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]

2024-03-11 Thread via GitHub
flinkbot commented on PR #24482: URL: https://github.com/apache/flink/pull/24482#issuecomment-1988514486 ## CI report: * 808ee4160daf8fb9f5f06271ab6fd280915bec92 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825323#comment-17825323 ] Matthias Pohl commented on FLINK-34227: --- Interestingly, the behavior is only obser

[jira] [Comment Edited] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825323#comment-17825323 ] Matthias Pohl edited comment on FLINK-34227 at 3/11/24 2:03 PM: --

Re: [PR] [FLINK-34524] Scale down JM deployment to 0 before deletion [flink-kubernetes-operator]

2024-03-11 Thread via GitHub
mxm commented on PR #791: URL: https://github.com/apache/flink-kubernetes-operator/pull/791#issuecomment-1988538289 @gyfora Nice! LGTM -- 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 specifi

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825326#comment-17825326 ] Matthias Pohl commented on FLINK-34643: --- FLINK-34417 introduced this test. @roman

[jira] [Created] (FLINK-34643) JobIDLoggingITCase failed

2024-03-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34643: - Summary: JobIDLoggingITCase failed Key: FLINK-34643 URL: https://issues.apache.org/jira/browse/FLINK-34643 Project: Flink Issue Type: Bug Compone

[jira] [Comment Edited] (FLINK-34643) JobIDLoggingITCase failed

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825326#comment-17825326 ] Matthias Pohl edited comment on FLINK-34643 at 3/11/24 2:13 PM: --

Re: [PR] [FLINK-34152][autoscaler] Refactor the MemoryTuning to avoid the huge method [flink-kubernetes-operator]

2024-03-11 Thread via GitHub
mxm commented on code in PR #795: URL: https://github.com/apache/flink-kubernetes-operator/pull/795#discussion_r1519792431 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/tuning/MemoryTuning.java: ## @@ -92,24 +99,51 @@ public static ConfigChanges tuneTaskManagerM

[jira] [Updated] (FLINK-34643) JobIDLoggingITCase failed

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34643: -- Description: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58187&view

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

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825327#comment-17825327 ] Matthias Pohl commented on FLINK-34273: --- https://dev.azure.com/apache-flink/apache

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

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825328#comment-17825328 ] Matthias Pohl commented on FLINK-17274: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825329#comment-17825329 ] Matthias Pohl commented on FLINK-29114: --- * https://dev.azure.com/apache-flink/apa

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825330#comment-17825330 ] Matthias Pohl commented on FLINK-34643: --- * https://dev.azure.com/apache-flink/apa

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-03-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825334#comment-17825334 ] Roman Khachatryan commented on FLINK-34643: --- Sure [~mapohl] , will take a look

[jira] [Created] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException

2024-03-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34644: - Summary: RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException Key: FLINK-34644 URL: https://issues.apache.org/jira/browse/FLINK-3

[jira] [Assigned] (FLINK-34643) JobIDLoggingITCase failed

2024-03-11 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-34643: - Assignee: Roman Khachatryan > JobIDLoggingITCase failed > -

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825337#comment-17825337 ] Matthias Pohl commented on FLINK-34227: --- This one is a 1.19 workflow run: https://

[jira] [Comment Edited] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825329#comment-17825329 ] Matthias Pohl edited comment on FLINK-29114 at 3/11/24 2:35 PM: --

[jira] [Updated] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34227: -- Affects Version/s: 1.19.0 > Job doesn't disconnect from ResourceManager >

[jira] [Comment Edited] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825329#comment-17825329 ] Matthias Pohl edited comment on FLINK-29114 at 3/11/24 2:36 PM: --

[PR] [FLINK-25544][streaming][JUnit5 Migration] The runtime package of module flink-stream-java [flink]

2024-03-11 Thread via GitHub
Jiabao-Sun opened a new pull request, #24483: URL: https://github.com/apache/flink/pull/24483 ## What is the purpose of the change [FLINK-25544][streaming][JUnit5 Migration] The runtime package of module flink-stream-java ## Brief change log [JUnit5 Migration] Th

[jira] [Comment Edited] (FLINK-34404) GroupWindowAggregateProcTimeRestoreTest#testRestore times out

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825338#comment-17825338 ] Matthias Pohl edited comment on FLINK-34404 at 3/11/24 2:42 PM: --

[jira] [Commented] (FLINK-34404) GroupWindowAggregateProcTimeRestoreTest#testRestore times out

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825338#comment-17825338 ] Matthias Pohl commented on FLINK-34404: --- {{WindowTableFunctionProcTimeRestoreTest}

[jira] [Comment Edited] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825329#comment-17825329 ] Matthias Pohl edited comment on FLINK-29114 at 3/11/24 2:43 PM: --

[jira] [Comment Edited] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825329#comment-17825329 ] Matthias Pohl edited comment on FLINK-29114 at 3/11/24 2:43 PM: --

[jira] [Commented] (FLINK-31472) AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825339#comment-17825339 ] Matthias Pohl commented on FLINK-31472: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34645) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825341#comment-17825341 ] Matthias Pohl commented on FLINK-34645: --- https://github.com/XComp/flink/actions/ru

Re: [PR] [FLINK-25544][streaming][JUnit5 Migration] The runtime package of module flink-stream-java [flink]

2024-03-11 Thread via GitHub
flinkbot commented on PR #24483: URL: https://github.com/apache/flink/pull/24483#issuecomment-1988624311 ## CI report: * 61d65bc13a578c9385d8615c1166da3ee4119997 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-34645) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails

2024-03-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34645: - Summary: StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails Key: FLINK-34645 URL: https://issues.apache.org/jira/browse/FLINK-3464

[jira] [Commented] (FLINK-34645) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825342#comment-17825342 ] Matthias Pohl commented on FLINK-34645: --- https://github.com/apache/flink/actions/r

[jira] [Closed] (FLINK-24333) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredOnCheckpoint fails on azure

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-24333. - Resolution: Cannot Reproduce I'm closing this one as not reproducible. The GHA workflow failures

[jira] [Created] (FLINK-34646) AggregateITCase.testDistinctWithRetract timed out

2024-03-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34646: - Summary: AggregateITCase.testDistinctWithRetract timed out Key: FLINK-34646 URL: https://issues.apache.org/jira/browse/FLINK-34646 Project: Flink Issue Typ

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825344#comment-17825344 ] Matthias Pohl commented on FLINK-34227: --- AggregateITCase: https://github.com/apach

Re: [PR] [FLINK-20398][e2e] Migrate test_batch_sql.sh to Java e2e tests framework [flink]

2024-03-11 Thread via GitHub
affo commented on PR #24471: URL: https://github.com/apache/flink/pull/24471#issuecomment-1988639429 @wuchong @XComp Hi guys, here is the PR for https://issues.apache.org/jira/browse/FLINK-20398. I decided to go for `LocalStandaloneFlinkResourceFactory` as it is already used

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825345#comment-17825345 ] Matthias Pohl commented on FLINK-34227: --- https://github.com/apache/flink/actions/r

[jira] [Comment Edited] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825329#comment-17825329 ] Matthias Pohl edited comment on FLINK-29114 at 3/11/24 3:01 PM: --

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-03-11 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825347#comment-17825347 ] Matthias Pohl commented on FLINK-34643: --- Thanks. * https://github.com/apache/fli

[jira] [Updated] (FLINK-34641) Possibility to add Python Files from http/https sources in PythonDriver

2024-03-11 Thread Aleksei Perminov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksei Perminov updated FLINK-34641: - Component/s: API / Python (was: flink-contrib) > Possibility to add

Re: [PR] [FLINK-33132] Flink Connector Redshift TableSink Implementation [flink-connector-aws]

2024-03-11 Thread via GitHub
vahmed-hamdy commented on code in PR #114: URL: https://github.com/apache/flink-connector-aws/pull/114#discussion_r1519868784 ## flink-connector-aws/flink-connector-redshift/src/main/java/org/apache/flink/connector/redshift/table/RedshiftDynamicTableFactory.java: ## @@ -0,0 +1,

[PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-11 Thread via GitHub
rkhachatryan opened a new pull request, #24484: URL: https://github.com/apache/flink/pull/24484 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring th

[jira] [Updated] (FLINK-34643) JobIDLoggingITCase failed

2024-03-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34643: --- Labels: pull-request-available test-stability (was: test-stability) > JobIDLoggingITCase fa

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
lincoln-lil commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519951825 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date: "202

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-11 Thread via GitHub
flinkbot commented on PR #24484: URL: https://github.com/apache/flink/pull/24484#issuecomment-1988769298 ## CI report: * 9c6a7e35aaaed23cc54ebcfa6bdc1719a347d760 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
rmoff commented on PR #721: URL: https://github.com/apache/flink-web/pull/721#issuecomment-1988775115 FWIW on [the question of inline examples](https://github.com/apache/flink-web/pull/721#discussion_r1519951825) I would be in favour of including some light-weight content. Definitely not r

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
lincoln-lil commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1519964324 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- +authors: +- LincolnLee: + name: "Lincoln Lee" + twitter: lincoln_86xy + +date: "202

[jira] [Commented] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825369#comment-17825369 ] Zhanghao Chen commented on FLINK-25068: --- Hi [~zlzhang0122][~lincoln.86xy], given t

[jira] [Comment Edited] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825369#comment-17825369 ] Zhanghao Chen edited comment on FLINK-25068 at 3/11/24 4:04 PM: --

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
lincoln-lil commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1520017882 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- Review Comment: @MartijnVisser Thanks for reviewing this! Yes, these changes need

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-11 Thread via GitHub
lincoln-lil commented on code in PR #721: URL: https://github.com/apache/flink-web/pull/721#discussion_r1520017882 ## docs/content/posts/2024-03-xx-release-1.19.0.md: ## @@ -0,0 +1,456 @@ +--- Review Comment: @MartijnVisser Thanks for reviewing this! Yes, these changes need

Re: [PR] [FLINK-34642] Add a test for zero lower utilization boundary [flink-kubernetes-operator]

2024-03-11 Thread via GitHub
gyfora commented on code in PR #796: URL: https://github.com/apache/flink-kubernetes-operator/pull/796#discussion_r1520023441 ## flink-autoscaler/src/test/java/org/apache/flink/autoscaler/ScalingExecutorTest.java: ## @@ -146,6 +150,55 @@ op1, evaluated(1, 70, 100), as

[jira] [Commented] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825377#comment-17825377 ] lincoln lee commented on FLINK-25068: - [~Zhanghao Chen] Thanks for the updates. Clos

[jira] [Updated] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-25068: Fix Version/s: 1.18.0 (was: 1.20.0) > Show the maximum parallelism (number

[jira] [Closed] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

2024-03-11 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-25068. --- Resolution: Fixed > Show the maximum parallelism (number of key groups) of a job in Web UI > ---

<    5   6   7   8   9   10   11   >