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

2023-02-27 Thread leo.zhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694395#comment-17694395 ] leo.zhi commented on FLINK-31211: - I checked the flink source code of  version 1.14 and 1.15, maybe 

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

2023-02-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694392#comment-17694392 ] Matthias Pohl commented on FLINK-31092: ---

[jira] [Updated] (FLINK-31254) Improve the read performance for files table

2023-02-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31254: --- Labels: pull-request-available (was: ) > Improve the read performance for files table >

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #564: [FLINK-31254] Improve the read performance for files table

2023-02-27 Thread via GitHub
JingsongLi opened a new pull request, #564: URL: https://github.com/apache/flink-table-store/pull/564 At present, the reading performance of the Files table is very poor. Even every data read will read the schema file. We can optimize the reading performance. -- This is an

[jira] [Created] (FLINK-31254) Improve the read performance for files table

2023-02-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-31254: Summary: Improve the read performance for files table Key: FLINK-31254 URL: https://issues.apache.org/jira/browse/FLINK-31254 Project: Flink Issue Type:

[GitHub] [flink] slfan1989 commented on pull request #22028: [FLINK-31230] Improve YarnClusterDescriptor memory unit display.

2023-02-27 Thread via GitHub
slfan1989 commented on PR #22028: URL: https://github.com/apache/flink/pull/22028#issuecomment-1447722200 @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

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

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

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

2023-02-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-31253: Summary: Port itcases to Flink 1.15 and 1.14 Key: FLINK-31253 URL: https://issues.apache.org/jira/browse/FLINK-31253 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-31205) do optimize for multi sink in a single relNode tree

2023-02-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694386#comment-17694386 ] Aitozi commented on FLINK-31205: looking forward to your opinion CC [~godfreyhe] [~twalthr] [~snuyanzin]

[jira] [Comment Edited] (FLINK-31140) Load additional dependencies in operator classpath

2023-02-27 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694379#comment-17694379 ] Tamir Sagi edited comment on FLINK-31140 at 2/28/23 7:32 AM: - I think you

[jira] [Commented] (FLINK-31140) Load additional dependencies in operator classpath

2023-02-27 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694379#comment-17694379 ] Tamir Sagi commented on FLINK-31140: I think you are confusing with Flink application. Oppose to

[GitHub] [flink] flinkbot commented on pull request #22044: [FLINK-30971][table-planner] Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'

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

[jira] [Commented] (FLINK-31205) do optimize for multi sink in a single relNode tree

2023-02-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694372#comment-17694372 ] Aitozi commented on FLINK-31205: After some research, I found that there are better choices than using a

[GitHub] [flink] swuferhong opened a new pull request, #22044: [FLINK-30971][table-planner] Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'

2023-02-27 Thread via GitHub
swuferhong opened a new pull request, #22044: URL: https://github.com/apache/flink/pull/22044 ## What is the purpose of the change cherry-pick FLINK-30971 to `release-1.17` : In our test environment, we set the default parallelism to 1 and got the most appropriate default

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

2023-02-27 Thread leo.zhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694356#comment-17694356 ] leo.zhi edited comment on FLINK-31211 at 2/28/23 7:07 AM: -- Hi [~martijnvisser]

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

2023-02-27 Thread leo.zhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694356#comment-17694356 ] leo.zhi commented on FLINK-31211: - Hi [~martijnvisser] , Sorry for the trouble, I really can not figure

[GitHub] [flink-connector-aws] luoyuxia commented on a diff in pull request #47: [FLINK-30481][FLIP-277] GlueCatalog Implementation

2023-02-27 Thread via GitHub
luoyuxia commented on code in PR #47: URL: https://github.com/apache/flink-connector-aws/pull/47#discussion_r1119553822 ## flink-catalog-aws-glue/pom.xml: ## @@ -0,0 +1,114 @@ + + +http://maven.apache.org/POM/4.0.0; +

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

2023-02-27 Thread via GitHub
slfan1989 commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-144700 @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

