[jira] [Commented] (FLINK-28984) FsCheckpointStateOutputStream is not being released normally

2022-08-17 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581190#comment-17581190 ] ChangjiGuo commented on FLINK-28984: Hi [~yunta], I have verified on Flink-1.15.1.

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #349: [FLINK-28218] Add liveness probe to k8s operator

2022-08-17 Thread GitBox
morhidi commented on code in PR #349: URL: https://github.com/apache/flink-kubernetes-operator/pull/349#discussion_r948718050 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/health/DummyHealthProbe.java: ## @@ -0,0 +1,27 @@ +/* + * Licensed to th

[GitHub] [flink-kubernetes-operator] kaskol10 commented on pull request #348: [docs] Adding helm-docs step in CI and README.md

2022-08-17 Thread GitBox
kaskol10 commented on PR #348: URL: https://github.com/apache/flink-kubernetes-operator/pull/348#issuecomment-1219104794 The description could be added to the current values.yaml based on the [helm-docs documentation](https://github.com/norwoodj/helm-docs#helm-docs) and it would be pretty

[GitHub] [flink] flinkbot commented on pull request #20616: [FLINK-29005][Connectors/Parquet] Parquet row type reader should not …

2022-08-17 Thread GitBox
flinkbot commented on PR #20616: URL: https://github.com/apache/flink/pull/20616#issuecomment-1219097341 ## CI report: * 1cd1fb528f210189a88f0662d0aa3b883913c3aa UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #348: [docs] Adding helm-docs step in CI and README.md

2022-08-17 Thread GitBox
gyfora commented on PR #348: URL: https://github.com/apache/flink-kubernetes-operator/pull/348#issuecomment-1219096705 It would be great to integrate this into the regular docs but the problem I see is that this is not actually “documentation “ . it only lists the possible config par

[GitHub] [flink] snuyanzin commented on pull request #20546: [FLINK-28919][table] Add built-in generate_series function.

2022-08-17 Thread GitBox
snuyanzin commented on PR #20546: URL: https://github.com/apache/flink/pull/20546#issuecomment-1219095561 Thanks for contribution It would be great to have filled PR template i also left some comments -- This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] snuyanzin commented on a diff in pull request #20546: [FLINK-28919][table] Add built-in generate_series function.

2022-08-17 Thread GitBox
snuyanzin commented on code in PR #20546: URL: https://github.com/apache/flink/pull/20546#discussion_r948708082 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/GenerateSeriesFunction.java: ## @@ -0,0 +1,109 @@ +/* + * Licensed to t

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20592: [FLINK-28987][table-planner] Fix incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread GitBox
lincoln-lil commented on code in PR #20592: URL: https://github.com/apache/flink/pull/20592#discussion_r948708427 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/LookupJoinHintOptions.java: ## @@ -64,17 +62,14 @@ private LookupJoinHintOptions

[GitHub] [flink] snuyanzin commented on a diff in pull request #20546: [FLINK-28919][table] Add built-in generate_series function.

2022-08-17 Thread GitBox
snuyanzin commented on code in PR #20546: URL: https://github.com/apache/flink/pull/20546#discussion_r948706751 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/GenerateSeriesFunction.java: ## @@ -0,0 +1,109 @@ +/* + * Licensed to t

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20592: [FLINK-28987][table-planner] Fix incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread GitBox
lincoln-lil commented on code in PR #20592: URL: https://github.com/apache/flink/pull/20592#discussion_r948706335 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLookupJoin.java: ## @@ -246,18 +254,23 @@ protected

[jira] [Updated] (FLINK-29005) Parquet row type reader should not return null value when some child fields is null

2022-08-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29005: --- Labels: pull-request-available (was: ) > Parquet row type reader should not return null val

[GitHub] [flink] yuchuanchen opened a new pull request, #20616: [FLINK-29005][Connectors/Parquet] Parquet row type reader should not …

