[jira] [Commented] (FLINK-33656) If json.ignose-parse-errors =true is configured and Array parsing errors occur, other columns will be empty

2023-11-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789955#comment-17789955 ] Martijn Visser commented on FLINK-33656: [~duke13] Can you please provide a repr

[jira] [Commented] (FLINK-33443) Make the test "testWriteComplexType" stable

2023-11-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789957#comment-17789957 ] Martijn Visser commented on FLINK-33443: [~hannahchi] Looking at the number of o

[jira] [Created] (FLINK-33657) Insert message in top n without row number didn't consider it's number and may not correct

2023-11-27 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-33657: --- Summary: Insert message in top n without row number didn't consider it's number and may not correct Key: FLINK-33657 URL: https://issues.apache.org/jira/browse/FLINK-33657

[jira] [Updated] (FLINK-33657) Insert message in top n without row number didn't consider it's number and may not correct

2023-11-27 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zlzhang0122 updated FLINK-33657: Description: The new insert message in top n without row number didn't consider it's order and ju

[jira] [Updated] (FLINK-33657) Insert message in top n without row number didn't consider it's number and may not correct

2023-11-27 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zlzhang0122 updated FLINK-33657: Description: The new insert message in top n without row number didn't consider it's order and ju

[jira] [Updated] (FLINK-33657) Insert message in top n without row number didn't consider it's number and may incorrect

