[jira] [Created] (FLINK-31275) Generate job id in planner

2023-02-28 Thread Shammon (Jira)
Shammon created FLINK-31275: --- Summary: Generate job id in planner Key: FLINK-31275 URL: https://issues.apache.org/jira/browse/FLINK-31275 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-31274) Python code examples in documentation are not complete

2023-02-28 Thread Ari Huttunen (Jira)
Ari Huttunen created FLINK-31274: Summary: Python code examples in documentation are not complete Key: FLINK-31274 URL: https://issues.apache.org/jira/browse/FLINK-31274 Project: Flink Issue

[jira] [Commented] (FLINK-31266) dashboard info error (received and send alway show 0 when having data)

2023-02-28 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694909#comment-17694909 ] ming li commented on FLINK-31266: - hi, [~Weijie Guo], [~Zhanghao Chen]  It is indeed con

[jira] [Comment Edited] (FLINK-30444) State recovery error not handled correctly and always causes JM failure

2023-02-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694907#comment-17694907 ] Gyula Fora edited comment on FLINK-30444 at 3/1/23 7:48 AM:

[jira] [Commented] (FLINK-30444) State recovery error not handled correctly and always causes JM failure

2023-02-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694907#comment-17694907 ] Gyula Fora commented on FLINK-30444: [~dmvk] I only tested this for 1.16 but it appe

[GitHub] [flink] swuferhong commented on pull request #21622: [FLINK-30570] Fix error inferred partition condition

2023-02-28 Thread via GitHub
swuferhong commented on PR #21622: URL: https://github.com/apache/flink/pull/21622#issuecomment-1449498272 LGTM, cc @godfreyhe -- 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 commen

[GitHub] [flink] flinkbot commented on pull request #22049: [FLINK-31273][table-planner] Fix left join with IS_NULL filter be wrongly pushed down and get wrong join results

2023-02-28 Thread via GitHub
flinkbot commented on PR #22049: URL: https://github.com/apache/flink/pull/22049#issuecomment-1449496876 ## CI report: * 4b12337f38745fb12ab25339c2ccf90531935bc7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-30444) State recovery error not handled correctly and always causes JM failure

2023-02-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694902#comment-17694902 ] David Morávek commented on FLINK-30444: --- > this problem seems to occur even in sim

[GitHub] [flink-kubernetes-operator] tamirsagi commented on a diff in pull request #539: [FLINK-31246] Remove PodTemplate description from the SpecChange message

2023-02-28 Thread via GitHub
tamirsagi commented on code in PR #539: URL: https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1121282661 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java: ## @@ -59,18 +63,48 @@ public String

[jira] [Updated] (FLINK-31092) Hive ITCases fail with OutOfMemoryError

2023-02-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-31092: -- Attachment: -__w-2-s-flink-connectors-flink-connector-hive-target-surefire-reports-2023-02-15T

[jira] [Updated] (FLINK-31273) Left join with IS_NULL filter be wrongly pushed down and get wrong join results

2023-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31273: --- Labels: pull-request-available (was: ) > Left join with IS_NULL filter be wrongly pushed do

[GitHub] [flink] swuferhong opened a new pull request, #22049: [FLINK-31273][table-planner] Fix left join with IS_NULL filter be wrongly pushed down and get wrong join results

2023-02-28 Thread via GitHub
swuferhong opened a new pull request, #22049: URL: https://github.com/apache/flink/pull/22049 ## What is the purpose of the change This pr is aims to fix left join with IS_NULL filter be wrongly pushed down and get wrong join results. The example case is: `SELECT * FROM MyT

[jira] [Commented] (FLINK-31259) Gateway supports initialization of catalog at startup

2023-02-28 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694894#comment-17694894 ] Shammon commented on FLINK-31259: - [~jark] I'm not sure whether my understanding of `glo

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #562: [FLINK-31248] Improve documentation for append-only table

2023-02-28 Thread via GitHub
tsreaper commented on code in PR #562: URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1121244930 ## docs/content/docs/concepts/primary-key-table.md: ## @@ -158,12 +154,28 @@ Full compaction changelog producer can produce complete changelog for any type o