2022-08-17 Thread GitBox
yuchuanchen opened a new pull request, #20616: URL: https://github.com/apache/flink/pull/20616 …return null value when some child fields is null ## What is the purpose of the change This patch fixes the bug that the parquet row type reader returns null value when some c

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20592: [FLINK-28987][table-planner] Fix incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread GitBox
lincoln-lil commented on code in PR #20592: URL: https://github.com/apache/flink/pull/20592#discussion_r948688414 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/LookupJoinHintOptions.java: ## @@ -64,17 +62,14 @@ private LookupJoinHintOptions

[GitHub] [flink] snuyanzin commented on pull request #20544: [FLINK-28893][table] Add built-in conv function.

2022-08-17 Thread GitBox
snuyanzin commented on PR #20544: URL: https://github.com/apache/flink/pull/20544#issuecomment-1219087986 Thanks for the contribution It would be great to have a filled template for PR also I left some comments -- This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] snuyanzin commented on a diff in pull request #20544: [FLINK-28893][table] Add built-in conv function.

2022-08-17 Thread GitBox
snuyanzin commented on code in PR #20544: URL: https://github.com/apache/flink/pull/20544#discussion_r948700567 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/ConvFunctionITCase.java: ## @@ -0,0 +1,149 @@ +/* + * Licensed to the Apache

[GitHub] [flink] snuyanzin commented on a diff in pull request #20544: [FLINK-28893][table] Add built-in conv function.

2022-08-17 Thread GitBox
snuyanzin commented on code in PR #20544: URL: https://github.com/apache/flink/pull/20544#discussion_r948699559 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ConvFunction.java: ## @@ -0,0 +1,59 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-29028) Add the missing cache api in Python DataStream API

2022-08-17 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-29028: Summary: Add the missing cache api in Python DataStream API Key: FLINK-29028 URL: https://issues.apache.org/jira/browse/FLINK-29028 Project: Flink Issue Type

[GitHub] [flink-kubernetes-operator] kaskol10 commented on pull request #348: [docs] Adding helm-docs step in CI and README.md

2022-08-17 Thread GitBox
kaskol10 commented on PR #348: URL: https://github.com/apache/flink-kubernetes-operator/pull/348#issuecomment-1219078933 Hi! Thank you for your question! In the current project there is no [README from Helm charts](https://github.com/apache/flink-kubernetes-operator/tree/main/helm/f

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #142: [FLINK-28943] Add Transformer and Estimator for MaxAbsScaler

2022-08-17 Thread GitBox
yunfengzhou-hub commented on code in PR #142: URL: https://github.com/apache/flink-ml/pull/142#discussion_r948687937 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/maxabsscaler/MaxAbsScaler.java: ## @@ -0,0 +1,193 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20592: [FLINK-28987][table-planner] Fix incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread GitBox
lincoln-lil commented on code in PR #20592: URL: https://github.com/apache/flink/pull/20592#discussion_r948688751 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/common/CommonPhysicalLookupJoin.scala: ## @@ -108,6 +112,31 @@ a

[jira] [Created] (FLINK-29027) Fix HiveTableSink failed to report statistic to hive metastore in stream mode

2022-08-17 Thread luoyuxia (Jira)
luoyuxia created FLINK-29027: Summary: Fix HiveTableSink failed to report statistic to hive metastore in stream mode Key: FLINK-29027 URL: https://issues.apache.org/jira/browse/FLINK-29027 Project: Flink

[GitHub] [flink-ml] lindong28 merged pull request #143: [FLINK-27535] Optimize the unit test execution time

2022-08-17 Thread GitBox
lindong28 merged PR #143: URL: https://github.com/apache/flink-ml/pull/143 -- 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.apac

[GitHub] [flink-ml] lindong28 commented on pull request #143: [FLINK-27535] Optimize the unit test execution time

2022-08-17 Thread GitBox
lindong28 commented on PR #143: URL: https://github.com/apache/flink-ml/pull/143#issuecomment-1219058845 Thanks for the update. Can you provide the statistics of the CI execution time before and after this PR? And can you update the PR description as appropriate? -- This is an automated

[GitHub] [flink] godfreyhe commented on a diff in pull request #20592: [FLINK-28987][table-planner] Updates description of lookup join transformation with async params and retry strategy for easier de

