[jira] [Created] (FLINK-33954) Large record may cause the hybrid shuffle hang

2023-12-27 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-33954: - Summary: Large record may cause the hybrid shuffle hang Key: FLINK-33954 URL: https://issues.apache.org/jira/browse/FLINK-33954 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-33944) Apache Flink: Process to restore more than one job on job manager startup from the respective savepoints

2023-12-27 Thread Vijay (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800927#comment-17800927 ] Vijay commented on FLINK-33944: --- [~martijnvisser] Can we use Aligned checkpointing instead of Savepoint

[jira] [Updated] (FLINK-33929) Support jdbc read shard Read string fields as shard keys

2023-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33929: --- Labels: pull-request-available (was: ) > Support jdbc read shard Read string fields as

Re: [PR] [FLINK-33929][jdbc-connector] Support JDBC String field read Fragment read [flink-connector-jdbc]

2023-12-27 Thread via GitHub
boring-cyborg[bot] commented on PR #87: URL: https://github.com/apache/flink-connector-jdbc/pull/87#issuecomment-1870825211 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[jira] [Comment Edited] (FLINK-33929) Support jdbc read shard Read string fields as shard keys

2023-12-27 Thread zhilinli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800917#comment-17800917 ] zhilinli edited comment on FLINK-33929 at 12/28/23 4:51 AM:

[jira] [Comment Edited] (FLINK-33929) Support jdbc read shard Read string fields as shard keys

2023-12-27 Thread zhilinli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800917#comment-17800917 ] zhilinli edited comment on FLINK-33929 at 12/28/23 4:48 AM: {code:java}

[jira] [Commented] (FLINK-33929) Support jdbc read shard Read string fields as shard keys

2023-12-27 Thread zhilinli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800917#comment-17800917 ] zhilinli commented on FLINK-33929: -- {code:java} CREATE TABLE MyUserTable ( id int, name STRING, age

[jira] [Comment Edited] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800913#comment-17800913 ] Wencong Liu edited comment on FLINK-33949 at 12/28/23 3:45 AM: --- Suppose we

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800913#comment-17800913 ] Wencong Liu commented on FLINK-33949: - Suppose we have two completely independent interfaces, I and

Re: [PR] [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods [flink]

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

Re: [PR] [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods [flink]

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

[PR] [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods [flink]

2023-12-27 Thread via GitHub
1996fanrui opened a new pull request, #24005: URL: https://github.com/apache/flink/pull/24005 backporting https://github.com/apache/flink/pull/23994 to 1.17 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[PR] [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods [flink]

2023-12-27 Thread via GitHub
1996fanrui opened a new pull request, #24004: URL: https://github.com/apache/flink/pull/24004 backporting https://github.com/apache/flink/pull/23994 to 1.18 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-33565][Scheduler] ConcurrentExceptions works with exception merging [flink]

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

[jira] [Updated] (FLINK-33565) The concurrentExceptions doesn't work

2023-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33565: --- Labels: pull-request-available (was: ) > The concurrentExceptions doesn't work >

[PR] [FLINK-33565][Scheduler] ConcurrentExceptions works with exception merging [flink]

2023-12-27 Thread via GitHub
1996fanrui opened a new pull request, #24003: URL: https://github.com/apache/flink/pull/24003 ## What is the purpose of the change The concurrent exceptions doesn't work. ## Brief change log - [FLINK-33565][Exception] Archive exceptions into the exception history

[jira] [Commented] (FLINK-33932) Support retry mechanism for rocksdb uploader

2023-12-27 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800910#comment-17800910 ] xiangyu feng commented on FLINK-33932: -- [~martijnvisser] Yes, like the default

Re: [PR] [FLINK-33879] Avoids the potential hang of Hybrid Shuffle during redistribution [flink]

2023-12-27 Thread via GitHub
jiangxin369 commented on PR #23957: URL: https://github.com/apache/flink/pull/23957#issuecomment-1870758405 @xintongsong Could you take a look at this PR? -- 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

[jira] [Commented] (FLINK-33933) SerializedThrowable will be java.lang.StackOverflowError when AsyncLookupFunction throw an exception

2023-12-27 Thread KarlManong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800905#comment-17800905 ] KarlManong commented on FLINK-33933: [~martijnvisser] I do return a CompletableFuture when exception

Re: [PR] [FLINK-33925][connectors/opensearch] Allow customising bulk failure handling [flink-connector-opensearch]

2023-12-27 Thread via GitHub
schulzp commented on PR #39: URL: https://github.com/apache/flink-connector-opensearch/pull/39#issuecomment-1870649037 @reswqa, I checked the CI logs and it looks like `TestCodeArchitectureTest` breaks the pipeline. It requires that "ITCASE tests should use a MiniCluster resource or

Re: [PR] [FLINK-33518] Implement restore tests for WatermarkAssigner node [flink]

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

[jira] [Updated] (FLINK-33518) Implement restore tests for WatermarkAssigner node

2023-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33518: --- Labels: pull-request-available (was: ) > Implement restore tests for WatermarkAssigner

[PR] [FLINK-33518] Implement restore tests for WatermarkAssigner node [flink]

2023-12-27 Thread via GitHub
bvarghese1 opened a new pull request, #24002: URL: https://github.com/apache/flink/pull/24002 ## What is the purpose of the change *Add restore tests for WatermarkAssigner node* ## Verifying this change This change added tests and can be verified as follows:

[jira] [Assigned] (FLINK-33518) Implement restore tests for WatermarkAssigner node

2023-12-27 Thread Bonnie Varghese (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bonnie Varghese reassigned FLINK-33518: --- Assignee: Bonnie Varghese > Implement restore tests for WatermarkAssigner node >

[jira] [Commented] (FLINK-33952) Flink JDBC connector build fail on JDK 17

2023-12-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800849#comment-17800849 ] Sergey Nuyanzin commented on FLINK-33952: - oops, seems I forgot to create a backport since 3.1

[jira] [Updated] (FLINK-33952) Flink JDBC connector build fail on JDK 17

2023-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33952: --- Labels: pull-request-available test-stability (was: test-stability) > Flink JDBC connector

[jira] [Commented] (FLINK-33944) Apache Flink: Process to restore more than one job on job manager startup from the respective savepoints

2023-12-27 Thread Vijay (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800823#comment-17800823 ] Vijay commented on FLINK-33944: --- [~martijnvisser] Using "application mode" we can run multiple run

Re: [PR] [FLINK-33947][configuration] Fix bugs about the prefix attribute in the DelegatingConfiguration class. [flink]

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

[jira] [Updated] (FLINK-33947) Fix bugs about prefix in DelegatingConfiguration

2023-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33947: --- Labels: pull-request-available (was: ) > Fix bugs about prefix in DelegatingConfiguration

[PR] [FLINK-33947][configuration] Fix bugs about the prefix attribute in the DelegatingConfiguration class. [flink]

2023-12-27 Thread via GitHub
RocMarshal opened a new pull request, #24001: URL: https://github.com/apache/flink/pull/24001 ## What is the purpose of the change [FLINK-33947][configuration] Fix bugs about the prefix attribute in the DelegatingConfiguration class. It was resulted from

[jira] [Updated] (FLINK-33947) Fix bugs about prefix in DelegatingConfiguration

2023-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33947: --- Summary: Fix bugs about prefix in DelegatingConfiguration (was: Fix bugs in

Re: [PR] [FLINK-33884] Update Pulsar dependency to 3.0.2 in Pulsar Connector [flink-connector-pulsar]

2023-12-27 Thread via GitHub
MartijnVisser commented on PR #72: URL: https://github.com/apache/flink-connector-pulsar/pull/72#issuecomment-1870426727 @dchristle I've triggered the CI, but I'm expecting that upgrading the version will also have impact on the license checks (the listed versions in the NOTICE files)

[jira] [Assigned] (FLINK-33884) Update Pulsar dependency to 3.0.2 in Pulsar Connector

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-33884: -- Assignee: David Christle > Update Pulsar dependency to 3.0.2 in Pulsar Connector >

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800818#comment-17800818 ] Martijn Visser commented on FLINK-33949: [~Wencong Liu] Thanks. For reference, per the JAPICMP

[jira] [Commented] (FLINK-33856) Add metrics to monitor the interaction performance between task and external storage system in the process of checkpoint making

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800816#comment-17800816 ] Martijn Visser commented on FLINK-33856: Just to be thorough, metrics are considered to be

[jira] [Closed] (FLINK-33953) Bump com.google.guava:guava from 31.1-jre to 33.0.0-jre

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

[jira] [Updated] (FLINK-33953) Bump com.google.guava:guava from 31.1-jre to 33.0.0-jre

2023-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33953: --- Labels: pull-request-available (was: ) > Bump com.google.guava:guava from 31.1-jre to

Re: [PR] [FLINK-33953] Bump com.google.guava:guava from 31.1-jre to 33.0.0-jre [flink-connector-jdbc]

2023-12-27 Thread via GitHub
MartijnVisser merged PR #81: URL: https://github.com/apache/flink-connector-jdbc/pull/81 -- 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:

Re: [PR] fix compile [flink-connector-elasticsearch]

2023-12-27 Thread via GitHub
reswqa closed pull request #84: fix compile URL: https://github.com/apache/flink-connector-elasticsearch/pull/84 -- 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

Re: [PR] fix compile [flink-connector-elasticsearch]

2023-12-27 Thread via GitHub
reswqa commented on PR #84: URL: https://github.com/apache/flink-connector-elasticsearch/pull/84#issuecomment-1870404912 Ah,just a test. There should be no problem now, I forgot to close this PR. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-33922) table-planner jar will be removed as it is created at /tmp by default

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800812#comment-17800812 ] Martijn Visser commented on FLINK-33922: [~dianer17] During which process if this JAR generated?

Re: [PR] Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.14 in /flink-connector-elasticsearch-base [flink-connector-elasticsearch]

2023-12-27 Thread via GitHub
dependabot[bot] commented on PR #82: URL: https://github.com/apache/flink-connector-elasticsearch/pull/82#issuecomment-1870401973 OK, I won't notify you again about this release, but will get in touch when a new version is available. If you'd rather skip all updates until the next major

Re: [PR] Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.14 in /flink-connector-elasticsearch-base [flink-connector-elasticsearch]

2023-12-27 Thread via GitHub
MartijnVisser commented on PR #82: URL: https://github.com/apache/flink-connector-elasticsearch/pull/82#issuecomment-1870401929 We can't merge this because of the change in the license in this newer version of Elastic -- This is an automated message from the Apache Git Service. To

Re: [PR] Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.14 in /flink-connector-elasticsearch-base [flink-connector-elasticsearch]

2023-12-27 Thread via GitHub
MartijnVisser closed pull request #82: Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.14 in /flink-connector-elasticsearch-base URL: https://github.com/apache/flink-connector-elasticsearch/pull/82 -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] fix compile [flink-connector-elasticsearch]

2023-12-27 Thread via GitHub
MartijnVisser commented on PR #84: URL: https://github.com/apache/flink-connector-elasticsearch/pull/84#issuecomment-1870401497 @reswqa What needs to be fixed, given that the nightly builds work as expected? -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (FLINK-33857) Expose BulkProcessor.flush via RequestIndexer to allow custom flush logic

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-33857: -- Assignee: Peter Schulz > Expose BulkProcessor.flush via RequestIndexer to allow

[jira] [Assigned] (FLINK-33925) Extended failure handling for bulk requests (elasticsearch back port)

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-33925: -- Assignee: Peter Schulz > Extended failure handling for bulk requests (elasticsearch

[jira] [Commented] (FLINK-33929) Support jdbc read shard Read string fields as shard keys

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800811#comment-17800811 ] Martijn Visser commented on FLINK-33929: [~sunnny] Can you please elaborate more on what you're

[jira] [Commented] (FLINK-33933) SerializedThrowable will be java.lang.StackOverflowError when AsyncLookupFunction throw an exception

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800809#comment-17800809 ] Martijn Visser commented on FLINK-33933: [~KarlManong] I believe that the asyncLookup() method

[jira] [Commented] (FLINK-33932) Support retry mechanism for rocksdb uploader

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800808#comment-17800808 ] Martijn Visser commented on FLINK-33932: I'm no expert on checkpointing, but I'm also wondering

[jira] [Commented] (FLINK-33932) Support retry mechanism for rocksdb uploader

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800806#comment-17800806 ] Martijn Visser commented on FLINK-33932: [~xiangyu0xf] If I'm understanding you correctly, you

[jira] [Commented] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800805#comment-17800805 ] RocMarshal commented on FLINK-33947: > And how about allow prefix is empty? SGTM +1. > Fix bugs in

[jira] [Updated] (FLINK-33937) Translate "Stateful Stream Processing" page into Chinese

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33937: --- Fix Version/s: (was: 1.8.4) > Translate "Stateful Stream Processing" page into Chinese

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800802#comment-17800802 ] Wencong Liu commented on FLINK-33949: - For the users have built implementations themselves, they

[jira] [Updated] (FLINK-33938) Correct implicit coercions in relational operators to adopt typescript 5.0

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33938: --- Fix Version/s: (was: 1.17.3) (was: 1.18.2) > Correct implicit

[jira] [Resolved] (FLINK-27851) Join can't access the pk from source table

2023-12-27 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-27851. --- Fix Version/s: 1.19.0 Resolution: Fixed > Join can't access the pk from source table >

[jira] [Commented] (FLINK-27851) Join can't access the pk from source table

2023-12-27 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800798#comment-17800798 ] dalongliu commented on FLINK-27851: --- Merged to master branch: dd16a4c07b2f8c96740fb522cb54cfd1d5a5e835

[jira] [Updated] (FLINK-33944) Apache Flink: Process to restore more than one job on job manager startup from the respective savepoints

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33944: --- Issue Type: New Feature (was: Bug) > Apache Flink: Process to restore more than one job on

[jira] [Commented] (FLINK-33944) Apache Flink: Process to restore more than one job on job manager startup from the respective savepoints

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800796#comment-17800796 ] Martijn Visser commented on FLINK-33944: [~vrang...@in.ibm.com] Given that Application Mode is

[jira] [Comment Edited] (FLINK-33944) Apache Flink: Process to restore more than one job on job manager startup from the respective savepoints

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800796#comment-17800796 ] Martijn Visser edited comment on FLINK-33944 at 12/27/23 2:51 PM: --

[jira] [Commented] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-27 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800795#comment-17800795 ] Rui Fan commented on FLINK-33947: - Mark the prefix as @Nonnull makes sense. And how about allow prefix

[jira] [Closed] (FLINK-20036) Join Has NoUniqueKey when using mini-batch

2023-12-27 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu closed FLINK-20036. - Resolution: Duplicate > Join Has NoUniqueKey when using mini-batch >

[jira] [Commented] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800794#comment-17800794 ] RocMarshal commented on FLINK-33947: hi, [~fanrui] thanks for your attention. I want to set the

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800793#comment-17800793 ] Martijn Visser commented on FLINK-33949: I was thinking about situations where users have build

Re: [PR] [FLINK-27851][table-planner] support to access source pks through MiniBatchAssigner [flink]

2023-12-27 Thread via GitHub
lsyldliu closed pull request #19850: [FLINK-27851][table-planner] support to access source pks through MiniBatchAssigner URL: https://github.com/apache/flink/pull/19850 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800787#comment-17800787 ] Wencong Liu commented on FLINK-33949: - Thanks [~martijnvisser] for your comments. The implementation

[jira] [Commented] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-27 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800785#comment-17800785 ] Rui Fan commented on FLINK-33947: - I  don't think prefix can be null. If it's null or empty, why don't

[jira] [Commented] (FLINK-33952) Flink JDBC connector build fail on JDK 17

2023-12-27 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800782#comment-17800782 ] Jiabao Sun commented on FLINK-33952: Seems missing f8de82b4c52a688c5bd36c4c4bd3012ff4081eb8 on

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800780#comment-17800780 ] Martijn Visser commented on FLINK-33949: [~mapohl] Also curious on your thoughts here >

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800779#comment-17800779 ] Martijn Visser commented on FLINK-33949: [~Wencong Liu] Your change could still be source

[jira] [Comment Edited] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800774#comment-17800774 ] RocMarshal edited comment on FLINK-33947 at 12/27/23 2:09 PM: -- Before

[jira] [Commented] (FLINK-33950) Update max aggregate functions to new type system

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800777#comment-17800777 ] Martijn Visser commented on FLINK-33950: [~jackylau] Before pinging people, can you first make

[jira] [Commented] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800774#comment-17800774 ] RocMarshal commented on FLINK-33947: Before officially starting the repair, there are two issues

[jira] [Commented] (FLINK-33951) should use aggCallNeedRetractions instead of needRetraction to check retract method, orelse throw not implement retract method

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800775#comment-17800775 ] Martijn Visser commented on FLINK-33951: [~jackylau] Can you please add a better description for

Re: [PR] Bump org.apache.derby:derby from 10.14.2.0 to 10.17.1.0 in /flink-connector-jdbc [flink-connector-jdbc]

2023-12-27 Thread via GitHub
MartijnVisser commented on PR #80: URL: https://github.com/apache/flink-connector-jdbc/pull/80#issuecomment-1870333980 > Mitigation: Users should upgrade to Java 21 and Derby 10.17.1.0. Alternatively, users who wish to remain on older Java versions should build their own Derby

Re: [PR] Bump org.apache.derby:derby from 10.14.2.0 to 10.17.1.0 in /flink-connector-jdbc [flink-connector-jdbc]

2023-12-27 Thread via GitHub
dependabot[bot] commented on PR #80: URL: https://github.com/apache/flink-connector-jdbc/pull/80#issuecomment-1870334027 OK, I won't notify you again about this release, but will get in touch when a new version is available. If you'd rather skip all updates until the next major or minor

Re: [PR] Bump org.apache.derby:derby from 10.14.2.0 to 10.17.1.0 in /flink-connector-jdbc [flink-connector-jdbc]

2023-12-27 Thread via GitHub
MartijnVisser closed pull request #80: Bump org.apache.derby:derby from 10.14.2.0 to 10.17.1.0 in /flink-connector-jdbc URL: https://github.com/apache/flink-connector-jdbc/pull/80 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-33888] Add release flink-1.18.1 [flink-web]

2023-12-27 Thread via GitHub
Myasuka commented on code in PR #706: URL: https://github.com/apache/flink-web/pull/706#discussion_r1437055487 ## docs/content/posts/2023-12-20-release-1.18.1.md: ## @@ -0,0 +1,142 @@ +--- +title: "Apache Flink 1.18.1 Release Announcement" +date: "2023-12-20T00:00:00.000Z"

[jira] [Created] (FLINK-33953) Bump com.google.guava:guava from 31.1-jre to 33.0.0-jre

2023-12-27 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33953: -- Summary: Bump com.google.guava:guava from 31.1-jre to 33.0.0-jre Key: FLINK-33953 URL: https://issues.apache.org/jira/browse/FLINK-33953 Project: Flink

Re: [PR] Jsonb support [flink-connector-jdbc]

2023-12-27 Thread via GitHub
MartijnVisser commented on PR #68: URL: https://github.com/apache/flink-connector-jdbc/pull/68#issuecomment-1870325816 This requires a proper FLIP and implementation, see also https://issues.apache.org/jira/browse/FLINK-29267. Next to that, please follow the contributing code process as

Re: [PR] Jsonb support [flink-connector-jdbc]

2023-12-27 Thread via GitHub
MartijnVisser closed pull request #68: Jsonb support URL: https://github.com/apache/flink-connector-jdbc/pull/68 -- 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-33952) Flink JDBC connector build fail on JDK 17

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800771#comment-17800771 ] Martijn Visser commented on FLINK-33952: [~snuyanzin] Was it intended to test if the v3.1 branch

[jira] [Updated] (FLINK-33952) Flink JDBC connector build fail on JDK 17

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33952: --- Environment: (was: {code:java} aused by: java.lang.RuntimeException:

[jira] [Created] (FLINK-33952) Flink JDBC connector build fail on JDK 17

2023-12-27 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33952: -- Summary: Flink JDBC connector build fail on JDK 17 Key: FLINK-33952 URL: https://issues.apache.org/jira/browse/FLINK-33952 Project: Flink Issue Type:

[jira] [Updated] (FLINK-33952) Flink JDBC connector build fail on JDK 17

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33952: --- Description: {code:java} aused by: java.lang.RuntimeException:

[jira] [Closed] (FLINK-33329) Bump commons-compress to address CVEs

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33329. -- Resolution: Fixed > Bump commons-compress to address CVEs >

[jira] [Commented] (FLINK-33329) Bump commons-compress to address CVEs

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800769#comment-17800769 ] Martijn Visser commented on FLINK-33329: Re-opened to also add this for:

[jira] [Updated] (FLINK-33329) Bump commons-compress to address CVEs

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33329: --- Fix Version/s: jdbc-3.2.0 (was: jdbc-3.0.1) > Bump commons-compress

Re: [PR] Bump org.apache.commons:commons-compress from 1.23.0 to 1.24.0 [flink-connector-jdbc]

2023-12-27 Thread via GitHub
MartijnVisser merged PR #84: URL: https://github.com/apache/flink-connector-jdbc/pull/84 -- 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:

[jira] [Updated] (FLINK-33329) Bump commons-compress to address CVEs

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33329: --- Fix Version/s: jdbc-3.0.1 > Bump commons-compress to address CVEs >

[jira] [Reopened] (FLINK-33329) Bump commons-compress to address CVEs

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reopened FLINK-33329: > Bump commons-compress to address CVEs > - > >

[jira] [Assigned] (FLINK-32877) Support for HTTP connect and timeout options while writes in GCS connector

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-32877: -- Assignee: Ravi Singh > Support for HTTP connect and timeout options while writes in

[jira] [Commented] (FLINK-33514) FlinkScalaKryoInstantiator class not found in KryoSerializer

2023-12-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800747#comment-17800747 ] Martijn Visser commented on FLINK-33514: [~Cyberness] I think this ticket lacks information in

[jira] [Created] (FLINK-33951) should use aggCallNeedRetractions instead of needRetraction to check retract method, orelse throw not implement retract method

2023-12-27 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-33951: - Summary: should use aggCallNeedRetractions instead of needRetraction to check retract method, orelse throw not implement retract method Key: FLINK-33951 URL:

[jira] [Commented] (FLINK-33950) Update max aggregate functions to new type system

2023-12-27 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800726#comment-17800726 ] Jacky Lau commented on FLINK-33950: --- hi [~twalthr]  do you have time to help review it? > Update max

Re: [PR] [FLINK-33950][table] Update max aggregate functions to new type system [flink]

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

[jira] [Updated] (FLINK-33950) Update max aggregate functions to new type system

2023-12-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33950: --- Labels: pull-request-available (was: ) > Update max aggregate functions to new type system

[PR] [FLINK-33950][table] Update max aggregate functions to new type system [flink]

2023-12-27 Thread via GitHub
liuyongvs opened a new pull request, #24000: URL: https://github.com/apache/flink/pull/24000 ## 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 them

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core package api-common [flink]

2023-12-27 Thread via GitHub
1996fanrui commented on code in PR #23960: URL: https://github.com/apache/flink/pull/23960#discussion_r1436848236 ## flink-core/src/test/java/org/apache/flink/api/common/eventtime/WatermarkOutputMultiplexerTest.java: ## @@ -58,29 +53,29 @@ public void singleImmediateIdleness()

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core package api-common [flink]

2023-12-27 Thread via GitHub
Jiabao-Sun commented on code in PR #23960: URL: https://github.com/apache/flink/pull/23960#discussion_r1436819321 ## flink-core/src/test/java/org/apache/flink/api/common/eventtime/WatermarkOutputMultiplexerTest.java: ## @@ -44,12 +39,12 @@ public void singleImmediateWatermark()

  1   2   >