[GitHub] [flink] ruanhang1993 commented on pull request #21589: [FLINK-25509][connector-base/connector-kafka] Add RecordEvaluator to dynamically stop source based on de-serialized records

2023-02-27 Thread via GitHub
ruanhang1993 commented on PR #21589: URL: https://github.com/apache/flink/pull/21589#issuecomment-1447661070 @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

[jira] [Commented] (FLINK-31235) Flink Jdbc Connector can not push down where condition

2023-02-27 Thread leo.zhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694339#comment-17694339 ] leo.zhi commented on FLINK-31235: - Since jdbc push down feature which will effective at the unreleased

[jira] [Updated] (FLINK-31235) Flink Jdbc Connector can not push down where condition

2023-02-27 Thread leo.zhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leo.zhi updated FLINK-31235: Attachment: image-2023-02-28-14-31-43-387.png > Flink Jdbc Connector can not push down where condition >

[jira] [Assigned] (FLINK-26203) Support Table API in Pulsar Connector

2023-02-27 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-26203: -- Assignee: Yufan Sheng (was: Yufei Zhang) > Support Table API in Pulsar Connector >

[jira] [Commented] (FLINK-26203) Support Table API in Pulsar Connector

2023-02-27 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694337#comment-17694337 ] Weijie Guo commented on FLINK-26203: [~syhily] Thanks for taking over this, you are assigned. >

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

2023-02-27 Thread via GitHub
slfan1989 commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-1447654008 @1996fanrui Can you help to review this PR again? Thank you very much! ``` --2023-02-28 03:11:51--

[jira] [Commented] (FLINK-22793) HybridSource Table Implementation

2023-02-27 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694334#comment-17694334 ] Ran Tao commented on FLINK-22793: - [~nicholasjiang] [~thw]  Thank you Jiang and Thomas.  I will try to

[GitHub] [flink] flinkbot commented on pull request #22043: [FLINK-31250][formats][parquet] Parquet format supports MULTISET type

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

[jira] [Updated] (FLINK-31250) Parquet format supports MULTISET type

2023-02-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31250: --- Labels: pull-request-available (was: ) > Parquet format supports MULTISET type >

[GitHub] [flink] SteNicholas opened a new pull request, #22043: [FLINK-31250][formats][parquet] Parquet format supports MULTISET type

2023-02-27 Thread via GitHub
SteNicholas opened a new pull request, #22043: URL: https://github.com/apache/flink/pull/22043 ## What is the purpose of the change Parquet format supports MULTISET type. ## Brief change log - The reader, writer and schema converter of parquet format supports MULTISET

[jira] [Updated] (FLINK-31252) Improve StaticFileStoreSplitEnumerator to assign batch splits

2023-02-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-31252: - Description: The following batch assignment operation is for two things: 1. It can be evenly

[jira] [Created] (FLINK-31252) Improve StaticFileStoreSplitEnumerator to assign batch splits

2023-02-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-31252: Summary: Improve StaticFileStoreSplitEnumerator to assign batch splits Key: FLINK-31252 URL: https://issues.apache.org/jira/browse/FLINK-31252 Project: Flink

[GitHub] [flink] luoyuxia commented on pull request #22032: [FLINK-30667][hive] introduce flink-table-calcite-bridge module

2023-02-27 Thread via GitHub
luoyuxia commented on PR #22032: URL: https://github.com/apache/flink/pull/22032#issuecomment-1447636769 @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-31251) Deprecate deserialize method in DeserializationSchema

2023-02-27 Thread Shammon (Jira)
Shammon created FLINK-31251: --- Summary: Deprecate deserialize method in DeserializationSchema Key: FLINK-31251 URL: https://issues.apache.org/jira/browse/FLINK-31251 Project: Flink Issue Type:

[jira] [Updated] (FLINK-31250) Parquet format supports MULTISET type

2023-02-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31250: --- Description: Parquet format supports ARRAY, MAP and ROW type, doesn't support MULTISET

[jira] [Updated] (FLINK-31250) Parquet format supports MULTISET type

2023-02-27 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-31250: --- Summary: Parquet format supports MULTISET type (was: ParquetSchemaConverter supports

[GitHub] [flink-ml] lindong28 merged pull request #214: [FLINK-31127] Add public API classes for FLIP-289

2023-02-27 Thread via GitHub
lindong28 merged PR #214: URL: https://github.com/apache/flink-ml/pull/214 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-ml] lindong28 commented on pull request #214: [FLINK-31127] Add public API classes for FLIP-289

2023-02-27 Thread via GitHub
lindong28 commented on PR #214: URL: https://github.com/apache/flink-ml/pull/214#issuecomment-1447626627 Thanks @zhipeng93 @Fanoid @jiangxin369 for the review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink-ml] Fanoid commented on pull request #214: [FLINK-31127] Add public API classes for FLIP-289

2023-02-27 Thread via GitHub
Fanoid commented on PR #214: URL: https://github.com/apache/flink-ml/pull/214#issuecomment-1447625618 @lindong28 Thanks for your explanation. I missed the point that we already have the orders in the `GraphBuilder#buildEstimator`. Then, I'm OK with this change. -- This is an