2022-08-17 Thread GitBox
godfreyhe commented on code in PR #20592: URL: https://github.com/apache/flink/pull/20592#discussion_r948639908 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/LookupJoinUtil.java: ## @@ -197,92 +363,177 @@ public static int[] getOrder

[jira] [Updated] (FLINK-28987) Incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28987: Description: FLINK-28779 introduces a new lookup hint, for LegacyTableSourceTable interface, it d

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #143: [FLINK-27535] Optimize the unit test execution time

2022-08-17 Thread GitBox
yunfengzhou-hub commented on code in PR #143: URL: https://github.com/apache/flink-ml/pull/143#discussion_r948641898 ## pom.xml: ## @@ -548,12 +548,13 @@ under the License. maven-surefire-plugin 2.22.1 + classes Review Comment: I have not

[GitHub] [flink] godfreyhe commented on a diff in pull request #20592: [FLINK-28987][table-planner] Updates description of lookup join transformation with async params and retry strategy for easier de

2022-08-17 Thread GitBox
godfreyhe commented on code in PR #20592: URL: https://github.com/apache/flink/pull/20592#discussion_r948635867 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/common/CommonPhysicalLookupJoin.scala: ## @@ -108,6 +112,31 @@ abs

[jira] [Updated] (FLINK-28956) FIx non-multi insert statement fall into multi insert logic in Hive dialect

2022-08-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28956: - Affects Version/s: 1.16.0 > FIx non-multi insert statement fall into multi insert logic in Hive dialect

[jira] [Updated] (FLINK-29026) Add docs for HiveServer2 integration

2022-08-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29026: -- Component/s: Documentation > Add docs for HiveServer2 integration > --

[jira] [Updated] (FLINK-28956) FIx non-multi insert statement fall into multi insert logic in Hive dialect

2022-08-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28956: - Fix Version/s: 1.16.0 > FIx non-multi insert statement fall into multi insert logic in Hive dialect > -

[jira] [Updated] (FLINK-28956) FIx non-multi insert statement fall into multi insert logic in Hive dialect

2022-08-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28956: - Priority: Critical (was: Major) > FIx non-multi insert statement fall into multi insert logic in Hive

[jira] [Updated] (FLINK-29026) Add docs for HiveServer2 integration

2022-08-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29026: -- Component/s: Connectors / Hive Table SQL / Gateway > Add docs for HiveServer2

[jira] [Updated] (FLINK-29026) Add docs for HiveServer2 integration

2022-08-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29026: -- Affects Version/s: 1.16.0 > Add docs for HiveServer2 integration > ---

[jira] [Assigned] (FLINK-29026) Add docs for HiveServer2 integration

2022-08-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-29026: - Assignee: Shengkai Fang > Add docs for HiveServer2 integration > --

[jira] [Updated] (FLINK-29026) Add docs for HiveServer2 integration

2022-08-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29026: -- Priority: Critical (was: Major) > Add docs for HiveServer2 integration >

[jira] [Updated] (FLINK-29026) Add docs for HiveServer2 integration

2022-08-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29026: -- Fix Version/s: 1.16.0 > Add docs for HiveServer2 integration > ---

[jira] [Created] (FLINK-29025) Add docs for Hive Dialect

2022-08-17 Thread luoyuxia (Jira)
luoyuxia created FLINK-29025: Summary: Add docs for Hive Dialect Key: FLINK-29025 URL: https://issues.apache.org/jira/browse/FLINK-29025 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-29026) Add docs for HiveServer2 integration

2022-08-17 Thread luoyuxia (Jira)
luoyuxia created FLINK-29026: Summary: Add docs for HiveServer2 integration Key: FLINK-29026 URL: https://issues.apache.org/jira/browse/FLINK-29026 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29024) Add basic doc structure for Hive Compatibility

2022-08-17 Thread luoyuxia (Jira)
luoyuxia created FLINK-29024: Summary: Add basic doc structure for Hive Compatibility Key: FLINK-29024 URL: https://issues.apache.org/jira/browse/FLINK-29024 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-29021) [Umbrella] Add docs for Hive Compatibility

