[GitHub] [flink] flinkbot edited a comment on pull request #19217: [FLINK-26789][tests] Fix broken RescaleCheckpointManuallyITCase

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19217: URL: https://github.com/apache/flink/pull/19217#issuecomment-1077144718 ## CI report: * 965321417c1b700dcc11e639807b2aeb175885bb Azure:

[GitHub] [flink] flinkbot commented on pull request #19217: [FLINK-26789][tests] Fix broken RescaleCheckpointManuallyITCase

2022-03-23 Thread GitBox
flinkbot commented on pull request #19217: URL: https://github.com/apache/flink/pull/19217#issuecomment-1077144718 ## CI report: * 965321417c1b700dcc11e639807b2aeb175885bb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 0724fedd6789ee0c8b95dfba9e85e689b9186c20 UNKNOWN * a3818995538b52aef26035d82256b58651ce3a57 Azure:

[GitHub] [flink] fredia opened a new pull request #19217: [FLINK-26789][tests] Fix broken RescaleCheckpointManuallyITCase

2022-03-23 Thread GitBox
fredia opened a new pull request #19217: URL: https://github.com/apache/flink/pull/19217 ## What is the purpose of the change *Fix `RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState` fail* ## Brief change log - *Restore `RescalingITCase` to

[jira] [Updated] (FLINK-12163) Use correct ClassLoader for Hadoop Writable TypeInfo

