[jira] [Created] (FLINK-27764) SetOperatorsITCase tests failed

2022-05-24 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-27764: Summary: SetOperatorsITCase tests failed Key: FLINK-27764 URL: https://issues.apache.org/jira/browse/FLINK-27764 Project: Flink Issue Type: Bug Com

[jira] [Updated] (FLINK-27763) Remove netty bundling&relocation in flink-streaming-kinesis-tests

2022-05-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27763: --- Labels: pull-request-available (was: ) > Remove netty bundling&relocation in flink-streamin

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-24 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r881284890 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegressionParams.java: ## @@ -0,0 +1,80 @@ +/* + * Licensed to the Apach

issues@flink.apache.org

2022-05-24 Thread GitBox
zentol opened a new pull request, #19813: URL: https://github.com/apache/flink/pull/19813 flink-streaming-kinesis-tests bundles and relocates netty (and no other dependency). We can safely remove this because no class within this module references netty, nor any other module relies on the r

[jira] [Created] (FLINK-27763) Remove netty bundling&relocation in flink-streaming-kinesis-tests

2022-05-24 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27763: Summary: Remove netty bundling&relocation in flink-streaming-kinesis-tests Key: FLINK-27763 URL: https://issues.apache.org/jira/browse/FLINK-27763 Project: Fl

[jira] [Closed] (FLINK-27615) Document how to define namespaceSelector for k8s operator's webhook for different k8s versions

2022-05-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-27615. - Fix Version/s: kubernetes-operator-1.0.0 Resolution: Fixed Fixed via: main: e04a91d8cef121e4ad078

[GitHub] [flink] Sxnan commented on a diff in pull request #19653: [FLINK-27523] Runtime supports producing and consuming cached intermediate results

2022-05-24 Thread GitBox
Sxnan commented on code in PR #19653: URL: https://github.com/apache/flink/pull/19653#discussion_r879216461 ## flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java: ## @@ -84,6 +86,33 @@ CompletableFuture registerPartitionWithProducer( Par

[GitHub] [flink-kubernetes-operator] wangyang0918 merged pull request #242: [FLINK-27615] Document how to define namespaceSelector for k8s operator's webhook

2022-05-24 Thread GitBox
wangyang0918 merged PR #242: URL: https://github.com/apache/flink-kubernetes-operator/pull/242 -- 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-un

[jira] [Closed] (FLINK-27752) Change 'path' to 'root-path' in table store

2022-05-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27752. Resolution: Fixed master: 14c26f9f0fa4a9fa4094c338729036fb4166ed66 > Change 'path' to 'root-path'

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-24 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r881275210 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegression.java: ## @@ -0,0 +1,434 @@ +/* + * Licensed to the Apache Sof

[jira] [Updated] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-24 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucan updated FLINK-27762: --- Description:   We enable dynamic partition discovery in our flink job, but job failed when kafka partition

[jira] [Updated] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-24 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucan updated FLINK-27762: --- Description:   We enable dynamic partition discovery in our flink job, but job failed when kafka partition

[jira] [Updated] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-24 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucan updated FLINK-27762: --- Description:   We enable dynamic partition discovery in our flink job, but job failed when kafka partition

[GitHub] [flink-table-store] JingsongLi merged pull request #136: [FLINK-27752] Change 'path' to 'root-path' in table store

2022-05-24 Thread GitBox
JingsongLi merged PR #136: URL: https://github.com/apache/flink-table-store/pull/136 -- 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...@

[jira] [Closed] (FLINK-27251) Timeout aligned to unaligned checkpoint barrier in the output buffers of an upstream subtask

2022-05-24 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-27251. -- Resolution: Fixed Merged to master as e68d679e8ac^^..e68d679e8ac. Thank you [~fanrui] for a v

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-24 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r881266473 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegression.java: ## @@ -0,0 +1,434 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] pnowojski merged pull request #19723: [FLINK-27251][checkpoint] Timeout aligned to unaligned checkpoint barrier in the output buffers

2022-05-24 Thread GitBox
pnowojski merged PR #19723: URL: https://github.com/apache/flink/pull/19723 -- 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.apa

