[jira] [Commented] (FLINK-25343) HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure

2022-09-26 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609858#comment-17609858 ] Martijn Visser commented on FLINK-25343: [~ferenc-csaky] Could you help with thi

[jira] [Assigned] (FLINK-25343) HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure

2022-09-26 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25343: -- Assignee: Ferenc Csaky (was: Jing Ge) > HBaseConnectorITCase.testTableSourceSinkWith

[jira] [Assigned] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-29419: Assignee: Weijie Guo > HybridShuffle.testHybridFullExchangesRestart hangs > -

[jira] [Comment Edited] (FLINK-29427) LookupJoinITCase failed with classloader problem

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609843#comment-17609843 ] Huang Xingbo edited comment on FLINK-29427 at 9/27/22 6:23 AM: ---

[jira] [Commented] (FLINK-29427) LookupJoinITCase failed with classloader problem

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609843#comment-17609843 ] Huang Xingbo commented on FLINK-29427: -- cc [~renqs] > LookupJoinITCase failed with

[jira] [Created] (FLINK-29427) LookupJoinITCase failed with classloader problem

2022-09-26 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-29427: Summary: LookupJoinITCase failed with classloader problem Key: FLINK-29427 URL: https://issues.apache.org/jira/browse/FLINK-29427 Project: Flink Issue Type:

[jira] [Commented] (FLINK-29408) HiveCatalogITCase failed with NPE

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609841#comment-17609841 ] Huang Xingbo commented on FLINK-29408: -- cc [~luoyuxia] > HiveCatalogITCase failed

[jira] [Commented] (FLINK-29408) HiveCatalogITCase failed with NPE

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609832#comment-17609832 ] Huang Xingbo commented on FLINK-29408: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-29408) HiveCatalogITCase failed with NPE

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-29408: - Priority: Critical (was: Major) > HiveCatalogITCase failed with NPE > -

[jira] [Updated] (FLINK-29408) HiveCatalogITCase failed with NPE

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-29408: - Affects Version/s: 1.16.0 > HiveCatalogITCase failed with NPE >

[GitHub] [flink] leletan commented on pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-26 Thread GitBox
leletan commented on PR #20852: URL: https://github.com/apache/flink/pull/20852#issuecomment-1259021651 Hi folks, @pnowojski @stevenzwu @zentol I believe I addressed all comments except the pending naming of the old CheckpointType class name. Personally I don't have any strong opinion ab

[jira] [Updated] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-29419: - Affects Version/s: 1.16.0 > HybridShuffle.testHybridFullExchangesRestart hangs > ---

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609830#comment-17609830 ] Huang Xingbo commented on FLINK-29419: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609828#comment-17609828 ] Huang Xingbo commented on FLINK-29387: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-29408) HiveCatalogITCase failed with NPE

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609827#comment-17609827 ] Huang Xingbo commented on FLINK-29408: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-29424) Add Pull Request Template for flink-ml Project

2022-09-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29424: --- Labels: pull-request-available (was: ) > Add Pull Request Template for flink-ml Project > -

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #159: [FLINK-29424] Add Pull Request Template

2022-09-26 Thread GitBox
jiangxin369 opened a new pull request, #159: URL: https://github.com/apache/flink-ml/pull/159 ## What is the purpose of the change Add Pull Request Template for Flink ML ## Brief change log - Add Pull Request Template for Flink ML ## Does this pull request potent

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #158: [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector

2022-09-26 Thread GitBox
jiangxin369 commented on code in PR #158: URL: https://github.com/apache/flink-ml/pull/158#discussion_r980765655 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/variancethresholdselector/VarianceThresholdSelectorParams.java: ## @@ -0,0 +1,48 @@ +/* + * Licensed to the

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #158: [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector

2022-09-26 Thread GitBox
yunfengzhou-hub commented on code in PR #158: URL: https://github.com/apache/flink-ml/pull/158#discussion_r980705519 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/variancethresholdselector/VarianceThresholdSelectorParams.java: ## @@ -0,0 +1,48 @@ +/* + * Licensed to

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #158: [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector

2022-09-26 Thread GitBox
yunfengzhou-hub commented on code in PR #158: URL: https://github.com/apache/flink-ml/pull/158#discussion_r980705519 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/variancethresholdselector/VarianceThresholdSelectorParams.java: ## @@ -0,0 +1,48 @@ +/* + * Licensed to