2022-03-23 Thread morvenhuang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] morvenhuang updated FLINK-12163: Summary: Use correct ClassLoader for Hadoop Writable TypeInfo (was: User correct ClassLoader for

[jira] [Comment Edited] (FLINK-26728) Support min operation in KeyedStream

2022-03-23 Thread CaoYu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511587#comment-17511587 ] CaoYu edited comment on FLINK-26728 at 3/24/22, 4:28 AM: - Hi [~dianfu]   

[jira] [Commented] (FLINK-26728) Support min operation in KeyedStream

2022-03-23 Thread CaoYu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511587#comment-17511587 ] CaoYu commented on FLINK-26728: --- Hi [~dianfu]    Currently, I have preliminarily implemented some

[GitHub] [flink] flinkbot edited a comment on pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #18958: URL: https://github.com/apache/flink/pull/18958#issuecomment-1056725576 ## CI report: * 94f1b47ba27eed0de18a2867f5ac25cc48ed0925 Azure:

[jira] [Comment Edited] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source

2022-03-23 Thread Adrian Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511578#comment-17511578 ] Adrian Zhong edited comment on FLINK-22766 at 3/24/22, 4:04 AM: I'd like

[jira] [Comment Edited] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source

2022-03-23 Thread Adrian Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511578#comment-17511578 ] Adrian Zhong edited comment on FLINK-22766 at 3/24/22, 4:01 AM: I'd like

[jira] [Comment Edited] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source

2022-03-23 Thread Adrian Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511578#comment-17511578 ] Adrian Zhong edited comment on FLINK-22766 at 3/24/22, 4:00 AM: I'd like

[jira] [Comment Edited] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source

2022-03-23 Thread Adrian Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511578#comment-17511578 ] Adrian Zhong edited comment on FLINK-22766 at 3/24/22, 4:00 AM: I'd like

[jira] [Comment Edited] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source

2022-03-23 Thread Adrian Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511578#comment-17511578 ] Adrian Zhong edited comment on FLINK-22766 at 3/24/22, 3:57 AM: I'd like

[jira] [Commented] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source

2022-03-23 Thread Adrian Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511578#comment-17511578 ] Adrian Zhong commented on FLINK-22766: -- I'd like to say: KafkaPartitionSplitReader is using

[GitHub] [flink] fredia closed pull request #19215: [FLINK-26789][state] Fix RescaleCheckpointManuallyITCase fail

2022-03-23 Thread GitBox
fredia closed pull request #19215: URL: https://github.com/apache/flink/pull/19215 -- 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-26805) Managed table breaks legacy connector without 'connector.type'

2022-03-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26805. Resolution: Fixed > Managed table breaks legacy connector without 'connector.type' >

[jira] [Comment Edited] (FLINK-26805) Managed table breaks legacy connector without 'connector.type'

2022-03-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511017#comment-17511017 ] Jingsong Lee edited comment on FLINK-26805 at 3/24/22, 3:54 AM: master:

[GitHub] [flink] JingsongLi merged pull request #19209: [FLINK-26805][table] Managed table breaks legacy connector without 'connector.type'

2022-03-23 Thread GitBox
JingsongLi merged pull request #19209: URL: https://github.com/apache/flink/pull/19209 -- 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:

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #58: [FLINK-26669] Refactor ReadWriteTableITCase

2022-03-23 Thread GitBox
JingsongLi commented on a change in pull request #58: URL: https://github.com/apache/flink-table-store/pull/58#discussion_r833892291 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ReadWriteTableITCase.java ## @@ -19,73 +19,242

[jira] [Updated] (FLINK-26834) Introduce BlockingIterator to help testing

2022-03-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26834: --- Labels: pull-request-available (was: ) > Introduce BlockingIterator to help testing >

[jira] [Created] (FLINK-26834) Introduce BlockingIterator to help testing

2022-03-23 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26834: Summary: Introduce BlockingIterator to help testing Key: FLINK-26834 URL: https://issues.apache.org/jira/browse/FLINK-26834 Project: Flink Issue Type:

[GitHub] [flink-table-store] JingsongLi opened a new pull request #60: [FLINK-26834] Introduce BlockingIterator to help testing

2022-03-23 Thread GitBox
JingsongLi opened a new pull request #60: URL: https://github.com/apache/flink-table-store/pull/60 BlockingIterator provides the ability to bring timeout to blocking iterators. It use a static cached {@link ExecutorService}. We don't limit the number of threads since the work inside

[GitHub] [flink] flinkbot edited a comment on pull request #19216: hive dialect supports dividing by zero.

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19216: URL: https://github.com/apache/flink/pull/19216#issuecomment-1077035902 ## CI report: * d6b0ee4743643655b4326b9584928f7e05680d26 Azure:

[GitHub] [flink] flinkbot commented on pull request #19216: hive dialect supports dividing by zero.

2022-03-23 Thread GitBox
flinkbot commented on pull request #19216: URL: https://github.com/apache/flink/pull/19216#issuecomment-1077035902 ## CI report: * d6b0ee4743643655b4326b9584928f7e05680d26 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19179: [FLINK-26756][table-planner] Fix the deserialization error for match recognize

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19179: URL: https://github.com/apache/flink/pull/19179#issuecomment-1073567241 ## CI report: * 9e677e67f510daf93704bd46cd3d4a8672c498ec Azure:

[jira] [Assigned] (FLINK-26832) Output more status info for JobObserver

2022-03-23 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-26832: - Assignee: Biao Geng > Output more status info for JobObserver >

[GitHub] [flink] luoyuxia opened a new pull request #19216: hive dialect supports dividing by zero.

2022-03-23 Thread GitBox
luoyuxia opened a new pull request #19216: URL: https://github.com/apache/flink/pull/19216 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] flinkbot edited a comment on pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062931101 ## CI report: * d3ec7878c8779c901bec0a7497b247cbe354b96e UNKNOWN * 65c05c107320acecd49d3264212cd34d1b75beb2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062931101 ## CI report: * d3ec7878c8779c901bec0a7497b247cbe354b96e UNKNOWN * 65c05c107320acecd49d3264212cd34d1b75beb2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 0724fedd6789ee0c8b95dfba9e85e689b9186c20 UNKNOWN * 2b16e626ba9f3efac8bd6b796353efaaf8b98de0 Azure:

[GitHub] [flink] ChengkaiYang2022 commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-23 Thread GitBox
ChengkaiYang2022 commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r833876402 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -24,31 +24,33 @@ specific language governing permissions and limitations

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 0724fedd6789ee0c8b95dfba9e85e689b9186c20 UNKNOWN * 2b16e626ba9f3efac8bd6b796353efaaf8b98de0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 0724fedd6789ee0c8b95dfba9e85e689b9186c20 UNKNOWN * 2b16e626ba9f3efac8bd6b796353efaaf8b98de0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 0724fedd6789ee0c8b95dfba9e85e689b9186c20 UNKNOWN * 2b16e626ba9f3efac8bd6b796353efaaf8b98de0 Azure:

[GitHub] [flink] zoltar9264 commented on a change in pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
zoltar9264 commented on a change in pull request #19207: URL: https://github.com/apache/flink/pull/19207#discussion_r833871458 ## File path: docs/content.zh/docs/ops/state/savepoints.md ## @@ -157,10 +157,54 @@ $ bin/flink run -s :savepointPath [:runArgs] 默认情况下,resume

[jira] [Updated] (FLINK-26833) missing link to setup-pyflink-virtual-env.sh / error during deploy

2022-03-23 Thread Kafka Chris (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kafka Chris updated FLINK-26833: Description: When I navigate to

[jira] [Created] (FLINK-26833) missing link to setup-pyflink-virtual-env.sh / error during deploy

2022-03-23 Thread Kafka Chris (Jira)
Kafka Chris created FLINK-26833: --- Summary: missing link to setup-pyflink-virtual-env.sh / error during deploy Key: FLINK-26833 URL: https://issues.apache.org/jira/browse/FLINK-26833 Project: Flink

[jira] [Comment Edited] (FLINK-26799) StateChangeFormat#read not seek to offset correctly

2022-03-23 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511558#comment-17511558 ] Feifan Wang edited comment on FLINK-26799 at 3/24/22, 2:32 AM: --- [~roman] ,

[jira] [Commented] (FLINK-26799) StateChangeFormat#read not seek to offset correctly

2022-03-23 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511558#comment-17511558 ] Feifan Wang commented on FLINK-26799: - [~roman] , here the problem is *`underlyingStream.getPos() ==

[GitHub] [flink] flinkbot edited a comment on pull request #19179: [FLINK-26756][table-planner] Fix the deserialization error for match recognize

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19179: URL: https://github.com/apache/flink/pull/19179#issuecomment-1073567241 ## CI report: * 9e677e67f510daf93704bd46cd3d4a8672c498ec Azure:

[GitHub] [flink] PatrickRen commented on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flink1.11

2022-03-23 Thread GitBox
PatrickRen commented on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1077001529 Thanks for the update. LGTM. @fapaul Could you help to take a look and merge this PR? Thanks -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #19179: [FLINK-26756][table-planner] Fix the deserialization error for match recognize

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19179: URL: https://github.com/apache/flink/pull/19179#issuecomment-1073567241 ## CI report: * 9e677e67f510daf93704bd46cd3d4a8672c498ec Azure:

[jira] [Commented] (FLINK-26799) StateChangeFormat#read not seek to offset correctly

2022-03-23 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511550#comment-17511550 ] Feifan Wang commented on FLINK-26799: - Hi [~roman] , I'm not mean seek on the underlying stream

[GitHub] [flink] godfreyhe commented on pull request #19179: [FLINK-26756][table-planner] Fix the deserialization error for match recognize

2022-03-23 Thread GitBox
godfreyhe commented on pull request #19179: URL: https://github.com/apache/flink/pull/19179#issuecomment-1076999830 @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

[GitHub] [flink-ml] yunfengzhou-hub commented on pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-23 Thread GitBox
yunfengzhou-hub commented on pull request #70: URL: https://github.com/apache/flink-ml/pull/70#issuecomment-1076988591 Thanks for the comments. I have updated the PR according to the comments. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #18958: URL: https://github.com/apache/flink/pull/18958#issuecomment-1056725576 ## CI report: * d34eb21ae0bda39ec119ef18a9782fbaad2310bc Azure:

[jira] [Commented] (FLINK-26827) FlinkSQL和hive整合报错

2022-03-23 Thread zhushifeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511545#comment-17511545 ] zhushifeng commented on FLINK-26827: OK, no problem, I have done it. Can you help me solve with the

[GitHub] [flink] chenzihao5 commented on pull request #19101: [FLINK-26634][docs-zh] Update Chinese version of Elasticsearch connector docs

2022-03-23 Thread GitBox
chenzihao5 commented on pull request #19101: URL: https://github.com/apache/flink/pull/19101#issuecomment-1076986910 Hi, @gaoyunhaii . Can you help to review this? Thanks a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] luoyuxia commented on pull request #19012: [FLINK-26540][hive] Support handle join involving complex types in on…

2022-03-23 Thread GitBox
luoyuxia commented on pull request #19012: URL: https://github.com/apache/flink/pull/19012#issuecomment-1076986032 @beyond1920 Thanks for your reminder. I'm glad to improve. But could you please explain a bit more about what kind of improvement so that I can pay attention to these stuff

[GitHub] [flink] flinkbot edited a comment on pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #18958: URL: https://github.com/apache/flink/pull/18958#issuecomment-1056725576 ## CI report: * d34eb21ae0bda39ec119ef18a9782fbaad2310bc Azure:

[jira] [Commented] (FLINK-26718) Limitations of flink+hive dimension table

2022-03-23 Thread kunghsu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511543#comment-17511543 ] kunghsu commented on FLINK-26718: - [~luoyuxia] Considering the amount of data is 25 million, when using

[GitHub] [flink] luoyuxia edited a comment on pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-03-23 Thread GitBox
luoyuxia edited a comment on pull request #18958: URL: https://github.com/apache/flink/pull/18958#issuecomment-1076984299 @twalthr Thanks for your reminder. Rebased now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] luoyuxia commented on pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-03-23 Thread GitBox
luoyuxia commented on pull request #18958: URL: https://github.com/apache/flink/pull/18958#issuecomment-1076984299 @twalthr Thanks for your reminder. I rebased now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-26829) ClassCastException will be thrown when the second operand of divide is a function call

2022-03-23 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511542#comment-17511542 ] xuyang commented on FLINK-26829: I'll try to fix it > ClassCastException will be thrown when the

[jira] [Updated] (FLINK-26827) FlinkSQL和hive整合报错

2022-03-23 Thread zhushifeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhushifeng updated FLINK-26827: --- Description: Topic : FlinkSQL combine with Hive   *step1:* environment: HIVE2.1   Flink1.13.3

[jira] [Updated] (FLINK-26827) FlinkSQL和hive整合报错

2022-03-23 Thread zhushifeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhushifeng updated FLINK-26827: --- Attachment: image-2022-03-24-09-33-31-786.png > FlinkSQL和hive整合报错 > - > >

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-23 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r833839951 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,562 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-26799) StateChangeFormat#read not seek to offset correctly

2022-03-23 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511536#comment-17511536 ] Roman Khachatryan commented on FLINK-26799: --- Hi [~Feifan Wang] , thanks for looking into it,

[jira] [Updated] (FLINK-26817) Update ingress docs with templating examples

2022-03-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26817: --- Labels: pull-request-available (was: ) > Update ingress docs with templating examples >

[GitHub] [flink] pnowojski commented on a change in pull request #19198: [FLINK-26783] Restore from a stop-with-savepoint if failed during committing

2022-03-23 Thread GitBox
pnowojski commented on a change in pull request #19198: URL: https://github.com/apache/flink/pull/19198#discussion_r833684250 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1243,7 +1243,7 @@ private void

[GitHub] [flink] pnowojski commented on a change in pull request #19198: [FLINK-26783] Restore from a stop-with-savepoint if failed during committing

2022-03-23 Thread GitBox
pnowojski commented on a change in pull request #19198: URL: https://github.com/apache/flink/pull/19198#discussion_r833684250 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1243,7 +1243,7 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #19205: [hotfix][table-planner] Cleanup code around TableConfig/ReadableConfig

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19205: URL: https://github.com/apache/flink/pull/19205#issuecomment-1075253969 ## CI report: * 0abeef29c3501174803ec2d7ce4421b914db9626 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19215: [FLINK-26789][state] Fix RescaleCheckpointManuallyITCase fail

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19215: URL: https://github.com/apache/flink/pull/19215#issuecomment-1076533796 ## CI report: * 8a5e2f0be2021d6fdf42ec913ad7199b0e78f9ef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 0724fedd6789ee0c8b95dfba9e85e689b9186c20 UNKNOWN * 2b16e626ba9f3efac8bd6b796353efaaf8b98de0 Azure:

[jira] [Commented] (FLINK-26639) Publish flink-kubernetes-operator maven artifacts

2022-03-23 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511396#comment-17511396 ] Thomas Weise commented on FLINK-26639: -- [~chesnay] thanks for the pointer. I was mainly looking to

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 0724fedd6789ee0c8b95dfba9e85e689b9186c20 UNKNOWN * 98001b33616f6c01f235d95342c27d4aae7e0a85 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19205: [hotfix][table-planner] Cleanup code around TableConfig/ReadableConfig

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19205: URL: https://github.com/apache/flink/pull/19205#issuecomment-1075253969 ## CI report: * 189e31dfbd7cf3196de8191bec0ec01b9ff20fd5 Azure:

[jira] [Updated] (FLINK-26830) Move jobs to suspended state before upgrading

2022-03-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26830: --- Labels: pull-request-available (was: ) > Move jobs to suspended state before upgrading >

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 55dba54d849604a41e5dfcb8e8eef9fbdbc093ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19205: [hotfix][table-planner] Cleanup code around TableConfig/ReadableConfig

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19205: URL: https://github.com/apache/flink/pull/19205#issuecomment-1075253969 ## CI report: * 189e31dfbd7cf3196de8191bec0ec01b9ff20fd5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 55dba54d849604a41e5dfcb8e8eef9fbdbc093ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19205: [hotfix][table-planner] Cleanup code around TableConfig/ReadableConfig

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19205: URL: https://github.com/apache/flink/pull/19205#issuecomment-1075253969 ## CI report: * 189e31dfbd7cf3196de8191bec0ec01b9ff20fd5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19215: [FLINK-26789][state] Fix RescaleCheckpointManuallyITCase fail

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19215: URL: https://github.com/apache/flink/pull/19215#issuecomment-1076533796 ## CI report: * 8a5e2f0be2021d6fdf42ec913ad7199b0e78f9ef Azure:

[jira] [Commented] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

2022-03-23 Thread Jianhui Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511363#comment-17511363 ] Jianhui Dong commented on FLINK-26738: -- And I think this is an issue worth discussing, from my

[GitHub] [flink] Myasuka commented on a change in pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
Myasuka commented on a change in pull request #19207: URL: https://github.com/apache/flink/pull/19207#discussion_r833469968 ## File path: docs/content.zh/docs/ops/state/savepoints.md ## @@ -157,10 +157,54 @@ $ bin/flink run -s :savepointPath [:runArgs] 默认情况下,resume 操作将尝试将

[GitHub] [flink] flinkbot commented on pull request #19215: [FLINK-26789][state] Fix RescaleCheckpointManuallyITCase fail

2022-03-23 Thread GitBox
flinkbot commented on pull request #19215: URL: https://github.com/apache/flink/pull/19215#issuecomment-1076533796 ## CI report: * 8a5e2f0be2021d6fdf42ec913ad7199b0e78f9ef Azure:

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #58: [FLINK-26669] Refactor ReadWriteTableITCase

2022-03-23 Thread GitBox
LadyForest commented on a change in pull request #58: URL: https://github.com/apache/flink-table-store/pull/58#discussion_r833463128 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ReadWriteTableITCase.java ## @@ -19,73 +19,242

[GitHub] [flink] RocMarshal commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-23 Thread GitBox
RocMarshal commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r833463004 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -24,31 +24,33 @@ specific language governing permissions and limitations

[jira] [Updated] (FLINK-26789) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed

2022-03-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26789: --- Labels: pull-request-available (was: ) >

[GitHub] [flink] fredia opened a new pull request #19215: [FLINK-26789][state] Fix RescaleCheckpointManuallyITCase fail

2022-03-23 Thread GitBox
fredia opened a new pull request #19215: URL: https://github.com/apache/flink/pull/19215 ## What is the purpose of the change *Fix `RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState` fail* ## Brief change log - *Restore `RescalingITCase` to

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 55dba54d849604a41e5dfcb8e8eef9fbdbc093ed Azure:

[GitHub] [flink] RocMarshal commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-23 Thread GitBox
RocMarshal commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r833455207 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -24,31 +24,33 @@ specific language governing permissions and limitations

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 55dba54d849604a41e5dfcb8e8eef9fbdbc093ed Azure:

[jira] [Commented] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

2022-03-23 Thread Jianhui Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511354#comment-17511354 ] Jianhui Dong commented on FLINK-26738: -- sorry, I forget to add the ValueState#value() method,

[GitHub] [flink] flinkbot edited a comment on pull request #19214: [FLINK-25256][streaming] Externally induced sources replay barriers received over RPC instead of inventing them out of thin air. [1.1

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19214: URL: https://github.com/apache/flink/pull/19214#issuecomment-1076367540 ## CI report: * a7b305a767dd75115548a41848577554e2634178 Azure:

[GitHub] [flink-table-store] LadyForest commented on pull request #58: [FLINK-26669] Refactor ReadWriteTableITCase

2022-03-23 Thread GitBox
LadyForest commented on pull request #58: URL: https://github.com/apache/flink-table-store/pull/58#issuecomment-1076507370 > * How to debug test in IDE? `No tests found matching testSequentialWriteRead with parameter` Did you click a single case and rerun it? It seems like

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 55dba54d849604a41e5dfcb8e8eef9fbdbc093ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19205: [hotfix][table-planner] Cleanup code around TableConfig/ReadableConfig

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19205: URL: https://github.com/apache/flink/pull/19205#issuecomment-1075253969 ## CI report: * 189e31dfbd7cf3196de8191bec0ec01b9ff20fd5 Azure:

[GitHub] [flink] matriv commented on a change in pull request #19205: [hotfix][table-planner] Cleanup code around TableConfig/ReadableConfig

2022-03-23 Thread GitBox
matriv commented on a change in pull request #19205: URL: https://github.com/apache/flink/pull/19205#discussion_r833421257 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdHandlerTestBase.scala ## @@ -82,27

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 55dba54d849604a41e5dfcb8e8eef9fbdbc093ed Azure:

[GitHub] [flink] zoltar9264 commented on a change in pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
zoltar9264 commented on a change in pull request #19207: URL: https://github.com/apache/flink/pull/19207#discussion_r833412889 ## File path: docs/content.zh/docs/ops/state/savepoints.md ## @@ -157,10 +157,54 @@ $ bin/flink run -s :savepointPath [:runArgs] 默认情况下,resume

[GitHub] [flink] ChengkaiYang2022 commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-23 Thread GitBox
ChengkaiYang2022 commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r833410865 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -24,31 +24,33 @@ specific language governing permissions and limitations

[jira] [Created] (FLINK-26832) Output more status info for JobObserver

2022-03-23 Thread Biao Geng (Jira)
Biao Geng created FLINK-26832: - Summary: Output more status info for JobObserver Key: FLINK-26832 URL: https://issues.apache.org/jira/browse/FLINK-26832 Project: Flink Issue Type: Sub-task

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #58: [FLINK-26669] Refactor ReadWriteTableITCase

2022-03-23 Thread GitBox
LadyForest commented on a change in pull request #58: URL: https://github.com/apache/flink-table-store/pull/58#discussion_r833410546 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ReadWriteTableITCase.java ## @@ -19,73 +19,242

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 55dba54d849604a41e5dfcb8e8eef9fbdbc093ed Azure:

[GitHub] [flink] matriv commented on a change in pull request #19205: [hotfix][table-planner] Cleanup code around TableConfig/ReadableConfig

2022-03-23 Thread GitBox
matriv commented on a change in pull request #19205: URL: https://github.com/apache/flink/pull/19205#discussion_r833406719 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/schema/LegacyCatalogSourceTable.scala ## @@ -75,25

[GitHub] [flink] flinkbot edited a comment on pull request #19138: [FLINK-25256][streaming] Externally induced sources replay barriers received over RPC instead of inventing them out of thin air.

2022-03-23 Thread GitBox
flinkbot edited a comment on pull request #19138: URL: https://github.com/apache/flink/pull/19138#issuecomment-1071624475 ## CI report: * 5e263a620aa70714d4958dd4dc47ad1b1b3866a8 Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
Myasuka commented on a change in pull request #19207: URL: https://github.com/apache/flink/pull/19207#discussion_r833375035 ## File path: docs/content.zh/docs/ops/state/savepoints.md ## @@ -157,10 +157,54 @@ $ bin/flink run -s :savepointPath [:runArgs] 默认情况下,resume 操作将尝试将

[GitHub] [flink] Myasuka commented on a change in pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-23 Thread GitBox
Myasuka commented on a change in pull request #19207: URL: https://github.com/apache/flink/pull/19207#discussion_r833371461 ## File path: docs/content.zh/docs/ops/state/savepoints.md ## @@ -157,10 +157,54 @@ $ bin/flink run -s :savepointPath [:runArgs] 默认情况下,resume 操作将尝试将

[jira] [Commented] (FLINK-26712) Metadata keys should not conflict with physical columns

2022-03-23 Thread jinfeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511301#comment-17511301 ] jinfeng commented on FLINK-26712: - [~twalthr] Thanks for your reply, maybe I'm thinking a bit

  1   2   3   4   5   >