[jira] [Created] (FLINK-31273) Left join with IS_NULL filter be wrongly pushed down and get wrong join results

2023-02-28 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-31273: - Summary: Left join with IS_NULL filter be wrongly pushed down and get wrong join results Key: FLINK-31273 URL: https://issues.apache.org/jira/browse/FLINK-31273 Pro

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #539: [FLINK-31246] Remove PodTemplate description from the SpecChange message

2023-02-28 Thread via GitHub
gyfora commented on code in PR #539: URL: https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1121264500 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/diff/SpecDiffTest.java: ## @@ -181,4 +181,28 @@ public void t

[jira] [Comment Edited] (FLINK-30978) ExecutorImplITCase.testInterruptExecution hangs waiting for SQL gateway service closing

2023-02-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694885#comment-17694885 ] Shengkai Fang edited comment on FLINK-30978 at 3/1/23 7:22 AM: ---

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #210: [FLINK-31010] Add Transformer and Estimator for GBTClassifier and GBTRegressor

2023-02-28 Thread via GitHub
Fanoid commented on code in PR #210: URL: https://github.com/apache/flink-ml/pull/210#discussion_r1121260483 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/gbt/defs/Split.java: ## @@ -0,0 +1,170 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + *

[jira] [Commented] (FLINK-30978) ExecutorImplITCase.testInterruptExecution hangs waiting for SQL gateway service closing

2023-02-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694885#comment-17694885 ] Shengkai Fang commented on FLINK-30978: --- After discussing with colleagues, I find

[jira] [Created] (FLINK-31272) Duplicate operators appear in the StreamGraph for Python DataStream API jobs

2023-02-28 Thread Dian Fu (Jira)
Dian Fu created FLINK-31272: --- Summary: Duplicate operators appear in the StreamGraph for Python DataStream API jobs Key: FLINK-31272 URL: https://issues.apache.org/jira/browse/FLINK-31272 Project: Flink

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #210: [FLINK-31010] Add Transformer and Estimator for GBTClassifier and GBTRegressor

2023-02-28 Thread via GitHub
Fanoid commented on code in PR #210: URL: https://github.com/apache/flink-ml/pull/210#discussion_r1121248937 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/gbt/datastorage/IterationSharedStorage.java: ## @@ -0,0 +1,187 @@ +/* + * Licensed to the Apache Software Foundat

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #210: [FLINK-31010] Add Transformer and Estimator for GBTClassifier and GBTRegressor

2023-02-28 Thread via GitHub
Fanoid commented on code in PR #210: URL: https://github.com/apache/flink-ml/pull/210#discussion_r1121246360 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/gbt/GBTModelParams.java: ## @@ -0,0 +1,56 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one +

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #210: [FLINK-31010] Add Transformer and Estimator for GBTClassifier and GBTRegressor

2023-02-28 Thread via GitHub
Fanoid commented on code in PR #210: URL: https://github.com/apache/flink-ml/pull/210#discussion_r1121245542 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/gbt/GBTModelParams.java: ## @@ -0,0 +1,56 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one +

[jira] [Created] (FLINK-31271) Introduce system database for catalog in table store

2023-02-28 Thread Shammon (Jira)
Shammon created FLINK-31271: --- Summary: Introduce system database for catalog in table store Key: FLINK-31271 URL: https://issues.apache.org/jira/browse/FLINK-31271 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-31259) Gateway supports initialization of catalog at startup

2023-02-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694875#comment-17694875 ] Jark Wu commented on FLINK-31259: - Thank you [~zjureel], do you mean supporting the init

[GitHub] [flink] reswqa commented on a diff in pull request #21673: [FLINK-30513] Cleanup HA storage path on cluster termination

2023-02-28 Thread via GitHub
reswqa commented on code in PR #21673: URL: https://github.com/apache/flink/pull/21673#discussion_r1121208835 ## flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java: ## @@ -225,6 +237,13 @@ public CompletableFuture globalCleanupAsync(Job