[GitHub] [flink] pnowojski commented on pull request #19723: [FLINK-27251][checkpoint] Timeout aligned to unaligned checkpoint barrier in the output buffers

2022-05-24 Thread GitBox
pnowojski commented on PR #19723: URL: https://github.com/apache/flink/pull/19723#issuecomment-1136792865 All looks good, merging. -- 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 com

[jira] [Updated] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-24 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucan updated FLINK-27762: --- Description:   We enable dynamic partition discovery in our flink job, but job is failed when kafka partit

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-24 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r881264766 ## flink-ml-lib/src/test/java/org/apache/flink/ml/classification/OnlineLogisticRegressionTest.java: ## @@ -0,0 +1,661 @@ +/* + * Licensed to the Apache Software Foundatio

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-24 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r881258511 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegression.java: ## @@ -0,0 +1,434 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] snuyanzin commented on a diff in pull request #19807: [FLINK-27185][connectors] Convert connector-jdbc module to assertj

2022-05-24 Thread GitBox
snuyanzin commented on code in PR #19807: URL: https://github.com/apache/flink/pull/19807#discussion_r881243667 ## flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcInputFormatTest.java: ## @@ -279,7 +279,7 @@ public void testJdbcInputForma

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-24 Thread GitBox
yunfengzhou-hub commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r881176285 ## flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java: ## @@ -71,6 +71,43 @@ public static double dot(DenseVector x, DenseVector y) { return

[jira] [Created] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-24 Thread zoucan (Jira)
zoucan created FLINK-27762: -- Summary: Kafka WakeUpException during handling splits changes Key: FLINK-27762 URL: https://issues.apache.org/jira/browse/FLINK-27762 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-24 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucan updated FLINK-27762: --- Description:   We enable dynamic partition discovery in our flink job, but job is failed when kafka partit

[jira] [Updated] (FLINK-27762) Kafka WakeUpException during handling splits changes

2022-05-24 Thread zoucan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zoucan updated FLINK-27762: --- Description:   We enable dynamic partition discovery in our flink job, but job is failed when kafka partit

[GitHub] [flink] snuyanzin commented on pull request #19811: [FLINK-27758][tests][table] Migrate flink-table-runtime to JUnit5

2022-05-24 Thread GitBox
snuyanzin commented on PR #19811: URL: https://github.com/apache/flink/pull/19811#issuecomment-1136752374 The PR is based on commit https://github.com/apache/flink/pull/19780 migrating `TypeSerializerUpgradeTestBase` to JUnit5 -- This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-05-24 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541827#comment-17541827 ] Feifan Wang commented on FLINK-27155: - Thanks for [~roman] 's explain and sorry for

[GitHub] [flink] flinkbot commented on pull request #19812: [hotfix] [docs] Fix misspelled word...

2022-05-24 Thread GitBox
flinkbot commented on PR #19812: URL: https://github.com/apache/flink/pull/19812#issuecomment-1136710187 ## CI report: * fd022e91a80dd313e74a6c93a507ffa5aef0312b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] leewallen opened a new pull request, #19812: Fix misspelled word...

2022-05-24 Thread GitBox
leewallen opened a new pull request, #19812: URL: https://github.com/apache/flink/pull/19812 unefficient -> inefficient ## 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

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #242: [FLINK-27615] Document how to define namespaceSelector for k8s operator's webhook

2022-05-24 Thread GitBox
bgeng777 commented on code in PR #242: URL: https://github.com/apache/flink-kubernetes-operator/pull/242#discussion_r881193136 ## docs/content/docs/operations/helm.md: ## @@ -107,6 +107,29 @@ The webhook can be disabled during helm install by passing the `--set webhook.cr The

[jira] [Created] (FLINK-27761) Add database and table field in canal-json sink

2022-05-24 Thread Zhiwen Sun (Jira)
Zhiwen Sun created FLINK-27761: -- Summary: Add database and table field in canal-json sink Key: FLINK-27761 URL: https://issues.apache.org/jira/browse/FLINK-27761 Project: Flink Issue Type: Impro

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #242: [FLINK-27615] Document how to define namespaceSelector for k8s operator's webhook

