[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] snuyanzin opened a new pull request #17922: [FLINK-24908][Table SQL/Client] Improve SQL Error description for SQL Client

snuyanzin opened a new pull request #17922: URL: https://github.com/apache/flink/pull/17922 ## What is the purpose of the change There are some problem queries with misprints like ```sql ELECT 1; /* comment */ SEECT 1; ``` Currently SQL client responses for such que

[GitHub] [flink] AHeise merged pull request #17881: [FLINK-24971][tests] Adding retry mechanism in case git clone fails

AHeise merged pull request #17881: URL: https://github.com/apache/flink/pull/17881 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] shenzhu commented on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

shenzhu commented on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-979761896 Hey @JingsongLi , thanks for assigning the ticket to me! Would you mind taking a look at this PR when you have a moment? -- This is an automated message from the Apache Git Se

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] xiangqiao123 commented on a change in pull request #17826: [FLINK-24953][Connectors / Hive]Optime hive parallelism inference

xiangqiao123 commented on a change in pull request #17826: URL: https://github.com/apache/flink/pull/17826#discussion_r757281586 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveParallelismInference.java ## @@ -63,10 +63,10

[GitHub] [flink] xiangqiao123 commented on a change in pull request #17826: [FLINK-24953][Connectors / Hive]Optime hive parallelism inference

xiangqiao123 commented on a change in pull request #17826: URL: https://github.com/apache/flink/pull/17826#discussion_r757281586 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveParallelismInference.java ## @@ -63,10 +63,10

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] Tartarus0zm commented on a change in pull request #17826: [FLINK-24953][Connectors / Hive]Optime hive parallelism inference

Tartarus0zm commented on a change in pull request #17826: URL: https://github.com/apache/flink/pull/17826#discussion_r757279531 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveParallelismInference.java ## @@ -63,10 +63,10

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[jira] [Created] (FLINK-25068) Show the maximum parallelism (number of key groups) of a job in Web UI

zlzhang0122 created FLINK-25068: --- Summary: Show the maximum parallelism (number of key groups) of a job in Web UI Key: FLINK-25068 URL: https://issues.apache.org/jira/browse/FLINK-25068 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

yunfengzhou-hub commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r757264541 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnParams.java ## @@ -0,0 +1,18 @@ +package org.apache.flink.ml.clas

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

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

[GitHub] [flink] flinkbot edited a comment on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

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

[GitHub] [flink] banmoy commented on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

banmoy commented on pull request #17921: URL: https://github.com/apache/flink/pull/17921#issuecomment-979737934 @Myasuka Please help to review this PR. -- 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

[GitHub] [flink] flinkbot commented on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

flinkbot commented on pull request #17921: URL: https://github.com/apache/flink/pull/17921#issuecomment-979737516 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

[GitHub] [flink] flinkbot commented on pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

flinkbot commented on pull request #17921: URL: https://github.com/apache/flink/pull/17921#issuecomment-979737381 ## CI report: * 80213498bbe8a905b5fcd2ee0077b3c59853b443 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-23798) Avoid using reflection to get filter when partition filter is enabled

