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

2023-12-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801114#comment-17801114 ] Rui Fan commented on FLINK-33947: - Merged to master(1.19) via :

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

2023-12-28 Thread via GitHub
1996fanrui merged PR #24001: URL: https://github.com/apache/flink/pull/24001 -- 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] [FLINK-33737][Scheduler] Merge multiple Exceptions into one attempt for exponential-delay restart-strategy [flink]

2023-12-28 Thread via GitHub
1996fanrui commented on code in PR #23867: URL: https://github.com/apache/flink/pull/23867#discussion_r1438066538 ## flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/ExponentialDelayRestartBackoffTimeStrategyTest.java: ## @@ -214,28 +266,111 @@ void

Re: [PR] [FLINK-26369][doc-zh] Translate the part zh-page mixed with not be translated. [flink]

2023-12-28 Thread via GitHub
GOODBOY008 commented on PR #20340: URL: https://github.com/apache/flink/pull/20340#issuecomment-1871793058 @1996fanrui @Jiabao-Sun PTAL -- 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

[jira] [Commented] (FLINK-23687) Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys

2023-12-28 Thread yunfan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801104#comment-17801104 ] yunfan commented on FLINK-23687: Hello, [~jingzhang] . Are you still working on this issue? If not, I

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

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

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

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

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

2023-12-28 Thread via GitHub
RocMarshal opened a new pull request, #24011: URL: https://github.com/apache/flink/pull/24011 ## What is the purpose of the change The patch is BP from https://github.com/apache/flink/pull/24001 for 1.17 ## Brief change log - Marked prefix as @Nonnull and

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

2023-12-28 Thread via GitHub
RocMarshal opened a new pull request, #24010: URL: https://github.com/apache/flink/pull/24010 ## What is the purpose of the change The patch BP for https://github.com/apache/flink/pull/24001 ## Brief change log - Marked prefix as @Nonnull and adapted

Re: [PR] [FLINK-33737][Scheduler] Merge multiple Exceptions into one attempt for exponential-delay restart-strategy [flink]

2023-12-28 Thread via GitHub
qinf commented on PR #23867: URL: https://github.com/apache/flink/pull/23867#issuecomment-1871704522 @1996fanrui Thanks for the PR, LGTM. I just have one comment, please take a look. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [FLINK-33737][Scheduler] Merge multiple Exceptions into one attempt for exponential-delay restart-strategy [flink]

2023-12-28 Thread via GitHub
qinf commented on code in PR #23867: URL: https://github.com/apache/flink/pull/23867#discussion_r1437967171 ## flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/ExponentialDelayRestartBackoffTimeStrategyTest.java: ## @@ -214,28 +266,111 @@ void

Re: [PR] [FLINK-33958] Implement restore tests for IntervalJoin node [flink]

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

[jira] [Updated] (FLINK-33958) Implement restore tests for IntervalJoin node

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

[PR] [FLINK-33958] Implement restore tests for IntervalJoin node [flink]

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

[jira] [Created] (FLINK-33958) Implement restore tests for IntervalJoin node

2023-12-28 Thread Bonnie Varghese (Jira)
Bonnie Varghese created FLINK-33958: --- Summary: Implement restore tests for IntervalJoin node Key: FLINK-33958 URL: https://issues.apache.org/jira/browse/FLINK-33958 Project: Flink Issue

[jira] [Commented] (FLINK-33863) Compressed Operator state restore failed

2023-12-28 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801086#comment-17801086 ] Ruibin Xing commented on FLINK-33863: - [~martijnvisser] I think so. I have created a backport PR for

Re: [PR] [BP-1.18] [FLINK-33863][checkpoint] Fix restoring compressed operator state [flink]

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

[PR] [BP-1.18] [FLINK-33863][checkpoint] Fix restoring compressed operator state [flink]

2023-12-28 Thread via GitHub
ruibinx opened a new pull request, #24008: URL: https://github.com/apache/flink/pull/24008 - Update for 1.18.0 - [FLINK-32827][table-runtime] Fix the operator fusion codegen may not take effect when enabling runtime filter - [FLINK-32296][table] Support cast of collections with row

[jira] [Commented] (FLINK-33957) Generic Log-Based Incremental Checkpoint fails when Task Local Recovery is enabled

