[jira] [Updated] (FLINK-25123) Improve expression description in SQL operator

[ https://issues.apache.org/jira/browse/FLINK-25123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25123: --- Labels: pull-request-available (was: ) > Improve expression description in SQL operator >

[GitHub] [flink] flinkbot edited a comment on pull request #18110: [FLINK-25310][Documentation] Fix the incorrect description for output network buffers in buffer debloat documenation

flinkbot edited a comment on pull request #18110: URL: https://github.com/apache/flink/pull/18110#issuecomment-994244366 ## CI report: * c7ce675ebbb98339bc05e357623ced593df8efa3 Azure:

[GitHub] [flink] wenlong88 opened a new pull request #18127: [FLINK-25123][table-planner] Improve description of expression in ExecNode

wenlong88 opened a new pull request #18127: URL: https://github.com/apache/flink/pull/18127 ## What is the purpose of the change this is part of This PR is part of

[GitHub] [flink] MartijnVisser commented on pull request #18110: [FLINK-25310][Documentation] Fix the incorrect description for output network buffers in buffer debloat documenation

MartijnVisser commented on pull request #18110: URL: https://github.com/apache/flink/pull/18110#issuecomment-995526705 @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] [Comment Edited] (FLINK-24348) Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460466#comment-17460466 ] Yun Gao edited comment on FLINK-24348 at 12/16/21, 7:53 AM:

[jira] [Commented] (FLINK-24348) Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460466#comment-17460466 ] Yun Gao commented on FLINK-24348: -

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770295193 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/SparseVectorSerializer.java ## @@ -0,0 +1,151 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure:

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460465#comment-17460465 ] Martijn Visser commented on FLINK-25336: [~straw] This version is not supported anymore per

[jira] [Reopened] (FLINK-24348) Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container startup failed"

[ https://issues.apache.org/jira/browse/FLINK-24348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-24348: - > Kafka ITCases (e.g. KafkaTableITCase) fail with "ContainerLaunch Container > startup failed" >

[GitHub] [flink] flinkbot edited a comment on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

flinkbot edited a comment on pull request #18068: URL: https://github.com/apache/flink/pull/18068#issuecomment-989975508 ## CI report: * 6832524d7d78de814cbeadb44fa8037da5c10ca9 Azure:

[GitHub] [flink] mbalassi commented on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

mbalassi commented on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-995521569 I see, @viirya. Sent you an email to address this separately from the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] gaoyunhaii commented on pull request #18068: [FLINK-25105][checkpoint] Enables final checkpoint by default

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

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * Unknown: [CANCELED](TBD) * d2242677110bbd6b38963379d4f8624f13c7 Azure:

[GitHub] [flink] spoon-lz commented on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

spoon-lz commented on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-995518247 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * Unknown: [CANCELED](TBD) * d2242677110bbd6b38963379d4f8624f13c7 Azure:

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770286109 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/SparseVector.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770285422 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/SparseVector.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] shenzhu commented on pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

shenzhu commented on pull request #17793: URL: https://github.com/apache/flink/pull/17793#issuecomment-995513366 Hey @zentol , would you mind taking a look at this PR when you have a moment? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-25339) Moving to the hadoop-free flink runtime.

