[GitHub] [flink] wanglijie95 commented on a diff in pull request #20153: [FLINK-28144][runtime] Let JobMaster support blocklist.

wanglijie95 commented on code in PR #20153: URL: https://github.com/apache/flink/pull/20153#discussion_r917595775 ## flink-runtime/src/main/java/org/apache/flink/runtime/blocklist/BlocklistHandler.java: ## @@ -64,4 +68,23 @@ public interface BlocklistHandler { * @param blo

[GitHub] [flink] wanglijie95 commented on a diff in pull request #20153: [FLINK-28144][runtime] Let JobMaster support blocklist.

wanglijie95 commented on code in PR #20153: URL: https://github.com/apache/flink/pull/20153#discussion_r917595351 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolServiceTest.java: ## @@ -230,14 +228,13 @@ public void testCreateAlloca

[GitHub] [flink] wanglijie95 commented on a diff in pull request #20153: [FLINK-28144][runtime] Let JobMaster support blocklist.

wanglijie95 commented on code in PR #20153: URL: https://github.com/apache/flink/pull/20153#discussion_r917594508 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java: ## @@ -1384,8 +1374,9 @@ public void testRequestPartitionState() throws Excepti

[GitHub] [flink] wanglijie95 commented on a diff in pull request #20153: [FLINK-28144][runtime] Let JobMaster support blocklist.

wanglijie95 commented on code in PR #20153: URL: https://github.com/apache/flink/pull/20153#discussion_r917593936 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java: ## @@ -959,20 +951,20 @@ public void testReconnectionAfterDisconnect() throws

[jira] [Commented] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