[GitHub] [flink-kubernetes-operator] gauravmiglanid11 commented on pull request #533: [FLINK-30920] [AutoScaler] adds exclude vertex ids for autoscaler to ignore for evaluation and scaling

2023-02-27 Thread via GitHub
gauravmiglanid11 commented on PR #533: URL: https://github.com/apache/flink-kubernetes-operator/pull/533#issuecomment-1447617533 @gyfora CI Passed successfully. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Created] (FLINK-31250) ParquetSchemaConverter supports MULTISET type for parquet format

2023-02-27 Thread Nicholas Jiang (Jira)
Nicholas Jiang created FLINK-31250: -- Summary: ParquetSchemaConverter supports MULTISET type for parquet format Key: FLINK-31250 URL: https://issues.apache.org/jira/browse/FLINK-31250 Project: Flink

[GitHub] [flink-ml] lindong28 commented on pull request #214: [FLINK-31127] Add public API classes for FLIP-289

2023-02-27 Thread via GitHub
lindong28 commented on PR #214: URL: https://github.com/apache/flink-ml/pull/214#issuecomment-1447612921 > Hi, I just found we have made this change. I have a question: how do we obtain the corresponding input stream for each GraphNode in the GraphModel? modelDataInputs are linearly

[jira] [Commented] (FLINK-26203) Support Table API in Pulsar Connector

2023-02-27 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694315#comment-17694315 ] Yufan Sheng commented on FLINK-26203: - [~guoweijie] After discussing with [~affe], I will working on

[GitHub] [flink-ml] Fanoid commented on pull request #214: [FLINK-31127] Add public API classes for FLIP-289

2023-02-27 Thread via GitHub
Fanoid commented on PR #214: URL: https://github.com/apache/flink-ml/pull/214#issuecomment-1447574309 > > > It seems additional parameters are required in the signature of setModelData to help map InputStreams to GraphNodes. > > IMO, indeed we need to map

[GitHub] [flink] liuyongvs commented on pull request #21993: [FLINK-31166][table] Fix array_contains does not support null argumen…

2023-02-27 Thread via GitHub
liuyongvs commented on PR #21993: URL: https://github.com/apache/flink/pull/21993#issuecomment-1447572658 @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

[jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck

2023-02-27 Thread renxiang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] renxiang zhou updated FLINK-31249: -- Description: When jobmanager receives all ACKs of tasks, it will finalize the pending

[jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck

2023-02-27 Thread renxiang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] renxiang zhou updated FLINK-31249: -- Attachment: image-2023-02-28-12-17-19-607.png > Checkpoint timeout mechanism fails when

[jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck

2023-02-27 Thread renxiang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] renxiang zhou updated FLINK-31249: -- Attachment: image-2023-02-28-12-04-35-178.png > Checkpoint timeout mechanism fails when

[jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck

2023-02-27 Thread renxiang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] renxiang zhou updated FLINK-31249: -- Summary: Checkpoint timeout mechanism fails when finalizeCheckpoint is stuck (was:

[GitHub] [flink] FangYongs commented on a diff in pull request #13081: [FLINK-18590][json] Support json array explode to multi messages

2023-02-27 Thread via GitHub
FangYongs commented on code in PR #13081: URL: https://github.com/apache/flink/pull/13081#discussion_r1119548371 ## docs/content/docs/connectors/table/formats/json.md: ## @@ -241,6 +241,41 @@ The following table lists the type mapping from Flink type to JSON type.

[jira] [Updated] (FLINK-31249) Checkpoint timeout mechanism fails when completePendingCheckpoint is stuck

2023-02-27 Thread renxiang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] renxiang zhou updated FLINK-31249: -- Summary: Checkpoint timeout mechanism fails when completePendingCheckpoint is stuck (was:

[jira] [Updated] (FLINK-31249) Checkpoint Timer failed to process timeout events when it blocked at writing _metadata to DFS

2023-02-27 Thread renxiang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] renxiang zhou updated FLINK-31249: -- Description: The {{jobmanager-future}} thread may be blocked at writing metadata to DFS

[jira] [Updated] (FLINK-31249) Checkpoint Timer failed to process timeout events when it blocked at writing _metadata to DFS

2023-02-27 Thread renxiang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] renxiang zhou updated FLINK-31249: -- Language: (was: JAVA) > Checkpoint Timer failed to process timeout events when it blocked

[jira] [Created] (FLINK-31249) Checkpoint Timer failed to process timeout events when it blocked at writing _metadata to DFS

2023-02-27 Thread renxiang zhou (Jira)
renxiang zhou created FLINK-31249: - Summary: Checkpoint Timer failed to process timeout events when it blocked at writing _metadata to DFS Key: FLINK-31249 URL: https://issues.apache.org/jira/browse/FLINK-31249

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

2023-02-27 Thread ZhuoYu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694284#comment-17694284 ] ZhuoYu Chen commented on FLINK-27548: - hi [~lzljs3620320] ,please assign to me; thx。 > Improve

[GitHub] [flink] xuzhiwen1255 commented on a diff in pull request #21971: [FLINK-31084][connectors/dataGen] Add default value for dataGen seque…

2023-02-27 Thread via GitHub
xuzhiwen1255 commented on code in PR #21971: URL: https://github.com/apache/flink/pull/21971#discussion_r1119522105 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java: ## @@ -53,6 +54,8 @@ * @param end End

[GitHub] [flink] xuzhiwen1255 commented on a diff in pull request #21971: [FLINK-31084][connectors/dataGen] Add default value for dataGen seque…

2023-02-27 Thread via GitHub
xuzhiwen1255 commented on code in PR #21971: URL: https://github.com/apache/flink/pull/21971#discussion_r1119521354 ## flink-table/flink-table-api-java-bridge/src/test/java/org/apache/flink/table/factories/DataGenTableSourceFactoryTest.java: ## @@ -264,7 +267,68 @@ void

[GitHub] [flink] xuzhiwen1255 commented on a diff in pull request #21971: [FLINK-31084][connectors/dataGen] Add default value for dataGen seque…

2023-02-27 Thread via GitHub
xuzhiwen1255 commented on code in PR #21971: URL: https://github.com/apache/flink/pull/21971#discussion_r1119520839 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java: ## @@ -83,9 +86,11 @@ public void open(

[GitHub] [flink] slfan1989 commented on pull request #22019: [hotfix] Fix Typo in YarnConfigOptions.

2023-02-27 Thread via GitHub
slfan1989 commented on PR #22019: URL: https://github.com/apache/flink/pull/22019#issuecomment-1447487689 @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

[jira] [Updated] (FLINK-31228) flink-playgrounds is using a buggy zookeeper

2023-02-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31228: --- Labels: Docker pull-request-available (was: Docker) > flink-playgrounds is using a buggy

[GitHub] [flink-playgrounds] ChenZhongPu opened a new pull request, #41: [FLINK-31228] Update kafka and zookeeper docker image