2022-05-24 Thread GitBox
bgeng777 commented on code in PR #242: URL: https://github.com/apache/flink-kubernetes-operator/pull/242#discussion_r881193136 ## docs/content/docs/operations/helm.md: ## @@ -107,6 +107,29 @@ The webhook can be disabled during helm install by passing the `--set webhook.cr The

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #242: [FLINK-27615] Document how to define namespaceSelector for k8s operator's webhook

2022-05-24 Thread GitBox
bgeng777 commented on code in PR #242: URL: https://github.com/apache/flink-kubernetes-operator/pull/242#discussion_r881193025 ## docs/content/docs/operations/helm.md: ## @@ -107,6 +107,28 @@ The webhook can be disabled during helm install by passing the `--set webhook.cr The

[jira] [Commented] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

2022-05-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541809#comment-17541809 ] Yang Wang commented on FLINK-27579: --- The root cause is we do not get the {{clientTimeo

[jira] [Created] (FLINK-27760) NPE is thrown when executing PyFlink jobs in batch mode

2022-05-24 Thread Dian Fu (Jira)
Dian Fu created FLINK-27760: --- Summary: NPE is thrown when executing PyFlink jobs in batch mode Key: FLINK-27760 URL: https://issues.apache.org/jira/browse/FLINK-27760 Project: Flink Issue Type: Bug

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #136: [FLINK-27752] Change 'path' to 'root-path' in table store

2022-05-24 Thread GitBox
LadyForest commented on code in PR #136: URL: https://github.com/apache/flink-table-store/pull/136#discussion_r881192269 ## flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/TableStoreManagedFactoryTest.java: ## @@ -355,4 +380,42 @@ private static

[jira] [Commented] (FLINK-27639) Flink JOIN uses the now() function when inserting data, resulting in data that cannot be deleted

2022-05-24 Thread lvycc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541808#comment-17541808 ] lvycc commented on FLINK-27639: --- Run  init  sql in Mysql: {code:java} //代码占位符 CREATE TABLE

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #136: [FLINK-27752] Change 'path' to 'root-path' in table store

2022-05-24 Thread GitBox
LadyForest commented on code in PR #136: URL: https://github.com/apache/flink-table-store/pull/136#discussion_r881189824 ## flink-table-store-kafka/src/main/java/org/apache/flink/table/store/kafka/KafkaLogStoreFactory.java: ## @@ -93,6 +96,23 @@ public Set> optionalOptions() {

[GitHub] [flink] dianfu commented on pull request #15491: [FLINK-21966][python]Support Kinesis connector in Python DataStream API

2022-05-24 Thread GitBox
dianfu commented on PR #15491: URL: https://github.com/apache/flink/pull/15491#issuecomment-1136690230 What's the status of this PR? I can help to review if it's updated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] CodingCaproni commented on pull request #19783: [FLINK-27616][Table SQL/Planner] Modify the spelling mistakes of the …

2022-05-24 Thread GitBox
CodingCaproni commented on PR #19783: URL: https://github.com/apache/flink/pull/19783#issuecomment-1136687147 @wuchong Can you please review it ? -- 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] snuyanzin commented on pull request #19811: [FLINK-27758][tests][table] Migrate flink-table-runtime to JUnit5

2022-05-24 Thread GitBox
snuyanzin commented on PR #19811: URL: https://github.com/apache/flink/pull/19811#issuecomment-1136687056 @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-kubernetes-operator] wangyang0918 commented on a diff in pull request #242: [FLINK-27615] Document how to define namespaceSelector for k8s operator's webhook

2022-05-24 Thread GitBox
wangyang0918 commented on code in PR #242: URL: https://github.com/apache/flink-kubernetes-operator/pull/242#discussion_r881185048 ## docs/content/docs/operations/helm.md: ## @@ -107,6 +107,28 @@ The webhook can be disabled during helm install by passing the `--set webhook.cr

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-24 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r881173528 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasL2.java: ## @@ -0,0 +1,37 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or m

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #83: [FLINK-27170] Add Transformer and Estimator for OnlineLogisticRegression