[jira] [Assigned] (FLINK-28256) Move the write and prepareCommit logic of AbstractTableWrite to FileStoreWrite

2022-09-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28256: Assignee: Shammon > Move the write and prepareCommit logic of AbstractTableWrite to FileS

[jira] [Updated] (FLINK-28256) Move the write and prepareCommit logic of AbstractTableWrite to FileStoreWrite

2022-09-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28256: --- Labels: pull-request-available (was: ) > Move the write and prepareCommit logic of Abstract

[GitHub] [flink-table-store] zjureel opened a new pull request, #305: [FLINK-28256] Move the write and prepareCommit logic of AbstractTableWrite to FileStoreWrite

2022-09-26 Thread GitBox
zjureel opened a new pull request, #305: URL: https://github.com/apache/flink-table-store/pull/305 Currently `TableWrite` creates and manages the `RecordWriter`, which is created by `FileStoreWrite`. As `TableWrite` corresponds to `FileStoreTable` and `FileStoreWrite` corresponds to `FileSt

[jira] [Created] (FLINK-29426) Flink ML 2.1.0 Installation

2022-09-26 Thread Tony Sun (Jira)
Tony Sun created FLINK-29426: Summary: Flink ML 2.1.0 Installation Key: FLINK-29426 URL: https://issues.apache.org/jira/browse/FLINK-29426 Project: Flink Issue Type: Bug Components: Qui

[GitHub] [flink-docker] HuangXingBo closed pull request #136: Update Dockerfiles for 1.14.6 release

2022-09-26 Thread GitBox
HuangXingBo closed pull request #136: Update Dockerfiles for 1.14.6 release URL: https://github.com/apache/flink-docker/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.

[GitHub] [flink-docker] HuangXingBo closed pull request #135: Add GPG key for 1.14.6 release

2022-09-26 Thread GitBox
HuangXingBo closed pull request #135: Add GPG key for 1.14.6 release URL: https://github.com/apache/flink-docker/pull/135 -- 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 uns

[jira] [Created] (FLINK-29425) Hybrid full spilling strategy triggering spilling frequently

2022-09-26 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-29425: -- Summary: Hybrid full spilling strategy triggering spilling frequently Key: FLINK-29425 URL: https://issues.apache.org/jira/browse/FLINK-29425 Project: Flink Iss

[jira] [Commented] (FLINK-19822) Remove redundant shuffle for streaming

2022-09-26 Thread Alexander Smirnov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609812#comment-17609812 ] Alexander Smirnov commented on FLINK-19822: --- Hi [~godfreyhe]! I'm wondering wh

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #157: [FLINK-28906] Support windowing in AgglomerativeClustering

2022-09-26 Thread GitBox
lindong28 commented on code in PR #157: URL: https://github.com/apache/flink-ml/pull/157#discussion_r980594756 ## flink-ml-python/pyflink/ml/lib/clustering/agglomerativeclustering.py: ## @@ -112,15 +113,20 @@ def compute_full_tree(self): class AgglomerativeClustering(JavaCluste

[jira] [Updated] (FLINK-29424) Add Pull Request Template for flink-ml Project

2022-09-26 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-29424: -- Component/s: Library / Machine Learning > Add Pull Request Template for flink-ml Project > ---

[jira] [Created] (FLINK-29424) Add Pull Request Template for flink-ml Project

2022-09-26 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-29424: - Summary: Add Pull Request Template for flink-ml Project Key: FLINK-29424 URL: https://issues.apache.org/jira/browse/FLINK-29424 Project: Flink Issue Type: New Feat

[GitHub] [flink] wangyang0918 commented on a diff in pull request #20867: [FLINK-29372] Add suffix to all options that conflict with YAML

2022-09-26 Thread GitBox
wangyang0918 commented on code in PR #20867: URL: https://github.com/apache/flink/pull/20867#discussion_r980692851 ## flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java: ## @@ -447,7 +450,7 @@ public class KubernetesConfigOption

[jira] [Updated] (FLINK-29181) log.system can be congiured by dynamic options

2022-09-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29181: - Issue Type: Improvement (was: New Feature) > log.system can be congiured by dynamic options > -

[jira] [Updated] (FLINK-29154) Support LookupTableSource for table store

2022-09-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29154: - Issue Type: Improvement (was: New Feature) > Support LookupTableSource for table store > --

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #158: [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector

2022-09-26 Thread GitBox
jiangxin369 commented on code in PR #158: URL: https://github.com/apache/flink-ml/pull/158#discussion_r980677136 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/variancethresholdselector/VarianceThresholdSelectorModelData.java: ## @@ -0,0 +1,121 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-29154) Support LookupTableSource for table store

2022-09-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29154: - Fix Version/s: table-store-0.2.1 > Support LookupTableSource for table store > -

[jira] [Comment Edited] (FLINK-29154) Support LookupTableSource for table store

2022-09-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17600665#comment-17600665 ] Jingsong Lee edited comment on FLINK-29154 at 9/27/22 2:09 AM: ---

[jira] [Commented] (FLINK-29421) Support python 3.10

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609778#comment-17609778 ] Huang Xingbo commented on FLINK-29421: -- Currently, pyflink hasn't supported Python3

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #158: [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector

2022-09-26 Thread GitBox
jiangxin369 commented on code in PR #158: URL: https://github.com/apache/flink-ml/pull/158#discussion_r980656357 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/variancethresholdselector/VarianceThresholdSelectorModel.java: ## @@ -0,0 +1,172 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-29219) CREATE TABLE AS statement blocks SQL client's execution

2022-09-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-29219. --- Fix Version/s: 1.17.0 Resolution: Fixed Fixed in - master: 44009efc5400c6706563fa53335eccf445cf5d0c

[GitHub] [flink] wuchong merged pull request #20880: [FLINK-29219][table] Fix CREATE TABLE AS statement blocks SQL client's execution

2022-09-26 Thread GitBox
wuchong merged PR #20880: URL: https://github.com/apache/flink/pull/20880 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

[GitHub] [flink] wuchong merged pull request #20869: [FLINK-29219][table] Fix CREATE TABLE AS statement blocks SQL client's execution

2022-09-26 Thread GitBox
wuchong merged PR #20869: URL: https://github.com/apache/flink/pull/20869 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #158: [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector

2022-09-26 Thread GitBox
yunfengzhou-hub commented on code in PR #158: URL: https://github.com/apache/flink-ml/pull/158#discussion_r980634965 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/variancethresholdselector/VarianceThresholdSelectorParams.java: ## @@ -0,0 +1,47 @@ +/* + * Licensed to

[GitHub] [flink-ml] lindong28 commented on pull request #157: [FLINK-28906] Support windowing in AgglomerativeClustering

2022-09-26 Thread GitBox
lindong28 commented on PR #157: URL: https://github.com/apache/flink-ml/pull/157#issuecomment-1258769768 Thanks for the PR! LGTM overall. Can you fix the test failures? @zhipeng93 do you want to take a look at this PR? -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-29418) Update flink-shaded

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

[GitHub] [flink-shaded] zentol opened a new pull request, #112: [FLINK-29418] Everybody gets an upgrade!

2022-09-26 Thread GitBox
zentol opened a new pull request, #112: URL: https://github.com/apache/flink-shaded/pull/112 Except guava. The upgrades were all tested against 1.17-SNAPSHOT. For 1.16 I'm only interested in the Jackson upgrade, which has some slight behavior changes w.r.t. how the result of the docs

[GitHub] [flink] flinkbot commented on pull request #20903: [FLINK-29402][state backends] Add RocksDB options for DirectIO reads …

2022-09-26 Thread GitBox
flinkbot commented on PR #20903: URL: https://github.com/apache/flink/pull/20903#issuecomment-1258630220 ## CI report: * 70ab91e25623f474698e153622e52d459eaf0530 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