2023-02-27 Thread via GitHub
ChenZhongPu opened a new pull request, #41: URL: https://github.com/apache/flink-playgrounds/pull/41 As reported in [FLINK-31228](https://issues.apache.org/jira/browse/FLINK-31228) and [issue#734](https://github.com/wurstmeister/kafka-docker/issues/734), the zookeeper image maintained by

[jira] [Created] (FLINK-31248) Improve documentation for append-only table

2023-02-27 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-31248: Summary: Improve documentation for append-only table Key: FLINK-31248 URL: https://issues.apache.org/jira/browse/FLINK-31248 Project: Flink Issue Type:

[GitHub] [flink-ml] jiangxin369 commented on pull request #214: [FLINK-31127] Add public API classes for FLIP-289

2023-02-27 Thread via GitHub
jiangxin369 commented on PR #214: URL: https://github.com/apache/flink-ml/pull/214#issuecomment-1447459695 > GraphModel IMO, indeed we need to map `InputStream`s to `GraphNode`s, but it is implementation, not required in API. The existing `GraphModel` class has shown a way to

[jira] [Commented] (FLINK-31235) Flink Jdbc Connector can not push down where condition

2023-02-27 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694260#comment-17694260 ] Benchao Li commented on FLINK-31235: jdbc connector has been moved to a separate repo, see

[GitHub] [flink] xuzhiwen1255 commented on a diff in pull request #21971: [FLINK-31084][connectors/dataGen] Add default value for dataGen seque…

2023-02-27 Thread via GitHub
xuzhiwen1255 commented on code in PR #21971: URL: https://github.com/apache/flink/pull/21971#discussion_r1119495064 ## flink-table/flink-table-api-java-bridge/src/test/java/org/apache/flink/table/factories/DataGenTableSourceFactoryTest.java: ## @@ -264,7 +267,68 @@ void

[GitHub] [flink] xuzhiwen1255 commented on a diff in pull request #21971: [FLINK-31084][connectors/dataGen] Add default value for dataGen seque…

2023-02-27 Thread via GitHub
xuzhiwen1255 commented on code in PR #21971: URL: https://github.com/apache/flink/pull/21971#discussion_r1119485906 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java: ## @@ -83,9 +86,11 @@ public void open(

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

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

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

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

[GitHub] [flink] luoyuxia commented on pull request #22032: [FLINK-30667][hive] introduce flink-table-calcite-bridge module

2023-02-27 Thread via GitHub
luoyuxia commented on PR #22032: URL: https://github.com/apache/flink/pull/22032#issuecomment-1447424995 @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-table-store] JingsongLi commented on a diff in pull request #550: [FLINK-31178] Public Writer API

2023-02-27 Thread via GitHub
JingsongLi commented on code in PR #550: URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1119481919 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/FileStoreTable.java: ## @@ -55,9 +56,10 @@ default List partitionKeys() {

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

2023-02-27 Thread via GitHub
JingsongLi commented on code in PR #550: URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1119481740 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/AbstractFileStoreWrite.java: ## @@ -220,7 +227,9 @@ public void close()

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

2023-02-27 Thread via GitHub
JingsongLi commented on code in PR #550: URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1119481450 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/RecordWriter.java: ## @@ -54,10 +54,10 @@ /** * Prepare for a

[jira] [Commented] (FLINK-31235) Flink Jdbc Connector can not push down where condition

2023-02-27 Thread leo.zhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694247#comment-17694247 ] leo.zhi commented on FLINK-31235: - Hi [~libenchao] , Thanks for the quick reply, do you mean the jdbc

[jira] [Updated] (FLINK-31235) Flink Jdbc Connector can not push down where condition

2023-02-27 Thread leo.zhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leo.zhi updated FLINK-31235: Attachment: image-2023-02-28-09-03-16-225.png > Flink Jdbc Connector can not push down where condition >

[GitHub] [flink] slfan1989 commented on pull request #22028: [FLINK-31230] Improve YarnClusterDescriptor memory unit display.