[ https://issues.apache.org/jira/browse/FLINK-25339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-25339: -- Summary: Moving to the hadoop-free flink runtime. (was: Moving to hadoop-free flink

[jira] [Created] (FLINK-25339) Moving to hadoop-free flink runtime.

David Morávek created FLINK-25339: - Summary: Moving to hadoop-free flink runtime. Key: FLINK-25339 URL: https://issues.apache.org/jira/browse/FLINK-25339 Project: Flink Issue Type: Technical

[jira] [Commented] (FLINK-25311) DelimitedInputFormat cannot read compressed files correctly

[ https://issues.apache.org/jira/browse/FLINK-25311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460446#comment-17460446 ] Jinxin.Tang commented on FLINK-25311: - Thanks for your issue, work correct in spark, I will try fix

[GitHub] [flink] flinkbot edited a comment on pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

flinkbot edited a comment on pull request #18125: URL: https://github.com/apache/flink/pull/18125#issuecomment-995378571 ## CI report: * 5a3c5da78c91fe870a07d38b0683e725893c1fc7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

flinkbot edited a comment on pull request #18086: URL: https://github.com/apache/flink/pull/18086#issuecomment-991936309 ## CI report: * fc2b8b343e1400f86d2d300408829cb4a9bb8672 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18118: [FLINK-24907] Support side out late data for interval join

flinkbot edited a comment on pull request #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-994686917 ## CI report: * d8e09a1643cb2fffc9bf3c836dbfb20a9114f26b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

flinkbot edited a comment on pull request #18086: URL: https://github.com/apache/flink/pull/18086#issuecomment-991936309 ## CI report: * fc2b8b343e1400f86d2d300408829cb4a9bb8672 Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r770273532 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #18118: [FLINK-24907] Support side out late data for interval join

flinkbot edited a comment on pull request #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-994686917 ## CI report: * d8e09a1643cb2fffc9bf3c836dbfb20a9114f26b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16108: [FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

flinkbot edited a comment on pull request #16108: URL: https://github.com/apache/flink/pull/16108#issuecomment-856641884 ## CI report: * 03e33a13e8826f6cda49070c16679533f1223e94 Azure:

[GitHub] [flink] chenyuzhi459 commented on pull request #18118: [FLINK-24907] Support side out late data for interval join

chenyuzhi459 commented on pull request #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-995499315 @flinkbot re-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

[GitHub] [flink] chenyuzhi459 removed a comment on pull request #18118: [FLINK-24907] Support side out late data for interval join

chenyuzhi459 removed a comment on pull request #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-995390917 @flinkbot re-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

[GitHub] [flink] flinkbot edited a comment on pull request #16108: [FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

flinkbot edited a comment on pull request #16108: URL: https://github.com/apache/flink/pull/16108#issuecomment-856641884 ## CI report: * 03e33a13e8826f6cda49070c16679533f1223e94 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

flinkbot edited a comment on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-981363546 ## CI report: * ef63c831770e3921d33c30c410a903e6614acb78 Azure:

[GitHub] [flink] paul8263 commented on a change in pull request #16108: [FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

paul8263 commented on a change in pull request #16108: URL: https://github.com/apache/flink/pull/16108#discussion_r770268401 ## File path: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java ## @@ -102,10 +102,11 @@ public void setUp() throws Exception

[jira] [Commented] (FLINK-25286) Improve connector testing framework to support more scenarios

[ https://issues.apache.org/jira/browse/FLINK-25286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460438#comment-17460438 ] ZhuoYu Chen commented on FLINK-25286: - Hi [~renqs], I've done a lot of custom work on connectors at

[GitHub] [flink] paul8263 commented on a change in pull request #16108: [FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

paul8263 commented on a change in pull request #16108: URL: https://github.com/apache/flink/pull/16108#discussion_r770266892 ## File path: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ## @@ -498,4 +503,33 @@ public static boolean isValidClientPort(int port) {

[jira] [Updated] (FLINK-25338) Improvement of connection from TM to JM in session cluster

[ https://issues.apache.org/jira/browse/FLINK-25338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-25338: Description: When taskmanager receives slot request from resourcemanager for the specify job, it will

[GitHub] [flink] flinkbot edited a comment on pull request #18126: [FLINK-25036][runtime] Add stage wise scheduling strategy

flinkbot edited a comment on pull request #18126: URL: https://github.com/apache/flink/pull/18126#issuecomment-995489268 ## CI report: * f769f988700610398b4c9d1e6ad0210a28a07a16 Azure:

[GitHub] [flink] flinkbot commented on pull request #18126: [FLINK-25036][runtime] Add stage wise scheduling strategy

flinkbot commented on pull request #18126: URL: https://github.com/apache/flink/pull/18126#issuecomment-995489535 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 #18126: [FLINK-25036][runtime] Add stage wise scheduling strategy

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

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

[ https://issues.apache.org/jira/browse/FLINK-25036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25036: --- Labels: pull-request-available (was: ) > Introduce stage-wised scheduling strategy >

[GitHub] [flink] wanglijie95 opened a new pull request #18126: [FLINK-25036][runtime] Add stage wise scheduling strategy

wanglijie95 opened a new pull request #18126: URL: https://github.com/apache/flink/pull/18126 ## What is the purpose of the change Add stage wise scheduling strategy for adaptive batch scheduler. ## Brief change log f769f988700610398b4c9d1e6ad0210a28a07a16 Add stage wise

[jira] [Created] (FLINK-25338) Improvement of connection from TM to JM in session cluster

Shammon created FLINK-25338: --- Summary: Improvement of connection from TM to JM in session cluster Key: FLINK-25338 URL: https://issues.apache.org/jira/browse/FLINK-25338 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460432#comment-17460432 ] Bruce Wong edited comment on FLINK-25330 at 12/16/21, 6:11 AM: --- Hi,  

[jira] [Commented] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460432#comment-17460432 ] Bruce Wong commented on FLINK-25330: Hi, Wenlong Lyu In my opinion, if the user deletes data in

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

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

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

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

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460431#comment-17460431 ] Yuan Zhu commented on FLINK-25336: -- [~JasonLee] Why not make it configurable to support more versions?

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

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

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

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

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

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770243747 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/SparseVector.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770243574 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/SparseVector.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770243498 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/SparseVector.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770243384 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/SparseVectorTypeInfo.java ## @@ -0,0 +1,85 @@ +/* + * Licensed to the

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

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

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

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770241491 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/SparseVector.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770241406 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoderModelData.java ## @@ -0,0 +1,106 @@ +/* + *

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

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770241084 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoder.java ## @@ -0,0 +1,146 @@ +/* + * Licensed to the

[GitHub] [flink] chenyuzhi459 edited a comment on pull request #18118: [FLINK-24907] Support side out late data for interval join

chenyuzhi459 edited a comment on pull request #18118: URL: https://github.com/apache/flink/pull/18118#issuecomment-995390917 @flinkbot re-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

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

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770239537 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoder.java ## @@ -0,0 +1,146 @@ +/* + * Licensed to the

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

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770238822 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoderModelData.java ## @@ -0,0 +1,106 @@ +/* + *

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770238761 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoder.java ## @@ -0,0 +1,146 @@ +/* + * Licensed to the

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

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

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

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

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

[jira] [Commented] (FLINK-25332) When using Pyflink Table API, 'where' clause seems to work incorrectly

[ https://issues.apache.org/jira/browse/FLINK-25332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460425#comment-17460425 ] TongMeng commented on FLINK-25332: -- [~dianfu] ，I posted the sql explain to the appendix

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r770236389 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/SparseVector.java ## @@ -0,0 +1,174 @@ +/* + * Licensed to the Apache Software

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

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

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

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

[jira] [Updated] (FLINK-25332) When using Pyflink Table API, 'where' clause seems to work incorrectly

[ https://issues.apache.org/jira/browse/FLINK-25332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TongMeng updated FLINK-25332: - Attachment: sql_explain.txt > When using Pyflink Table API, 'where' clause seems to work incorrectly >

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[GitHub] [flink] wenlong88 commented on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

wenlong88 commented on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-995422266 this is a comparison example: 

[jira] [Commented] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460396#comment-17460396 ] Wenlong Lyu commented on FLINK-25330: - hi, [~Bruce Wong] I have a concern on deleting all of the

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460395#comment-17460395 ] JasonLee commented on FLINK-25336: -- [~straw] In fact, this is because the version of Kafka is too low.

[GitHub] [flink] flinkbot edited a comment on pull request #18044: [FLINK-25215][table] ISODOW, ISOYEAR fail and DECADE gives wrong result for timestamps with timezones

flinkbot edited a comment on pull request #18044: URL: https://github.com/apache/flink/pull/18044#issuecomment-987951721 ## CI report: * 5724a6b4e5c9f7706fa0f27ba05fe95aa34df198 Azure:

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

zhipeng93 commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r769422262 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoderModel.java ## @@ -0,0 +1,190 @@ +/* + * Licensed to the

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

zhipeng93 commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r769401955 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoder.java ## @@ -0,0 +1,146 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

zhipeng93 commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r769397742 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasDropLast.java ## @@ -0,0 +1,37 @@ +/* + * Licensed to the Apache Software

[jira] [Updated] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Zhu updated FLINK-25336: - Docs Text: (was: Kafka connector compatible problem in Flink sql) > Kafka connector compatible

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460391#comment-17460391 ] Yuan Zhu commented on FLINK-25336: -- Hi, [~becket_qin]. What's the purpose here? Can we make

[GitHub] [flink] Myasuka commented on a change in pull request #17774: [FLINK-24611] Prevent JM from discarding state on checkpoint abortion

Myasuka commented on a change in pull request #17774: URL: https://github.com/apache/flink/pull/17774#discussion_r770198103 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

flinkbot edited a comment on pull request #18114: URL: https://github.com/apache/flink/pull/18114#issuecomment-994556266 ## CI report: * 163245e6c628a06bc5ce593d014e1588262aae60 Azure:

[jira] [Created] (FLINK-25337) Check whether the target table is valid when SqlToOperationConverter.convertSqlInsert

vim-wang created FLINK-25337: Summary: Check whether the target table is valid when SqlToOperationConverter.convertSqlInsert Key: FLINK-25337 URL: https://issues.apache.org/jira/browse/FLINK-25337

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460387#comment-17460387 ] Yuan Zhu commented on FLINK-25336: -- The cause of this exception is invoked by the logic in 

[jira] [Updated] (FLINK-25335) Improvement of task deployment by enable source split asynchronous enumerate

[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Summary: Improvement of task deployment by enable source split asynchronous enumerate (was:

  1   2   3   4   5   6   7   8   9   >