[GitHub] [flink] lincoln-lil commented on a change in pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key

lincoln-lil commented on a change in pull request #17699: URL: https://github.com/apache/flink/pull/17699#discussion_r754006462 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala ##

[GitHub] [flink] fsk119 closed pull request #14444: [FLINK-20091][avro] add ignore-parse-error for avro formats

fsk119 closed pull request #1: URL: https://github.com/apache/flink/pull/1 -- 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] zuston edited a comment on pull request #17837: [FLINK-24963] Remove the tail separator when outputting yarn queue names

zuston edited a comment on pull request #17837: URL: https://github.com/apache/flink/pull/17837#issuecomment-973923338 @tillrohrmann @becketqin Could you help review it? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-24947) Flink on k8s support HostNetWork model

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447227#comment-17447227 ] liuzhuo commented on FLINK-24947: - It seems feasible to create the Service on the client

[jira] [Updated] (FLINK-24947) Flink on k8s support HostNetWork model

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhuo updated FLINK-24947: Attachment: (was: image-2021-11-22-15-23-17-881.png) > Flink on k8s support HostNetWork model > --

[jira] [Updated] (FLINK-24947) Flink on k8s support HostNetWork model

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhuo updated FLINK-24947: Attachment: image-2021-11-22-15-23-17-881.png > Flink on k8s support HostNetWork model > -

[GitHub] [flink] SteNicholas commented on pull request #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default

SteNicholas commented on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-975197030 > @SteNicholas Why not follow Flink's [code contribution process](https://flink.apache.org/contributing/contribute-code.html#code-contribution-process) to make the assignmen

[jira] [Closed] (FLINK-24781) Port from string casting logic to CastRule