2023-02-27 Thread via GitHub
slfan1989 commented on PR #22028: URL: https://github.com/apache/flink/pull/22028#issuecomment-1447328496 @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

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

2023-02-27 Thread via GitHub
slfan1989 commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-1447322665 @1996fanrui Thank you very much for your help to review the code, I resubmitted the code, but azure cannot be triggered. -- This is an automated message from the Apache Git Service.

[GitHub] [flink] pgaref commented on pull request #21923: FLINK-13871: Consolidate volatile status fields in StreamTask

2023-02-27 Thread via GitHub
pgaref commented on PR #21923: URL: https://github.com/apache/flink/pull/21923#issuecomment-1447279707 Thanks everyone for the useful comments! PTAL on the latest changes, in short: - Checked all state transitions and documented them as part of

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

2023-02-27 Thread via GitHub
slfan1989 commented on PR #22020: URL: https://github.com/apache/flink/pull/22020#issuecomment-1447250979 @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

[GitHub] [flink-kubernetes-operator] gauravmiglanid11 commented on pull request #533: [FLINK-30920] [AutoScaler] adds exclude vertex ids for autoscaler to ignore for evaluation and scaling

2023-02-27 Thread via GitHub
gauravmiglanid11 commented on PR #533: URL: https://github.com/apache/flink-kubernetes-operator/pull/533#issuecomment-1447248661 @gyfora ci tests passed, but somehow matrix ci workflows are getting canceled, can you please trigger them? -- This is an automated message from the Apache

[jira] [Created] (FLINK-31247) Support for fine-grained resource allocation (slot sharing groups) at the TableAPI level

2023-02-27 Thread Sergio Sainz (Jira)
Sergio Sainz created FLINK-31247: Summary: Support for fine-grained resource allocation (slot sharing groups) at the TableAPI level Key: FLINK-31247 URL: https://issues.apache.org/jira/browse/FLINK-31247

[jira] [Updated] (FLINK-21763) Extend Data Stream's batch mode to handle partitioning/grouping/ordering

2023-02-27 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-21763: -- Description: In the DataSet API, an undocumented (?) feature is using

[jira] [Commented] (FLINK-24150) Support to configure cpu resource request and limit in pod template

2023-02-27 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694197#comment-17694197 ] Alexis Sarda-Espinosa commented on FLINK-24150: --- [~wangyang0918] this has been

[jira] [Commented] (FLINK-31140) Load additional dependencies in operator classpath

2023-02-27 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694194#comment-17694194 ] Alexis Sarda-Espinosa commented on FLINK-31140: --- If you don't mind me asking a question

[jira] [Created] (FLINK-31246) Remove PodTemplate description from the SpecChange message

2023-02-27 Thread Peter Vary (Jira)
Peter Vary created FLINK-31246: -- Summary: Remove PodTemplate description from the SpecChange message Key: FLINK-31246 URL: https://issues.apache.org/jira/browse/FLINK-31246 Project: Flink Issue

[GitHub] [flink] venkata91 commented on pull request #22033: [FLINK-31109][BP 1.17][Yarn] Support Hadoop proxy user when delegation token fetch is disabled

2023-02-27 Thread via GitHub
venkata91 commented on PR #22033: URL: https://github.com/apache/flink/pull/22033#issuecomment-1446897792 @MartijnVisser Thanks for backporting it to release-1.17! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] venkata91 commented on pull request #22009: [FLINK-31109][yarn] Support Hadoop proxy user when delegation token f…

2023-02-27 Thread via GitHub
venkata91 commented on PR #22009: URL: https://github.com/apache/flink/pull/22009#issuecomment-1446896844 > @venkata91 Can you also create a back port towards `release-1.17`? @MartijnVisser Looks like you already backported it. I was about to get to it. Thanks for backporting it to

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #533: [FLINK-30920] [AutoScaler] adds exclude vertex ids for autoscaler to ignore for evaluation and scaling

2023-02-27 Thread via GitHub
gyfora commented on PR #533: URL: https://github.com/apache/flink-kubernetes-operator/pull/533#issuecomment-1446878621 Please @gauravmiglanid11 also rebase on latest main as we pushed a test hotfix -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #538: [hotfix] Fix autoscaler module mockwebserver tests