2022-05-24 Thread GitBox
weibozhao commented on code in PR #83: URL: https://github.com/apache/flink-ml/pull/83#discussion_r881173256 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/OnlineLogisticRegression.java: ## @@ -0,0 +1,428 @@ +/* + * Licensed to the Apache Sof

[jira] [Comment Edited] (FLINK-27722) Slack: set up auto-updated invitation link

2022-05-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541800#comment-17541800 ] Jark Wu edited comment on FLINK-27722 at 5/25/22 2:54 AM: -- Anot

[jira] [Comment Edited] (FLINK-27722) Slack: set up auto-updated invitation link

2022-05-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541800#comment-17541800 ] Jark Wu edited comment on FLINK-27722 at 5/25/22 2:54 AM: -- Anot

[jira] [Commented] (FLINK-27722) Slack: set up auto-updated invitation link

2022-05-24 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541800#comment-17541800 ] Jark Wu commented on FLINK-27722: - Another workaround is using a shorturl + never expire

[jira] [Closed] (FLINK-27747) Flink kubernetes operator helm chart release the Chart.yaml file doesn't have an apache license header

2022-05-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-27747. - Resolution: Fixed Fixed via: main: 710310b76d174526135e30ad236c32f74df45c78 release-1.0: 4a70fe364ec4a

[jira] [Closed] (FLINK-27746) Flink kubernetes operator docker image could not build with source release

2022-05-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-27746. - Resolution: Fixed Fixed via: main: cf8f99b2c7cd61828ce94228d1b6b31c235d4cb8 release-1.0: d0482f91b6603

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #136: [FLINK-27752] Change 'path' to 'root-path' in table store

2022-05-24 Thread GitBox
JingsongLi commented on code in PR #136: URL: https://github.com/apache/flink-table-store/pull/136#discussion_r881164055 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreManagedFactory.java: ## @@ -0,0 +1,188 @@ +/* + * Licensed to th

[jira] [Commented] (FLINK-27759) Rethink how to get the git commit id for docker image in Flink Kubernetes operator

2022-05-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541787#comment-17541787 ] Yang Wang commented on FLINK-27759: --- Thanks for the volunteering. I believe this is no

[jira] [Assigned] (FLINK-27759) Rethink how to get the git commit id for docker image in Flink Kubernetes operator

2022-05-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-27759: - Assignee: Nicholas Jiang > Rethink how to get the git commit id for docker image in Flink Kuber

[jira] [Updated] (FLINK-27747) Flink kubernetes operator helm chart release the Chart.yaml file doesn't have an apache license header

2022-05-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27747: --- Labels: pull-request-available (was: ) > Flink kubernetes operator helm chart release the C

[GitHub] [flink-kubernetes-operator] wangyang0918 merged pull request #240: [FLINK-27747] Use tar instead of helm package when creating source release

2022-05-24 Thread GitBox
wangyang0918 merged PR #240: URL: https://github.com/apache/flink-kubernetes-operator/pull/240 -- 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-un

[jira] [Commented] (FLINK-27759) Rethink how to get the git commit id for docker image in Flink Kubernetes operator

2022-05-24 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541784#comment-17541784 ] Nicholas Jiang commented on FLINK-27759: [~wangyang0918], I will investigate the

[GitHub] [flink-kubernetes-operator] wangyang0918 merged pull request #243: [FLINK-27746] Flink kubernetes operator docker image could not build with source release

2022-05-24 Thread GitBox
wangyang0918 merged PR #243: URL: https://github.com/apache/flink-kubernetes-operator/pull/243 -- 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-un

[jira] [Created] (FLINK-27759) Rethink how to get the git commit id for docker image in Flink Kubernetes operator

2022-05-24 Thread Yang Wang (Jira)
Yang Wang created FLINK-27759: - Summary: Rethink how to get the git commit id for docker image in Flink Kubernetes operator Key: FLINK-27759 URL: https://issues.apache.org/jira/browse/FLINK-27759 Project:

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #243: [FLINK-27746] Flink kubernetes operator docker image could not build with source release