2023-12-28 Thread Prabhu Joseph (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801082#comment-17801082 ] Prabhu Joseph commented on FLINK-33957: --- [~Yanfei Lei] Could you take a look into this? Any idea

[jira] [Updated] (FLINK-33957) Generic Log-Based Incremental Checkpoint fails when Task Local Recovery is enabled

2023-12-28 Thread Prabhu Joseph (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabhu Joseph updated FLINK-33957: -- Description: Generic Log-Based Incremental Checkpoint fails when Task Local Recovery is

[jira] [Created] (FLINK-33957) Generic Log-Based Incremental Checkpoint fails when Task Local Recovery is enabled

2023-12-28 Thread Prabhu Joseph (Jira)
Prabhu Joseph created FLINK-33957: - Summary: Generic Log-Based Incremental Checkpoint fails when Task Local Recovery is enabled Key: FLINK-33957 URL: https://issues.apache.org/jira/browse/FLINK-33957

[jira] [Resolved] (FLINK-33942) DelegatingConfiguration misses the perfix for some methods

2023-12-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33942. - Resolution: Fixed > DelegatingConfiguration misses the perfix for some methods >

[jira] [Commented] (FLINK-33942) DelegatingConfiguration misses the perfix for some methods

2023-12-28 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801081#comment-17801081 ] Rui Fan commented on FLINK-33942: - Merged to: master(1.19) via:

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

2023-12-28 Thread via GitHub
1996fanrui merged PR #24004: URL: https://github.com/apache/flink/pull/24004 -- 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] [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods [flink]

2023-12-28 Thread via GitHub
1996fanrui merged PR #24005: URL: https://github.com/apache/flink/pull/24005 -- 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] [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods [flink]

2023-12-28 Thread via GitHub
1996fanrui merged PR #23994: URL: https://github.com/apache/flink/pull/23994 -- 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] [Closed] (FLINK-33857) Expose BulkProcessor.flush via RequestIndexer to allow custom flush logic

2023-12-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33857. -- Fix Version/s: elasticsearch-3.1.0 Resolution: Fixed main

Re: [PR] [FLINK-33857][connectors/elasticsearch] Expose BulkProcessor.flush [flink-connector-elasticsearch]

2023-12-28 Thread via GitHub
reswqa merged PR #85: URL: https://github.com/apache/flink-connector-elasticsearch/pull/85 -- 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] [FLINK-33792] Generate the same code for the same logic [flink]

2023-12-28 Thread via GitHub
zoudan commented on PR #23984: URL: https://github.com/apache/flink/pull/23984#issuecomment-1871674246 @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-33933) SerializedThrowable will be java.lang.StackOverflowError when AsyncLookupFunction throw an exception

2023-12-28 Thread KarlManong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801073#comment-17801073 ] KarlManong edited comment on FLINK-33933 at 12/29/23 1:06 AM: --

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

2023-12-28 Thread KarlManong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801073#comment-17801073 ] KarlManong edited comment on FLINK-33933 at 12/29/23 1:06 AM: --

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

2023-12-28 Thread KarlManong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801073#comment-17801073 ] KarlManong edited comment on FLINK-33933 at 12/29/23 1:05 AM: --

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

2023-12-28 Thread KarlManong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801073#comment-17801073 ] KarlManong commented on FLINK-33933: [~martijnvisser] yes, when exception occurs, We'll got  a

Re: [PR] [hotfix] [docs] Update README.md to remove Maven [flink]

2023-12-28 Thread via GitHub
asafm commented on PR #23981: URL: https://github.com/apache/flink/pull/23981#issuecomment-1871374396 Guys, I just thought it make sense that if you use internally maven wrapper, then the getting started README should mention that and not "force" users to download maven and run the build

[jira] [Commented] (FLINK-33882) UT/IT for checkpointing statistics

2023-12-28 Thread Tongtong Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801033#comment-17801033 ] Tongtong Zhu commented on FLINK-33882: -- [~jingge] I have completed it > UT/IT for checkpointing

[jira] [Updated] (FLINK-33882) UT/IT for checkpointing statistics

2023-12-28 Thread Tongtong Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tongtong Zhu updated FLINK-33882: - Attachment: FLINK-33882.patch > UT/IT for checkpointing statistics >

Re: [PR] [FLINK-33882] UT/IT for checkpointing statistics [flink]

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

[jira] [Updated] (FLINK-33882) UT/IT for checkpointing statistics

2023-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33882: --- Labels: pull-request-available (was: ) > UT/IT for checkpointing statistics >

[PR] [FLINK-33882] UT/IT for checkpointing statistics [flink]

2023-12-28 Thread via GitHub
zhutong6688 opened a new pull request, #24007: URL: https://github.com/apache/flink/pull/24007 ## What is the purpose of the change UT/IT for checkpointing statistics for FLINK-33588(Fix Flink Checkpointing Statistics Bug) ## Brief change log 1、add a

Re: [PR] [FLINK-33440] Update Flink version matrix, add 1.18.0 and 1.19-SNAPSHOT to GH workflows [flink-connector-hbase]

2023-12-28 Thread via GitHub
MartijnVisser commented on PR #35: URL: https://github.com/apache/flink-connector-hbase/pull/35#issuecomment-1871254126 We need to decide how to resolve the Guava dependency convergence: we can't pin the latest version, since that misses classes that are required by HBase. Perhaps we

Re: [PR] Bump org.apache.derby:derby from 10.10.2.0 to 10.17.1.0 in /flink-connectors/flink-connector-hive [flink]

2023-12-28 Thread via GitHub
dependabot[bot] commented on PR #23769: URL: https://github.com/apache/flink/pull/23769#issuecomment-1871221818 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 version,

Re: [PR] Bump org.apache.derby:derby from 10.10.2.0 to 10.17.1.0 in /flink-connectors/flink-connector-hive [flink]

2023-12-28 Thread via GitHub
MartijnVisser commented on PR #23769: URL: https://github.com/apache/flink/pull/23769#issuecomment-1871221787 Can't fix since this only works for JDK 21 -- 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

Re: [PR] Bump org.apache.derby:derby from 10.10.2.0 to 10.17.1.0 in /flink-connectors/flink-connector-hive [flink]

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

Re: [PR] Bump org.apache.zookeeper:zookeeper from 3.7.1 to 3.7.2 [flink]

2023-12-28 Thread via GitHub
MartijnVisser commented on PR #23939: URL: https://github.com/apache/flink/pull/23939#issuecomment-1871221369 Merging this PR is blocked on the new Flink Shaded release CC @snuyanzin -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Created] (FLINK-33956) Bump org.apache.zookeeper:zookeeper from 3.7.1 to 3.7.2

2023-12-28 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-33956: -- Summary: Bump org.apache.zookeeper:zookeeper from 3.7.1 to 3.7.2 Key: FLINK-33956 URL: https://issues.apache.org/jira/browse/FLINK-33956 Project: Flink

Re: [PR] [FLINK-33584][Filesystems] Update Hadoop Filesystem dependencies to 3.3.6 [flink]

2023-12-28 Thread via GitHub
MartijnVisser commented on PR #23844: URL: https://github.com/apache/flink/pull/23844#issuecomment-1871212810 Summary of the situation per @snuyanzin as discussed offline: > seems this [HADOOP-18382](https://issues.apache.org/jira/browse/HADOOP-18382) broke work of previous upgrades

Re: [PR] [FLINK-28513] Fix Flink Table API CSV streaming sink throws SerializedThrowable exception [flink]

2023-12-28 Thread via GitHub
MartijnVisser commented on PR #21458: URL: https://github.com/apache/flink/pull/21458#issuecomment-1871208283 In hindsight I'm quite concerned that we have merged this without any change to the tests. We run nightly tests for the FileSink and StreamingFileSink against S3. Why have those

Re: [PR] [FLINK-30702] Add Elasticsearch dialect [flink-connector-jdbc]

2023-12-28 Thread via GitHub
MartijnVisser commented on code in PR #67: URL: https://github.com/apache/flink-connector-jdbc/pull/67#discussion_r1437683689 ## flink-connector-jdbc/pom.xml: ## @@ -38,10 +38,12 @@ under the License. 2.12 2.12.7 3.23.1 +

[jira] [Updated] (FLINK-33955) UnsupportedFileSystemException when trying to save data to Azure's abfss File System

2023-12-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alek Łańduch updated FLINK-33955: - Priority: Minor (was: Major) > UnsupportedFileSystemException when trying to save data to

[jira] [Commented] (FLINK-33955) UnsupportedFileSystemException when trying to save data to Azure's abfss File System

2023-12-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-33955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801001#comment-17801001 ] Alek Łańduch commented on FLINK-33955: -- [~martijnvisser] Thanks for pointing it out. I was testing

Re: [PR] [FLINK-32175] [docs-zh] translate doc(datagen.md) into chinese [flink]

2023-12-28 Thread via GitHub
niliushall commented on PR #24006: URL: https://github.com/apache/flink/pull/24006#issuecomment-1871167020 @roncohen @is Can you help review this PR in your free time? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-33490) Validate the name conflicts when creating view

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800988#comment-17800988 ] Martijn Visser commented on FLINK-33490: I'm confused about FLINK-33740 - Have we now merged

[jira] [Commented] (FLINK-33740) Introduce a flip to list the supported sql patterns

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800987#comment-17800987 ] Martijn Visser commented on FLINK-33740: [~xuyangzhong] Have we now fixed the ticket without a

[jira] [Commented] (FLINK-33692) FlinkKafkaProducer could miss super.close

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800985#comment-17800985 ] Martijn Visser commented on FLINK-33692: [~tzulitai] Thoughts on this? > FlinkKafkaProducer

[jira] [Assigned] (FLINK-33761) Snowflake as JDBC source

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-33761: -- Assignee: Boris Litvak > Snowflake as JDBC source > > >

Re: [PR] [FLINK-33809] HiveCatalog load hivemetastore-site.xml [flink]

2023-12-28 Thread via GitHub
MartijnVisser commented on PR #23924: URL: https://github.com/apache/flink/pull/23924#issuecomment-1871114914 Given that we're planning to remove the Hive connector from Flink, I think it's best to hold of merging this until that work has completed CC @snuyanzin -- This is an automated

Re: [PR] [FLINK-32175] [chinese-translation] translate doc(datagen.md) into chinese [flink]

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

[jira] [Comment Edited] (FLINK-32175) translate doc(datagen.md) to chinese

2023-12-28 Thread wangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725725#comment-17725725 ] wangliang edited comment on FLINK-32175 at 12/28/23 12:17 PM: -- [~will86]

[jira] [Resolved] (FLINK-32175) translate doc(datagen.md) to chinese

2023-12-28 Thread wangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangliang resolved FLINK-32175. --- Resolution: Fixed > translate doc(datagen.md) to chinese > > >

[PR] [FLINK-32175] [chinese-translation] translate doc(datagen.md) into chinese [flink]

2023-12-28 Thread via GitHub
niliushall opened a new pull request, #24006: URL: https://github.com/apache/flink/pull/24006 jira: https://issues.apache.org/jira/browse/FLINK-32175 **(The sections below can be removed for hotfixes of typos)** --> ## What is the purpose of the change * translate

[jira] [Comment Edited] (FLINK-32175) translate doc(datagen.md) to chinese

2023-12-28 Thread wangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725725#comment-17725725 ] wangliang edited comment on FLINK-32175 at 12/28/23 12:08 PM: -- [~will86]

[jira] [Comment Edited] (FLINK-32175) translate doc(datagen.md) to chinese

2023-12-28 Thread wangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725725#comment-17725725 ] wangliang edited comment on FLINK-32175 at 12/28/23 12:06 PM: -- [~will86]

[jira] [Updated] (FLINK-32175) translate doc(datagen.md) to chinese

2023-12-28 Thread wangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangliang updated FLINK-32175: -- External issue ID: (was: 22636) > translate doc(datagen.md) to chinese >

[jira] [Updated] (FLINK-32175) translate doc(datagen.md) to chinese

2023-12-28 Thread wangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangliang updated FLINK-32175: -- External issue URL: (was: https://github.com/apache/flink/pull/22636) > translate doc(datagen.md)

[jira] [Reopened] (FLINK-32175) translate doc(datagen.md) to chinese

2023-12-28 Thread wangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangliang reopened FLINK-32175: --- > translate doc(datagen.md) to chinese > > > Key:

[jira] [Commented] (FLINK-33855) send flag message like checkpoint barrier

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800975#comment-17800975 ] Martijn Visser commented on FLINK-33855: If you have a user question, please reach out to the

[jira] [Closed] (FLINK-33855) send flag message like checkpoint barrier

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33855. -- Resolution: Invalid > send flag message like checkpoint barrier >

[jira] [Commented] (FLINK-33863) Compressed Operator state restore failed

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800974#comment-17800974 ] Martijn Visser commented on FLINK-33863: Shouldn't this also be backported to 1.18? >

[jira] [Commented] (FLINK-33866) KafkaSinkBuilder in flink-connector-kafka references DeliveryGuarantee in flink-connector-base

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800973#comment-17800973 ] Martijn Visser commented on FLINK-33866: [~tzulitai] WDYT? > KafkaSinkBuilder in

[jira] [Commented] (FLINK-33955) UnsupportedFileSystemException when trying to save data to Azure's abfss File System

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800971#comment-17800971 ] Martijn Visser commented on FLINK-33955: [~alekland] I think this is a duplicate of FLINK-32241,

[jira] [Created] (FLINK-33955) UnsupportedFileSystemException when trying to save data to Azure's abfss File System

2023-12-28 Thread Jira
Alek Łańduch created FLINK-33955: Summary: UnsupportedFileSystemException when trying to save data to Azure's abfss File System Key: FLINK-33955 URL: https://issues.apache.org/jira/browse/FLINK-33955

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

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800969#comment-17800969 ] Martijn Visser commented on FLINK-33933: How about something like: {code:java} @Override public

Re: [PR] Add Pulsar connector v4.1.0 release [flink-web]

2023-12-28 Thread via GitHub
leonardBang closed pull request #703: Add Pulsar connector v4.1.0 release URL: https://github.com/apache/flink-web/pull/703 -- 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-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800963#comment-17800963 ] Martijn Visser commented on FLINK-33949: Let's wait for the holidays to pass in Europe to pass,

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

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800962#comment-17800962 ] Martijn Visser commented on FLINK-33949: [~Wencong Liu] I think this is a Flink specific

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

2023-12-28 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 edited comment on FLINK-33949 at 12/28/23 10:23 AM: ---

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

2023-12-28 Thread via GitHub
1996fanrui commented on PR #24005: URL: https://github.com/apache/flink/pull/24005#issuecomment-1871024583 @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

Re: [PR] [FLINK-33792] Generate the same code for the same logic [flink]

2023-12-28 Thread via GitHub
zoudan commented on PR #23984: URL: https://github.com/apache/flink/pull/23984#issuecomment-1870974216 @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-33459][Connector/JDBC] Support the new source that keeps the same functionality as the original JDBC input format [flink-connector-jdbc]

2023-12-28 Thread via GitHub
RocMarshal commented on PR #78: URL: https://github.com/apache/flink-connector-jdbc/pull/78#issuecomment-1870955620 Hi, @Jiabao-Sun Would you mind helping take a look on this pr ? thank you~ -- This is an automated message from the Apache Git Service. To respond to the message, please

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

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800941#comment-17800941 ] Martijn Visser commented on FLINK-33944: [~vrang...@in.ibm.com] That's documented at

[jira] [Commented] (FLINK-33787) Java 17 support for jdbc connector

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800940#comment-17800940 ] Martijn Visser commented on FLINK-33787: Backported to apache/flink-connector-jdbc:v3.1

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

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33952. -- Assignee: Sergey Nuyanzin Resolution: Fixed > Flink JDBC connector build fail on JDK 17

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

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800939#comment-17800939 ] Martijn Visser commented on FLINK-33952: Fixed by backporting FLINK-33787 to v3.1 > Flink JDBC

[jira] [Updated] (FLINK-33787) Java 17 support for jdbc connector

2023-12-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33787: --- Fix Version/s: jdbc-3.1.2 > Java 17 support for jdbc connector >

Re: [PR] [FLINK-33952][FLINK-33787][jdbc] Java 17 support for jdbc connector [flink-connector-jdbc]

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