2022-08-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-29021: - Description: This Jira is for adding some docs for Hive Compatibility. Expect to add a new section belo

[jira] [Created] (FLINK-29023) Updating Jar statement document

2022-08-17 Thread dalongliu (Jira)
dalongliu created FLINK-29023: - Summary: Updating Jar statement document Key: FLINK-29023 URL: https://issues.apache.org/jira/browse/FLINK-29023 Project: Flink Issue Type: Sub-task Comp

[jira] [Updated] (FLINK-29021) [Umbrella] Add docs for Hive Compatibility

2022-08-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-29021: - Description: This Jira is for adding some docs for Hive Compatibility. Expect to put it in   , includin

[jira] [Updated] (FLINK-29021) [Umbrella] Add docs for Hive Compatibility

2022-08-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-29021: - Description: Expect to put it in  , including three part: 1:  Overview 2:  Hive Dialect 3:  HiveServe

[jira] [Updated] (FLINK-28987) Incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-28987: --- Affects Version/s: 1.16.0 > Incorrect async to sync lookup fallback path of LegacyTableSourceTable >

[jira] [Updated] (FLINK-28987) Incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-28987: --- Component/s: Table SQL / Planner > Incorrect async to sync lookup fallback path of LegacyTableSource

[jira] [Assigned] (FLINK-28987) Incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-28987: -- Assignee: lincoln lee > Incorrect async to sync lookup fallback path of LegacyTableSourceTabl

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-17 Thread GitBox
lincoln-lil commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r948631438 ## docs/content.zh/docs/dev/table/sql/queries/hints.md: ## @@ -79,4 +79,202 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select `

[jira] [Created] (FLINK-29022) Add document for CREATE FUNCTIOn USING JAR feature

2022-08-17 Thread dalongliu (Jira)
dalongliu created FLINK-29022: - Summary: Add document for CREATE FUNCTIOn USING JAR feature Key: FLINK-29022 URL: https://issues.apache.org/jira/browse/FLINK-29022 Project: Flink Issue Type: Sub-

[jira] [Updated] (FLINK-28987) Incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28987: Description: FLINK-28779 introduces a new lookup hint, for LegacyTableSourceTable interface, it d

[jira] [Updated] (FLINK-29021) [Umbrella] Add docs for Hive Compatibility

2022-08-17 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-29021: - Labels: documentation (was: ) > [Umbrella] Add docs for Hive Compatibility > --

[jira] [Created] (FLINK-29021) [Umbrella] Add docs for Hive Compatibility

2022-08-17 Thread luoyuxia (Jira)
luoyuxia created FLINK-29021: Summary: [Umbrella] Add docs for Hive Compatibility Key: FLINK-29021 URL: https://issues.apache.org/jira/browse/FLINK-29021 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-28987) Incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28987: Description: FLINK-28779 introduces a new lookup hint, for    Updates description of lookup join

[jira] [Updated] (FLINK-28987) Incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28987: Summary: Incorrect async to sync lookup fallback path of LegacyTableSourceTable (was: Fix) > Inc

[jira] [Updated] (FLINK-28987) Incorrect async to sync lookup fallback path of LegacyTableSourceTable

2022-08-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28987: Description:     Updates description of lookup join transformation with async params and retry

[jira] [Updated] (FLINK-28987) Fix