2022-05-24 Thread GitBox
wangyang0918 commented on PR #243: URL: https://github.com/apache/flink-kubernetes-operator/pull/243#issuecomment-1136640871 I have created a new ticket FLINK-27759 to follow the potential improvement. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] Sxnan commented on a diff in pull request #19653: [FLINK-27523] Runtime supports producing and consuming cached intermediate results

2022-05-24 Thread GitBox
Sxnan commented on code in PR #19653: URL: https://github.com/apache/flink/pull/19653#discussion_r879216461 ## flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java: ## @@ -84,6 +86,33 @@ CompletableFuture registerPartitionWithProducer( Par

[GitHub] [flink-kubernetes-operator] Aitozi commented on pull request #239: [FLINK-27714] Migrate to java-operator-sdk v3

2022-05-24 Thread GitBox
Aitozi commented on PR #239: URL: https://github.com/apache/flink-kubernetes-operator/pull/239#issuecomment-1136635601 Thanks @morhidi for this nice work, I'll take a closer look today -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] lsyldliu commented on pull request #19410: [FLINK-15635][table] Now EnvironmentSettings accepts the user ClassLoader

2022-05-24 Thread GitBox
lsyldliu commented on PR #19410: URL: https://github.com/apache/flink/pull/19410#issuecomment-1136633593 > > > > ping @matriv Can you help to complete this work as soon as possible? [FLIP-214](https://cwiki.apache.org/confluence/display/FLINK/FLIP-214+Support+Advanced+Function+DDL)

[GitHub] [flink] yangjunhan commented on a diff in pull request #19712: [FLINK-26207][runtime-web] make web ui's components depend on injected configurable object

2022-05-24 Thread GitBox
yangjunhan commented on code in PR #19712: URL: https://github.com/apache/flink/pull/19712#discussion_r881145686 ## flink-runtime-web/web-dashboard/src/app/pages/job/overview/backpressure/job-overview-drawer-backpressure.component.html: ## @@ -17,14 +17,17 @@ -->

[GitHub] [flink-kubernetes-operator] Aitozi commented on a diff in pull request #242: [FLINK-27615] Document how to define namespaceSelector for k8s operator's webhook

2022-05-24 Thread GitBox
Aitozi commented on code in PR #242: URL: https://github.com/apache/flink-kubernetes-operator/pull/242#discussion_r881142701 ## docs/content/docs/operations/helm.md: ## @@ -107,6 +107,29 @@ The webhook can be disabled during helm install by passing the `--set webhook.cr The o

[jira] [Commented] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

2022-05-24 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541780#comment-17541780 ] Liu commented on FLINK-27579: - [~paul8263] Thanks for the pr. We need a flink committer to v

[jira] [Closed] (FLINK-27478) datastream.print() failed by uncertain cause

2022-05-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-27478. --- Resolution: Not A Problem I'm closing this ticket as I think it don't think this is an issue. It might be c

[jira] [Closed] (FLINK-27690) Add Python documentation and examples for Pulsar connector

2022-05-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-27690. --- Fix Version/s: 1.16.0 Resolution: Fixed Merged to master via 8a2a396970156f1ddecf88a6498162506eb25069

[GitHub] [flink] dianfu closed pull request #19775: [FLINK-27690][python][connector/pulsar] Add Python documentation and examples for Pulsar connector

2022-05-24 Thread GitBox
dianfu closed pull request #19775: [FLINK-27690][python][connector/pulsar] Add Python documentation and examples for Pulsar connector URL: https://github.com/apache/flink/pull/19775 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-22599) Point to `client.timeout` in error messages where it is used for rpc timeout

2022-05-24 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17541744#comment-17541744 ] Mason Chen commented on FLINK-22599: +1 for fixing this issue and changing the prior

[GitHub] [flink] MartijnVisser commented on pull request #19806: [FLINK-27450][hive] Upgrade default hive version to fix Hive SessionState initialization issue with jdk11

2022-05-24 Thread GitBox
MartijnVisser commented on PR #19806: URL: https://github.com/apache/flink/pull/19806#issuecomment-1136414341 @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

[GitHub] [flink] flinkbot commented on pull request #19811: [FLINK-27758][tests][table] Migrate flink-table-runtime to JUnit5

