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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread GitBox
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…

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread Till Rohrmann (Jira)
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.

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread GitBox
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.

2021-12-05 Thread GitBox
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…

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread Piotr Nowojski (Jira)
[ 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.

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453821#comment-17453821 ] Martijn Visser commented on FLINK-25165: The Cassandra tests are all unstable and would probably

[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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread GitBox
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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread Martijn Visser (Jira)
[ 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

2021-12-05 Thread Martijn Visser (Jira)
[ 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.

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread Martijn Visser (Jira)
[ 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

2021-12-05 Thread Martijn Visser (Jira)
[ 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

2021-12-05 Thread Martijn Visser (Jira)
[ 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

2021-12-05 Thread Martijn Visser (Jira)
[ 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.

2021-12-05 Thread GitBox
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

2021-12-05 Thread GitBox
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:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread Jingsong Lee (Jira)
[ 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.

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453818#comment-17453818 ] Martijn Visser commented on FLINK-21858: I expect that this ticket will be resolved via

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 70e889191bc33c470e4a3746821856427b382387 Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread GitBox
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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread Jingsong Lee (Jira)
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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread GitBox
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

2021-12-05 Thread Jingsong Lee (Jira)
[ 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

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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread GitBox
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] [flink] flinkbot edited a comment on pull request #18016: [FLINK-25163] replace setIncreaseParallelism with setMaxBackgroundJobs.

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread shouzuo meng (Jira)
[ 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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread Jingsong Lee (Jira)
[ 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

2021-12-05 Thread shouzuo meng (Jira)
[ 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

2021-12-05 Thread GitBox
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…

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread GitBox
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:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread shouzuo meng (Jira)
[ 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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17990: URL: https://github.com/apache/flink/pull/17990#issuecomment-984420447 ## CI report: * 892dbf12c5dbdb02d17d936faa2cce06fe8ea4f8 Azure:

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

2021-12-05 Thread shouzuo meng (Jira)
[ 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

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

2021-12-05 Thread Jingsong Lee (Jira)
[ 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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18016: URL: https://github.com/apache/flink/pull/18016#issuecomment-986484985 ## CI report: * 6ebb1f895126a289540b77fcde82f45852a4a031 Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread Jingsong Lee (Jira)
[ 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

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

2021-12-05 Thread Jingsong Lee (Jira)
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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-961202648 ## CI report: * 7817e7dbf864eb758f7b7b46c0647042a03d4dd8 Azure:

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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread shouzuo meng (Jira)
[ 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

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

2021-12-05 Thread Jingsong Lee (Jira)
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

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

2021-12-05 Thread Jingsong Lee (Jira)
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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-986500405 ## CI report: * 99e0300b99aa2e0dc7d36db7feb791e8d09652b9 Azure:

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

2021-12-05 Thread Jingsong Lee (Jira)
[ 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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread Jingsong Lee (Jira)
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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread Jingsong Lee (Jira)
[ 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

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

2021-12-05 Thread Jingsong Lee (Jira)
[ 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

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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-949170131 ## CI report: * 1b1e007b3b10145f38249f664a6b69f70da12206 Azure:

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

2021-12-05 Thread Jingsong Lee (Jira)
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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread Jingsong Lee (Jira)
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

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17969: URL: https://github.com/apache/flink/pull/17969#issuecomment-983248559 ## CI report: * 061a04b1273c7ad00c812f0c2a9a85cc617d47aa Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread GitBox
flinkbot edited a comment on pull request #17977: URL: https://github.com/apache/flink/pull/17977#issuecomment-983482975 ## CI report: * eed0d26454078425557e4c618b0930128db1a38b Azure:

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

2021-12-05 Thread GitBox
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

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

2021-12-05 Thread GitBox
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

  1   2   3   >