2022-08-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28987: Summary: Fix (was: Updates description of lookup join transformation with async params and retry

[jira] [Updated] (FLINK-28987) Updates description of lookup join transformation with async params and retry strategy for easier debugging

2022-08-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28987: Description: Updates description of lookup join transformation with async params and retry strateg

[jira] [Updated] (FLINK-28987) Updates description of lookup join transformation with async params and retry strategy for easier debugging

2022-08-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28987: Parent: (was: FLINK-28779) Issue Type: Bug (was: Sub-task) > Updates description of l

[jira] [Created] (FLINK-29020) Add document for CTAS feature

2022-08-17 Thread dalongliu (Jira)
dalongliu created FLINK-29020: - Summary: Add document for CTAS feature Key: FLINK-29020 URL: https://issues.apache.org/jira/browse/FLINK-29020 Project: Flink Issue Type: Sub-task Compon

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-17 Thread GitBox
lincoln-lil commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r948622726 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,205 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[GitHub] [flink-table-store] JingsongLi merged pull request #269: [hotfix][docs] Optimizing Spark documentation about engines.

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

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #141: [FLINK-28805] Add Transformer for HashingTF

2022-08-17 Thread GitBox
zhipeng93 commented on code in PR #141: URL: https://github.com/apache/flink-ml/pull/141#discussion_r948618698 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/hashingtf/HashingTF.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #141: [FLINK-28805] Add Transformer for HashingTF

2022-08-17 Thread GitBox
zhipeng93 commented on code in PR #141: URL: https://github.com/apache/flink-ml/pull/141#discussion_r948626062 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/hashingtf/HashingTF.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Created] (FLINK-29019) Updating parquet format document that support complex type

2022-08-17 Thread dalongliu (Jira)
dalongliu created FLINK-29019: - Summary: Updating parquet format document that support complex type Key: FLINK-29019 URL: https://issues.apache.org/jira/browse/FLINK-29019 Project: Flink Issue Ty

[jira] [Comment Edited] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails

2022-08-17 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580261#comment-17580261 ] ChangjiGuo edited comment on FLINK-28927 at 8/18/22 3:46 AM: -

[jira] [Comment Edited] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails

2022-08-17 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580261#comment-17580261 ] ChangjiGuo edited comment on FLINK-28927 at 8/18/22 3:36 AM: -

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #141: [FLINK-28805] Add Transformer for HashingTF

2022-08-17 Thread GitBox
zhipeng93 commented on code in PR #141: URL: https://github.com/apache/flink-ml/pull/141#discussion_r948618698 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/hashingtf/HashingTF.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Comment Edited] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails

2022-08-17 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580261#comment-17580261 ] ChangjiGuo edited comment on FLINK-28927 at 8/18/22 3:31 AM: -

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #141: [FLINK-28805] Add Transformer for HashingTF

2022-08-17 Thread GitBox
zhipeng93 commented on code in PR #141: URL: https://github.com/apache/flink-ml/pull/141#discussion_r948618302 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/hashingtf/HashingTF.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink] WencongLiu commented on a diff in pull request #20574: [FLINK-28963][sql-gateway]Add API compatibility test for sql gateway rest endpoint

2022-08-17 Thread GitBox
WencongLiu commented on code in PR #20574: URL: https://github.com/apache/flink/pull/20574#discussion_r948617198 ## flink-runtime/pom.xml: ## @@ -179,6 +179,11 @@ under the License. flink-test-utils-junit + +

[jira] [Updated] (FLINK-28927) Can not clean up the uploaded shared files when the checkpoint fails

2022-08-17 Thread ChangjiGuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChangjiGuo updated FLINK-28927: --- Description: If a checkpoint times out, the task will cancel all snapshot futures and do some clean

[GitHub] [flink] WencongLiu commented on a diff in pull request #20574: [FLINK-28963][sql-gateway]Add API compatibility test for sql gateway rest endpoint

2022-08-17 Thread GitBox
WencongLiu commented on code in PR #20574: URL: https://github.com/apache/flink/pull/20574#discussion_r948617198 ## flink-runtime/pom.xml: ## @@ -179,6 +179,11 @@ under the License. flink-test-utils-junit + +

[GitHub] [flink] WencongLiu commented on pull request #20574: [FLINK-28963][sql-gateway]Add API compatibility test for sql gateway rest endpoint

2022-08-17 Thread GitBox
WencongLiu commented on PR #20574: URL: https://github.com/apache/flink/pull/20574#issuecomment-1218958271 @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-29018) KafkaITCase.testMultipleSourcesOnePartition failed with TopicExistsException

2022-08-17 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-29018: Summary: KafkaITCase.testMultipleSourcesOnePartition failed with TopicExistsException Key: FLINK-29018 URL: https://issues.apache.org/jira/browse/FLINK-29018 Project:

[jira] [Commented] (FLINK-29018) KafkaITCase.testMultipleSourcesOnePartition failed with TopicExistsException

2022-08-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581107#comment-17581107 ] Huang Xingbo commented on FLINK-29018: -- [~renqs] Could help take a look? Thx. > Ka

[GitHub] [flink-table-store] liuzhuang2017 opened a new pull request, #269: [hotfix][docs] Optimizing Spark documentation about engines.

2022-08-17 Thread GitBox
liuzhuang2017 opened a new pull request, #269: URL: https://github.com/apache/flink-table-store/pull/269 # What is the purpose of the change - Modify _Spark_ in "engine" documentation to _Spark3_. # Brief change log - Optimizing Spark documentation about engines. # Verifyi

[GitHub] [flink-web] HuangXingBo commented on a diff in pull request #566: Release flink 1.15.2

2022-08-17 Thread GitBox
HuangXingBo commented on code in PR #566: URL: https://github.com/apache/flink-web/pull/566#discussion_r948583460 ## _posts/2022-08-17-release-1.15.2.md: ## @@ -0,0 +1,166 @@ +--- +layout: post +title: "Apache Flink 1.15.2 Release Announcement" +date: 2022-08-17T08:00:00.000Z +

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #141: [FLINK-28805] Add Transformer for HashingTF

2022-08-17 Thread GitBox
yunfengzhou-hub commented on code in PR #141: URL: https://github.com/apache/flink-ml/pull/141#discussion_r948579924 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/hashingtf/HashingTF.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] xintongsong commented on a diff in pull request #20574: [FLINK-28963][sql-gateway]Add API compatibility test for sql gateway rest endpoint

2022-08-17 Thread GitBox
xintongsong commented on code in PR #20574: URL: https://github.com/apache/flink/pull/20574#discussion_r948577004 ## flink-runtime/pom.xml: ## @@ -179,6 +179,11 @@ under the License. flink-test-utils-junit + +

[GitHub] [flink] Mrzyxing commented on pull request #20510: [FLINK-28815][docs] Translate the Real Time Reporting with the Table API page into Chinese

2022-08-17 Thread GitBox
Mrzyxing commented on PR #20510: URL: https://github.com/apache/flink/pull/20510#issuecomment-1218868029 @ChengkaiYang2022 There is one last unresovled conversation, looks like you haven't catch this . Very expect your ideas. ![image](https://user-images.githubusercontent.com/15867085

[GitHub] [flink] Mrzyxing commented on a diff in pull request #20510: [FLINK-28815][docs] Translate the Real Time Reporting with the Table API page into Chinese

2022-08-17 Thread GitBox
Mrzyxing commented on code in PR #20510: URL: https://github.com/apache/flink/pull/20510#discussion_r948566977 ## docs/content.zh/docs/try-flink/table_api.md: ## @@ -163,44 +161,41 @@ tEnv.executeSql("CREATE TABLE spend_report (\n" + ")"); ``` -The second table, `spend_r

[GitHub] [flink] Mrzyxing commented on a diff in pull request #20510: [FLINK-28815][docs] Translate the Real Time Reporting with the Table API page into Chinese

2022-08-17 Thread GitBox
Mrzyxing commented on code in PR #20510: URL: https://github.com/apache/flink/pull/20510#discussion_r948565208 ## docs/content.zh/docs/try-flink/table_api.md: ## @@ -275,38 +270,38 @@ public static Table report(Table transactions) { } ``` -This defines your application as us

[GitHub] [flink] Mrzyxing commented on a diff in pull request #20510: [FLINK-28815][docs] Translate the Real Time Reporting with the Table API page into Chinese

2022-08-17 Thread GitBox
Mrzyxing commented on code in PR #20510: URL: https://github.com/apache/flink/pull/20510#discussion_r948565208 ## docs/content.zh/docs/try-flink/table_api.md: ## @@ -275,38 +270,38 @@ public static Table report(Table transactions) { } ``` -This defines your application as us

[GitHub] [flink] Mrzyxing commented on a diff in pull request #20510: [FLINK-28815][docs] Translate the Real Time Reporting with the Table API page into Chinese

2022-08-17 Thread GitBox
Mrzyxing commented on code in PR #20510: URL: https://github.com/apache/flink/pull/20510#discussion_r948565208 ## docs/content.zh/docs/try-flink/table_api.md: ## @@ -275,38 +270,38 @@ public static Table report(Table transactions) { } ``` -This defines your application as us

[GitHub] [flink] lsyldliu commented on a diff in pull request #20613: [FLINK-29007][e2e] Fix UsingRemoteJarITCase failed with NPE in hadoop3

2022-08-17 Thread GitBox
lsyldliu commented on code in PR #20613: URL: https://github.com/apache/flink/pull/20613#discussion_r948564591 ## flink-end-to-end-tests/flink-end-to-end-tests-sql/pom.xml: ## @@ -199,4 +199,25 @@ + + + + +hadoop3-tes

[jira] [Updated] (FLINK-11529) Support Chinese Documentation for Apache Flink

2022-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11529: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was: a

[jira] [Updated] (FLINK-24931) Remove deprecated/unused class files in flink-scala module.

2022-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24931: --- Labels: auto-deprioritized-minor pull-request-available (was: pull-request-available stal

[jira] [Updated] (FLINK-5080) Cassandra connector ignores saveAsync result onSuccess

2022-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5080: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-availa

[jira] [Updated] (FLINK-24573) ZooKeeperJobGraphsStoreITCase crashes JVM

2022-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24573: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-27719) Create Apache Flink slack workspace

2022-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27719: --- Labels: Umbrella stale-assigned (was: Umbrella) I am the [Flink Jira Bot|https://github.com

[jira] [Updated] (FLINK-19674) Translate "Docker" of "Clusters & Depolyment" page into Chinese

2022-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19674: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-ava

[jira] [Updated] (FLINK-28575) support hbase connector 2.2 to write to hbase 2.4.9

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

[jira] [Updated] (FLINK-28424) JdbcExactlyOnceSinkE2eTest hangs on Azure

2022-08-17 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-28424: --- Labels: auto-deprioritized-critical stale-critical test-stability (was: auto-deprioritized-

[jira] [Closed] (FLINK-28996) Move parameter parsing into Datadog reporter factory

2022-08-17 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28996. Resolution: Fixed master: 56a7c847df16b70f321d5445e447ca4dc0d8bba4 > Move parameter parsi

[jira] [Closed] (FLINK-28997) Add a switch to datadog reporter to use logical scope

2022-08-17 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28997. Resolution: Fixed master: 7e7fd76078e6499a50edb2c69fff5088326390b6 > Add a switch to data

[jira] [Updated] (FLINK-29002) Deprecate Datadog reporter 'tags' option

2022-08-17 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29002: - Release Note: The 'tags' option from the DatadogReporter has been deprecated in favor of

[jira] [Comment Edited] (FLINK-28488) KafkaMetricWrapper does incorrect cast

2022-08-17 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581037#comment-17581037 ] Chesnay Schepler edited comment on FLINK-28488 at 8/17/22 9:59 PM: ---

[jira] [Closed] (FLINK-29002) Deprecate Datadog reporter 'tags' option

2022-08-17 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29002. Resolution: Fixed master: 3e6f47c9d3623c240bbb86845893f9a022dde03d > Deprecate Datadog re

[jira] [Closed] (FLINK-28488) KafkaMetricWrapper does incorrect cast

2022-08-17 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28488. Resolution: Fixed > KafkaMetricWrapper does incorrect cast > -

[GitHub] [flink] zentol merged pull request #20598: [FLINK-28997][datadog] Add switch to use logical identifier

2022-08-17 Thread GitBox
zentol merged PR #20598: URL: https://github.com/apache/flink/pull/20598 -- 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.apache

[jira] [Commented] (FLINK-28488) KafkaMetricWrapper does incorrect cast

2022-08-17 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581037#comment-17581037 ] Chesnay Schepler commented on FLINK-28488: -- master: 3c2fa303074453d4f4c95c2290b

  1   2   3   >