2022-05-24 Thread GitBox
flinkbot commented on PR #19811: URL: https://github.com/apache/flink/pull/19811#issuecomment-1136400172 ## CI report: * 55083d6ce49a1e36922d059e19bf463d0a375914 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27758) [JUnit5 Migration] Module: flink-table-runtime

2022-05-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27758: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Module: flink-table-runtime > -

[GitHub] [flink] snuyanzin opened a new pull request, #19811: [FLINK-27758][tests][table] Migrate flink-table-runtime to JUnit5

2022-05-24 Thread GitBox
snuyanzin opened a new pull request, #19811: URL: https://github.com/apache/flink/pull/19811 ## What is the purpose of the change Update the flink-table-runtime module to AssertJ and JUnit 5 following the [JUnit 5 Migration Guide](https://docs.google.com/document/d/1514Wa_aNB9bJUen4x

[jira] [Created] (FLINK-27758) [JUnit5 Migration] Module: flink-table-runtime

2022-05-24 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-27758: --- Summary: [JUnit5 Migration] Module: flink-table-runtime Key: FLINK-27758 URL: https://issues.apache.org/jira/browse/FLINK-27758 Project: Flink Issue Ty

[GitHub] [flink] flinkbot commented on pull request #19810: [FLINK-27757][Connector][Elasticsearch] Elasticsearch connector should not use `flink-table-planner` but `flink-table-planner-loader`

2022-05-24 Thread GitBox
flinkbot commented on PR #19810: URL: https://github.com/apache/flink/pull/19810#issuecomment-1136300616 ## CI report: * 6895512a70ccc28846dcb49bc0144f7a10372ef8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] MartijnVisser opened a new pull request, #19810: [FLINK-27757][Connector][Elasticsearch] Elasticsearch connector should not use `flink-table-planner` but `flink-table-planner-loader`

2022-05-24 Thread GitBox
MartijnVisser opened a new pull request, #19810: URL: https://github.com/apache/flink/pull/19810 ## What is the purpose of the change Elasticsearch connector should not use `flink-table-planner` but `flink-table-planner-loader`. We also need to add `flink-table-runtime` to avoid Clas

[jira] [Updated] (FLINK-27757) Elasticsearch connector should not use flink-table-planner but flink-table-planner-loader

2022-05-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27757: --- Labels: pull-request-available (was: ) > Elasticsearch connector should not use flink-table

[GitHub] [flink-connector-elasticsearch] MartijnVisser opened a new pull request, #20: [FLINK-27757][Connector][Elasticsearch] Elasticsearch connector should not use `flink-table-planner` but `flink-t

2022-05-24 Thread GitBox
MartijnVisser opened a new pull request, #20: URL: https://github.com/apache/flink-connector-elasticsearch/pull/20 We also need to add `flink-table-runtime` to avoid ClassNotFoundException on `org.apache.flink.table.shaded.com.jayway.jsonpath.spi.mapper.MappingProvider` -- This is an auto

[jira] [Created] (FLINK-27757) Elasticsearch connector should not use flink-table-planner but flink-table-planner-loader

2022-05-24 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-27757: -- Summary: Elasticsearch connector should not use flink-table-planner but flink-table-planner-loader Key: FLINK-27757 URL: https://issues.apache.org/jira/browse/FLINK-27757

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19448: [FLINK-25872][state] Support restore from non-changelog checkpoint with changelog enabled in CLAIM mode

2022-05-24 Thread GitBox
rkhachatryan commented on code in PR #19448: URL: https://github.com/apache/flink/pull/19448#discussion_r880787079 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java: ## @@ -57,13 +58,30 @@ public interface SharedStateRegistry extends AutoClos

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19448: [FLINK-25872][state] Support restore from non-changelog checkpoint with changelog enabled in CLAIM mode

2022-05-24 Thread GitBox
rkhachatryan commented on code in PR #19448: URL: https://github.com/apache/flink/pull/19448#discussion_r880782026 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java: ## @@ -227,6 +229,14 @@ private static void registerSharedState(

[GitHub] [flink] chenqin closed pull request #19779: [FLINK-27726] [Connector-Hive] shade thrift and fb303 in hive connector

