[GitHub] [flink] senlizishi closed pull request #19800: [docs]update User-defined Sources & Sinks document

2023-04-06 Thread via GitHub
senlizishi closed pull request #19800: [docs]update User-defined Sources & Sinks document URL: https://github.com/apache/flink/pull/19800 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specifi

[GitHub] [flink] KinoMin commented on pull request #22103: [FLINK-28825] Add K8S pod scheduler into Kubernetes options [FLINK-28829] Support prepreparing K8S resources before JM creation [FLINK-28831]

2023-04-06 Thread via GitHub
KinoMin commented on PR #22103: URL: https://github.com/apache/flink/pull/22103#issuecomment-1499971995 We are still using flink1.12, what should I do for this pr I want to use in 1.12, I try to merge this pr in 1.12, and find that the difference is too big and it is difficult to merge, if

[jira] [Commented] (FLINK-28528) Table.getSchema fails on table with watermark

2023-04-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709597#comment-17709597 ] Dian Fu commented on FLINK-28528: - The exception happens when converting TableSchema to

[jira] [Commented] (FLINK-28528) Table.getSchema fails on table with watermark

2023-04-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709595#comment-17709595 ] Dian Fu commented on FLINK-28528: - The root cause is that currently table.get_schema() o

[jira] [Commented] (FLINK-28528) Table.getSchema fails on table with watermark

2023-04-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709591#comment-17709591 ] Dian Fu commented on FLINK-28528: - A similar issue reported in slack channel: https://a

[GitHub] [flink] nateab commented on a diff in pull request #22359: [FLINK-31660][table] add jayway json path dependency to table-planner

2023-04-06 Thread via GitHub
nateab commented on code in PR #22359: URL: https://github.com/apache/flink/pull/22359#discussion_r1160430061 ## flink-table/flink-table-planner/pom.xml: ## @@ -301,6 +301,13 @@ under the License. ${project.version} test

[jira] [Commented] (FLINK-31628) ArrayIndexOutOfBoundsException in watermark processing

2023-04-06 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709583#comment-17709583 ] Lijie Wang commented on FLINK-31628: This problem may occur when the source configur

[jira] [Comment Edited] (FLINK-31628) ArrayIndexOutOfBoundsException in watermark processing

2023-04-06 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709580#comment-17709580 ] Lijie Wang edited comment on FLINK-31628 at 4/7/23 4:32 AM:

[jira] [Updated] (FLINK-31628) ArrayIndexOutOfBoundsException in watermark processing

2023-04-06 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-31628: --- Fix Version/s: 1.18.0 1.17.1 > ArrayIndexOutOfBoundsException in watermark proces

[jira] [Commented] (FLINK-31628) ArrayIndexOutOfBoundsException in watermark processing

2023-04-06 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709581#comment-17709581 ] Lijie Wang commented on FLINK-31628: We should check if the channel is in the heap b

[jira] [Assigned] (FLINK-31628) ArrayIndexOutOfBoundsException in watermark processing

2023-04-06 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-31628: -- Assignee: Lijie Wang > ArrayIndexOutOfBoundsException in watermark processing > -

[jira] [Commented] (FLINK-31628) ArrayIndexOutOfBoundsException in watermark processing

2023-04-06 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709580#comment-17709580 ] Lijie Wang commented on FLINK-31628: This is caused by FLINK-30544, in which we intr

[jira] [Commented] (FLINK-27925) Avoid to create watcher without the resourceVersion

2023-04-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709578#comment-17709578 ] Weijie Guo commented on FLINK-27925: Hi [~huwh]. AFAIK, This PR is waiting for revi

[jira] [Updated] (FLINK-31447) Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager

2023-04-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31447: --- Fix Version/s: 1.18.0 > Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager >

[jira] [Resolved] (FLINK-31447) Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager

2023-04-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-31447. Resolution: Fixed master(1.18) via 69131d29497fadf5ca55532ff0f7ed55c5e72c73. > Aligning unit test

[jira] [Closed] (FLINK-31447) Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager

2023-04-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31447. -- > Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager >

[jira] [Updated] (FLINK-31447) Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager

2023-04-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31447: --- Affects Version/s: 1.18.0 > Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManage

[GitHub] [flink] reswqa closed pull request #22306: [FLINK-31447][runtime] Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager

2023-04-06 Thread via GitHub
reswqa closed pull request #22306: [FLINK-31447][runtime] Aligning unit tests of FineGrainedSlotManager with DeclarativeSlotManager URL: https://github.com/apache/flink/pull/22306 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[jira] [Commented] (FLINK-27925) Avoid to create watcher without the resourceVersion

2023-04-06 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709567#comment-17709567 ] Weihua Hu commented on FLINK-27925: --- Hi [~ouyangwulin] . Are you still working on this

[GitHub] [flink] haishui126 commented on a diff in pull request #22291: [FLINK-31632] Fix maxAllowedWatermark arithmetic overflow when the source is idle

2023-04-06 Thread via GitHub
haishui126 commented on code in PR #22291: URL: https://github.com/apache/flink/pull/22291#discussion_r1160405755 ## flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java: ## @@ -178,9 +178,16 @@ void announceCombinedWatermark() {

[GitHub] [flink] nateab commented on a diff in pull request #22359: [FLINK-31660][table] add jayway json path dependency to table-planner

2023-04-06 Thread via GitHub
nateab commented on code in PR #22359: URL: https://github.com/apache/flink/pull/22359#discussion_r1160403337 ## flink-table/flink-table-planner/pom.xml: ## @@ -301,6 +301,13 @@ under the License. ${project.version} test

[jira] [Comment Edited] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

2023-04-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708930#comment-17708930 ] Weijie Guo edited comment on FLINK-30989 at 4/7/23 3:05 AM:

[jira] [Closed] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

2023-04-06 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-30989. -- Resolution: Fixed > Configuration table.exec.spill-compression.block-size not take effect in > batch

[GitHub] [flink] pltbkd commented on a diff in pull request #22291: [FLINK-31632] Fix maxAllowedWatermark arithmetic overflow when the source is idle

2023-04-06 Thread via GitHub
pltbkd commented on code in PR #22291: URL: https://github.com/apache/flink/pull/22291#discussion_r1160398514 ## flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java: ## @@ -178,9 +178,16 @@ void announceCombinedWatermark() {

[jira] [Created] (FLINK-31750) Hash Keys are duplicate when join reorder happens in stream mode

2023-04-06 Thread ZhengYi Weng (Jira)
ZhengYi Weng created FLINK-31750: Summary: Hash Keys are duplicate when join reorder happens in stream mode Key: FLINK-31750 URL: https://issues.apache.org/jira/browse/FLINK-31750 Project: Flink

[jira] [Commented] (FLINK-31593) Update reference data for Migration Tests

2023-04-06 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709549#comment-17709549 ] Yanfei Lei commented on FLINK-31593: [~roman] > It was likely generated during chan

[jira] [Updated] (FLINK-31749) The Using Hadoop OutputFormats example is not avaliable for DataStream