[jira] [Assigned] (FLINK-31268) OperatorCoordinator.Context#metricGroup will return null when restore from a savepoint

2023-02-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-31268: --- Assignee: Hang Ruan > OperatorCoordinator.Context#metricGroup will return null when restore from a

[jira] [Closed] (FLINK-31257) Fix errors in “CSV Formats" page

2023-02-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-31257. --- Fix Version/s: 1.18.0 Resolution: Fixed Fixed in master: 33da59089554f74de6330cd9455d34bc8269a580 >

[GitHub] [flink] wuchong merged pull request #22047: [FLINK-31257][docs-zh] Fix errors in “CSV Formats" page

2023-02-28 Thread via GitHub
wuchong merged PR #22047: URL: https://github.com/apache/flink/pull/22047 -- 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

[jira] [Assigned] (FLINK-31257) Fix errors in “CSV Formats" page

2023-02-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-31257: --- Assignee: ZhengYi Weng > Fix errors in “CSV Formats" page > - > >

[jira] [Commented] (FLINK-31211) Flink chk files not delete automic after 1.13

2023-02-28 Thread leo.zhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694872#comment-17694872 ] leo.zhi commented on FLINK-31211: - Thanks, I am trying to upgrade to 1.16 > Flink chk f

[jira] [Comment Edited] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-02-28 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694835#comment-17694835 ] Yue Ma edited comment on FLINK-31238 at 3/1/23 6:03 AM: [~master

[GitHub] [flink] slfan1989 commented on pull request #22020: [FLINK-31222] Remove usage of deprecated ConverterUtils.toApplicationId.

2023-02-28 Thread via GitHub
slfan1989 commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-1449401392 @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] [Commented] (FLINK-26945) Add DATE_SUB supported in SQL & Table API

2023-02-28 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694860#comment-17694860 ] jackylau commented on FLINK-26945: -- and there is a bug is times bultin function, which

[jira] [Closed] (FLINK-31270) Fix flink jar name in docs for table store

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-31270. Fix Version/s: table-store-0.4.0 Assignee: Shammon Resolution: Fixed master: 32e0c

[jira] [Updated] (FLINK-31270) Fix flink jar name in docs for table store

2023-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31270: --- Labels: pull-request-available (was: ) > Fix flink jar name in docs for table store > -

[GitHub] [flink-table-store] JingsongLi merged pull request #567: [FLINK-31270] Fix flink jar name in docs for table store

2023-02-28 Thread via GitHub
JingsongLi merged PR #567: URL: https://github.com/apache/flink-table-store/pull/567 -- 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-26945) Add DATE_SUB supported in SQL & Table API

2023-02-28 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694858#comment-17694858 ] jackylau commented on FLINK-26945: -- and i commit a pr [~lsy] what do you think? > Add

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #550: [FLINK-31178] Public Writer API

2023-02-28 Thread via GitHub
JingsongLi commented on code in PR #550: URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1121176424 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/WriteBuilder.java: ## @@ -0,0 +1,108 @@ +/* + * Licensed to the Apache Softwa

[jira] [Commented] (FLINK-26945) Add DATE_SUB supported in SQL & Table API

2023-02-28 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694857#comment-17694857 ] jackylau commented on FLINK-26945: -- i think it is not good. because the numDays is limi

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #550: [FLINK-31178] Public Writer API

2023-02-28 Thread via GitHub
JingsongLi commented on code in PR #550: URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1121169759 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableCommit.java: ## @@ -18,121 +18,76 @@ package org.apache.flink.table.s

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #550: [FLINK-31178] Public Writer API

2023-02-28 Thread via GitHub
tsreaper commented on code in PR #550: URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1121081241 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableCommit.java: ## @@ -18,121 +18,76 @@ package org.apache.flink.table.sto

[jira] [Created] (FLINK-31270) Fix flink jar name in docs for table store

2023-02-28 Thread Shammon (Jira)
Shammon created FLINK-31270: --- Summary: Fix flink jar name in docs for table store Key: FLINK-31270 URL: https://issues.apache.org/jira/browse/FLINK-31270 Project: Flink Issue Type: Bug Co