2022-05-24 Thread GitBox
chenqin closed pull request #19779: [FLINK-27726] [Connector-Hive] shade thrift and fb303 in hive connector URL: https://github.com/apache/flink/pull/19779 -- 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

[GitHub] [flink-kubernetes-operator] tisonkun commented on pull request #243: [FLINK-27746] Flink kubernetes operator docker image could not build with source release

2022-05-24 Thread GitBox
tisonkun commented on PR #243: URL: https://github.com/apache/flink-kubernetes-operator/pull/243#issuecomment-1136209005 @wangyang0918 I'm thinking of `COPY . .` with a `.dockerignore` file. But yes, we can investigate better way after release 1.0.0. -- This is an automated message from

[GitHub] [flink-kubernetes-operator] SteNicholas commented on a diff in pull request #243: [FLINK-27746] Flink kubernetes operator docker image could not build with source release

2022-05-24 Thread GitBox
SteNicholas commented on code in PR #243: URL: https://github.com/apache/flink-kubernetes-operator/pull/243#discussion_r880660035 ## Dockerfile: ## @@ -36,7 +36,7 @@ COPY $DOCS_DIR/pom.xml ./$DOCS_DIR/ COPY $OPERATOR_DIR/src ./$OPERATOR_DIR/src COPY $WEBHOOK_DIR/src ./$WEBHOO

[GitHub] [flink-kubernetes-operator] tisonkun commented on a diff in pull request #243: [FLINK-27746] Flink kubernetes operator docker image could not build with source release

2022-05-24 Thread GitBox
tisonkun commented on code in PR #243: URL: https://github.com/apache/flink-kubernetes-operator/pull/243#discussion_r880657077 ## Dockerfile: ## @@ -36,7 +36,7 @@ COPY $DOCS_DIR/pom.xml ./$DOCS_DIR/ COPY $OPERATOR_DIR/src ./$OPERATOR_DIR/src COPY $WEBHOOK_DIR/src ./$WEBHOOK_D

[GitHub] [flink-kubernetes-operator] tisonkun commented on a diff in pull request #243: [FLINK-27746] Flink kubernetes operator docker image could not build with source release

2022-05-24 Thread GitBox
tisonkun commented on code in PR #243: URL: https://github.com/apache/flink-kubernetes-operator/pull/243#discussion_r880657077 ## Dockerfile: ## @@ -36,7 +36,7 @@ COPY $DOCS_DIR/pom.xml ./$DOCS_DIR/ COPY $OPERATOR_DIR/src ./$OPERATOR_DIR/src COPY $WEBHOOK_DIR/src ./$WEBHOOK_D

[GitHub] [flink-kubernetes-operator] SteNicholas commented on a diff in pull request #243: [FLINK-27746] Flink kubernetes operator docker image could not build with source release

2022-05-24 Thread GitBox
SteNicholas commented on code in PR #243: URL: https://github.com/apache/flink-kubernetes-operator/pull/243#discussion_r880655702 ## Dockerfile: ## @@ -36,7 +36,7 @@ COPY $DOCS_DIR/pom.xml ./$DOCS_DIR/ COPY $OPERATOR_DIR/src ./$OPERATOR_DIR/src COPY $WEBHOOK_DIR/src ./$WEBHOO

[GitHub] [flink-kubernetes-operator] tisonkun closed pull request #241: [FLINK-27746] Replace git-commit-id-maven-plugin with script

2022-05-24 Thread GitBox
tisonkun closed pull request #241: [FLINK-27746] Replace git-commit-id-maven-plugin with script URL: https://github.com/apache/flink-kubernetes-operator/pull/241 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[GitHub] [flink-kubernetes-operator] tisonkun commented on pull request #241: [FLINK-27746] Replace git-commit-id-maven-plugin with script

2022-05-24 Thread GitBox
tisonkun commented on PR #241: URL: https://github.com/apache/flink-kubernetes-operator/pull/241#issuecomment-1136067938 Closed in favor of #243. This patch never builds the image with git props. -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink-kubernetes-operator] tisonkun commented on a diff in pull request #243: [FLINK-27746] Flink kubernetes operator docker image could not build with source release