[ https://issues.apache.org/jira/browse/FLINK-28227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564807#comment-17564807 ] Martijn Visser commented on FLINK-28227: [~Leo Zhou] I've assigned it to you >

[jira] [Assigned] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

[ https://issues.apache.org/jira/browse/FLINK-28227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-28227: -- Assignee: zhouli > Add implementations for classes in o.a.f.streaming.examples based

[GitHub] [flink] MartijnVisser commented on pull request #20205: [FLINK-28250][Connector/Kafka] Fix exactly-once Kafka Sink out of memory

MartijnVisser commented on PR #20205: URL: https://github.com/apache/flink/pull/20205#issuecomment-1180026255 @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 comm

[jira] [Created] (FLINK-28483) Basic schema evolution for table store

Jingsong Lee created FLINK-28483: Summary: Basic schema evolution for table store Key: FLINK-28483 URL: https://issues.apache.org/jira/browse/FLINK-28483 Project: Flink Issue Type: New Featur

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #307: [FLINK-28187] Handle SessionJob errors on observe

Aitozi commented on code in PR #307: URL: https://github.com/apache/flink-kubernetes-operator/pull/307#discussion_r917582951 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/sessionjob/SessionJobObserver.java: ## @@ -115,4 +131,62 @@ publ

[jira] [Created] (FLINK-28482) num-sorted-run.stop-trigger introduced a unstable merging

Jingsong Lee created FLINK-28482: Summary: num-sorted-run.stop-trigger introduced a unstable merging Key: FLINK-28482 URL: https://issues.apache.org/jira/browse/FLINK-28482 Project: Flink Iss

[jira] [Commented] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564802#comment-17564802 ] Martijn Visser commented on FLINK-27916: [~thw] Could you have a look? > Hybri

[GitHub] [flink] flinkbot commented on pull request #20239: [FLINK-27703][core] Extend timeout and add logs for FileChannelManagerImplTest

flinkbot commented on PR #20239: URL: https://github.com/apache/flink/pull/20239#issuecomment-117569 ## CI report: * ddced8360225f615303f78ead910797e090db3d1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27703: --- Labels: pull-request-available test-stability (was: test-stability) > FileChannelManagerImp

[GitHub] [flink] gaoyunhaii opened a new pull request, #20239: [FLINK-27703][core] Extend timeout and add logs for FileChannelManagerImplTest

gaoyunhaii opened a new pull request, #20239: URL: https://github.com/apache/flink/pull/20239 ## What is the purpose of the change This PR extends the timeout and add some logs to help debugging the reason that file creation is delayed. ## Verifying this change This

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564796#comment-17564796 ] Yun Gao commented on FLINK-27703: - Hi [~hxbks2ks] it seems to me that the file creation

[GitHub] [flink-kubernetes-operator] bgeng777 commented on pull request #306: [FLINK-28364] Add Python Job example using Kubernetes Operator

bgeng777 commented on PR #306: URL: https://github.com/apache/flink-kubernetes-operator/pull/306#issuecomment-1179995677 @wangyang0918 thanks for the review and your comments are addressed in 38dcf032f4470c2aa349804e797657c4b16b78b1. PTAL -- This is an automated message from the Apache G

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #306: [FLINK-28364] Add Python Job example using Kubernetes Operator

bgeng777 commented on code in PR #306: URL: https://github.com/apache/flink-kubernetes-operator/pull/306#discussion_r917557463 ## examples/flink-python-example/README.md: ## @@ -0,0 +1,83 @@ + + +# Flink Kubernetes Operator Python Example + +## Overview + +This is an end-to-end

[GitHub] [flink-kubernetes-operator] SteNicholas commented on a diff in pull request #306: [FLINK-28364] Add Python Job example using Kubernetes Operator

SteNicholas commented on code in PR #306: URL: https://github.com/apache/flink-kubernetes-operator/pull/306#discussion_r917553854 ## examples/flink-python-example/README.md: ## @@ -0,0 +1,83 @@ + + +# Flink Kubernetes Operator Python Example + +## Overview + +This is an end-to-

[GitHub] [flink-kubernetes-operator] SteNicholas commented on a diff in pull request #306: [FLINK-28364] Add Python Job example using Kubernetes Operator

SteNicholas commented on code in PR #306: URL: https://github.com/apache/flink-kubernetes-operator/pull/306#discussion_r917553854 ## examples/flink-python-example/README.md: ## @@ -0,0 +1,83 @@ + + +# Flink Kubernetes Operator Python Example + +## Overview + +This is an end-to-

[GitHub] [flink] Aitozi commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

Aitozi commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r917544164 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java: ## @@ -504,8 +522,11 @@ private void checkResourceRequire

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #307: [FLINK-28187] Handle SessionJob errors on observe

gyfora commented on code in PR #307: URL: https://github.com/apache/flink-kubernetes-operator/pull/307#discussion_r917540203 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/sessionjob/SessionJobObserver.java: ## @@ -115,4 +131,62 @@ publ

[GitHub] [flink] masteryhx commented on pull request #19701: [FLINK-24786][state] Introduce and expose RocksDB statistics as metrics

masteryhx commented on PR #19701: URL: https://github.com/apache/flink/pull/19701#issuecomment-1179957769 LGTM -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscrib

[GitHub] [flink] libenchao commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

libenchao commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r917464697 ## flink-formats/flink-protobuf/pom.xml: ## @@ -0,0 +1,123 @@ + + +http://maven.apache.org/POM/4.0.0"; +xmlns:xsi="http://www.w3.org/2001/XMLSchema-ins

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a diff in pull request #306: [FLINK-28364] Add Python Job example using Kubernetes Operator

wangyang0918 commented on code in PR #306: URL: https://github.com/apache/flink-kubernetes-operator/pull/306#discussion_r917506830 ## examples/flink-python-example/Dockerfile: ## @@ -0,0 +1,43 @@ +

[GitHub] [flink] libenchao commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

libenchao commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r917351320 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbFormatConfig.java: ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [flink] lsyldliu commented on a diff in pull request #20001: [FLINK-27659][table] Planner support to use jar which is registered by 'CREATE FUNTION USING JAR' syntax

lsyldliu commented on code in PR #20001: URL: https://github.com/apache/flink/pull/20001#discussion_r917526758 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FunctionDefinitionFactory.java: ## @@ -34,4 +35,29 @@ public interface FunctionDefiniti

[GitHub] [flink] lsyldliu commented on a diff in pull request #20001: [FLINK-27659][table] Planner support to use jar which is registered by 'CREATE FUNTION USING JAR' syntax

lsyldliu commented on code in PR #20001: URL: https://github.com/apache/flink/pull/20001#discussion_r917526478 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FunctionDefinitionFactory.java: ## @@ -34,4 +35,29 @@ public interface FunctionDefiniti

[GitHub] [flink] KarmaGYZ commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

KarmaGYZ commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r917525860 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java: ## @@ -504,8 +522,11 @@ private void checkResourceRequi

[GitHub] [flink] KarmaGYZ commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

KarmaGYZ commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r917525528 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java: ## @@ -504,8 +522,11 @@ private void checkResourceRequi

[jira] [Closed] (FLINK-28065) A never reached code in ProcessMemoryUtils Class

[ https://issues.apache.org/jira/browse/FLINK-28065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28065. Resolution: Won't Fix > A never reached code in ProcessMemoryUtils Class > ---

[GitHub] [flink] xintongsong closed pull request #19991: [FLINK-28065][Runtime/Configuration] Fix a never reached code in ProcessMemoryUtils Class

xintongsong closed pull request #19991: [FLINK-28065][Runtime/Configuration] Fix a never reached code in ProcessMemoryUtils Class URL: https://github.com/apache/flink/pull/19991 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-27708) Add background compaction task for append-only table when ingesting.

[ https://issues.apache.org/jira/browse/FLINK-27708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27708. Resolution: Fixed master: 9f760307f9da361ddb4ee786a9f3ab1651db149c > Add background compaction ta

[GitHub] [flink-table-store] JingsongLi merged pull request #182: [FLINK-27708] Add background compaction task for append-only table when ingesting

JingsongLi merged PR #182: URL: https://github.com/apache/flink-table-store/pull/182 -- 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] Aitozi commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

Aitozi commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r917521227 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java: ## @@ -504,8 +522,11 @@ private void checkResourceRequire

[GitHub] [flink] yangjunhan commented on pull request #20212: [FLINK-28314][runtime-web] introduce "Cluster Environment" tab under history server

yangjunhan commented on PR #20212: URL: https://github.com/apache/flink/pull/20212#issuecomment-1179933831 @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] [Closed] (FLINK-28477) Support to scan the history server dir with max depth

[ https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-28477. -- Resolution: Won't Fix > Support to scan the history server dir with max depth > --

[jira] [Commented] (FLINK-28477) Support to scan the history server dir with max depth

[ https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564777#comment-17564777 ] Aitozi commented on FLINK-28477: Got it, closed. > Support to scan the history server d

[GitHub] [flink] X-czh commented on pull request #20232: [FLINK-25371] Include data port as part of the host info for subtask detail panel on Web UI

X-czh commented on PR #20232: URL: https://github.com/apache/flink/pull/20232#issuecomment-1179928667 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[GitHub] [flink] KarmaGYZ commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

KarmaGYZ commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r917515028 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java: ## @@ -504,8 +522,11 @@ private void checkResourceRequi

[GitHub] [flink] 1996fanrui commented on pull request #19781: Just for test : output buffer aligned to uc

1996fanrui commented on PR #19781: URL: https://github.com/apache/flink/pull/19781#issuecomment-1179922313 @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] Aitozi commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

Aitozi commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r917512143 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java: ## @@ -504,8 +522,11 @@ private void checkResourceRequire

[jira] [Commented] (FLINK-27357) In Flink HA Service on K8S, Web UI External Service should point to elected Job Manager leader's IP

[ https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564774#comment-17564774 ] Yang Wang commented on FLINK-27357: --- If we mount a shared persist volume for all the J

[jira] [Commented] (FLINK-28390) Allows RocksDB to configure FIFO Compaction to reduce CPU overhead.

[ https://issues.apache.org/jira/browse/FLINK-28390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564772#comment-17564772 ] Zhanghao Chen commented on FLINK-28390: --- Option "state.backend.rocksdb.compaction.

[GitHub] [flink] 1996fanrui commented on pull request #20214: [FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

1996fanrui commented on PR #20214: URL: https://github.com/apache/flink/pull/20214#issuecomment-1179909721 Hi @PatrickRen , I have submitted #20237 and #20238 to back port this PR to 1.14 and 1.15. 1.15 is the same as this PR. 1.14 don't have KafkaSource Chinese doc, so the PR of

[GitHub] [flink] flinkbot commented on pull request #20238: [BP-1.15][FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

flinkbot commented on PR #20238: URL: https://github.com/apache/flink/pull/20238#issuecomment-1179909060 ## CI report: * a26550fdc809e3068e4fd02edf2c916314b0d42d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zhuzhurk commented on pull request #20222: [FLINK-28137] Introduce SpeculativeScheduler

zhuzhurk commented on PR #20222: URL: https://github.com/apache/flink/pull/20222#issuecomment-1179908830 @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] flinkbot commented on pull request #20237: [BP-1.14][FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

flinkbot commented on PR #20237: URL: https://github.com/apache/flink/pull/20237#issuecomment-1179908784 ## CI report: * 90d4bcb3c9f24c9f27eee4a00159f35e6f8bc98a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-28390) Allows RocksDB to configure FIFO Compaction to reduce CPU overhead.

[ https://issues.apache.org/jira/browse/FLINK-28390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564770#comment-17564770 ] Hangxiang Yu commented on FLINK-28390: -- Hi, [~Ming Li] . I have also seen some user

[GitHub] [flink] 1996fanrui opened a new pull request, #20238: [BP-1.15][FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

1996fanrui opened a new pull request, #20238: URL: https://github.com/apache/flink/pull/20238 Back port of #20214 -- 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 unsubs

[GitHub] [flink] 1996fanrui opened a new pull request, #20237: [BP-1.14][FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

1996fanrui opened a new pull request, #20237: URL: https://github.com/apache/flink/pull/20237 Back port of #20214 -- 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 unsubs

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #207: [FLINK-28456] Document streaming query page

JingsongLi commented on code in PR #207: URL: https://github.com/apache/flink-table-store/pull/207#discussion_r917503762 ## docs/content/docs/development/streaming-query.md: ## @@ -0,0 +1,115 @@ +--- +title: "Streaming Query" +weight: 5 +type: docs +aliases: +- /development/stre

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #306: [FLINK-28364] Add Python Job example using Kubernetes Operator

bgeng777 commented on code in PR #306: URL: https://github.com/apache/flink-kubernetes-operator/pull/306#discussion_r917503186 ## examples/flink-python-example/README.md: ## @@ -0,0 +1,83 @@ + + +# Flink Kubernetes Operator Python Example + +## Overview + +This is an end-to-end

[GitHub] [flink] xintongsong commented on a diff in pull request #19108: [FLINK-26675][runtime] Parallelized heavy serialization in StreamingJ…

xintongsong commented on code in PR #19108: URL: https://github.com/apache/flink/pull/19108#discussion_r917502613 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java: ## @@ -132,6 +136,12 @@ public class StreamConfig implements Serializab

[jira] [Created] (FLINK-28481) Bump the fabric8 kubernetes-client to 5.12.3

Yang Wang created FLINK-28481: - Summary: Bump the fabric8 kubernetes-client to 5.12.3 Key: FLINK-28481 URL: https://issues.apache.org/jira/browse/FLINK-28481 Project: Flink Issue Type: Bug

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #207: [FLINK-28456] Document streaming query page

JingsongLi commented on code in PR #207: URL: https://github.com/apache/flink-table-store/pull/207#discussion_r917501482 ## docs/content/docs/development/query-table.md: ## @@ -26,49 +26,67 @@ under the License. # Query Table -The Table Store is streaming batch unified, you

[GitHub] [flink] KarmaGYZ commented on a diff in pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

KarmaGYZ commented on code in PR #19840: URL: https://github.com/apache/flink/pull/19840#discussion_r917500734 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java: ## @@ -504,8 +522,11 @@ private void checkResourceRequi

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #207: [FLINK-28456] Document streaming query page

JingsongLi commented on code in PR #207: URL: https://github.com/apache/flink-table-store/pull/207#discussion_r917500198 ## docs/content/docs/development/query-table.md: ## @@ -26,49 +26,67 @@ under the License. # Query Table -The Table Store is streaming batch unified, you

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #207: [FLINK-28456] Document streaming query page

JingsongLi commented on code in PR #207: URL: https://github.com/apache/flink-table-store/pull/207#discussion_r917500198 ## docs/content/docs/development/query-table.md: ## @@ -26,49 +26,67 @@ under the License. # Query Table -The Table Store is streaming batch unified, you

[GitHub] [flink] 1996fanrui commented on pull request #20214: [FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

1996fanrui commented on PR #20214: URL: https://github.com/apache/flink/pull/20214#issuecomment-1179899413 > @1996fanrui Merged to master. Also could you back port the commit to 1.14 and 1.15? Thanks for your review, I will do it now. -- This is an automated message from the Apache

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564766#comment-17564766 ] Huang Xingbo commented on FLINK-27703: -- HI [~gaoyunhaii], any updates on this issue

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #207: [FLINK-28456] Document streaming query page

JingsongLi commented on code in PR #207: URL: https://github.com/apache/flink-table-store/pull/207#discussion_r917499833 ## docs/content/docs/development/query-table.md: ## @@ -26,49 +26,67 @@ under the License. # Query Table -The Table Store is streaming batch unified, you

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564765#comment-17564765 ] Huang Xingbo commented on FLINK-27703: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #306: [FLINK-28364] Add Python Job example using Kubernetes Operator

bgeng777 commented on code in PR #306: URL: https://github.com/apache/flink-kubernetes-operator/pull/306#discussion_r917499478 ## examples/flink-python-example/Dockerfile: ## @@ -0,0 +1,41 @@ + +#

[jira] [Updated] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-27916: - Priority: Critical (was: Major) > HybridSourceReaderTest.testReader failed with AssertionError

[jira] [Commented] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564764#comment-17564764 ] Huang Xingbo commented on FLINK-27916: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink-table-store] JingsongLi commented on pull request #182: [FLINK-27708] Add background compaction task for append-only table when ingesting

JingsongLi commented on PR #182: URL: https://github.com/apache/flink-table-store/pull/182#issuecomment-1179898114 Looks very good~ Left two minor comments. -- 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-table-store] JingsongLi commented on a diff in pull request #182: [FLINK-27708] Add background compaction task for append-only table when ingesting

JingsongLi commented on code in PR #182: URL: https://github.com/apache/flink-table-store/pull/182#discussion_r917496474 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/data/AppendOnlyWriter.java: ## @@ -93,21 +109,30 @@ public void write(RowData rowDat

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564762#comment-17564762 ] Huang Xingbo commented on FLINK-27703: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] luoyuxia commented on a diff in pull request #20001: [FLINK-27659][table] Planner support to use jar which is registered by 'CREATE FUNTION USING JAR' syntax

luoyuxia commented on code in PR #20001: URL: https://github.com/apache/flink/pull/20001#discussion_r917498564 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FunctionDefinitionFactory.java: ## @@ -34,4 +35,29 @@ public interface FunctionDefiniti

[jira] [Commented] (FLINK-28453) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

[ https://issues.apache.org/jira/browse/FLINK-28453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564759#comment-17564759 ] Huang Xingbo commented on FLINK-28453: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-28453) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

[ https://issues.apache.org/jira/browse/FLINK-28453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28453: - Priority: Critical (was: Major) > KafkaSourceLegacyITCase.testBrokerFailure hang on azure > ---

[jira] [Commented] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

[ https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564758#comment-17564758 ] Huang Xingbo commented on FLINK-28177: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564757#comment-17564757 ] Huang Xingbo commented on FLINK-27703: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-28199) Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564756#comment-17564756 ] Huang Xingbo commented on FLINK-28199: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] fredia commented on a diff in pull request #20160: [FLINK-28286][state] move 'enablechangelog' constant to flink-core module

fredia commented on code in PR #20160: URL: https://github.com/apache/flink/pull/20160#discussion_r915792964 ## flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java: ## @@ -138,6 +139,8 @@ public class ExecutionConfig implements Serializable, Archiveable

[jira] [Commented] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564755#comment-17564755 ] Huang Xingbo commented on FLINK-26721: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] luoyuxia commented on a diff in pull request #20001: [FLINK-27659][table] Planner support to use jar which is registered by 'CREATE FUNTION USING JAR' syntax

luoyuxia commented on code in PR #20001: URL: https://github.com/apache/flink/pull/20001#discussion_r917495970 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FunctionDefinitionFactory.java: ## @@ -34,4 +35,29 @@ public interface FunctionDefiniti

[GitHub] [flink] yangjunhan commented on a diff in pull request #20212: [FLINK-28314][runtime-web] introduce "Cluster Environment" tab under history server

yangjunhan commented on code in PR #20212: URL: https://github.com/apache/flink/pull/20212#discussion_r91749 ## flink-runtime-web/web-dashboard/src/app/app.component.html: ## @@ -58,29 +58,31 @@ Apache Flink Dashboard - - -

[GitHub] [flink] yangjunhan commented on a diff in pull request #20212: [FLINK-28314][runtime-web] introduce "Cluster Environment" tab under history server

yangjunhan commented on code in PR #20212: URL: https://github.com/apache/flink/pull/20212#discussion_r91749 ## flink-runtime-web/web-dashboard/src/app/app.component.html: ## @@ -58,29 +58,31 @@ Apache Flink Dashboard - - -

[jira] [Commented] (FLINK-28477) Support to scan the history server dir with max depth

[ https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564754#comment-17564754 ] Xintong Song commented on FLINK-28477: -- -1 to this change. At the cost of complexi

[jira] [Updated] (FLINK-28471) Translate hive_read_write.md into Chinese

[ https://issues.apache.org/jira/browse/FLINK-28471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28471: - Component/s: Connectors / Hive > Translate hive_read_write.md into Chinese > ---

[jira] [Commented] (FLINK-28250) exactly-once sink kafka cause out of memory

[ https://issues.apache.org/jira/browse/FLINK-28250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564753#comment-17564753 ] Qingsheng Ren commented on FLINK-28250: --- Thanks for the contribution [~charles-tan

[jira] [Assigned] (FLINK-28250) exactly-once sink kafka cause out of memory

[ https://issues.apache.org/jira/browse/FLINK-28250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-28250: - Assignee: Chalres Tan > exactly-once sink kafka cause out of memory > -

[jira] [Commented] (FLINK-28454) Fix the wrong timestamp example of KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-28454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564751#comment-17564751 ] Qingsheng Ren commented on FLINK-28454: --- Merged to master: ce56e01aeaa6ebd3b350fe0

[jira] [Assigned] (FLINK-28454) Fix the wrong timestamp example of KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-28454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-28454: - Assignee: fanrui > Fix the wrong timestamp example of KafkaSource > ---

[jira] [Commented] (FLINK-28471) Translate hive_read_write.md into Chinese

[ https://issues.apache.org/jira/browse/FLINK-28471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564752#comment-17564752 ] luoyuxia commented on FLINK-28471: -- [~eyys] Thanks for your contribution. I'll find som

[GitHub] [flink] PatrickRen commented on pull request #20214: [FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

PatrickRen commented on PR #20214: URL: https://github.com/apache/flink/pull/20214#issuecomment-1179878678 @1996fanrui Merged to master. Also could you back port the commit to 1.14 and 1.15? -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] PatrickRen merged pull request #20214: [FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

PatrickRen merged PR #20214: URL: https://github.com/apache/flink/pull/20214 -- 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.ap

[GitHub] [flink] Aitozi commented on pull request #19840: [FLINK-24713][Runtime/Coordination] Support the initial delay for SlotManager to wait fo…

Aitozi commented on PR #19840: URL: https://github.com/apache/flink/pull/19840#issuecomment-1179873752 Hi @KarmaGYZ, Please help take a look again, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above t

[jira] [Commented] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

[ https://issues.apache.org/jira/browse/FLINK-28227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564750#comment-17564750 ] zhouli commented on FLINK-28227: Hi [~afedulov] ，if you don't mind, I'd like to take thi

[GitHub] [flink] luoyuxia commented on pull request #19218: [FLINK-27376][sql] Support current_database function

luoyuxia commented on PR #19218: URL: https://github.com/apache/flink/pull/19218#issuecomment-1179860781 @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] bzhaoopenstack commented on pull request #20193: [WIP][FLINK-28433][connector/jdbc]Add mariadb jdbc connection validation

bzhaoopenstack commented on PR #20193: URL: https://github.com/apache/flink/pull/20193#issuecomment-1179836772 > I would expect that we add MariaDB to the `JdbcExactlyOnceSinkE2eTest` with the correct test container and have a MariaDB dialect implemented (even if that would be just a copy o

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #307: [FLINK-28187] Handle SessionJob errors on observe

Aitozi commented on code in PR #307: URL: https://github.com/apache/flink-kubernetes-operator/pull/307#discussion_r917459062 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/sessionjob/SessionJobObserver.java: ## @@ -115,4 +131,62 @@ publ

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #307: [FLINK-28187] Handle SessionJob errors on observe

Aitozi commented on code in PR #307: URL: https://github.com/apache/flink-kubernetes-operator/pull/307#discussion_r917459062 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/sessionjob/SessionJobObserver.java: ## @@ -115,4 +131,62 @@ publ

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #307: [FLINK-28187] Handle SessionJob errors on observe

Aitozi commented on code in PR #307: URL: https://github.com/apache/flink-kubernetes-operator/pull/307#discussion_r917458759 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/sessionjob/SessionJobObserver.java: ## @@ -115,4 +131,62 @@ publ

[jira] [Updated] (FLINK-25119) The name of freeSlots parameter in SlotSharingSlotAllocator#determineParallelism method is named incorrectly.

[ https://issues.apache.org/jira/browse/FLINK-25119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25119: --- Labels: pull-request-available stale-minor (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-26771) Hive dialect supports to compare boolean type with numeric type

[ https://issues.apache.org/jira/browse/FLINK-26771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26771: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Comment Edited] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564726#comment-17564726 ] Alexander Fedulov edited comment on FLINK-27142 at 7/10/22 10:27 PM: -

[jira] [Commented] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564726#comment-17564726 ] Alexander Fedulov commented on FLINK-27142: --- [~twalthr] I still do not quite u

[jira] [Comment Edited] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17564726#comment-17564726 ] Alexander Fedulov edited comment on FLINK-27142 at 7/10/22 10:26 PM: -

  1   2   >