2023-04-06 Thread junzhong qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] junzhong qin updated FLINK-31749: - Description: The following example shows how to use Hadoop’s {{TextOutputFormat from the doc:

[GitHub] [flink] nateab commented on a diff in pull request #22359: [FLINK-31660][table] add jayway json path dependency to table-planner

2023-04-06 Thread via GitHub
nateab commented on code in PR #22359: URL: https://github.com/apache/flink/pull/22359#discussion_r1160394865 ## flink-table/flink-table-planner/pom.xml: ## @@ -301,6 +301,13 @@ under the License. ${project.version} test

[jira] [Created] (FLINK-31749) The Using Hadoop OutputFormats example is not avaliable for DataStream

2023-04-06 Thread junzhong qin (Jira)
junzhong qin created FLINK-31749: Summary: The Using Hadoop OutputFormats example is not avaliable for DataStream Key: FLINK-31749 URL: https://issues.apache.org/jira/browse/FLINK-31749 Project: Flink

[GitHub] [flink-ml] jiangxin369 commented on pull request #229: [FLINK-31255] Wraps the operator config about serializer

2023-04-06 Thread via GitHub
jiangxin369 commented on PR #229: URL: https://github.com/apache/flink-ml/pull/229#issuecomment-1499866189 @zhipeng93 Could you help review this PR? And I have no idea why the workflow needs additional approval to run in this PR, could you help approve the workflow running? -- This is a

[jira] [Created] (FLINK-31748) Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar

2023-04-06 Thread Zili Chen (Jira)
Zili Chen created FLINK-31748: - Summary: Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar Key: FLINK-31748 URL: https://issues.apache.org/jira/browse/FLINK-31748 Project: Flink I

[GitHub] [flink] nateab commented on a diff in pull request #22359: [FLINK-31660][table] add jayway json path dependency to table-planner

2023-04-06 Thread via GitHub
nateab commented on code in PR #22359: URL: https://github.com/apache/flink/pull/22359#discussion_r1160388987 ## flink-table/flink-table-planner/pom.xml: ## @@ -301,6 +301,13 @@ under the License. ${project.version} test

[GitHub] [flink] haishui126 commented on a diff in pull request #22291: [FLINK-31632] Fix maxAllowedWatermark arithmetic overflow when the source is idle

2023-04-06 Thread via GitHub
haishui126 commented on code in PR #22291: URL: https://github.com/apache/flink/pull/22291#discussion_r1160388130 ## flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java: ## @@ -178,9 +178,16 @@ void announceCombinedWatermark() {

[GitHub] [flink] flinkbot commented on pull request #22367: [FLINK-27144][runtime] Provide timeout details when calling FutureUtils.orTimeout

2023-04-06 Thread via GitHub
flinkbot commented on PR #22367: URL: https://github.com/apache/flink/pull/22367#issuecomment-1499860845 ## CI report: * 5432ca4507169c8e39f19d7e7aa741002ab7fd7e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27144) Provide timeout details when calling FutureUtils.orTimeout

2023-04-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27144: --- Labels: pull-request-available (was: ) > Provide timeout details when calling FutureUtils.o

[GitHub] [flink] wanglijie95 opened a new pull request, #22367: [FLINK-27144][runtime] Provide timeout details when calling FutureUtils.orTimeout

2023-04-06 Thread via GitHub
wanglijie95 opened a new pull request, #22367: URL: https://github.com/apache/flink/pull/22367 ## What is the purpose of the change Currently, there are two versions of FutureUtils.orTimeout() that use null as an error message when the timeout happens. This makes it difficult to debug

[GitHub] [flink-connector-pulsar] boring-cyborg[bot] commented on pull request #42: [hotfix] Improve CI trigger and cancel strategy

2023-04-06 Thread via GitHub
boring-cyborg[bot] commented on PR #42: URL: https://github.com/apache/flink-connector-pulsar/pull/42#issuecomment-1499824593 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-connector-pulsar] tisonkun merged pull request #42: [hotfix] Improve CI trigger and cancel strategy

2023-04-06 Thread via GitHub
tisonkun merged PR #42: URL: https://github.com/apache/flink-connector-pulsar/pull/42 -- 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...

[GitHub] [flink-connector-pulsar] tisonkun commented on pull request #42: [hotfix] Improve CI trigger and cancel strategy

2023-04-06 Thread via GitHub
tisonkun commented on PR #42: URL: https://github.com/apache/flink-connector-pulsar/pull/42#issuecomment-1499824519 Merging... It seems the daily CI always failed on compilation now. Let me take a look.. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] yangjf2019 commented on pull request #22274: [FLINK-31617] Upgrade the SnakeYaml and fabric8 version

2023-04-06 Thread via GitHub
yangjf2019 commented on PR #22274: URL: https://github.com/apache/flink/pull/22274#issuecomment-1499816668 @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

[GitHub] [flink-connector-kafka] tzulitai closed pull request #16: [FLINK-30859] Externalize confluent avro related code

2023-04-06 Thread via GitHub
tzulitai closed pull request #16: [FLINK-30859] Externalize confluent avro related code URL: https://github.com/apache/flink-connector-kafka/pull/16 -- 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 t

[GitHub] [flink-connector-kafka] tzulitai commented on pull request #9: [FLINK-31559][connector/kafka] Update the flink version to 1.18-SNAPSHOT and drop support for 1.16

2023-04-06 Thread via GitHub
tzulitai commented on PR #9: URL: https://github.com/apache/flink-connector-kafka/pull/9#issuecomment-1499758433 I'm not so sure we should merge this. I believe we want to always develop against the latest stable Flink version, even in `main` branch. For example in `main` right no

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #16: [FLINK-30859] Externalize confluent avro related code

2023-04-06 Thread via GitHub
tzulitai commented on code in PR #16: URL: https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160329477 ## flink-confluent-schema-registry-e2e-tests/pom.xml: ## @@ -0,0 +1,136 @@ + +http://maven.apache.org/POM/4.0.0"; +xmlns:xsi="http://www.w3.

[jira] [Commented] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2023-04-06 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709522#comment-17709522 ] Tzu-Li (Gordon) Tai commented on FLINK-25916: - Merged to apache/flink-connec

[jira] [Updated] (FLINK-25916) Using upsert-kafka with a flush buffer results in Null Pointer Exception

2023-04-06 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-25916: Fix Version/s: kafka-3.0.0 > Using upsert-kafka with a flush buffer results in Nul

[GitHub] [flink-connector-kafka] tzulitai closed pull request #5: [FLINK-25916][connector-kafka] Using upsert-kafka with a flush buffer…

2023-04-06 Thread via GitHub
tzulitai closed pull request #5: [FLINK-25916][connector-kafka] Using upsert-kafka with a flush buffer… URL: https://github.com/apache/flink-connector-kafka/pull/5 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink-connector-kafka] mas-chen commented on a diff in pull request #16: [FLINK-30859] Externalize confluent avro related code

2023-04-06 Thread via GitHub
mas-chen commented on code in PR #16: URL: https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160320646 ## flink-formats-kafka/flink-json-debezium/pom.xml: ## @@ -0,0 +1,141 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSche

[GitHub] [flink-connector-kafka] mas-chen commented on a diff in pull request #16: [FLINK-30859] Externalize confluent avro related code

2023-04-06 Thread via GitHub
mas-chen commented on code in PR #16: URL: https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160320646 ## flink-formats-kafka/flink-json-debezium/pom.xml: ## @@ -0,0 +1,141 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSche

[jira] [Created] (FLINK-31747) Externalize debezium from flink-json

2023-04-06 Thread Mason Chen (Jira)
Mason Chen created FLINK-31747: -- Summary: Externalize debezium from flink-json Key: FLINK-31747 URL: https://issues.apache.org/jira/browse/FLINK-31747 Project: Flink Issue Type: Improvement

[GitHub] [flink-connector-kafka] RamanVerma commented on a diff in pull request #20: [FLINK-29398][connector/kafka] Provide rack ID to Kafka Source to take advantage of Rack Awareness

2023-04-06 Thread via GitHub
RamanVerma commented on code in PR #20: URL: https://github.com/apache/flink-connector-kafka/pull/20#discussion_r1160275482 ## flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java: ## @@ -319,6 +321,51 @@ public v

[GitHub] [flink-connector-kafka] RamanVerma commented on a diff in pull request #20: [FLINK-29398][connector/kafka] Provide rack ID to Kafka Source to take advantage of Rack Awareness

2023-04-06 Thread via GitHub
RamanVerma commented on code in PR #20: URL: https://github.com/apache/flink-connector-kafka/pull/20#discussion_r1160264888 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java: ## @@ -80,11 +80,20 @@ public KafkaP

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #18: [FLINK-31049] [flink-connector-kafka]Add support for Kafka record headers to KafkaSink

2023-04-06 Thread via GitHub
tzulitai commented on code in PR #18: URL: https://github.com/apache/flink-connector-kafka/pull/18#discussion_r1160175017 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/HeaderProducer.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Softwar

[jira] [Commented] (FLINK-31746) Batch workload output completes while the job client fails

2023-04-06 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709484#comment-17709484 ] Martijn Visser commented on FLINK-31746: [~functioner] Please let us know what t

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #16: [FLINK-30859] Externalize confluent avro related code

2023-04-06 Thread via GitHub
tzulitai commented on code in PR #16: URL: https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160139972 ## flink-formats-kafka/flink-json-debezium/pom.xml: ## @@ -0,0 +1,141 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSche

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #16: [FLINK-30859] Externalize confluent avro related code

2023-04-06 Thread via GitHub
tzulitai commented on code in PR #16: URL: https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160139972 ## flink-formats-kafka/flink-json-debezium/pom.xml: ## @@ -0,0 +1,141 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSche

[jira] [Updated] (FLINK-31746) Batch workload output completes while the job client fails

2023-04-06 Thread Haoze Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haoze Wu updated FLINK-31746: - Description: We are doing testing on Flink-1.14.0 (We know 1.14.0 is not supported now so we are also t

[jira] [Created] (FLINK-31746) Batch workload output completes while the job client fails

2023-04-06 Thread Haoze Wu (Jira)
Haoze Wu created FLINK-31746: Summary: Batch workload output completes while the job client fails Key: FLINK-31746 URL: https://issues.apache.org/jira/browse/FLINK-31746 Project: Flink Issue Type

[GitHub] [flink-connector-kafka] zentol commented on a diff in pull request #16: [FLINK-30859] Externalize confluent avro related code

2023-04-06 Thread via GitHub
zentol commented on code in PR #16: URL: https://github.com/apache/flink-connector-kafka/pull/16#discussion_r1160135014 ## flink-formats-kafka/flink-json-debezium/pom.xml: ## @@ -0,0 +1,141 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema

[GitHub] [flink-connector-kafka] tzulitai closed pull request #23: [hotfix] Update NOTICE files to reflect year 2023

2023-04-06 Thread via GitHub
tzulitai closed pull request #23: [hotfix] Update NOTICE files to reflect year 2023 URL: https://github.com/apache/flink-connector-kafka/pull/23 -- 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 s

[GitHub] [flink] HuangZhenQiu commented on a diff in pull request #22298: [FLINK-31656][runtime][security] Obtain delegation tokens early to support external file system usage in HA services

2023-04-06 Thread via GitHub
HuangZhenQiu commented on code in PR #22298: URL: https://github.com/apache/flink/pull/22298#discussion_r1160103711 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/DefaultDelegationTokenManager.java: ## @@ -213,6 +213,20 @@ public void obtainDelegationTok

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #16: [hotfix] Fix nightly build for 1.18-SNAPSHOT, drop 1.16-SNAPSHOT from the nightly matrix

2023-04-06 Thread via GitHub
reta commented on code in PR #16: URL: https://github.com/apache/flink-connector-opensearch/pull/16#discussion_r1160093049 ## .github/workflows/weekly.yml: ## @@ -26,7 +26,7 @@ jobs: if: github.repository_owner == 'apache' strategy: matrix: -flink: [1.1

[jira] [Assigned] (FLINK-31717) Unit tests running with local kube config

2023-04-06 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-31717: -- Assignee: Mate Czagany (was: Matyas Orhidi) > Unit tests running with local kube con

[GitHub] [flink] flinkbot commented on pull request #22366: [FLINK-31702][Connectors/Opensearch][docs] Integrate Opensearch docs …

2023-04-06 Thread via GitHub
flinkbot commented on PR #22366: URL: https://github.com/apache/flink/pull/22366#issuecomment-1499317476 ## CI report: * af31921182b351ba1a50629f82f998933f1aa427 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #22365: [FLINK-31702][Connectors/Opensearch][docs] Integrate Opensearch docs …

2023-04-06 Thread via GitHub
flinkbot commented on PR #22365: URL: https://github.com/apache/flink/pull/22365#issuecomment-1499317260 ## CI report: * c11af68e7aa448a62ef168c075fcdb72a597541e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] darenwkt commented on pull request #22366: [FLINK-31702][Connectors/Opensearch][docs] Integrate Opensearch docs …

2023-04-06 Thread via GitHub
darenwkt commented on PR #22366: URL: https://github.com/apache/flink/pull/22366#issuecomment-1499316939 ![Screenshot 2023-04-06 at 17-18-12 下载页面](https://user-images.githubusercontent.com/108749182/230438101-da203605-72c2-48c1-b25c-673e364af3c6.png) ![Screenshot 2023-04-06 at 17-17-56 D

[GitHub] [flink] darenwkt opened a new pull request, #22366: [FLINK-31702][Connectors/Opensearch][docs] Integrate Opensearch docs …

2023-04-06 Thread via GitHub
darenwkt opened a new pull request, #22366: URL: https://github.com/apache/flink/pull/22366 …into Flink docs ## What is the purpose of the change Integrate Opensearch docs into Flink docs for Flink master branch ## Brief change log - See comment for pages c

[GitHub] [flink] darenwkt commented on pull request #22365: [FLINK-31702][Connectors/Opensearch][docs] Integrate Opensearch docs …

2023-04-06 Thread via GitHub
darenwkt commented on PR #22365: URL: https://github.com/apache/flink/pull/22365#issuecomment-1499309235 ![Screenshot 2023-04-06 at 17-11-02 下载页面](https://user-images.githubusercontent.com/108749182/230436571-55fe1951-60cc-4950-b1e4-1931f9504f9a.png) ![Screenshot 2023-04-06 at 17-10-29 D

[GitHub] [flink] darenwkt opened a new pull request, #22365: [FLINK-31702][Connectors/Opensearch][docs] Integrate Opensearch docs …

2023-04-06 Thread via GitHub
darenwkt opened a new pull request, #22365: URL: https://github.com/apache/flink/pull/22365 …into Flink docs ## What is the purpose of the change Integrate Opensearch docs into Flink docs for Flink 1.16 ## Brief change log - See comment for pages changed

[jira] [Commented] (FLINK-31740) Allow setting boundedness for upsert-kafka SQL connector

2023-04-06 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709440#comment-17709440 ] Tzu-Li (Gordon) Tai commented on FLINK-31740: - Fix via fc31198d864ebafd36cf2

[jira] [Updated] (FLINK-31740) Allow setting boundedness for upsert-kafka SQL connector

2023-04-06 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-31740: Fix Version/s: kafka-4.1.0 > Allow setting boundedness for upsert-kafka SQL connec

[GitHub] [flink-connector-kafka] tzulitai closed pull request #22: [FLINK-31740] [upsert-kafka] Allows setting boundedness for SQL Upsert Kafka Connector

2023-04-06 Thread via GitHub
tzulitai closed pull request #22: [FLINK-31740] [upsert-kafka] Allows setting boundedness for SQL Upsert Kafka Connector URL: https://github.com/apache/flink-connector-kafka/pull/22 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink-connector-kafka] tzulitai commented on pull request #22: [FLINK-31740] [upsert-kafka] Allows setting boundedness for SQL Upsert Kafka Connector

2023-04-06 Thread via GitHub
tzulitai commented on PR #22: URL: https://github.com/apache/flink-connector-kafka/pull/22#issuecomment-1499280862 Thank you for the review @Ge @dawidwys! Merging this ... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[jira] [Closed] (FLINK-31735) JobDetailsInfo plan incorrectly documented as string

2023-04-06 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-31735. Resolution: Fixed master: 8ee66535879ce90882f0320b0c0d8ab7ef44ed37 1.17: a70554b51a4f73527

[GitHub] [flink] zentol merged pull request #22357: [FLINK-31735][docs] Document 'plan' field as object

2023-04-06 Thread via GitHub
zentol merged PR #22357: URL: https://github.com/apache/flink/pull/22357 -- 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] [Commented] (FLINK-30844) TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM shutdown with exit code 239

2023-04-06 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709423#comment-17709423 ] Anton Kalashnikov commented on FLINK-30844: --- In conclusion, I haven't found an

[jira] [Closed] (FLINK-30844) TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM shutdown with exit code 239

2023-04-06 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov closed FLINK-30844. - Resolution: Fixed > TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM s

[GitHub] [flink-connector-opensearch] MartijnVisser commented on a diff in pull request #16: [hotfix] Fix nightly build for 1.18-SNAPSHOT, drop 1.16-SNAPSHOT from the nightly matrix

2023-04-06 Thread via GitHub
MartijnVisser commented on code in PR #16: URL: https://github.com/apache/flink-connector-opensearch/pull/16#discussion_r1159923772 ## .github/workflows/weekly.yml: ## @@ -26,7 +26,7 @@ jobs: if: github.repository_owner == 'apache' strategy: matrix: -fl

[jira] [Closed] (FLINK-31733) Model name clashes in OpenAPI spec

2023-04-06 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-31733. Resolution: Fixed master: 76d1a4678c383a927caf596ee594ba0ae5b5e1df dcca520cb47a22354301174

[jira] [Updated] (FLINK-30844) TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a JVM shutdown with exit code 239

2023-04-06 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-30844: -- Fix Version/s: 1.17.1 > TaskTest.testInterruptibleSharedLockInInvokeAndCancel causes a

[GitHub] [flink] akalash merged pull request #22354: [FLINK-30844][runtime] Increased TASK_CANCELLATION_TIMEOUT for testInterruptibleSharedLockInInvokeAndCancel

2023-04-06 Thread via GitHub
akalash merged PR #22354: URL: https://github.com/apache/flink/pull/22354 -- 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.apach

[GitHub] [flink] zentol merged pull request #22355: [FLINK-31733][docs] Fix/Detect OpenAPI model name clashes

2023-04-06 Thread via GitHub
zentol merged PR #22355: URL: https://github.com/apache/flink/pull/22355 -- 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

[GitHub] [flink-connector-opensearch] reta commented on a diff in pull request #16: [hotfix] Fix nightly build for 1.18-SNAPSHOT, drop 1.16-SNAPSHOT from the nightly matrix

2023-04-06 Thread via GitHub
reta commented on code in PR #16: URL: https://github.com/apache/flink-connector-opensearch/pull/16#discussion_r1159891707 ## .github/workflows/weekly.yml: ## @@ -26,7 +26,7 @@ jobs: if: github.repository_owner == 'apache' strategy: matrix: -flink: [1.1

[jira] [Updated] (FLINK-31722) Remove dependency on flink-shaded

2023-04-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31722: --- Labels: pull-request-available (was: ) > Remove dependency on flink-shaded > --

[GitHub] [flink-connector-cassandra] echauchot opened a new pull request, #7: [FLINK-31722] use cassandra driver provided guava and shade provided guava

2023-04-06 Thread via GitHub
echauchot opened a new pull request, #7: URL: https://github.com/apache/flink-connector-cassandra/pull/7 R: @zentol -- 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 unsu

[jira] [Commented] (FLINK-31593) Update reference data for Migration Tests

2023-04-06 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709396#comment-17709396 ] Matthias Pohl commented on FLINK-31593: --- [~Yanfei Lei] Roman has a point with temp

[GitHub] [flink-connector-elasticsearch] MartijnVisser commented on pull request #57: [FLINK-31739][ci] Reuse ci.yml in flink-connector-shared-utils.

2023-04-06 Thread via GitHub
MartijnVisser commented on PR #57: URL: https://github.com/apache/flink-connector-elasticsearch/pull/57#issuecomment-1499113198 > Thanks @MartijnVisser for the sync~ Thank you for the PR! -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Closed] (FLINK-31739) ElasticSearch and Cassandra connector v3.0 branch's CI is not working properly

2023-04-06 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31739. -- Resolution: Fixed Elasticsearch v3.0: 57e7883e270b1e3d5814bf52e808ce6099e45481 Cassandra v3.0:

[GitHub] [flink-connector-elasticsearch] MartijnVisser merged pull request #57: [FLINK-31739][ci] Reuse ci.yml in flink-connector-shared-utils.

2023-04-06 Thread via GitHub
MartijnVisser merged PR #57: URL: https://github.com/apache/flink-connector-elasticsearch/pull/57 -- 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

[jira] [Created] (FLINK-31745) Performance regression on serializerHeavyString since April 3rd

2023-04-06 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-31745: -- Summary: Performance regression on serializerHeavyString since April 3rd Key: FLINK-31745 URL: https://issues.apache.org/jira/browse/FLINK-31745 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #22364: [FLINK-31744] Include JobVertex info in sparse EG

2023-04-06 Thread via GitHub
flinkbot commented on PR #22364: URL: https://github.com/apache/flink/pull/22364#issuecomment-1499063492 ## CI report: * 6109c840dde0f7a435d5076081c651d901272704 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-web] mendansandesh opened a new pull request, #629: English sentence correction

2023-04-06 Thread via GitHub
mendansandesh opened a new pull request, #629: URL: https://github.com/apache/flink-web/pull/629 - removed duplicate word - some english grammar/formatting fix -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-31744) Extend Adaptive Scheduler sparse EG to contain maxParallelism

2023-04-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31744: --- Labels: pull-request-available (was: ) > Extend Adaptive Scheduler sparse EG to contain max

[GitHub] [flink-connector-elasticsearch] reswqa commented on pull request #57: [FLINK-31739][ci] Reuse ci.yml in flink-connector-shared-utils.

2023-04-06 Thread via GitHub
reswqa commented on PR #57: URL: https://github.com/apache/flink-connector-elasticsearch/pull/57#issuecomment-1499055091 Thanks @MartijnVisser for the sync~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[GitHub] [flink] zentol opened a new pull request, #22364: [FLINK-31744] Include JobVertex info in sparse EG

2023-04-06 Thread via GitHub
zentol opened a new pull request, #22364: URL: https://github.com/apache/flink/pull/22364 Include all JobVertex-level information in the sparse execution graph, created by the Adaptive Scheduler when in the WaitingForResources state, like the vertex id/name and the maxParallelism. Th

[jira] [Created] (FLINK-31744) Extend Adaptive Scheduler sparse EG to contain maxParallelism

2023-04-06 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-31744: Summary: Extend Adaptive Scheduler sparse EG to contain maxParallelism Key: FLINK-31744 URL: https://issues.apache.org/jira/browse/FLINK-31744 Project: Flink

[jira] [Closed] (FLINK-31728) Remove Scala API dependencies from batch/streaming examples

2023-04-06 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-31728. Resolution: Fixed master: 0415f7d1f9f32f93cbafa1000f1a33d66b06e1d1 > Remove Scala API dep

[GitHub] [flink] zentol merged pull request #22349: [FLINK-31728][examples] Remove scala api dependency

2023-04-06 Thread via GitHub
zentol merged PR #22349: URL: https://github.com/apache/flink/pull/22349 -- 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] [Commented] (FLINK-31233) no error should be logged when retrieving the task manager's stdout if it does not exist

2023-04-06 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709369#comment-17709369 ] Weihua Hu commented on FLINK-31233: --- [~xtsong] Could you take a look at this > no err

[jira] [Commented] (FLINK-31529) Let yarn client exit early before JobManager running

2023-04-06 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17709367#comment-17709367 ] Weihua Hu commented on FLINK-31529: --- [~xtsong] Could you take a look at this > Let ya

[GitHub] [flink-connector-cassandra] boring-cyborg[bot] commented on pull request #6: [FLINK-31739][ci] Reuse ci.yml in flink-connector-shared-utils.

2023-04-06 Thread via GitHub
boring-cyborg[bot] commented on PR #6: URL: https://github.com/apache/flink-connector-cassandra/pull/6#issuecomment-1499006407 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log o

  1   2   >