2022-05-24 Thread GitBox
tisonkun commented on code in PR #243: URL: https://github.com/apache/flink-kubernetes-operator/pull/243#discussion_r880649631 ## Dockerfile: ## @@ -36,7 +36,7 @@ COPY $DOCS_DIR/pom.xml ./$DOCS_DIR/ COPY $OPERATOR_DIR/src ./$OPERATOR_DIR/src COPY $WEBHOOK_DIR/src ./$WEBHOOK_D

[GitHub] [flink-kubernetes-operator] SteNicholas opened a new pull request, #243: [FLINK-27746] Flink kubernetes operator docker image could not build with source release

2022-05-24 Thread GitBox
SteNicholas opened a new pull request, #243: URL: https://github.com/apache/flink-kubernetes-operator/pull/243 Flink kubernetes operator docker image could not build with source release at present. The `.git` directory should be copied when the directory exists. -- This is an automated me

[GitHub] [flink] flinkbot commented on pull request #19807: [FLINK-27185][connectors] Convert connector-jdbc module to assertj

2022-05-24 Thread GitBox
flinkbot commented on PR #19807: URL: https://github.com/apache/flink/pull/19807#issuecomment-1136037139 ## CI report: * e88da15ad3a8b6e3f431a89ac2dca2d62d28c63c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #19809: [FLINK-27185][connectors] Convert connector-kinesis module to assertj

2022-05-24 Thread GitBox
flinkbot commented on PR #19809: URL: https://github.com/apache/flink/pull/19809#issuecomment-1136037406 ## CI report: * 45950ba3dd1aa8da0a2d980cba7c87c6c6b006f5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #19808: [FLINK-27185][connectors] Convert connector-kafka module to assertj

2022-05-24 Thread GitBox
flinkbot commented on PR #19808: URL: https://github.com/apache/flink/pull/19808#issuecomment-1136037272 ## CI report: * a0e1e050f0325c0eff8386dafee3b4b2cafef7bd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] alpreu closed pull request #19660: [FLINK-27185][connectors] Convert connector modules to assertj

2022-05-24 Thread GitBox
alpreu closed pull request #19660: [FLINK-27185][connectors] Convert connector modules to assertj URL: https://github.com/apache/flink/pull/19660 -- 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] alpreu opened a new pull request, #19809: [FLINK-27185][connectors] Convert connector-kinesis module to assertj

2022-05-24 Thread GitBox
alpreu opened a new pull request, #19809: URL: https://github.com/apache/flink/pull/19809 Cherry-picked commits from https://github.com/apache/flink/pull/19660 to get the individual changes merged faster -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] alpreu opened a new pull request, #19808: [FLINK-27185][connectors] Convert connector-kafka module to assertj

2022-05-24 Thread GitBox
alpreu opened a new pull request, #19808: URL: https://github.com/apache/flink/pull/19808 Cherry-picked commits from https://github.com/apache/flink/pull/19660 to get the individual changes merged faster -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] alpreu opened a new pull request, #19807: [FLINK-27185][connectors] Convert connector-jdbc module to assertj

2022-05-24 Thread GitBox
alpreu opened a new pull request, #19807: URL: https://github.com/apache/flink/pull/19807 Cherry-picked commits from https://github.com/apache/flink/pull/19660 to get the individual changes merged faster -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink-kubernetes-operator] tisonkun commented on pull request #241: [FLINK-27746] Replace git-commit-id-maven-plugin with script

2022-05-24 Thread GitBox
tisonkun commented on PR #241: URL: https://github.com/apache/flink-kubernetes-operator/pull/241#issuecomment-1136032335 It happens that I get some spare time to work on this issue. So now I replace git-commit-id-maven-plugin with script and get rid of force dependency on `.git`. No

[GitHub] [flink-kubernetes-operator] bgeng777 commented on pull request #242: [FLINK-27615] Document how to define namespaceSelector for k8s operator's webhook

2022-05-24 Thread GitBox
bgeng777 commented on PR #242: URL: https://github.com/apache/flink-kubernetes-operator/pull/242#issuecomment-1136017180 cc @wangyang0918 @Aitozi -- 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

  1   2   3   >