[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

gaoyunhaii commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r762770760 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java ## @@ -0,0 +1,243 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-25180) Jepsen test fails while setting up libzip4

Till Rohrmann created FLINK-25180: - Summary: Jepsen test fails while setting up libzip4 Key: FLINK-25180 URL: https://issues.apache.org/jira/browse/FLINK-25180 Project: Flink Issue Type: Bug

[GitHub] [flink] Myasuka edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

Myasuka edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986521676 @liufangqi Why not squash your two commits into one? BTW, I think the commit message could be `[FLINK-25163][state] Replace setIncreaseParallelism with setMaxBackground

[GitHub] [flink] Myasuka commented on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

Myasuka commented on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986521676 @liufangqi Why not squash your two commits into one? BTW, I think the commit message could be `[FLINK-25163][state] Replace setIncreaseParallelism with setMaxBackgroundJobs in

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] liufangqi commented on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

liufangqi commented on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986520370 @Myasuka You are so kind, THX. Did I solve it now? -- 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] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wanglijie95 commented on a change in pull request #17952: [FLINK-25011][runtime] Introduce vertex parallelism decider and the default implementation.

wanglijie95 commented on a change in pull request #17952: URL: https://github.com/apache/flink/pull/17952#discussion_r762767146 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java ## @@ -0,0 +1,132 @@

[GitHub] [flink] wanglijie95 commented on a change in pull request #17952: [FLINK-25011][runtime] Introduce vertex parallelism decider and the default implementation.

wanglijie95 commented on a change in pull request #17952: URL: https://github.com/apache/flink/pull/17952#discussion_r762767146 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java ## @@ -0,0 +1,132 @@

[GitHub] [flink] Myasuka commented on a change in pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

Myasuka commented on a change in pull request #17686: URL: https://github.com/apache/flink/pull/17686#discussion_r762767208 ## File path: docs/content.zh/docs/ops/monitoring/checkpoint_monitoring.md ## @@ -74,8 +74,7 @@ Checkpoint 历史记录保存有关最近触发的 checkpoint 的统计信息， - **Latest Ack

[jira] [Updated] (FLINK-25028) java.lang.OutOfMemoryError: Java heap space

[ https://issues.apache.org/jira/browse/FLINK-25028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25028: --- Priority: Major (was: Critical) > java.lang.OutOfMemoryError: Java heap space > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-25165) CassandraConnectorITCase.testCassandraPojoAtLeastOnceSink failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453821#comment-17453821 ] Martijn Visser commented on FLINK-25165: The Cassandra tests are all unstable an

[GitHub] [flink] KarmaGYZ commented on a change in pull request #18007: [FLINK-25085][runtime] Add a scheduled thread pool in Endpoint and close it when the endpoint is stopped

KarmaGYZ commented on a change in pull request #18007: URL: https://github.com/apache/flink/pull/18007#discussion_r762739538 ## File path: flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/FencedRpcEndpoint.java ## @@ -40,8 +41,10 @@ public abstract class Fe

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] MartijnVisser edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

MartijnVisser edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-986500834 > @leonardBang Are there any good examples from the other dialects that could be used to add more tests? Let me add a bit of background that I know. The test

[GitHub] [flink] MartijnVisser edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

MartijnVisser edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-986500834 @leonardBang Are there any good examples from the other dialects that could be used to add more tests? Let me add a bit of background that I know. The test of

[jira] [Closed] (FLINK-25170) cep supports dynamic rule updates