[GitHub] [flink-table-store] JingsongLi closed pull request #566: [hotfix] Add DelegateCatalog

2023-02-28 Thread via GitHub
JingsongLi closed pull request #566: [hotfix] Add DelegateCatalog URL: https://github.com/apache/flink-table-store/pull/566 -- 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 u

[GitHub] [flink] flinkbot commented on pull request #22048: [FLINK-31268][metrics] Change not to initialize operator coordinator metric group lazily

2023-02-28 Thread via GitHub
flinkbot commented on PR #22048: URL: https://github.com/apache/flink/pull/22048#issuecomment-1449309260 ## CI report: * 805b73fddd5070e43501a0a8d18c72da76799751 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] slfan1989 commented on pull request #22020: [FLINK-31222] Remove usage of deprecated ConverterUtils.toApplicationId.

2023-02-28 Thread via GitHub
slfan1989 commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-1449306495 @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] [Updated] (FLINK-31268) OperatorCoordinator.Context#metricGroup will return null when restore from a savepoint

2023-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31268: --- Labels: pull-request-available (was: ) > OperatorCoordinator.Context#metricGroup will retur

[GitHub] [flink] ruanhang1993 opened a new pull request, #22048: [FLINK-31268][metrics] Change not to initialize operator coordinator metric group lazily

2023-02-28 Thread via GitHub
ruanhang1993 opened a new pull request, #22048: URL: https://github.com/apache/flink/pull/22048 ## What is the purpose of the change This pull request makes operator coordinator metric group not to be initialized lazily. ## Brief change log - Pass the JobManagerJobMet

[GitHub] [flink] slfan1989 commented on pull request #22020: [FLINK-31222] Remove usage of deprecated ConverterUtils.toApplicationId.

2023-02-28 Thread via GitHub
slfan1989 commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-1449296895 @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] weng1424 commented on pull request #22047: [FLINK-31257][docs-zh] Fix errors in “CSV Formats" page

2023-02-28 Thread via GitHub
weng1424 commented on PR #22047: URL: https://github.com/apache/flink/pull/22047#issuecomment-1449291709 @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] [Created] (FLINK-31269) Split hive connector to each module of each version

2023-02-28 Thread Shammon (Jira)
Shammon created FLINK-31269: --- Summary: Split hive connector to each module of each version Key: FLINK-31269 URL: https://issues.apache.org/jira/browse/FLINK-31269 Project: Flink Issue Type: Improve

[GitHub] [flink] flinkbot commented on pull request #22047: [FLINK-31257][docs-zh] Fix errors in “CSV Formats" page

2023-02-28 Thread via GitHub
flinkbot commented on PR #22047: URL: https://github.com/apache/flink/pull/22047#issuecomment-1449289574 ## CI report: * c50f53b251c6a707d044a8a2d44a946e3dd2f92d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-31257) Fix errors in “CSV Formats" page

2023-02-28 Thread ZhengYi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694837#comment-17694837 ] ZhengYi Weng commented on FLINK-31257: -- Thanks [~jark] ,I have pull the pr for this

[jira] [Created] (FLINK-31268) OperatorCoordinator.Context#metricGroup will return null when restore from a savepoint

2023-02-28 Thread Hang Ruan (Jira)
Hang Ruan created FLINK-31268: - Summary: OperatorCoordinator.Context#metricGroup will return null when restore from a savepoint Key: FLINK-31268 URL: https://issues.apache.org/jira/browse/FLINK-31268 Proj

[GitHub] [flink] X-czh commented on pull request #21673: [FLINK-30513] Cleanup HA storage path on cluster termination

2023-02-28 Thread via GitHub
X-czh commented on PR #21673: URL: https://github.com/apache/flink/pull/21673#issuecomment-1449288098 @reswqa Hi, Weijie. It seems that Wang Yang is busy recently. Could you help review this PR when you are free? -- This is an automated message from the Apache Git Service. To respond to t

[jira] [Updated] (FLINK-31257) Fix errors in “CSV Formats" page