2023-02-27 Thread via GitHub
gyfora merged PR #538: URL: https://github.com/apache/flink-kubernetes-operator/pull/538 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] reswqa commented on pull request #22042: [FLINK-27954] JobVertexFlameGraphHandler does not work on standby Dispatcher.

2023-02-27 Thread via GitHub
reswqa commented on PR #22042: URL: https://github.com/apache/flink/pull/22042#issuecomment-1446839774 Hi @XComp , would you mind taking a look at this in your free time~ In general, I want to fix this in the same way as `MetricFetcherImpl`. As a result, the retrieval logic of

[GitHub] [flink] flinkbot commented on pull request #22042: [FLINK-27954] JobVertexFlameGraphHandler does not work on standby Dispatcher.

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

[jira] [Updated] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher

2023-02-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27954: --- Labels: pull-request-available (was: ) > JobVertexFlameGraphHandler does not work on

[GitHub] [flink] reswqa opened a new pull request, #22042: [FLINK-27954] JobVertexFlameGraphHandler does not work on standby Dispatcher.

2023-02-27 Thread via GitHub
reswqa opened a new pull request, #22042: URL: https://github.com/apache/flink/pull/22042 ## What is the purpose of the change *The `JobVertexFlameGraphHandler` relies internally on the `JobVertexThreadInfoTracker` which calls

[jira] [Commented] (FLINK-30879) KafkaShuffleITCase failed with multiple test failures due to a TimeoutException while creating topics

2023-02-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694118#comment-17694118 ] Matthias Pohl commented on FLINK-30879: --- Another one with unexpected error in

[jira] [Comment Edited] (FLINK-31243) KryoSerializer when loaded from user code classloader cannot load Scala extensions from app classloader

2023-02-27 Thread Amit Gurdasani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694087#comment-17694087 ] Amit Gurdasani edited comment on FLINK-31243 at 2/27/23 5:02 PM: -

[jira] [Commented] (FLINK-31243) KryoSerializer when loaded from user code classloader cannot load Scala extensions from app classloader

2023-02-27 Thread Amit Gurdasani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694087#comment-17694087 ] Amit Gurdasani commented on FLINK-31243: [~martijnvisser] I can confirm that I still see the

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-27 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119009430 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java: ## @@ -978,8 +983,8 @@ public

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-27 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119007288 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/DefaultSlotAssigner.java: ## @@ -0,0 +1,78 @@ +/* + * Licensed to the Apache

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21981: [FLINK-21450][runtime] Support LocalRecovery by AdaptiveScheduler

2023-02-27 Thread via GitHub
rkhachatryan commented on code in PR #21981: URL: https://github.com/apache/flink/pull/21981#discussion_r1119006691 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/AllocationsInfo.java: ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache

[GitHub] [flink-web] gyfora merged pull request #613: Kubernetes Operator 1.4.0 blogpost

2023-02-27 Thread via GitHub
gyfora merged PR #613: URL: https://github.com/apache/flink-web/pull/613 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot commented on pull request #22041: [FLINK-xxx][table-planner] Add targetColumns to DynamicTableSink#Context

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

[GitHub] [flink] XComp commented on a diff in pull request #21971: [FLINK-31084][connectors/dataGen] Add default value for dataGen seque…

2023-02-27 Thread via GitHub
XComp commented on code in PR #21971: URL: https://github.com/apache/flink/pull/21971#discussion_r1118919072 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java: ## @@ -83,9 +86,11 @@ public void open(

[GitHub] [flink] reswqa commented on pull request #22010: [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi…

2023-02-27 Thread via GitHub
reswqa commented on PR #22010: URL: https://github.com/apache/flink/pull/22010#issuecomment-1446551387 Thanks @xuzhiwen1255 for creating this, It seems that the CI is failure, PTAL first. -- This is an automated message from the Apache Git Service. To respond to the message, please log

  1   2   3   4   >