[ https://issues.apache.org/jira/browse/FLINK-25170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25170. -- Resolution: Duplicate This is a duplicate of https://issues.apache.org/jira/browse/FLINK-7129

[jira] [Updated] (FLINK-25170) cep supports dynamic rule updates

[ https://issues.apache.org/jira/browse/FLINK-25170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25170: --- Affects Version/s: (was: 1.15.0) > cep supports dynamic rule updates > -

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-25172) Fix Document display bug

[ https://issues.apache.org/jira/browse/FLINK-25172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25172: --- Issue Type: Improvement (was: Bug) > Fix Document display bug > >

[jira] [Updated] (FLINK-25172) Fix Document display bug

[ https://issues.apache.org/jira/browse/FLINK-25172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25172: --- Fix Version/s: (was: 1.14.0) > Fix Document display bug > > >

[jira] [Updated] (FLINK-25172) Fix Document display bug

[ https://issues.apache.org/jira/browse/FLINK-25172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25172: --- Priority: Minor (was: Major) > Fix Document display bug > > >

[jira] [Updated] (FLINK-25172) Fix Document display bug

[ https://issues.apache.org/jira/browse/FLINK-25172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25172: --- Labels: (was: pull-requests-available) > Fix Document display bug > --

[GitHub] [flink] Myasuka commented on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

Myasuka commented on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986515823 @liufangqi There is no need to abandon this PR. You could rebase your local `rocksdb-config` branch with latest remote flink's `master` branch and then **force** push to remote

[GitHub] [flink] skyguard1 closed pull request #16646: [FLINK-23550] [FLINK-CORE] Support brotli compression algorithm

skyguard1 closed pull request #16646: URL: https://github.com/apache/flink/pull/16646 -- 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-unsub

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r762762819 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,185 @@ +/* + * Licensed to t

[jira] [Updated] (FLINK-25152) FLIP-188: Introduce Built-in Dynamic Table Storage

[ https://issues.apache.org/jira/browse/FLINK-25152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25152: - Description: introduce built-in storage support for dynamic table, a truly unified changelog &

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] AHeise commented on a change in pull request #17924: [FLINK-25072][streaming] Introduce description on Transformation and …

AHeise commented on a change in pull request #17924: URL: https://github.com/apache/flink/pull/17924#discussion_r762756877 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java ## @@ -242,6 +243,14 @@ public String getOperatorNam

[jira] [Commented] (FLINK-21858) TaskMetricGroup taskName is too long, especially in sql tasks.

[ https://issues.apache.org/jira/browse/FLINK-21858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453818#comment-17453818 ] Martijn Visser commented on FLINK-21858: I expect that this ticket will be resol

[GitHub] [flink] flinkbot edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 70e889191bc33c470e4a3746821856427b382387 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] liufangqi commented on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

liufangqi commented on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986511412 @Myasuka Could I delete the remote branch rocksdb-config, then create a new branch? -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-25179) Add document for array,map,row types support for parquet row writer

Jingsong Lee created FLINK-25179: Summary: Add document for array,map,row types support for parquet row writer Key: FLINK-25179 URL: https://issues.apache.org/jira/browse/FLINK-25179 Project: Flink

[GitHub] [flink] JingsongLi commented on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-986510346 I create https://issues.apache.org/jira/browse/FLINK-25179 for documentation, comment it if you want to take it. -- This is an automated message from the Apache Git Service

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] camilesing commented on a change in pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

camilesing commented on a change in pull request #17686: URL: https://github.com/apache/flink/pull/17686#discussion_r762757526 ## File path: docs/content.zh/docs/ops/monitoring/checkpoint_monitoring.md ## @@ -74,8 +74,7 @@ Checkpoint 历史记录保存有关最近触发的 checkpoint 的统计信息， - **Latest

[jira] [Closed] (FLINK-17782) Add array,map,row types support for parquet row writer

[ https://issues.apache.org/jira/browse/FLINK-17782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17782. Resolution: Fixed master: dac64256a0c961f76d2de35678861accd9927bd7 > Add array,map,row types supp

[GitHub] [flink] liufangqi commented on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

liufangqi commented on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986509927 @Myasuka Wait for a minute. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] liufangqi commented on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

liufangqi commented on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986509502 @Myasuka Sorry for my fault. I think I solve the conflict now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shouzuo meng updated FLINK-25171: - Attachment: 5261638775663_.pic.jpg > When the DDL statement was executed, the column names of th

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-17782) Add array,map,row types support for parquet row writer

[ https://issues.apache.org/jira/browse/FLINK-17782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17782: - Fix Version/s: 1.15.0 > Add array,map,row types support for parquet row writer > ---

[jira] [Updated] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shouzuo meng updated FLINK-25171: - Attachment: (was: 5251638775474_.pic.jpg) > When the DDL statement was executed, the column

[GitHub] [flink] JingsongLi commented on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-986507622 @meetjunsu Can you create PR for modifying this page: https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/formats/parquet/#data-type-mapping -- This

[GitHub] [flink] Myasuka commented on a change in pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

Myasuka commented on a change in pull request #17686: URL: https://github.com/apache/flink/pull/17686#discussion_r762754553 ## File path: docs/content.zh/docs/ops/monitoring/checkpoint_monitoring.md ## @@ -74,8 +74,7 @@ Checkpoint 历史记录保存有关最近触发的 checkpoint 的统计信息， - **Latest Ack

[GitHub] [flink] JingsongLi merged pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi merged pull request #17542: URL: https://github.com/apache/flink/pull/17542 -- 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-unsu

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shouzuo meng updated FLINK-25171: - Description: When I execute the DDL statement, I mistakenly use the duplicate field name in THE

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17990: [FLINK-25142][Connectors / Hive]Fix user-defined hive udtf initialize exception in hive dialect

flinkbot edited a comment on pull request #17990: URL: https://github.com/apache/flink/pull/17990#issuecomment-984420447 ## CI report: * 892dbf12c5dbdb02d17d936faa2cce06fe8ea4f8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shouzuo meng updated FLINK-25171: - Attachment: 5251638775474_.pic.jpg > When the DDL statement was executed, the column names of th

[jira] [Updated] (FLINK-25178) Throw exception when managed table sink needs checkpointing

[ https://issues.apache.org/jira/browse/FLINK-25178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25178: - Component/s: Table SQL / Planner (was: Table SQL / API) > Throw exception w

[GitHub] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-25178) Throw exception when managed table sink needs checkpointing

[ https://issues.apache.org/jira/browse/FLINK-25178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25178: - Summary: Throw exception when managed table sink needs checkpointing (was: Throw exception when

[jira] [Created] (FLINK-25178) Throw exception when managed table sink needs checkpoint

Jingsong Lee created FLINK-25178: Summary: Throw exception when managed table sink needs checkpoint Key: FLINK-25178 URL: https://issues.apache.org/jira/browse/FLINK-25178 Project: Flink Issu

[GitHub] [flink] flinkbot edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #32: [FLINK-24817] Add Naive Bayes implementation

zhipeng93 commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r762744664 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayesModelData.java ## @@ -0,0 +1,151 @@ +/* + * Licensed to t

[jira] [Updated] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shouzuo meng updated FLINK-25171: - Description: When I execute the DDL statement, I mistakenly use the duplicate field name in THE

[jira] [Created] (FLINK-25177) Support "DESCRIBE TABLE EXTENDED" with managed table

Jingsong Lee created FLINK-25177: Summary: Support "DESCRIBE TABLE EXTENDED" with managed table Key: FLINK-25177 URL: https://issues.apache.org/jira/browse/FLINK-25177 Project: Flink Issue Ty

[jira] [Created] (FLINK-25176) Introduce "ALTER TABLE ... COMPACT" SQL

Jingsong Lee created FLINK-25176: Summary: Introduce "ALTER TABLE ... COMPACT" SQL Key: FLINK-25176 URL: https://issues.apache.org/jira/browse/FLINK-25176 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #18017: [FLINK-25171] Validation of duplicate fields in derived tables

flinkbot edited a comment on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-986500405 ## CI report: * 99e0300b99aa2e0dc7d36db7feb791e8d09652b9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-25173) Introduce CatalogLock

[ https://issues.apache.org/jira/browse/FLINK-25173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25173: - Description: Currently, only HiveCatalog can provide this catalog lock. {code:java} /**  * An in

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #18017: [FLINK-25171] Validation of duplicate fields in derived tables

flinkbot commented on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-986501578 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Created] (FLINK-25175) Introduce TableDescriptor.forManaged

Jingsong Lee created FLINK-25175: Summary: Introduce TableDescriptor.forManaged Key: FLINK-25175 URL: https://issues.apache.org/jira/browse/FLINK-25175 Project: Flink Issue Type: Sub-task

[GitHub] [flink] MartijnVisser commented on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

MartijnVisser commented on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-986500834 @leonardBang Are there any good examples from the other dialects that could be used to add more tests? -- This is an automated message from the Apache Git Service. To re

[jira] [Updated] (FLINK-25174) Introduce ManagedTableFactory

[ https://issues.apache.org/jira/browse/FLINK-25174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25174: - Description: We need an interface to discover the managed table factory implementation for mana

[jira] [Updated] (FLINK-25174) Introduce ManagedTableFactory

[ https://issues.apache.org/jira/browse/FLINK-25174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25174: - Description: We need an interface to discover the managed table factory implementation for mana

[GitHub] [flink] flinkbot commented on pull request #18017: [FLINK-25171] Validation of duplicate fields in derived tables

flinkbot commented on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-986500405 ## CI report: * 99e0300b99aa2e0dc7d36db7feb791e8d09652b9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

flinkbot edited a comment on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-949170131 ## CI report: * 1b1e007b3b10145f38249f664a6b69f70da12206 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-25174) Introduce ManagedTableFactory

Jingsong Lee created FLINK-25174: Summary: Introduce ManagedTableFactory Key: FLINK-25174 URL: https://issues.apache.org/jira/browse/FLINK-25174 Project: Flink Issue Type: Sub-task

[GitHub] [flink] jelly-1203 opened a new pull request #18017: [FLINK-25171] Added validation for duplicate fields in derived tables

jelly-1203 opened a new pull request #18017: URL: https://github.com/apache/flink/pull/18017 ## What is the purpose of the change The purpose of this pull Request is to add validation to the derived table that the fields are duplicated ## Brief change log *(for exam

[jira] [Created] (FLINK-25173) Introduce CatalogLock

Jingsong Lee created FLINK-25173: Summary: Introduce CatalogLock Key: FLINK-25173 URL: https://issues.apache.org/jira/browse/FLINK-25173 Project: Flink Issue Type: Sub-task Componen

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17969: [FLINK-25031][runtime] Job finishes iff all job vertices finish.

flinkbot edited a comment on pull request #17969: URL: https://github.com/apache/flink/pull/17969#issuecomment-983248559 ## CI report: * 061a04b1273c7ad00c812f0c2a9a85cc617d47aa Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17977: [FLINK-24661][core][table] ConfigOption add isSecret method to judge sensitive options

flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r762744248 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,185 @@ +/* + * Licensed to t

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r762744248 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,185 @@ +/* + * Licensed to t

  1   2   3   >