[GitHub] [flink] dannycranmer commented on a change in pull request #17785: [FLINK-24580][Connectors/Kinesis] Make ConnectTimeoutException recoverable

dannycranmer commented on a change in pull request #17785: URL: https://github.com/apache/flink/pull/17785#discussion_r755780760 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java ## @@

[GitHub] [flink] AHeise merged pull request #17848: [FLINK-24583] [connectors/elasticsearch] Improve test stability by blocking until ES has acknowledged all records

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

[jira] [Commented] (FLINK-24592) FlinkSQL multiline parser improvements

[ https://issues.apache.org/jira/browse/FLINK-24592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448419#comment-17448419 ] Sergey Nuyanzin commented on FLINK-24592: - [~jark] thanks for the assignment could you or anyone

[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: * 1592494d4260563af4f170fb1cd45ccec9e5f0cb Azure:

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448416#comment-17448416 ] Fabian Paul commented on FLINK-16419: - The error still seems very strange to me because every time

[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_r755766209 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayesModel.java ## @@ -0,0 +1,223 @@ +/* + * Licensed

[GitHub] [flink-ml] HuangXingBo commented on a change in pull request #36: [FLINK-24933][python] Support ML Python API to implement FLIP-173 and FLP-174

HuangXingBo commented on a change in pull request #36: URL: https://github.com/apache/flink-ml/pull/36#discussion_r755771519 ## File path: flink-ml-python/README.md ## @@ -0,0 +1,20 @@ +Flink ML is a library which provides machine learning (ML) APIs and libraries that

[jira] [Commented] (FLINK-15571) Create a Redis Streams Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448413#comment-17448413 ] Yun Tang commented on FLINK-15571: -- [~monster#12] Already assigned to you. > Create a Redis Streams

[jira] [Updated] (FLINK-24861) Support to disable caching missing key for lookup cache

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24861: --- Release Note: You can now configure the JDBC connector to enable or disable caching results

[GitHub] [flink] flinkbot edited a comment on pull request #17715: [FLINK-24820][table][docs] Examples in documentation for value1 IS DISTINCT …

flinkbot edited a comment on pull request #17715: URL: https://github.com/apache/flink/pull/17715#issuecomment-962987530 ## CI report: * 863b790976db36e3ddb858f118e964f9ca48927f Azure:

[jira] [Assigned] (FLINK-15571) Create a Redis Streams Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-15571: Assignee: ZhuoYu Chen > Create a Redis Streams Connector for Flink >

[GitHub] [flink] pnowojski commented on a change in pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

pnowojski commented on a change in pull request #16582: URL: https://github.com/apache/flink/pull/16582#discussion_r755767863 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -1405,59 +1406,80 @@ private void declineCheckpoint(

[GitHub] [flink] flinkbot edited a comment on pull request #17891: [FLINK-12941][chinese-translation, Documentation ]Translate "Amazon A…

flinkbot edited a comment on pull request #17891: URL: https://github.com/apache/flink/pull/17891#issuecomment-977556918 ## CI report: * 9f73f2713085e557107f1da2b68e77721721eb4d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17715: [FLINK-24820][table][docs] Examples in documentation for value1 IS DISTINCT …

flinkbot edited a comment on pull request #17715: URL: https://github.com/apache/flink/pull/17715#issuecomment-962987530 ## CI report: * 863b790976db36e3ddb858f118e964f9ca48927f Azure:

[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_r755766209 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayesModel.java ## @@ -0,0 +1,223 @@ +/* + * Licensed

[GitHub] [flink] snuyanzin commented on pull request #17715: [FLINK-24820][table][docs] Examples in documentation for value1 IS DISTINCT …

snuyanzin commented on pull request #17715: URL: https://github.com/apache/flink/pull/17715#issuecomment-977606105 @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

[jira] [Commented] (FLINK-25029) Hadoop Caller Context Setting In Flink

[ https://issues.apache.org/jira/browse/FLINK-25029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448409#comment-17448409 ] Jingsong Lee commented on FLINK-25029: -- [~liufangqi] Did you mean FileSystem API in Flink? >

[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_r755759816 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayes.java ## @@ -0,0 +1,333 @@ +/* + * Licensed to the

[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_r755759161 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayes.java ## @@ -0,0 +1,333 @@ +/* + * Licensed to the

[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_r755751841 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayesModelData.java ## @@ -0,0 +1,116 @@ +/* + *

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

RocMarshal commented on pull request #17789: URL: https://github.com/apache/flink/pull/17789#issuecomment-977590515 @MonsterChenzhuo Thanks for the update. Could you please have a check on the ci result? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

flinkbot edited a comment on pull request #17842: URL: https://github.com/apache/flink/pull/17842#issuecomment-974310249 ## CI report: * 45ac29fdd23a851dfcf47e70d9db5710a19d2af8 Azure:

[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_r755747903 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasLabelCol.java ## @@ -0,0 +1,42 @@ +/* + * 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_r755747666 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/util/StageTestUtils.java ## @@ -0,0 +1,50 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] jackwener commented on a change in pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

jackwener commented on a change in pull request #17842: URL: https://github.com/apache/flink/pull/17842#discussion_r755746986 ## File path: flink-java/src/test/java/org/apache/flink/api/java/utils/OptionsTest.java ## @@ -54,16 +54,6 @@ public void

[GitHub] [flink-ml] lindong28 commented on a change in pull request #36: [FLINK-24933][python] Support ML Python API to implement FLIP-173 and FLP-174

lindong28 commented on a change in pull request #36: URL: https://github.com/apache/flink-ml/pull/36#discussion_r755746945 ## File path: flink-ml-python/README.md ## @@ -0,0 +1,20 @@ +Flink ML is a library which provides machine learning (ML) APIs and libraries that simplify

[GitHub] [flink] jackwener commented on a change in pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

jackwener commented on a change in pull request #17842: URL: https://github.com/apache/flink/pull/17842#discussion_r755746522 ## File path: flink-java/src/test/java/org/apache/flink/api/java/utils/OptionsTest.java ## @@ -54,16 +54,6 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

flinkbot edited a comment on pull request #17842: URL: https://github.com/apache/flink/pull/17842#issuecomment-974310249 ## CI report: * 45ac29fdd23a851dfcf47e70d9db5710a19d2af8 Azure:

[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_r755746528 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayes.java ## @@ -0,0 +1,333 @@ +/* + * Licensed to the

[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_r755746409 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayes.java ## @@ -0,0 +1,333 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-25012) Cannot join hive tables with different column types

[ https://issues.apache.org/jira/browse/FLINK-25012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448402#comment-17448402 ] xiangqiao commented on FLINK-25012: --- Thank you [~luoyuxia] , i have added

[jira] [Updated] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loyi updated FLINK-23190: - Affects Version/s: 1.13.1 1.14.0 > Make task-slot allocation much more evenly >

[GitHub] [flink] jackwener edited a comment on pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

jackwener edited a comment on pull request #17842: URL: https://github.com/apache/flink/pull/17842#issuecomment-977582827 > The compile is failed. Please have a check @jackwener . After fix typo (`testChoicesWithInvalidDefautlValue`), there are same name function. I found

[GitHub] [flink] jackwener commented on pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

jackwener commented on pull request #17842: URL: https://github.com/apache/flink/pull/17842#issuecomment-977582827 > The compile is failed. Please have a check @jackwener . After fix typo (`testChoicesWithInvalidDefautlValue`), there are same name function. I found that

[GitHub] [flink] flinkbot edited a comment on pull request #17890: [BP-1.14][FLINK-24624][k8s] Clean up residual k8s resources when starting kubernetes session or application cluster failed

flinkbot edited a comment on pull request #17890: URL: https://github.com/apache/flink/pull/17890#issuecomment-977413087 ## CI report: * 1724c0b42250c88911e228025251ad3b764042ac Azure:

[jira] [Commented] (FLINK-25013) flink pulsar connector cannot consume deferred messages

[ https://issues.apache.org/jira/browse/FLINK-25013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448401#comment-17448401 ] Yufan Sheng commented on FLINK-25013: - I see. But I don't this is a bug. Delayed message delivery

[GitHub] [flink-ml] HuangXingBo commented on a change in pull request #36: [FLINK-24933][python] Support ML Python API to implement FLIP-173 and FLP-174

HuangXingBo commented on a change in pull request #36: URL: https://github.com/apache/flink-ml/pull/36#discussion_r755741660 ## File path: flink-ml-python/apache_flink_ml/version.py ## @@ -0,0 +1,23 @@

[GitHub] [flink-ml] lindong28 commented on a change in pull request #36: [FLINK-24933][python] Support ML Python API to implement FLIP-173 and FLP-174

lindong28 commented on a change in pull request #36: URL: https://github.com/apache/flink-ml/pull/36#discussion_r755732498 ## File path: flink-ml-python/apache_flink_ml/version.py ## @@ -0,0 +1,23 @@

[jira] [Assigned] (FLINK-11868) [filesystems] Introduce listStatusIterator API to file system

[ https://issues.apache.org/jira/browse/FLINK-11868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-11868: Assignee: Yun Tang > [filesystems] Introduce listStatusIterator API to file system >

[jira] [Commented] (FLINK-25029) Hadoop Caller Context Setting In Flink

[ https://issues.apache.org/jira/browse/FLINK-25029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448392#comment-17448392 ] 刘方奇 commented on FLINK-25029: - [~lzljs3620320]  please help review this comment. > Hadoop Caller Context

[jira] [Commented] (FLINK-15571) Create a Redis Streams Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448391#comment-17448391 ] ZhuoYu Chen commented on FLINK-15571: - [~yunta] Thank you for your reply, I think you can assign

[jira] [Created] (FLINK-25029) Hadoop Caller Context Setting In Flink

刘方奇 created FLINK-25029: --- Summary: Hadoop Caller Context Setting In Flink Key: FLINK-25029 URL: https://issues.apache.org/jira/browse/FLINK-25029 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-15571) Create a Redis Streams Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448382#comment-17448382 ] Yun Tang edited comment on FLINK-15571 at 11/24/21, 6:21 AM: - [~monster#12]

[jira] [Commented] (FLINK-15571) Create a Redis Streams Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448382#comment-17448382 ] Yun Tang commented on FLINK-15571: -- [~monster#12] Currently, Flink community would encourage

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

Aitozi commented on a change in pull request #17554: URL: https://github.com/apache/flink/pull/17554#discussion_r755729487 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -256,36 +244,51 @@ private String

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [WIP][FLINK-24703][connectors][formats] Add FileSource support for reading CSV files.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 077423c8c94f59aade26c2c57001a4551a1b28af Azure:

[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_r755727278 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayes.java ## @@ -0,0 +1,333 @@ +/* + * Licensed to the

[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_r755726294 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/NaiveBayesTest.java ## @@ -0,0 +1,291 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] gaoyunhaii closed pull request #34: [hotfix] Fix nullpointer exception when broadcast variables are cleaned

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

[GitHub] [flink-ml] 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_r755724605 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/NaiveBayesTest.java ## @@ -0,0 +1,291 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-24396) Add @Public annotations to Table & SQL API classes

[ https://issues.apache.org/jira/browse/FLINK-24396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448377#comment-17448377 ] ZhuoYu Chen commented on FLINK-24396: - Hi [~twalthr] I am very interested in this，and I want do some

[GitHub] [flink-ml] gaoyunhaii commented on pull request #34: [hotfix] Fix nullpointer exception when broadcast variables are cleaned

gaoyunhaii commented on pull request #34: URL: https://github.com/apache/flink-ml/pull/34#issuecomment-977559676 Very thanks @zhipeng93 for the fix! LGTM and merging... -- 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 #17813: [FLINK-24802][Table SQL/Planner] Improve cast ROW to STRING

flinkbot edited a comment on pull request #17813: URL: https://github.com/apache/flink/pull/17813#issuecomment-970956527 ## CI report: * d4a10bc3d83bb43c839ae7b54e8bd41a65b94925 Azure:

[jira] [Commented] (FLINK-24429) Port FileSystemTableSink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-24429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448376#comment-17448376 ] ZhuoYu Chen commented on FLINK-24429: - Hi [~alexanderpreuss] I am very interested in this，and I want

[GitHub] [flink] flinkbot edited a comment on pull request #17891: [FLINK-12941][chinese-translation, Documentation ]Translate "Amazon A…

flinkbot edited a comment on pull request #17891: URL: https://github.com/apache/flink/pull/17891#issuecomment-977556918 ## CI report: * 9f73f2713085e557107f1da2b68e77721721eb4d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17813: [FLINK-24802][Table SQL/Planner] Improve cast ROW to STRING

flinkbot edited a comment on pull request #17813: URL: https://github.com/apache/flink/pull/17813#issuecomment-970956527 ## CI report: * d4a10bc3d83bb43c839ae7b54e8bd41a65b94925 Azure:

[jira] [Commented] (FLINK-24959) Add a BitMap function to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448374#comment-17448374 ] ZhuoYu Chen commented on FLINK-24959: - Hi [~jark] I am very interested in this，and I want do some

[GitHub] [flink] flinkbot commented on pull request #17891: [FLINK-12941][chinese-translation, Documentation ]Translate "Amazon A…

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

[GitHub] [flink] flinkbot commented on pull request #17891: [FLINK-12941][chinese-translation, Documentation ]Translate "Amazon A…

flinkbot commented on pull request #17891: URL: https://github.com/apache/flink/pull/17891#issuecomment-977556918 ## CI report: * 9f73f2713085e557107f1da2b68e77721721eb4d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-12941) Translate "Amazon AWS Kinesis Streams Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12941: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > Translate "Amazon

[GitHub] [flink] MonsterChenzhuo opened a new pull request #17891: [FLINK-12941][chinese-translation, Documentation ]Translate "Amazon A…

MonsterChenzhuo opened a new pull request #17891: URL: https://github.com/apache/flink/pull/17891 …WS Kinesis Streams Connector" page into Chinese ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server,

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

cc13ny commented on a change in pull request #17554: URL: https://github.com/apache/flink/pull/17554#discussion_r755719881 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -256,36 +244,51 @@ private String

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

cc13ny commented on a change in pull request #17554: URL: https://github.com/apache/flink/pull/17554#discussion_r755719881 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -256,36 +244,51 @@ private String

[jira] [Assigned] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25015: --- Assignee: KevinyhZou > job name should not always be `collect` submitted by sql client >

[jira] [Commented] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448370#comment-17448370 ] KevinyhZou commented on FLINK-25015: [~jark] I agree with you. can you assign this issue to me, and

[GitHub] [flink] flinkbot edited a comment on pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

flinkbot edited a comment on pull request #17874: URL: https://github.com/apache/flink/pull/17874#issuecomment-976109395 ## CI report: * ce248c90c07d8df8d1d79651248cc8a7ad6e0e81 Azure:

[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 ## CI report: * ae6c6bc42146b7a72215b4ceda8108fdc21b41f6 Azure:

[jira] [Comment Edited] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached

[ https://issues.apache.org/jira/browse/FLINK-25027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448365#comment-17448365 ] FYung edited comment on FLINK-25027 at 11/24/21, 5:23 AM: -- Hi [~nkruber] Thank

[jira] [Comment Edited] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached

[ https://issues.apache.org/jira/browse/FLINK-25027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448365#comment-17448365 ] FYung edited comment on FLINK-25027 at 11/24/21, 5:22 AM: -- Hi [~nkruber] Thank

[jira] [Commented] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached

[ https://issues.apache.org/jira/browse/FLINK-25027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448365#comment-17448365 ] FYung commented on FLINK-25027: --- Hi [~nkruber] Thank you for creating this issue. I'm so glad to see it

[jira] [Resolved] (FLINK-24958) correct the example and link for temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-24958. Resolution: Fixed > correct the example and link for temporal table function documentation >

[jira] [Updated] (FLINK-24958) correct the example and link for temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24958: --- Fix Version/s: 1.14.1 > correct the example and link for temporal table function documentation >

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755690633 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/EuclideanDistance.java ## @@ -0,0 +1,272 @@ +package

[jira] [Commented] (FLINK-24958) correct the example and link for temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448356#comment-17448356 ] Leonard Xu commented on FLINK-24958: Fixed via master (1.15):

[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: * ca42ca0e3df01ed1ddbd020245528ecb7b4257eb Azure:

[GitHub] [flink] wuchong commented on pull request #17842: [FLINK-24966] [docs] Fix spelling errors in the project

wuchong commented on pull request #17842: URL: https://github.com/apache/flink/pull/17842#issuecomment-977518179 The compile is failed. Please have a check @jackwener . -- 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 #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: * ca42ca0e3df01ed1ddbd020245528ecb7b4257eb Azure:

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755688272 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/param/Param.java ## @@ -75,7 +75,7 @@ public String jsonEncode(T value) throws IOException {

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755688178 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/Knn.java ## @@ -0,0 +1,255 @@ +package

[GitHub] [flink] leonardBang merged pull request #17835: [FLINK-24958][docs]correct the example and link for temporal table function documentation

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

[jira] [Commented] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448354#comment-17448354 ] Jark Wu commented on FLINK-25015: - Yes. I think it makes sense to dispaly query as the job name. > job

[GitHub] [flink] leonardBang merged pull request #17832: [FLINK-24958][docs]correct the example and link for temporal table fu…

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

[jira] [Closed] (FLINK-21415) JDBC connector should support to disable caching missing key

[ https://issues.apache.org/jira/browse/FLINK-21415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21415. --- Assignee: (was: liwei li) Resolution: Duplicate > JDBC connector should support to disable

[jira] [Closed] (FLINK-24861) Support to disable caching missing key for lookup cache

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24861. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: f8fdb6713a9264691a10afe3e6e9ff6bcdc86ae1 >

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

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

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

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

[jira] [Updated] (FLINK-24861) Support to disable caching missing key for lookup cache

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24861: Summary: Support to disable caching missing key for lookup cache (was: Flink MySQL Look cache update

[GitHub] [flink] wuchong merged pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

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

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

[ https://issues.apache.org/jira/browse/FLINK-25028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448347#comment-17448347 ] Zhilong Hong commented on FLINK-25028: -- It seems that an OOM happens on the TaskExecutor. There are

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755682429 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,594 @@ +package

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755682171 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,594 @@ +package

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755678624 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,594 @@ +package

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755678460 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,594 @@ +package

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755678350 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,594 @@ +package

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755677909 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,594 @@ +package

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448343#comment-17448343 ] Jingsong Lee commented on FLINK-24763: -- Fixed in master: a5477938952863fb516a1a14d67808ecda047134

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755677169 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasFeatureColsDefaultAsNull.java ## @@ -0,0 +1,28 @@ +package

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

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r755676992 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/knn/KnnTest.java ## @@ -0,0 +1,172 @@ +package

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

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

[GitHub] [flink] JingsongLi merged pull request #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

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

  1   2   3   4   5   6   7   8   9   >