[ https://issues.apache.org/jira/browse/FLINK-24781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24781. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: commit 9f7eef293f723800945a9759c5

[GitHub] [flink] twalthr closed pull request #17800: [FLINK-24781] Add to string casting rules

twalthr closed pull request #17800: URL: https://github.com/apache/flink/pull/17800 -- 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-unsubsc

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

JingsongLi commented on a change in pull request #17699: URL: https://github.com/apache/flink/pull/17699#discussion_r753993288 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala ###

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

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

[jira] [Closed] (FLINK-24608) Sinks built with the unified sink framework do not receive timestamps when used in Table API

[ https://issues.apache.org/jira/browse/FLINK-24608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24608. Fix Version/s: 1.15.0 1.14.1 Release Note: This adds an additional operator

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

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

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

JingsongLi commented on a change in pull request #17699: URL: https://github.com/apache/flink/pull/17699#discussion_r753992140 ## File path: docs/layouts/shortcodes/generated/execution_config_configuration.html ## @@ -58,6 +58,12 @@ Enum The NOT NULL c

[GitHub] [flink] Airblader commented on a change in pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

Airblader commented on a change in pull request #17847: URL: https://github.com/apache/flink/pull/17847#discussion_r753989519 ## File path: flink-connectors/flink-connector-mongodb/src/main/java/org/apache/flink/mongodb/table/MongodbDynamicTableSourceSinkFactory.java ## @@ -0,

[GitHub] [flink] Airblader commented on a change in pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

Airblader commented on a change in pull request #17847: URL: https://github.com/apache/flink/pull/17847#discussion_r753988501 ## File path: flink-connectors/flink-connector-mongodb/src/main/java/org/apache/flink/mongodb/table/MongodbDynamicTableSourceSinkFactory.java ## @@ -0,

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

zhipeng93 edited a comment on pull request #28: URL: https://github.com/apache/flink-ml/pull/28#issuecomment-975178654 -- 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 un

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

zhipeng93 commented on pull request #28: URL: https://github.com/apache/flink-ml/pull/28#issuecomment-975178654 Hi @yunfengzhou-hub, thanks for the review. This PR is updated according to your comments. -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] flinkbot edited a comment on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

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

[GitHub] [flink] flinkbot edited a comment on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

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

[jira] [Comment Edited] (FLINK-24002) Support count window with the window TVF

[ https://issues.apache.org/jira/browse/FLINK-24002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440889#comment-17440889 ] Yuepeng Pan edited comment on FLINK-24002 at 11/22/21, 6:36 AM: --

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

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

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

[jira] [Comment Edited] (FLINK-24975) Add hooks and extension points to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447203#comment-17447203 ] junbiao chen edited comment on FLINK-24975 at 11/22/21, 6:06 AM: -

[jira] [Commented] (FLINK-24975) Add hooks and extension points to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447203#comment-17447203 ] junbiao chen commented on FLINK-24975: -- [~wenlong.lwl] I have developed some optimi

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

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

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

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

[GitHub] [flink] JasonLeeCoding commented on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

JasonLeeCoding commented on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-975149201 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the sp

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 96a6ba2a83ca22091099ef36201afcbd8e71

[GitHub] [flink] gaurav726 commented on a change in pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

gaurav726 commented on a change in pull request #17754: URL: https://github.com/apache/flink/pull/17754#discussion_r753941893 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java ## @@ -146,10 +1

[GitHub] [flink] gaurav726 commented on a change in pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

gaurav726 commented on a change in pull request #17754: URL: https://github.com/apache/flink/pull/17754#discussion_r753941893 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java ## @@ -146,10 +1

[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_r753910367 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,594 @@ +package org.apache.flink.ml.clas

[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_r753905182 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/EuclideanDistance.java ## @@ -0,0 +1,272 @@ +package org.apache.flin

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

yunfengzhou-hub commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r753928296 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasBatchSize.java ## @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache Softw

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

yunfengzhou-hub commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r753930171 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasL2.java ## @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [flink] dailai commented on pull request #17847: [FLINK-6573][Connectors/Common ] Flink MongoDB Connector

dailai commented on pull request #17847: URL: https://github.com/apache/flink/pull/17847#issuecomment-975096035 不支持upsert么 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Commented] (FLINK-24975) Add hooks and extension points to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447194#comment-17447194 ] Wenlong Lyu commented on FLINK-24975: - hi, [~dahaishuantuoba], it is an interesting

[jira] [Commented] (FLINK-24949) KafkaITCase.testBigRecordJob fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447195#comment-17447195 ] Jiangjie Qin commented on FLINK-24949: -- [~gaoyunhaii] not sure if this is the same

[jira] [Commented] (FLINK-24918) Support to specify the data dir for state benchmark

[ https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447188#comment-17447188 ] Yun Tang commented on FLINK-24918: -- Merged in flink-master: 726eead617bb3392df6a6ef1681

[GitHub] [flink] Myasuka closed pull request #17846: [FLINK-24918][Runtime/State Backends]Support to specify the data dir …

Myasuka closed pull request #17846: URL: https://github.com/apache/flink/pull/17846 -- 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-unsubsc

[jira] [Commented] (FLINK-24926) Key group is not in KeyGroupRange when joining two streams with table API

[ https://issues.apache.org/jira/browse/FLINK-24926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447187#comment-17447187 ] Yun Tang commented on FLINK-24926: -- [~liuhb86] Can you repeat this error every time? I

[GitHub] [flink] flinkbot edited a comment on pull request #17736: [FLINK-24694][docs-zh] Translate "Checkpointing under backpressure" page into Chinese

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

[jira] [Commented] (FLINK-24967) Make the IO pattern configureable in state benchmarks

[ https://issues.apache.org/jira/browse/FLINK-24967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447186#comment-17447186 ] Yun Tang commented on FLINK-24967: -- I think introducing various size of state related o

[jira] [Updated] (FLINK-24975) Add hooks and extension points to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] junbiao chen updated FLINK-24975: - Component/s: Table SQL / Planner > Add hooks and extension points to FlinkSQL >

[jira] [Created] (FLINK-24975) Add hooks and extension points to FlinkSQL

junbiao chen created FLINK-24975: Summary: Add hooks and extension points to FlinkSQL Key: FLINK-24975 URL: https://issues.apache.org/jira/browse/FLINK-24975 Project: Flink Issue Type: New Fe

[jira] [Commented] (FLINK-24947) Flink on k8s support HostNetWork model

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447179#comment-17447179 ] Yang Wang commented on FLINK-24947: --- Thanks for your detailed comments. I am curious

[jira] [Updated] (FLINK-24947) Flink on k8s support HostNetWork model

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-24947: -- Fix Version/s: 1.15.0 > Flink on k8s support HostNetWork model > -

[jira] [Updated] (FLINK-24947) Flink on k8s support HostNetWork model

[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-24947: -- Priority: Major (was: Minor) > Flink on k8s support HostNetWork model > -

[GitHub] [flink] Myasuka commented on pull request #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default

Myasuka commented on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-975029611 @SteNicholas Why not follow Flink's [code contribution process](https://flink.apache.org/contributing/contribute-code.html#code-contribution-process) to make the assignment in J

[jira] [Commented] (FLINK-24961) When the DDL statement is different from the actual schema in the database, ArrayIndexOutOfBoundsException will be reported

[ https://issues.apache.org/jira/browse/FLINK-24961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447177#comment-17447177 ] Fangliang Liu commented on FLINK-24961: --- Hi  [~jark] [~lzljs3620320], Take a look,

[jira] [Commented] (FLINK-24953) Optime hive parallelism inference

[ https://issues.apache.org/jira/browse/FLINK-24953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447174#comment-17447174 ] Jingsong Lee commented on FLINK-24953: -- cc: [~jark]  > Optime hive parallelism inf

[jira] [Commented] (FLINK-24758) filesystem sink: partition.time-extractor.kind support "yyyyMMdd"

[ https://issues.apache.org/jira/browse/FLINK-24758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447175#comment-17447175 ] Jingsong Lee commented on FLINK-24758: -- CC: [~jark]  > filesystem sink: partition.

[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_r753896511 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnParams.java ## @@ -0,0 +1,32 @@ +package org.apache.flink.ml.clas

[jira] [Closed] (FLINK-16937) ParquetTableSource should generate correct isFilterPushedDown

[ https://issues.apache.org/jira/browse/FLINK-16937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-16937. Resolution: Won't Fix ParquetTableSource is removed in latest version. > ParquetTableSource shoul

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 96a6ba2a83ca22091099ef36201afcbd8e71

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 96a6ba2a83ca22091099ef36201afcbd8e71

[GitHub] [flink] maosuhan commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-975009706 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] flinkbot edited a comment on pull request #17736: [FLINK-24694][docs-zh] Translate "Checkpointing under backpressure" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #17736: [FLINK-24694][docs-zh] Translate "Checkpointing under backpressure" page into Chinese

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

[GitHub] [flink] wangyang0918 commented on a change in pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

wangyang0918 commented on a change in pull request #17554: URL: https://github.com/apache/flink/pull/17554#discussion_r753895825 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -256,39 +247,50 @@ private String ge

[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_r753894135 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,343 @@ +package org.apache.flink.ml.clas

[jira] [Closed] (FLINK-24969) pyflink/table/tests/test_pandas_udf.py hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-24969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24969. --- Resolution: Duplicate It seems that it should be caused by the same reason as FLINK-24764. I'm closing this

[jira] [Commented] (FLINK-24803) Fix cast BINARY/VARBINARY to STRING

[ https://issues.apache.org/jira/browse/FLINK-24803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447166#comment-17447166 ] Shen Zhu commented on FLINK-24803: -- Hi Timo([~twalthr] ), Marios([~matriv]), I'm intere

[jira] [Updated] (FLINK-14458) Assert implementation classes of catalog objects

[ https://issues.apache.org/jira/browse/FLINK-14458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14458: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-10346) MemoryStateBackend does not clean up checkpoint directory

[ https://issues.apache.org/jira/browse/FLINK-10346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10346: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-10442) Make declined savepoints visible in WebUI

[ https://issues.apache.org/jira/browse/FLINK-10442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10442: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets

[ https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16468: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-10305) flink-conf.yaml grows continuously

[ https://issues.apache.org/jira/browse/FLINK-10305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10305: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii char in the column definition

[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16506: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-10382) Writer has already been opened while using AvroKeyValueSinkWriter and BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-10382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10382: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-10409) Collection data sink does not propagate exceptions

[ https://issues.apache.org/jira/browse/FLINK-10409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10409: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-14550) Can't use proctime attribute when register datastream to flink table which uses some fields in the nested fields

[ https://issues.apache.org/jira/browse/FLINK-14550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14550: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-10280) json that contains an object can not be parsed

[ https://issues.apache.org/jira/browse/FLINK-10280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10280: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-14412) Rename ML Pipeline to MLPipeline

[ https://issues.apache.org/jira/browse/FLINK-14412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14412: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-16452) Insert into static partition doesn't support order by or limit

[ https://issues.apache.org/jira/browse/FLINK-16452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16452: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-14438) Fix RowTypeInfo.equals()

[ https://issues.apache.org/jira/browse/FLINK-14438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14438: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-14514) Improve interface of FunctionContext#getJobParameter

[ https://issues.apache.org/jira/browse/FLINK-14514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14514: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-14508) google protobuf is not shaded

[ https://issues.apache.org/jira/browse/FLINK-14508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14508: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-10408) Cannot use window information in Table functions

[ https://issues.apache.org/jira/browse/FLINK-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10408: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed

[ https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14565: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was: au

[jira] [Updated] (FLINK-16682) Make batch size configurable for orc reader

[ https://issues.apache.org/jira/browse/FLINK-16682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16682: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Fli

[jira] [Updated] (FLINK-14523) Flink Stops Consuming from Kafka after Leader Election

[ https://issues.apache.org/jira/browse/FLINK-14523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14523: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-14616) Clarify the ordering guarantees in the "The Broadcast State Pattern"

[ https://issues.apache.org/jira/browse/FLINK-14616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14616: --- Labels: auto-deprioritized-major auto-deprioritized-minor broadcast (was: auto-deprioriti

[jira] [Updated] (FLINK-14615) Add Flink Web UI capabilities for savepoint

[ https://issues.apache.org/jira/browse/FLINK-14615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14615: --- Labels: auto-deprioritized-major auto-deprioritized-minor usability (was: auto-deprioriti

[GitHub] [flink] MartijnVisser commented on pull request #17808: [FLINK-24928][flink-runtime-web] Typing improvements for Flink UI

MartijnVisser commented on pull request #17808: URL: https://github.com/apache/flink/pull/17808#issuecomment-974894700 @AHeise Please merge :) -- 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

[jira] [Commented] (FLINK-24939) Support 'SHOW CREATE CATALOG' syntax

[ https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447121#comment-17447121 ] Shen Zhu commented on FLINK-24939: -- Hey Yubin([~liyubin117] ), Thanks for your feedbac

[jira] [Updated] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24974: - Affects Version/s: (was: 1.13.3) (was: shaded-14.0) > bli

[jira] [Closed] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24974. Resolution: Invalid > blink just translate select ... from a,b to nested loop join. >

[jira] [Updated] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24974: - Environment: was:1 > blink just translate select ... from a,b to nested loop join

[jira] [Updated] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24974: - Fix Version/s: (was: 1.7.3) > blink just translate select ... from a,b to nested loo

[jira] [Updated] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24974: - Component/s: (was: Tests) > blink just translate select ... from a,b to nested loop

[jira] [Reopened] (FLINK-24974) blink just translate select ... from a,b to nested loop join.

[ https://issues.apache.org/jira/browse/FLINK-24974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-24974: -- > blink just translate select ... from a,b to nested loop join. >

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN * 96a6ba2a83ca22091099ef36201afcbd8e71

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

zhipeng93 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r753647934 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/linalg/DenseVector.java ## @@ -42,14 +45,26 @@ public double get(int i) { return val

[GitHub] [flink] godfreyhe commented on a change in pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

godfreyhe commented on a change in pull request #17666: URL: https://github.com/apache/flink/pull/17666#discussion_r753816404 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/WindowTableFunctionTest.scala ## @@ -0,0 +1,

[GitHub] [flink] flinkbot edited a comment on pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

flinkbot edited a comment on pull request #17554: URL: https://github.com/apache/flink/pull/17554#issuecomment-950550174 -- 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

[GitHub] [flink] MonsterChenzhuo commented on pull request #17508: [FLINK-24351][docs] Translate "JSON Function" pages into Chinese

MonsterChenzhuo commented on pull request #17508: URL: https://github.com/apache/flink/pull/17508#issuecomment-974634974 @RocMarshal Please go to #17789 to review -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [flink] godfreyhe commented on a change in pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

godfreyhe commented on a change in pull request #17670: URL: https://github.com/apache/flink/pull/17670#discussion_r753819169 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-tvf.md ## @@ -48,15 +48,21 @@ See more how to apply further computations based on windo

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 -- 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

  1   2   3   4   >