2022-09-26 Thread Donatien (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Donatien updated FLINK-29402: - Fix Version/s: 1.16.0 (was: 1.15.2) Affects Version/s: 1.16.0

[jira] [Updated] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

2022-09-26 Thread Donatien (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Donatien updated FLINK-29402: - Labels: Enhancement pull-request-available rocksdb (was: Enhancement pull-request-available pull_reques

[jira] [Updated] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

2022-09-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29402: --- Labels: Enhancement pull-request-available rocksdb (was: Enhancement rocksdb) > Add USE_DI

[GitHub] [flink] Donaschmi opened a new pull request, #20903: [FLINK-29402][state backends] Add RocksDB options for DirectIO reads …

2022-09-26 Thread GitBox
Donaschmi opened a new pull request, #20903: URL: https://github.com/apache/flink/pull/20903 ## What is the purpose of the change This pull request adds two configurable RocksDB options enabling the use of DirectIO for reads and background flush and compactions. ##

[GitHub] [flink] stevenzwu commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-26 Thread GitBox
stevenzwu commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r980390428 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -863,11 +871,6 @@ public CompletableFuture triggerSavepoint( return sc

[GitHub] [flink] stevenzwu commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-26 Thread GitBox
stevenzwu commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r980387378 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java: ## @@ -878,7 +879,8 @@ public CompletableFuture triggerSavepoint( } @

[GitHub] [flink] cfedersp commented on pull request #19861: [hotfix] [docs] Fix use cases for HashMapStateBackend

2022-09-26 Thread GitBox
cfedersp commented on PR #19861: URL: https://github.com/apache/flink/pull/19861#issuecomment-1258459137 Theres also a factual error on this page where it states: The EmbeddedRocksDBStateBackend holds in-flight data in a RocksDB database that is (per default) stored in the TaskManager loc

[GitHub] [flink] afedulov commented on pull request #20865: [FLINK-14896][connectors/kinesis] Shade and relocate Jackson dependen…

2022-09-26 Thread GitBox
afedulov commented on PR #20865: URL: https://github.com/apache/flink/pull/20865#issuecomment-1258433441 @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] [Assigned] (FLINK-29423) JobDetails is incorrect OpenAPI spec

2022-09-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-29423: Assignee: Chesnay Schepler > JobDetails is incorrect OpenAPI spec >

[jira] [Created] (FLINK-29423) JobDetails is incorrect OpenAPI spec

2022-09-26 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29423: Summary: JobDetails is incorrect OpenAPI spec Key: FLINK-29423 URL: https://issues.apache.org/jira/browse/FLINK-29423 Project: Flink Issue Type: Bug

[GitHub] [flink] leletan commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-26 Thread GitBox
leletan commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r980354599 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -853,6 +855,12 @@ public CompletableFuture requestJob(Time timeout) { r

[GitHub] [flink] leletan commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-26 Thread GitBox
leletan commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r980350376 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -863,11 +871,6 @@ public CompletableFuture triggerSavepoint( return sche

[GitHub] [flink] leletan commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-26 Thread GitBox
leletan commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r980350376 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java: ## @@ -863,11 +871,6 @@ public CompletableFuture triggerSavepoint( return sche

[GitHub] [flink] stevenzwu commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-26 Thread GitBox
stevenzwu commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r980320317 ## flink-core/src/main/java/org/apache/flink/core/execution/CheckpointBackupType.java: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (ASF) und

[GitHub] [flink] reswqa commented on pull request #20902: [FLINK-29419] fix the problem that testHybridFullExchangesRestart hang.

2022-09-26 Thread GitBox
reswqa commented on PR #20902: URL: https://github.com/apache/flink/pull/20902#issuecomment-1258354359 @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. T

[jira] [Created] (FLINK-29422) Production tests return/argument types do not take transitivity into account

2022-09-26 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29422: Summary: Production tests return/argument types do not take transitivity into account Key: FLINK-29422 URL: https://issues.apache.org/jira/browse/FLINK-29422

[jira] [Updated] (FLINK-29413) Make it possible to associate triggered and completed savepoints

2022-09-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29413: --- Fix Version/s: kubernetes-operator-1.3.0 > Make it possible to associate triggered and completed sav

[jira] [Assigned] (FLINK-29413) Make it possible to associate triggered and completed savepoints

2022-09-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29413: -- Assignee: Gyula Fora > Make it possible to associate triggered and completed savepoints > ---

[jira] [Commented] (FLINK-29413) Make it possible to associate triggered and completed savepoints

2022-09-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609572#comment-17609572 ] Gyula Fora commented on FLINK-29413: We don't really see any other way to retrieve t

[jira] [Commented] (FLINK-29413) Make it possible to associate triggered and completed savepoints

2022-09-26 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609561#comment-17609561 ] Thomas Weise commented on FLINK-29413: -- +1 for tracking the triggering nonce Would

[GitHub] [flink] zentol commented on a diff in pull request #20893: [FLINK-29403][cep] Streamline SimpleCondition usage

2022-09-26 Thread GitBox
zentol commented on code in PR #20893: URL: https://github.com/apache/flink/pull/20893#discussion_r980213947 ## flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/SimpleCondition.java: ## @@ -40,4 +40,13 @@ public boolean filter(T value, Context

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #386: [FLINK-29376] Set SHUTDOWN_ON_APPLICATION_FINISH to false only on 1.15 and above

2022-09-26 Thread GitBox
gaborgsomogyi commented on PR #386: URL: https://github.com/apache/flink-kubernetes-operator/pull/386#issuecomment-1258232704 cc @gyfora -- 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 spec

[jira] [Updated] (FLINK-29376) Deployment already exists error if Flink version is not set correctly

2022-09-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29376: --- Labels: pull-request-available (was: ) > Deployment already exists error if Flink version i

[GitHub] [flink-kubernetes-operator] gaborgsomogyi opened a new pull request, #386: [FLINK-29376] Set SHUTDOWN_ON_APPLICATION_FINISH to false only on 1.15 and above

2022-09-26 Thread GitBox
gaborgsomogyi opened a new pull request, #386: URL: https://github.com/apache/flink-kubernetes-operator/pull/386 ## What is the purpose of the change If the user incorrectly sets a Flink version lower than 1.15 when using 1.15 or above: ``` image: flink:1.15 flinkVersion: v

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on a diff in pull request #382: [FLINK-29392] Trigger error when session job is lost without HA

2022-09-26 Thread GitBox
gaborgsomogyi commented on code in PR #382: URL: https://github.com/apache/flink-kubernetes-operator/pull/382#discussion_r980187297 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java: ## @@ -72,22 +81,91 @@ public boo

[jira] [Closed] (FLINK-29109) Checkpoint path conflict with stateless upgrade mode

2022-09-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29109. -- Fix Version/s: kubernetes-operator-1.2.0 Resolution: Fixed merged to main 6f0914bbd296c9daf2664

[jira] [Commented] (FLINK-29413) Make it possible to associate triggered and completed savepoints

2022-09-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609537#comment-17609537 ] Gyula Fora commented on FLINK-29413: I guess we could add that too if there is no ot

[jira] [Commented] (FLINK-29413) Make it possible to associate triggered and completed savepoints

2022-09-26 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609527#comment-17609527 ] Matyas Orhidi commented on FLINK-29413: --- Would it makes sense to add the format ty

[GitHub] [flink-kubernetes-operator] mbalassi commented on a diff in pull request #383: [FLINK-29384] Bump snakeyaml version to 1.32

2022-09-26 Thread GitBox
mbalassi commented on code in PR #383: URL: https://github.com/apache/flink-kubernetes-operator/pull/383#discussion_r980116122 ## flink-kubernetes-operator/pom.xml: ## @@ -47,6 +47,20 @@ under the License. io.fabric8 kubernetes-client ${fa

[jira] [Created] (FLINK-29421) Support python 3.10

2022-09-26 Thread Eric Sirianni (Jira)
Eric Sirianni created FLINK-29421: - Summary: Support python 3.10 Key: FLINK-29421 URL: https://issues.apache.org/jira/browse/FLINK-29421 Project: Flink Issue Type: Bug Components: A

[GitHub] [flink-kubernetes-operator] mbalassi commented on a diff in pull request #383: [FLINK-29384] Bump snakeyaml version to 1.32

2022-09-26 Thread GitBox
mbalassi commented on code in PR #383: URL: https://github.com/apache/flink-kubernetes-operator/pull/383#discussion_r980109419 ## flink-kubernetes-shaded/pom.xml: ## @@ -88,6 +103,7 @@ under the License. META-INF/DEPENDENCIES

[jira] [Created] (FLINK-29420) Add support for Zookeeper 3.7 / 3.8

2022-09-26 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29420: Summary: Add support for Zookeeper 3.7 / 3.8 Key: FLINK-29420 URL: https://issues.apache.org/jira/browse/FLINK-29420 Project: Flink Issue Type: Impro

[GitHub] [flink-kubernetes-operator] tweise merged pull request #385: [FLINK-29109] Avoid checkpoint path conflicts (Flink < 1.16)

2022-09-26 Thread GitBox
tweise merged PR #385: URL: https://github.com/apache/flink-kubernetes-operator/pull/385 -- 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-29414) Setup license checks

2022-09-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29414. Resolution: Fixed master: 575912de77153544a5e4211f504cc67e5ee776a8 > Setup license checks

[GitHub] [flink-shaded] zentol merged pull request #111: [FLINK-29414] Setup license check

2022-09-26 Thread GitBox
zentol merged PR #111: URL: https://github.com/apache/flink-shaded/pull/111 -- 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

[jira] [Commented] (FLINK-29416) One or more fetchers have encountered exception

2022-09-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609511#comment-17609511 ] Weijie Guo commented on FLINK-29416: It seems that direct memory is not enough, you

[GitHub] [flink-shaded] zentol commented on a diff in pull request #111: [FLINK-29414] Setup license check

2022-09-26 Thread GitBox
zentol commented on code in PR #111: URL: https://github.com/apache/flink-shaded/pull/111#discussion_r980060247 ## .github/workflows/ci.yml: ## @@ -5,12 +5,37 @@ on: [push, pull_request] jobs: build: runs-on: ubuntu-latest +env: + MVN_COMMON_OPTIONS: -U -B --no

[GitHub] [flink-shaded] MartijnVisser commented on a diff in pull request #111: [FLINK-29414] Setup license check

2022-09-26 Thread GitBox
MartijnVisser commented on code in PR #111: URL: https://github.com/apache/flink-shaded/pull/111#discussion_r980050857 ## .github/workflows/ci.yml: ## @@ -5,12 +5,37 @@ on: [push, pull_request] jobs: build: runs-on: ubuntu-latest +env: + MVN_COMMON_OPTIONS: -U

[GitHub] [flink] flinkbot commented on pull request #20902: [FLINK-29419] fix the problem that testHybridFullExchangesRestart hang.

2022-09-26 Thread GitBox
flinkbot commented on PR #20902: URL: https://github.com/apache/flink/pull/20902#issuecomment-1258054514 ## CI report: * f57a254ef0d910a65628bb709d8030cf7a63f39b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-09-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29419: --- Labels: pull-request-available test-stability (was: test-stability) > HybridShuffle.testHyb

[GitHub] [flink] reswqa opened a new pull request, #20902: [FLINK-29419] fix the problem that testHybridFullExchangesRestart hang.

2022-09-26 Thread GitBox
reswqa opened a new pull request, #20902: URL: https://github.com/apache/flink/pull/20902 ## 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 on

[jira] [Closed] (FLINK-29415) InitializationFailure when recovering from a checkpoint in Application Mode leads to the cleanup of all HA data

2022-09-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-29415. - Resolution: Invalid There is a solution for this specific case already with {{execution.submit-

[jira] [Closed] (FLINK-29412) Connection leak in orc reader

2022-09-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29412. Resolution: Fixed master: 29fc9adf023a04b02126f50d915feb55fdbc2327 release-0.2: 311ab67dd2d7dcb4a7

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-09-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609486#comment-17609486 ] Weijie Guo commented on FLINK-29419: [~hxbks2ks] Thanks for the feedback. I will che

[GitHub] [flink-table-store] JingsongLi merged pull request #304: [FLINK-29412] Connection leak in orc reader

2022-09-26 Thread GitBox
JingsongLi merged PR #304: URL: https://github.com/apache/flink-table-store/pull/304 -- 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] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609482#comment-17609482 ] Huang Xingbo commented on FLINK-29419: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609481#comment-17609481 ] Huang Xingbo commented on FLINK-29419: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-09-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609480#comment-17609480 ] Huang Xingbo commented on FLINK-29419: -- cc [~Weijie Guo] > HybridShuffle.testHybri

[jira] [Closed] (FLINK-27346) [umbrella] Introduce Hive reader for table store

2022-09-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27346. Resolution: Fixed > [umbrella] Introduce Hive reader for table store > ---

[jira] [Created] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-09-26 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-29419: Summary: HybridShuffle.testHybridFullExchangesRestart hangs Key: FLINK-29419 URL: https://issues.apache.org/jira/browse/FLINK-29419 Project: Flink Issue Type

[jira] [Commented] (FLINK-27843) Schema evolution for data file meta

2022-09-26 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609470#comment-17609470 ] liwei li commented on FLINK-27843: -- May i have a try? > Schema evolution for data file

[jira] [Commented] (FLINK-29243) Introduce a COW mode for table store

2022-09-26 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609465#comment-17609465 ] liwei li commented on FLINK-29243: -- i want to have a try, could you gave me the ticket?

[GitHub] [flink] flinkbot commented on pull request #20901: [FLINK-26943][table-planner-blink] Support date_add function in sql

2022-09-26 Thread GitBox
flinkbot commented on PR #20901: URL: https://github.com/apache/flink/pull/20901#issuecomment-1257928071 ## CI report: * e9ed9084724236b500271fdcf5d1de5aef056496 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

  1   2   3   >