[ https://issues.apache.org/jira/browse/FLINK-23798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23798: --- Labels: pull-request-available (was: ) > Avoid using reflection to get filter when partitio

[GitHub] [flink] banmoy opened a new pull request #17921: [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enable

banmoy opened a new pull request #17921: URL: https://github.com/apache/flink/pull/17921 ## What is the purpose of the change FLINK-20496 introduce partitioned index & filter to Flink. However, RocksDB only support new full format of filter in this feature, and we need to rep

[jira] [Updated] (FLINK-21027) Add isStateKeyValueSerialized() method to KeyedStateBackend interface

[ https://issues.apache.org/jira/browse/FLINK-21027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-21027: - Fix Version/s: 1.15.0 > Add isStateKeyValueSerialized() method to KeyedStateBackend interface >

[jira] [Assigned] (FLINK-21027) Add isStateKeyValueSerialized() method to KeyedStateBackend interface

[ https://issues.apache.org/jira/browse/FLINK-21027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-21027: Assignee: Yun Tang > Add isStateKeyValueSerialized() method to KeyedStateBackend interface >

[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_r757255599 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java ## @@ -146,7 +145,7 @@ public IterationBodyResult process(

[GitHub] [flink] flinkbot edited a comment on pull request #17920: [FLINK-25067][doc] Correct the description of RocksDB's background threads for flush and compaction

flinkbot edited a comment on pull request #17920: URL: https://github.com/apache/flink/pull/17920#issuecomment-979723335 ## CI report: * 92ab9a62c27a104103b1ba3d9d9d55a956dadb50 Azure: [PENDING](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_r757247408 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,213 @@ +/* + * 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_r757252256 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticGradient.java ## @@ -0,0 +1,95 @@ +/* + * Licensed to the Apach

[GitHub] [flink] flinkbot commented on pull request #17920: [FLINK-25067][doc] Correct the description of RocksDB's background threads for flush and compaction

flinkbot commented on pull request #17920: URL: https://github.com/apache/flink/pull/17920#issuecomment-979723264 -- 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 unsubsc

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][Table SQL/API] Casting to a CHAR() and VARCHAR() doesn't trim the string to the specified precision

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

[jira] [Updated] (FLINK-25067) Correct the description of RocksDB's background threads

[ https://issues.apache.org/jira/browse/FLINK-25067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25067: --- Labels: pull-request-available (was: ) > Correct the description of RocksDB's background th

[GitHub] [flink] Myasuka opened a new pull request #17920: [FLINK-25067][doc] Correct the description of RocksDB's background threads for flush and compaction

Myasuka opened a new pull request #17920: URL: https://github.com/apache/flink/pull/17920 ## What is the purpose of the change Correct the description of RocksDB's background threads for flush and compaction. ## Verifying this change This change is a trivial rework

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][Table SQL/API] Casting to a CHAR() and VARCHAR() doesn't trim the string to the specified precision

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

[GitHub] [flink] Zakelly commented on a change in pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

Zakelly commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r757248608 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBConfigurableOptions.java ## @

[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_r757248612 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/SortPartitionImpl.java ## @@ -0,0 +1,97 @@ +/* + * Licensed to the Apache S

[GitHub] [flink] flinkbot edited a comment on pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

flinkbot edited a comment on pull request #17761: URL: https://github.com/apache/flink/pull/17761#issuecomment-965943227 ## CI report: * 6b9562e4437590efafbfbc1d714f537c0567fba9 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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_r757248185 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java ## @@ -146,7 +145,7 @@ public IterationBodyResult process(

[GitHub] [flink] Zakelly commented on a change in pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

Zakelly commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r757247965 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java ## @@

[jira] [Assigned] (FLINK-25045) Introduce AdaptiveBatchScheduler

[ https://issues.apache.org/jira/browse/FLINK-25045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25045: --- Assignee: Lijie Wang > Introduce AdaptiveBatchScheduler > > >

[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_r757247408 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,213 @@ +/* + * Licensed to t

[jira] [Assigned] (FLINK-25033) Let some scheduler components updatable

[ https://issues.apache.org/jira/browse/FLINK-25033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25033: --- Assignee: Lijie Wang > Let some scheduler components updatable > --

[jira] [Assigned] (FLINK-25032) Allow to create execution vertices and execution edges lazily

[ https://issues.apache.org/jira/browse/FLINK-25032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25032: --- Assignee: Lijie Wang > Allow to create execution vertices and execution edges lazily >

[jira] [Assigned] (FLINK-25035) Shuffle Service Supports Consuming Subpartition Range

[ https://issues.apache.org/jira/browse/FLINK-25035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25035: --- Assignee: Lijie Wang > Shuffle Service Supports Consuming Subpartition Range >

[jira] [Assigned] (FLINK-25034) Support flexible number of subpartitions in IntermediateResultPartition

[ https://issues.apache.org/jira/browse/FLINK-25034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25034: --- Assignee: Lijie Wang > Support flexible number of subpartitions in IntermediateResultPartition > --

[jira] [Assigned] (FLINK-25036) Introduce stage-wised scheduling strategy

[ https://issues.apache.org/jira/browse/FLINK-25036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25036: --- Assignee: Lijie Wang > Introduce stage-wised scheduling strategy >

[jira] [Assigned] (FLINK-25011) Introduce VertexParallelismDecider

[ https://issues.apache.org/jira/browse/FLINK-25011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25011: --- Assignee: Lijie Wang > Introduce VertexParallelismDecider > -- > >

[jira] [Assigned] (FLINK-25031) Job finishes iff all job vertices finish

[ https://issues.apache.org/jira/browse/FLINK-25031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25031: --- Assignee: Lijie Wang > Job finishes iff all job vertices finish > -

[jira] [Assigned] (FLINK-24892) FLIP-187: Adaptive Batch Scheduler

[ https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-24892: --- Assignee: Lijie Wang > FLIP-187: Adaptive Batch Scheduler > -- > >

[jira] [Assigned] (FLINK-24980) Collect sizes of finished BLOCKING result partitions

[ https://issues.apache.org/jira/browse/FLINK-24980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-24980: --- Assignee: Lijie Wang > Collect sizes of finished BLOCKING result partitions > -

[GitHub] [flink] Zakelly commented on a change in pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

Zakelly commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r757247017 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackend.java ##

[GitHub] [flink] Zakelly commented on a change in pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

Zakelly commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r757246538 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java ## @@

[GitHub] [flink] Zakelly commented on a change in pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

Zakelly commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r757245729 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackend.java ##

[GitHub] [flink] Zakelly commented on a change in pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

Zakelly commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r757245444 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java ## @@ -50,26

[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_r757245219 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java ## @@ -146,7 +145,7 @@ public IterationBodyResult process(

[GitHub] [flink] Zakelly commented on a change in pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

Zakelly commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r757245062 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java ## @@ -83,35

[GitHub] [flink] Zakelly commented on a change in pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

Zakelly commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r757244954 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java ## @@ -131,55

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][Table SQL/API] Casting to a CHAR() and VARCHAR() doesn't trim the string to the specified precision

flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * aa962bd691e9648a1cfcacaebee015fecef2ec7c 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_r757242053 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/SortPartitionImpl.java ## @@ -0,0 +1,97 @@ +/* + * Licensed to the Apache S

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 12d370196fdbe6ff098e8c93512b90fb774aa5c6 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_r757240950 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasMaxIter.java ## @@ -26,7 +26,7 @@ /** Interface for the shared maxIter param

[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] part1: Fix wrong results when sink primary key is not the same with query result's changelog upsert key

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

[GitHub] [flink] liuyongvs commented on pull request #17777: [FLINK-24886][core] TimeUtils supports the form of m.

liuyongvs commented on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-979708663 @Thesharing , but if not modified the existing configurations, it will throw exception. and the "m" is also supports. so i think it is not problem, what do you think @tillroh

[jira] [Commented] (FLINK-24884) flink flame graph webui bug

[ https://issues.apache.org/jira/browse/FLINK-24884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449377#comment-17449377 ] jackylau commented on FLINK-24884: -- hi [~trohrmann] , anyone will have time to review i

[jira] (FLINK-24884) flink flame graph webui bug

[ https://issues.apache.org/jira/browse/FLINK-24884 ] jackylau deleted comment on FLINK-24884: -- was (Author: jackylau): hi [~junhany] any one will review it? > flink flame graph webui bug > --- > > Key: FLIN

[jira] [Commented] (FLINK-24884) flink flame graph webui bug

[ https://issues.apache.org/jira/browse/FLINK-24884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449376#comment-17449376 ] jackylau commented on FLINK-24884: -- hi [~junhany] any one will review it? > flink flam

[GitHub] [flink] xiangqiao123 commented on pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

xiangqiao123 commented on pull request #17761: URL: https://github.com/apache/flink/pull/17761#issuecomment-979703361 @rmetzger @Tartarus0zm Thank you for your review. I have modified the logic to skip validation: skip validate if the input is not instance of UserDefinedFunction.

[GitHub] [flink] flinkbot edited a comment on pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

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

[GitHub] [flink] flinkbot edited a comment on pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

flinkbot edited a comment on pull request #17761: URL: https://github.com/apache/flink/pull/17761#issuecomment-965943227 ## CI report: * d77e81463fafbc26a61207f3246bb82ecdce88ff 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_r757229351 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticGradient.java ## @@ -0,0 +1,95 @@ +/* + * Licensed to the Apach

[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_r757227966 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModelData.java ## @@ -0,0 +1,102 @@ +/* + * Licensed

[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_r757227966 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModelData.java ## @@ -0,0 +1,102 @@ +/* + * Licensed

[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_r757227812 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegressionModel.java ## @@ -0,0 +1,213 @@ +/* + * Licensed to t

[GitHub] [flink] Zakelly commented on a change in pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

Zakelly commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r757225258 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java ## @@ -83,35

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

yunfengzhou-hub commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r757201463 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/NaiveBayesTest.java ## @@ -0,0 +1,327 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-25067) Correct the description of RocksDB's background threads

Yun Tang created FLINK-25067: Summary: Correct the description of RocksDB's background threads Key: FLINK-25067 URL: https://issues.apache.org/jira/browse/FLINK-25067 Project: Flink Issue Type: B

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

yunfengzhou-hub commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r757201463 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/NaiveBayesTest.java ## @@ -0,0 +1,327 @@ +/* + * Licensed to the Apache

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

yunfengzhou-hub commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r757201463 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/NaiveBayesTest.java ## @@ -0,0 +1,327 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

zhipeng93 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r757194716 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Sof

[GitHub] [flink] shenzhu commented on a change in pull request #17831: [FLINK-15825][Table SQL/API] Add renameDatabase() to Catalog

shenzhu commented on a change in pull request #17831: URL: https://github.com/apache/flink/pull/17831#discussion_r757216616 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java ## @@ -398,6 +398,34 @@ public voi

[GitHub] [flink] Myasuka commented on a change in pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

Myasuka commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r757203945 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java ## @@ -50,26

[GitHub] [flink] ZhangChaoming closed pull request #14978: [hotfix][flink-yarn] Modify options' description format.

ZhangChaoming closed pull request #14978: URL: https://github.com/apache/flink/pull/14978 -- 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-u

[GitHub] [flink] ZhangChaoming closed pull request #14980: [hotfix][flink-streaming-java] Remove the reference of nonexistent class.

ZhangChaoming closed pull request #14980: URL: https://github.com/apache/flink/pull/14980 -- 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-u

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

yunfengzhou-hub commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r757211597 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/NaiveBayesTest.java ## @@ -0,0 +1,327 @@ +/* + * Licensed to the Apache

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

yunfengzhou-hub commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r757211597 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/NaiveBayesTest.java ## @@ -0,0 +1,327 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17918: [FLINK-25065][docs] Update document for jdbc connector

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

  1   2   3   4   5   6   7   >