2023-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31257: --- Labels: pull-request-available (was: ) > Fix errors in “CSV Formats" page > --

[GitHub] [flink] weng1424 opened a new pull request, #22047: [FLINK-31257][docs-zh] Fix errors in “CSV Formats" page

2023-02-28 Thread via GitHub
weng1424 opened a new pull request, #22047: URL: https://github.com/apache/flink/pull/22047 ## What is the purpose of the change *I find some errors in Format Options.And I will fix it.* ## Brief change log Fix errors in Format Options. ## Verifying

[GitHub] [flink-kubernetes-operator] haoxins commented on a diff in pull request #540: [FLINK-29566] Reschedule the cleanup logic if cancel job failed

2023-02-28 Thread via GitHub
haoxins commented on code in PR #540: URL: https://github.com/apache/flink-kubernetes-operator/pull/540#discussion_r1121099087 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconciler.java: ## @@ -100,6 +106,26 @

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-02-28 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694835#comment-17694835 ] Yue Ma commented on FLINK-31238: [~masteryhx] Thanks for reply. 1. In our current implem

[GitHub] [flink] 1996fanrui commented on pull request #22020: [FLINK-31222] Remove usage of deprecated ConverterUtils.toApplicationId.

2023-02-28 Thread via GitHub
1996fanrui commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-1449282757 Hi @slfan1989 , could you rebase the master branch? I see other CI works well, and your change shouldn't affect the CI. -- This is an automated message from the Apache Git Service. T

[GitHub] [flink-table-store] zhangjun0x01 closed pull request #547: [FLINK-31128] Add Create Table As for flink table store

2023-02-28 Thread via GitHub
zhangjun0x01 closed pull request #547: [FLINK-31128] Add Create Table As for flink table store URL: https://github.com/apache/flink-table-store/pull/547 -- 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

[jira] [Updated] (FLINK-31267) Fine-Grained Resource Management supports table and sql levels

2023-02-28 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-31267: - Fix Version/s: 1.18.0 > Fine-Grained Resource Management supports table and sql levels > ---

[jira] [Created] (FLINK-31267) Fine-Grained Resource Management supports table and sql levels

2023-02-28 Thread waywtdcc (Jira)
waywtdcc created FLINK-31267: Summary: Fine-Grained Resource Management supports table and sql levels Key: FLINK-31267 URL: https://issues.apache.org/jira/browse/FLINK-31267 Project: Flink Issue

[jira] [Commented] (FLINK-27548) Improve quick-start of table store

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694826#comment-17694826 ] Jingsong Lee commented on FLINK-27548: -- [~monster#12] Thanks assgined > Improve qu

[jira] [Assigned] (FLINK-27548) Improve quick-start of table store

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-27548: Assignee: ZhuoYu Chen > Improve quick-start of table store >

[jira] [Assigned] (FLINK-31253) Port itcases to Flink 1.15 and 1.14

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31253: Assignee: Chao Tian (was: Chao Tian) > Port itcases to Flink 1.15 and 1.14 > ---

[jira] [Commented] (FLINK-31253) Port itcases to Flink 1.15 and 1.14

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694827#comment-17694827 ] Jingsong Lee commented on FLINK-31253: -- [~tyrantlucifer] Assigned thanks! > Port i

[jira] [Assigned] (FLINK-31253) Port itcases to Flink 1.15 and 1.14

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-31253: Assignee: Chao Tian > Port itcases to Flink 1.15 and 1.14 > -

[jira] [Updated] (FLINK-23411) Expose Flink checkpoint details metrics

2023-02-28 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-23411: - Fix Version/s: 1.18.0 > Expose Flink checkpoint details metrics > --

[jira] [Commented] (FLINK-31266) dashboard info error (received and send alway show 0 when having data)

2023-02-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694822#comment-17694822 ] Weijie Guo commented on FLINK-31266: Generally speaking, flink compute the send & re

[jira] [Commented] (FLINK-31259) Gateway supports initialization of catalog at startup

2023-02-28 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694821#comment-17694821 ] Shammon commented on FLINK-31259: - Hi [~jark] We'd like to initialize catalogs in sessio

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #562: [FLINK-31248] Improve documentation for append-only table