2023-11-27 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zlzhang0122 updated FLINK-33657: Summary: Insert message in top n without row number didn't consider it's number and may incorrect

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Peter Vary (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789963#comment-17789963 ] Peter Vary commented on FLINK-25857: If you check the discussion [1] the diamond inh

[jira] [Created] (FLINK-33658) Hosted runner lost communication

2023-11-27 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33658: - Summary: Hosted runner lost communication Key: FLINK-33658 URL: https://issues.apache.org/jira/browse/FLINK-33658 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-33242) misc module: YARN tests are flaky

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-33242. - Resolution: Cannot Reproduce The issue didn't reappear for a while. I'm closing it as not-reprod

[jira] [Closed] (FLINK-33281) e2e 2 stage: PyFlink end-to-end test

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-33281. - Resolution: Cannot Reproduce The issue didn't reappear for a while. I'm closing it as not-reprod

[jira] [Closed] (FLINK-33283) core stage: WebFrontendBootstrapTest.testHandlersMustBeLoaded

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-33283. - Resolution: Cannot Reproduce The issue didn't reappear for a while. I'm closing it as not-reprod

[jira] [Closed] (FLINK-33284) core stage: HistoryServerStaticFileServerHandlerTest.testRespondWithFile(Path)

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-33284. - Resolution: Fixed The issue didn't reappear for a while. I'm closing it as not-reproducible. >

[jira] [Comment Edited] (FLINK-33284) core stage: HistoryServerStaticFileServerHandlerTest.testRespondWithFile(Path)

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789972#comment-17789972 ] Matthias Pohl edited comment on FLINK-33284 at 11/27/23 8:42 AM: -

[jira] [Comment Edited] (FLINK-33242) misc module: YARN tests are flaky

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789969#comment-17789969 ] Matthias Pohl edited comment on FLINK-33242 at 11/27/23 8:42 AM: -

[jira] [Comment Edited] (FLINK-33242) misc module: YARN tests are flaky

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789969#comment-17789969 ] Matthias Pohl edited comment on FLINK-33242 at 11/27/23 8:42 AM: -

[jira] [Comment Edited] (FLINK-33281) e2e 2 stage: PyFlink end-to-end test

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789970#comment-17789970 ] Matthias Pohl edited comment on FLINK-33281 at 11/27/23 8:42 AM: -

[jira] [Comment Edited] (FLINK-33284) core stage: HistoryServerStaticFileServerHandlerTest.testRespondWithFile(Path)

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789972#comment-17789972 ] Matthias Pohl edited comment on FLINK-33284 at 11/27/23 8:43 AM: -

[jira] [Comment Edited] (FLINK-33281) e2e 2 stage: PyFlink end-to-end test

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789970#comment-17789970 ] Matthias Pohl edited comment on FLINK-33281 at 11/27/23 8:43 AM: -

[jira] [Comment Edited] (FLINK-33242) misc module: YARN tests are flaky

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789969#comment-17789969 ] Matthias Pohl edited comment on FLINK-33242 at 11/27/23 8:43 AM: -

[jira] [Created] (FLINK-33659) Avoid unnecessary retries when restore from savepoint failed.

2023-11-27 Thread zhouli (Jira)
zhouli created FLINK-33659: -- Summary: Avoid unnecessary retries when restore from savepoint failed. Key: FLINK-33659 URL: https://issues.apache.org/jira/browse/FLINK-33659 Project: Flink Issue Type

Re: [PR] [FLINK-33655][tests] Upgrade ArchUnit to 1.2.0 to support java 21 [flink]

2023-11-27 Thread via GitHub
snuyanzin commented on PR #23808: URL: https://github.com/apache/flink/pull/23808#issuecomment-1827380143 Thanks for taking a look -- 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 com

[jira] [Commented] (FLINK-33656) If json.ignose-parse-errors =true is configured and Array parsing errors occur, other columns will be empty

2023-11-27 Thread duke (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789973#comment-17789973 ] duke commented on FLINK-33656: -- If the type of the attentionList field is defined as Array,

Re: [PR] [FLINK-33655][tests] Upgrade ArchUnit to 1.2.0 to support java 21 [flink]

2023-11-27 Thread via GitHub
snuyanzin merged PR #23808: URL: https://github.com/apache/flink/pull/23808 -- 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.apa

[jira] [Commented] (FLINK-33655) Upgrade Archunit to 1.1.0+

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789976#comment-17789976 ] Sergey Nuyanzin commented on FLINK-33655: - Merged to master as [83a6d1d57d7d544

[jira] [Closed] (FLINK-33655) Upgrade Archunit to 1.1.0+

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-33655. --- > Upgrade Archunit to 1.1.0+ > -- > > Key: FLINK-33655 >

[jira] [Commented] (FLINK-33552) Job (and its data) is lost

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

[jira] [Closed] (FLINK-33658) Hosted runner lost communication

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-33658. - Resolution: Duplicate > Hosted runner lost communication > > >

[jira] [Commented] (FLINK-33659) Avoid unnecessary retries when restore from savepoint failed.

2023-11-27 Thread zhouli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789974#comment-17789974 ] zhouli commented on FLINK-33659: Hi, [~zhuzh] , wdyt ? > Avoid unnecessary retries when

[jira] [Resolved] (FLINK-33655) Upgrade Archunit to 1.1.0+

2023-11-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33655. - Fix Version/s: 1.19.0 Resolution: Fixed > Upgrade Archunit to 1.1.0+ > --

[jira] [Updated] (FLINK-33660) AggregateITCase.testConstantGroupKeyWithUpsertSink due to unexpected behavior

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33660: -- Labels: test-stability (was: ) > AggregateITCase.testConstantGroupKeyWithUpsertSink due to un

[jira] [Created] (FLINK-33660) AggregateITCase.testConstantGroupKeyWithUpsertSink due to unexpected behavior

2023-11-27 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33660: - Summary: AggregateITCase.testConstantGroupKeyWithUpsertSink due to unexpected behavior Key: FLINK-33660 URL: https://issues.apache.org/jira/browse/FLINK-33660 Proje

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

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-31472: --- I'm reopening this issue because it now also appeared in CI: https://dev.azure.com/apache-flink/

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

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789982#comment-17789982 ] Matthias Pohl edited comment on FLINK-31472 at 11/27/23 9:00 AM: -

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

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31472: -- Labels: test-stability (was: ) > AsyncSinkWriterThrottlingTest failed with Illegal mailbox th

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

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31472: -- Affects Version/s: 1.19.0 > AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread >

[jira] [Updated] (FLINK-30132) Test LocalRecoveryITCase#testRecoverLocallyFromProcessCrashWithWorkingDirectory failed on azure due to File not exists

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30132: -- Labels: test-stability (was: ) > Test > LocalRecoveryITCase#testRecoverLocallyFromProcessCra

[jira] [Commented] (FLINK-30132) Test LocalRecoveryITCase#testRecoverLocallyFromProcessCrashWithWorkingDirectory failed on azure due to File not exists

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789983#comment-17789983 ] Matthias Pohl commented on FLINK-30132: --- Same issue in {{JoinITCase.testLeftOuterJ

[jira] [Updated] (FLINK-30132) Test LocalRecoveryITCase#testRecoverLocallyFromProcessCrashWithWorkingDirectory failed on azure due to File not exists

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30132: -- Affects Version/s: 1.19.0 > Test > LocalRecoveryITCase#testRecoverLocallyFromProcessCrashWith

[jira] [Updated] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-25857: --- Description: With Sink V2 we can now track the progress of a committable during committing and show

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789989#comment-17789989 ] Qingsheng Ren commented on FLINK-25857: --- [~pvary] I'm afraid we have to do somethi

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789988#comment-17789988 ] Weijie Guo commented on FLINK-25857: [~pvary], Well, sorry, I didn't realize we alre

[PR] [FLINK-33638] Support variable-length data generation for variable-length data types [flink]

2023-11-27 Thread via GitHub
liyubin117 opened a new pull request, #23810: URL: https://github.com/apache/flink/pull/23810 ## What is the purpose of the change Extending datagen to generate variable length values (using a new option to enable it, e.g.,'fields.f0.var-len'='true'). ## Brief change log

[jira] [Updated] (FLINK-33638) Support variable-length data generation for variable-length data types

2023-11-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33638: --- Labels: pull-request-available (was: ) > Support variable-length data generation for variab

[jira] [Created] (FLINK-33661) 'RocksDB Memory Management end-to-end test' failed due to unexpected error in logs

2023-11-27 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33661: - Summary: 'RocksDB Memory Management end-to-end test' failed due to unexpected error in logs Key: FLINK-33661 URL: https://issues.apache.org/jira/browse/FLINK-33661

Re: [PR] [FLINK-33638] Support variable-length data generation for variable-length data types [flink]

2023-11-27 Thread via GitHub
flinkbot commented on PR #23810: URL: https://github.com/apache/flink/pull/23810#issuecomment-1827450201 ## CI report: * a693b54cd283381ccd0b5e8e79470e7592f8cc30 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-33638] Support variable-length data generation for variable-length data types [flink]

2023-11-27 Thread via GitHub
liyubin117 commented on PR #23810: URL: https://github.com/apache/flink/pull/23810#issuecomment-1827455391 @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

Re: [PR] [FLINK-33418][test,ci] Uses getHost() to access HiveContainer (instead of hard-coded IP) [flink]

2023-11-27 Thread via GitHub
XComp merged PR #23649: URL: https://github.com/apache/flink/pull/23649 -- 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] [BP-1.18][FLINK-33418][test] Uses getHost() [flink]

2023-11-27 Thread via GitHub
XComp merged PR #23650: URL: https://github.com/apache/flink/pull/23650 -- 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.

[jira] [Resolved] (FLINK-33418) SqlGatewayE2ECase failed due to ConnectException

2023-11-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-33418. --- Fix Version/s: 1.19.0 1.18.1 Resolution: Fixed master: [f6f785fd1

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

2023-11-27 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789994#comment-17789994 ] Yue Ma commented on FLINK-27681: [~masteryhx] Thanks for the explaining , I agree with i

Re: [PR] [FLINK-33638] Support variable-length data generation for variable-length data types [flink]

2023-11-27 Thread via GitHub
liyubin117 commented on PR #23810: URL: https://github.com/apache/flink/pull/23810#issuecomment-1827468541 @lincoln-lil Looking forward your review, thanks :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789995#comment-17789995 ] Leonard Xu commented on FLINK-25857: I am very surprised that the public interface w

Re: [PR] [FLINK-33638] Support variable-length data generation for variable-length data types [flink]

2023-11-27 Thread via GitHub
liyubin117 commented on PR #23810: URL: https://github.com/apache/flink/pull/23810#issuecomment-1827470955 @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

[jira] [Comment Edited] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789995#comment-17789995 ] Leonard Xu edited comment on FLINK-25857 at 11/27/23 9:36 AM:

[jira] [Comment Edited] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789995#comment-17789995 ] Leonard Xu edited comment on FLINK-25857 at 11/27/23 9:36 AM:

[jira] [Comment Edited] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789995#comment-17789995 ] Leonard Xu edited comment on FLINK-25857 at 11/27/23 9:37 AM:

[jira] [Comment Edited] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789995#comment-17789995 ] Leonard Xu edited comment on FLINK-25857 at 11/27/23 9:39 AM:

Re: [PR] Bump h2 from 2.1.210 to 2.2.220 in /flink-connector-jdbc [flink-connector-jdbc]

2023-11-27 Thread via GitHub
eskabetxe commented on PR #69: URL: https://github.com/apache/flink-connector-jdbc/pull/69#issuecomment-1827482345 @dependabot rebase -- 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

[jira] [Updated] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

2023-11-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-33635: --- Fix Version/s: 1.19.0 > Some connectors can not compile in 1.19-SNAPSHOT > -

[jira] [Updated] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

2023-11-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-33635: --- Affects Version/s: 1.19.0 > Some connectors can not compile in 1.19-SNAPSHOT > -

Re: [PR] Bump h2 from 2.1.210 to 2.2.220 in /flink-connector-jdbc [flink-connector-jdbc]

2023-11-27 Thread via GitHub
dependabot[bot] commented on PR #69: URL: https://github.com/apache/flink-connector-jdbc/pull/69#issuecomment-1827482407 Sorry, only users with push access can use that command. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-33628][runtime] Upgrades default ZooKeeper version from 3.7.1 to 3.8.3 [flink]

2023-11-27 Thread via GitHub
XComp commented on PR #23784: URL: https://github.com/apache/flink/pull/23784#issuecomment-1827488207 @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. To

[jira] [Commented] (FLINK-33635) Some connectors can not compile in 1.19-SNAPSHOT

2023-11-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789998#comment-17789998 ] Leonard Xu commented on FLINK-33635: A blocker must be fixed in 1.19, my attitude he

Re: [PR] [FLINK-30593] Add tests for ScalingTracking#removeOldRecords() [flink-kubernetes-operator]

2023-11-27 Thread via GitHub
mxm commented on PR #715: URL: https://github.com/apache/flink-kubernetes-operator/pull/715#issuecomment-1827493243 > @mxm is this the right ticket? [[FLINK-33572](https://issues.apache.org/jira/browse/FLINK-33572)] Minimize ConfigMap API operations for autoscaler state Next time, p

Re: [PR] [FLINK-30593] Add tests for ScalingTracking#removeOldRecords() [flink-kubernetes-operator]

2023-11-27 Thread via GitHub
mxm commented on code in PR #715: URL: https://github.com/apache/flink-kubernetes-operator/pull/715#discussion_r1405904882 ## flink-autoscaler/src/test/java/org/apache/flink/autoscaler/ScalingTrackingTest.java: ## @@ -52,6 +52,7 @@ void setUp() { conf.set(AutoScalerOpt

Re: [PR] [FLINK-31339][tests] Fix unstable tests of flink-end-to-end-tests-sql module [flink]

2023-11-27 Thread via GitHub
ruanhang1993 commented on code in PR #23507: URL: https://github.com/apache/flink/pull/23507#discussion_r1405905020 ## flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/SqlITCaseBase.java: ## @@ -190,4 +231,76 @@ private static Li

[jira] [Created] (FLINK-33662) Bump com.h2database:h2

2023-11-27 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33662: -- Summary: Bump com.h2database:h2 Key: FLINK-33662 URL: https://issues.apache.org/jira/browse/FLINK-33662 Project: Flink Issue Type: Technical Debt

Re: [PR] [FLINK-33638] Support variable-length data generation for variable-length data types [flink]

2023-11-27 Thread via GitHub
liyubin117 commented on PR #23810: URL: https://github.com/apache/flink/pull/23810#issuecomment-1827514306 @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

Re: [PR] [FLINK-32881][checkpoint] Support triggering savepoint in detach mode for CLI and dumping all pending savepoint ids by rest api [flink]

2023-11-27 Thread via GitHub
xiangforever2014 commented on code in PR #23253: URL: https://github.com/apache/flink/pull/23253#discussion_r1405754517 ## flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java: ## @@ -157,6 +157,14 @@ public class CliFrontendParser {

Re: [PR] [FLINK-33459][Connector/JDBC] Support the new source that keeps the same functionality as the original JDBC input format [flink-connector-jdbc]

2023-11-27 Thread via GitHub
eskabetxe commented on code in PR #78: URL: https://github.com/apache/flink-connector-jdbc/pull/78#discussion_r1405917676 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/Utils.java: ## @@ -0,0 +1,72 @@ +/* + * Licensed to the Apache Software Foundat

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790006#comment-17790006 ] Martijn Visser commented on FLINK-25857: I think everyone is already on the same

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790007#comment-17790007 ] Márton Balassi commented on FLINK-25857: Hi team, Thanks for looking into this.

Re: [PR] [FLINK-30593] Add tests for ScalingTracking#removeOldRecords() [flink-kubernetes-operator]

2023-11-27 Thread via GitHub
afedulov commented on code in PR #715: URL: https://github.com/apache/flink-kubernetes-operator/pull/715#discussion_r1405924492 ## flink-autoscaler/src/test/java/org/apache/flink/autoscaler/ScalingTrackingTest.java: ## @@ -52,6 +52,7 @@ void setUp() { conf.set(AutoScal

Re: [PR] [FLINK-32881][checkpoint] Support triggering savepoint in detach mode for CLI and dumping all pending savepoint ids by rest api [flink]

2023-11-27 Thread via GitHub
xiangforever2014 commented on PR #23253: URL: https://github.com/apache/flink/pull/23253#issuecomment-1827533221 @masteryhx Many thanks for your insightful comments, I have updated the code according to the comments, PTAL, thanks again bro~ -- This is an automated message from the Apache

Re: [PR] [FLINK-33459][Connector/JDBC] Support the new source that keeps the same functionality as the original JDBC input format [flink-connector-jdbc]

2023-11-27 Thread via GitHub
eskabetxe commented on code in PR #78: URL: https://github.com/apache/flink-connector-jdbc/pull/78#discussion_r1405924661 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java: ## @@ -0,0 +1,190 @@ +/* + * Licensed to the Apache Software F

Re: [PR] [FLINK-33459][Connector/JDBC] Support the new source that keeps the same functionality as the original JDBC input format [flink-connector-jdbc]

2023-11-27 Thread via GitHub
eskabetxe commented on code in PR #78: URL: https://github.com/apache/flink-connector-jdbc/pull/78#discussion_r1405924661 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java: ## @@ -0,0 +1,190 @@ +/* + * Licensed to the Apache Software F

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

2023-11-27 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790010#comment-17790010 ] Rui Fan commented on FLINK-27681: - {quote} * That's why we'd like to focus on not upload

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790011#comment-17790011 ] Leonard Xu commented on FLINK-25857: > Leonard Xu : Jiabao Sun raised his concern af

Re: [PR] FLINK-28050][connectors] Introduce FLIP-27 alternative to StreamExecutionEnvironment#fromElements() [flink]

2023-11-27 Thread via GitHub
zentol merged PR #23553: URL: https://github.com/apache/flink/pull/23553 -- 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] FLINK-28050][connectors] Introduce FLIP-27 alternative to StreamExecutionEnvironment#fromElements() [flink]

2023-11-27 Thread via GitHub
zentol commented on code in PR #23553: URL: https://github.com/apache/flink/pull/23553#discussion_r1405936668 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java: ## @@ -1185,8 +1295,10 @@ public DataStreamSource fromS

Re: [PR] [FLINK-25857] Add committer metrics to track the status of committables [flink]

2023-11-27 Thread via GitHub
MartijnVisser commented on code in PR #23555: URL: https://github.com/apache/flink/pull/23555#discussion_r1399126249 ## flink-core/src/main/java/org/apache/flink/api/connector/sink2/Sink.java: ## @@ -55,17 +53,11 @@ public interface Sink extends Serializable { * @return A

[jira] [Updated] (FLINK-28050) Introduce Source API alternative to SourceExecutionContext#fromElements(*) methods

2023-11-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28050: - Fix Version/s: 1.19.0 > Introduce Source API alternative to SourceExecutionContext#fromE

[jira] [Closed] (FLINK-28050) Introduce Source API alternative to SourceExecutionContext#fromElements(*) methods

2023-11-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28050. Resolution: Fixed master: 68437b937a60c647abe1a4104289849c006b8fe7..d351c5bd9c1f28a3e5ffe9

[jira] [Commented] (FLINK-25857) Add committer metrics to track the status of committables

2023-11-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790019#comment-17790019 ] Martijn Visser commented on FLINK-25857: Hey all, I've opened https://lists.apa

Re: [PR] [FLINK-25857] Add committer metrics to track the status of committables [flink]

2023-11-27 Thread via GitHub
MartijnVisser commented on code in PR #23555: URL: https://github.com/apache/flink/pull/23555#discussion_r1399126249 ## flink-core/src/main/java/org/apache/flink/api/connector/sink2/Sink.java: ## @@ -55,17 +53,11 @@ public interface Sink extends Serializable { * @return A

[jira] [Closed] (FLINK-33659) Avoid unnecessary retries when restore from savepoint failed.

2023-11-27 Thread zhouli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhouli closed FLINK-33659. -- Resolution: Invalid > Avoid unnecessary retries when restore from savepoint failed. >

[jira] (FLINK-33659) Avoid unnecessary retries when restore from savepoint failed.

2023-11-27 Thread zhouli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33659 ] zhouli deleted comment on FLINK-33659: was (Author: leo zhou): Hi, [~zhuzh] , wdyt ? > Avoid unnecessary retries when restore from savepoint failed. > ---

[jira] [Created] (FLINK-33663) Serialize CallExpressions into SQL

2023-11-27 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-33663: Summary: Serialize CallExpressions into SQL Key: FLINK-33663 URL: https://issues.apache.org/jira/browse/FLINK-33663 Project: Flink Issue Type: Sub-ta

Re: [PR] Bump h2 from 2.1.210 to 2.2.220 in /flink-connector-jdbc [flink-connector-jdbc]

2023-11-27 Thread via GitHub
MartijnVisser merged PR #69: URL: https://github.com/apache/flink-connector-jdbc/pull/69 -- 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] Bump org.apache.derby:derby from 10.14.2.0 to 10.17.1.0 in /flink-connector-jdbc [flink-connector-jdbc]

2023-11-27 Thread via GitHub
dependabot[bot] opened a new pull request, #80: URL: https://github.com/apache/flink-connector-jdbc/pull/80 Bumps org.apache.derby:derby from 10.14.2.0 to 10.17.1.0. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-na

[PR] Bump com.google.guava:guava from 31.1-jre to 32.0.0-jre [flink-connector-jdbc]

2023-11-27 Thread via GitHub
dependabot[bot] opened a new pull request, #81: URL: https://github.com/apache/flink-connector-jdbc/pull/81 Bumps [com.google.guava:guava](https://github.com/google/guava) from 31.1-jre to 32.0.0-jre. Release notes Sourced from https://github.com/google/guava/releases";>com.google.

Re: [PR] [FLINK-30593] Add tests for ScalingTracking#removeOldRecords() [flink-kubernetes-operator]

2023-11-27 Thread via GitHub
mxm merged PR #715: URL: https://github.com/apache/flink-kubernetes-operator/pull/715 -- 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...

[jira] [Closed] (FLINK-33662) Bump com.h2database:h2

2023-11-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33662. -- Fix Version/s: jdbc-3.2.0 Resolution: Fixed Fixed in apache/flink-connector-jdbc:main

Re: [PR] Support Flink 1.17.1 [flink-statefun]

2023-11-27 Thread via GitHub
MartijnVisser commented on code in PR #332: URL: https://github.com/apache/flink-statefun/pull/332#discussion_r1405970736 ## pom.xml: ## @@ -76,15 +76,28 @@ under the License. 1.8 1.20.0 1.0-rc6 -3.7.1 -2.3.2 - 3.11.1 -1

Re: [PR] Support Flink 1.17.1 [flink-statefun]

2023-11-27 Thread via GitHub
MartijnVisser commented on code in PR #332: URL: https://github.com/apache/flink-statefun/pull/332#discussion_r1405987733 ## statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java: ## @@ -265,7 +265,7 @@ public void set

Re: [PR] [FLINK-33638] Support variable-length data generation for variable-length data types [flink]

2023-11-27 Thread via GitHub
liyubin117 commented on PR #23810: URL: https://github.com/apache/flink/pull/23810#issuecomment-1827611717 @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

[jira] [Commented] (FLINK-28051) Promote ExternallyInducedSourceReader to non-experimental @Public

2023-11-27 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790032#comment-17790032 ] Alexander Fedulov commented on FLINK-28051: --- Hi [~Brian Zhou], thanks a lot fo

[jira] [Commented] (FLINK-28051) Promote ExternallyInducedSourceReader to non-experimental @Public

2023-11-27 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790034#comment-17790034 ] Alexander Fedulov commented on FLINK-28051: --- [~Brian Zhou] can I assign this t

Re: [PR] [FLINK-33638] Support variable-length data generation for variable-length data types [flink]

2023-11-27 Thread via GitHub
liyubin117 commented on PR #23810: URL: https://github.com/apache/flink/pull/23810#issuecomment-1827646121 @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

[PR] [FLINK-33663] Serialize CallExpressions into SQL [flink]

2023-11-27 Thread via GitHub
dawidwys opened a new pull request, #23811: URL: https://github.com/apache/flink/pull/23811 ## What is the purpose of the change This PR adds a `CallSyntax` as described in the FLIP and implementations for specific non standard builtin functions. ## Brief change log

  1   2   3   >