2023-02-28 Thread via GitHub
SteNicholas commented on code in PR #562: URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1121073993 ## docs/content/docs/features/append-only-table.md: ## @@ -0,0 +1,97 @@ +--- +title: "Append Only Table" +weight: 2 +type: docs +aliases: +- /features/appen

[jira] [Comment Edited] (FLINK-31213) Aggregation merge engine supports retract inputs

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693969#comment-17693969 ] Jingsong Lee edited comment on FLINK-31213 at 3/1/23 2:39 AM:

[jira] [Updated] (FLINK-31213) Aggregation merge engine supports retract inputs

2023-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31213: - Fix Version/s: table-store-0.3.1 > Aggregation merge engine supports retract inputs > --

[jira] [Commented] (FLINK-31266) dashboard info error (received and send alway show 0 when having data)

2023-02-28 Thread linqichen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694816#comment-17694816 ] linqichen commented on FLINK-31266: --- No matter what connector, kafka, datagen It‘

[jira] [Comment Edited] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-02-28 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694813#comment-17694813 ] Hangxiang Yu edited comment on FLINK-31238 at 3/1/23 2:17 AM:

[jira] [Comment Edited] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-02-28 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694813#comment-17694813 ] Hangxiang Yu edited comment on FLINK-31238 at 3/1/23 2:17 AM:

[jira] [Commented] (FLINK-31266) dashboard info error (received and send alway show 0 when having data)

2023-02-28 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694814#comment-17694814 ] Zhanghao Chen commented on FLINK-31266: --- Are you using connectors that implements

[jira] [Commented] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-02-28 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694813#comment-17694813 ] Hangxiang Yu commented on FLINK-31238: -- Thank you for sharing the design. The durat

[jira] [Commented] (FLINK-31257) Fix errors in “CSV Formats" page

2023-02-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694812#comment-17694812 ] Jark Wu commented on FLINK-31257: - You can translate it into “指定识别成 null 值的字符串,在输入端会将该字符

[jira] [Commented] (FLINK-31259) Gateway supports initialization of catalog at startup

2023-02-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694811#comment-17694811 ] Jark Wu commented on FLINK-31259: - Could you share more details of the purpose and desig

[jira] [Commented] (FLINK-31266) dashboard info error (received and send alway show 0 when having data)

2023-02-28 Thread linqichen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694810#comment-17694810 ] linqichen commented on FLINK-31266: --- hey, guys!!  I find that the "0 recevied and 0 se

[jira] [Created] (FLINK-31266) dashboard info error (received and send alway show 0 when having data)

2023-02-28 Thread linqichen (Jira)
linqichen created FLINK-31266: - Summary: dashboard info error (received and send alway show 0 when having data) Key: FLINK-31266 URL: https://issues.apache.org/jira/browse/FLINK-31266 Project: Flink

[GitHub] [flink-table-store] zhangjun0x01 commented on pull request #547: [FLINK-31128] Add Create Table As for flink table store

2023-02-28 Thread via GitHub
zhangjun0x01 commented on PR #547: URL: https://github.com/apache/flink-table-store/pull/547#issuecomment-1449196021 > It seems that some comments are not solved. @zhangjun0x01 hi,@JingsongLi ,I updated the comment,but I run the failed UT `org.apache.flink.table.store.file.operation.

[jira] [Resolved] (FLINK-24545) job that read data from hive will finished even though i set streaming mode

2023-02-28 Thread linqichen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqichen resolved FLINK-24545. --- Resolution: Done > job that read data from hive will finished even though i set streaming mode > ---

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #562: [FLINK-31248] Improve documentation for append-only table

2023-02-28 Thread via GitHub
tsreaper commented on code in PR #562: URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1121019633 ## docs/content/docs/features/append-only-table.md: ## @@ -0,0 +1,97 @@ +--- +title: "Append Only Table" +weight: 2 +type: docs +aliases: +- /features/append-o

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #562: [FLINK-31248] Improve documentation for append-only table

2023-02-28 Thread via GitHub
JingsongLi commented on code in PR #562: URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1121010281 ## docs/content/docs/features/append-only-table.md: ## @@ -0,0 +1,97 @@ +--- +title: "Append Only Table" +weight: 2 +type: docs +aliases: +- /features/append

[jira] [Closed] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

2023-02-28 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-31082. -- Resolution: Fixed > Setting maven property 'flink.resueForks' to false in table planner module >

[jira] [Commented] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

2023-02-28 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694800#comment-17694800 ] Godfrey He commented on FLINK-31082: Fixed in 1.16.2: 247a099cc358e0006aa0e387a55cf6

[GitHub] [flink] godfreyhe merged pull request #22045: [FLINK-31082][table-planner] Setting maven property 'flink.resueForks' to false in table planner module

2023-02-28 Thread via GitHub
godfreyhe merged PR #22045: URL: https://github.com/apache/flink/pull/22045 -- 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] slfan1989 commented on pull request #22020: [FLINK-31222] Remove usage of deprecated ConverterUtils.toApplicationId.

2023-02-28 Thread via GitHub
slfan1989 commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-1449087453 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [flink] flinkbot commented on pull request #22046: [WIP][FLINK-31261][runtime] Make AdaptiveScheduler aware of local state size

2023-02-28 Thread via GitHub
flinkbot commented on PR #22046: URL: https://github.com/apache/flink/pull/22046#issuecomment-1449036232 ## CI report: * 027cb93f548f11e37c6d283413bfa9bc98d06c18 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22046: [WIP][FLINK-31261][runtime] Make AdaptiveScheduler aware of local state size

2023-02-28 Thread via GitHub
rkhachatryan commented on code in PR #22046: URL: https://github.com/apache/flink/pull/22046#discussion_r1120882084 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java: ## @@ -64,7 +64,7 @@ CompletedCheckpoint addCheckpointAndSubsumeO

[jira] [Updated] (FLINK-31261) Make AdaptiveScheduler aware of the (local) state size

2023-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31261: --- Labels: pull-request-available (was: ) > Make AdaptiveScheduler aware of the (local) state

[GitHub] [flink] rkhachatryan opened a new pull request, #22046: [WIP][FLINK-31261][runtime] Make AdaptiveScheduler aware of local state size

2023-02-28 Thread via GitHub
rkhachatryan opened a new pull request, #22046: URL: https://github.com/apache/flink/pull/22046 Work in progress. Includes commits from #21981 -- 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-kubernetes-operator] pvary commented on a diff in pull request #539: [FLINK-31246] Remove PodTemplate description from the SpecChange message

2023-02-28 Thread via GitHub
pvary commented on code in PR #539: URL: https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1120843867 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java: ## @@ -59,18 +63,48 @@ public String toS

[GitHub] [flink-kubernetes-operator] pvary commented on a diff in pull request #539: [FLINK-31246] Remove PodTemplate description from the SpecChange message

2023-02-28 Thread via GitHub
pvary commented on code in PR #539: URL: https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1120839501 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java: ## @@ -59,18 +63,48 @@ public String toS

[GitHub] [flink-kubernetes-operator] pvary commented on a diff in pull request #539: [FLINK-31246] Remove PodTemplate description from the SpecChange message

2023-02-28 Thread via GitHub
pvary commented on code in PR #539: URL: https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1120835414 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java: ## @@ -59,18 +63,48 @@ public String toS

[jira] [Commented] (FLINK-30444) State recovery error not handled correctly and always causes JM failure

2023-02-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694750#comment-17694750 ] Gyula Fora commented on FLINK-30444: [~dmvk] this problem seems to occur even in sim

[GitHub] [flink-kubernetes-operator] tamirsagi commented on a diff in pull request #539: [FLINK-31246] Remove PodTemplate description from the SpecChange message

2023-02-28 Thread via GitHub
tamirsagi commented on code in PR #539: URL: https://github.com/apache/flink-kubernetes-operator/pull/539#discussion_r1120494892 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java: ## @@ -59,18 +63,48 @@ public String

  1   2   3   >