[GitHub] [flink] flinkbot commented on pull request #18002: [FLINK-25150][API] Fix the violation of api annotation

flinkbot commented on pull request #18002: URL: https://github.com/apache/flink/pull/18002#issuecomment-985293724 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] matriv commented on a change in pull request #17962: [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable

matriv commented on a change in pull request #17962: URL: https://github.com/apache/flink/pull/17962#discussion_r761716124 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/metadata/MetadataTestUtil.scala ## @@ -298,6 +301,124 @@

[jira] [Resolved] (FLINK-24859) Document new File formats

[ https://issues.apache.org/jira/browse/FLINK-24859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser resolved FLINK-24859. Fix Version/s: 1.15.0 Resolution: Fixed Resolved in master:

[GitHub] [flink] flinkbot commented on pull request #18002: [FLINK-25150][API] Fix the violation of api annotation

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

[jira] [Updated] (FLINK-25150) org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader failed due to violate ApiAnnotationRules

[ https://issues.apache.org/jira/browse/FLINK-25150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25150: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] gaoyunhaii opened a new pull request #18002: [FLINK-25150][API] Fix the violation of api annotation

gaoyunhaii opened a new pull request #18002: URL: https://github.com/apache/flink/pull/18002 ## What is the purpose of the change This PR tries to fix the api annotation violation. ## Brief change log - ccaf8bc1a612ade65b53ab38bc71359f4b063c55 adds the

[jira] [Commented] (FLINK-25150) org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader failed due to violate ApiAnnotationRules

[ https://issues.apache.org/jira/browse/FLINK-25150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452802#comment-17452802 ] Yun Gao commented on FLINK-25150: - I'll first fix the violation. >

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

[ https://issues.apache.org/jira/browse/FLINK-25151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25151. Resolution: Duplicate Network problem, duplicated, see FLINK-25152 > FLIP-188: Introduce

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

Jingsong Lee created FLINK-25152: Summary: [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage Key: FLINK-25152 URL: https://issues.apache.org/jira/browse/FLINK-25152 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-25152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25152: - Summary: FLIP-188: Introduce Built-in Dynamic Table Storage (was: [DISCUSS] FLIP-188:

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

Jingsong Lee created FLINK-25151: Summary: FLIP-188: Introduce Built-in Dynamic Table Storage Key: FLINK-25151 URL: https://issues.apache.org/jira/browse/FLINK-25151 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[jira] [Commented] (FLINK-25150) org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader failed due to violate ApiAnnotationRules

[ https://issues.apache.org/jira/browse/FLINK-25150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452793#comment-17452793 ] Yun Gao commented on FLINK-25150: - Hi [~airblader] , it seems the method does violate the rules, but may

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r761700468 ## File path: flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriterTest.java ## @@ -158,6 +190,65 @@

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r761699867 ## File path: flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriterTest.java ## @@ -158,6 +190,65 @@

[jira] [Updated] (FLINK-25150) org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader failed due to violate ApiAnnotationRules

[ https://issues.apache.org/jira/browse/FLINK-25150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25150: Priority: Critical (was: Major) >

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[jira] [Created] (FLINK-25150) org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader failed due to violate ApiAnnotationRules

Yun Gao created FLINK-25150: --- Summary: org.apache.flink.connector.file.src.reader.TextLineInputFormat.createReader failed due to violate ApiAnnotationRules Key: FLINK-25150 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * bd5b6272b266dfe8dc494ee6decac510d1c73f2b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[jira] [Commented] (FLINK-25149) getScanRuntimeProvider method called before the pushDown method,

[ https://issues.apache.org/jira/browse/FLINK-25149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452788#comment-17452788 ] Wenlong Lyu commented on FLINK-25149: - [~waittting] currently the table planner will validate the

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17892: [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and support HA

flinkbot edited a comment on pull request #17892: URL: https://github.com/apache/flink/pull/17892#issuecomment-977710431 ## CI report: * 0c477cc849835f21dace860974ff6ebe61740893 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452785#comment-17452785 ] Qingsheng Ren commented on FLINK-20928: --- Sorry for my late response! I took a look in the log of

[GitHub] [flink] godfreyhe commented on a change in pull request #17962: [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable

godfreyhe commented on a change in pull request #17962: URL: https://github.com/apache/flink/pull/17962#discussion_r761692575 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/metadata/MetadataTestUtil.scala ## @@ -298,6 +301,124

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 ## CI report: * 26811181b8b06860cf50b28a8193114fc455bf37 Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #17945: [FLINK-21027][state] Introduce KeyedStateBackend#isSafeToReuseState for opmitization hint

Myasuka commented on a change in pull request #17945: URL: https://github.com/apache/flink/pull/17945#discussion_r761683066 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java ## @@ -137,10 +137,25 @@ */ boolean

[GitHub] [flink] flinkbot edited a comment on pull request #17462: [FLINK-23170] Write metadata after materialization

flinkbot edited a comment on pull request #17462: URL: https://github.com/apache/flink/pull/17462#issuecomment-942024789 ## CI report: * 26811181b8b06860cf50b28a8193114fc455bf37 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * 734f7484f6d2a72901fce53e14a49adc845816b7 Azure:

[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=17452777#comment-17452777 ] 刘方奇 commented on FLINK-25029: - [~arvid], Hi, I get your advice in the PR, that 's valuable for me. I try to

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

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

flinkbot edited a comment on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-982461620 ## CI report: * 8377539867f18f1bda4fba411f961558f926ee7e Azure:

[jira] [Commented] (FLINK-13395) Add source and sink connector for Alibaba Log Service

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

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r761672254 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java ## @@ -247,4 +248,43 @@ private static

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r761670505 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java ## @@ -105,6 +105,14 @@

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r761670210 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -431,6 +433,14 @@ public Task( // finally,

[GitHub] [flink] liufangqi commented on a change in pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

liufangqi commented on a change in pull request #17958: URL: https://github.com/apache/flink/pull/17958#discussion_r761670108 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -431,6 +433,14 @@ public Task( // finally,

[jira] [Commented] (FLINK-24152) Exactly-once semantics should be configurable through Flink configuration only

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

[GitHub] [flink] meetjunsu commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

meetjunsu commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r761667459 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java ## @@ -224,6 +277,153 @@

[GitHub] [flink] meetjunsu commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

meetjunsu commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r761667191 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java ## @@ -165,6 +187,11 @@ public

[jira] [Comment Edited] (FLINK-24794) AZP kills docker containers with exit code 137 (maybe OOM)

[ https://issues.apache.org/jira/browse/FLINK-24794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452766#comment-17452766 ] Yun Gao edited comment on FLINK-24794 at 12/3/21, 5:58 AM: --- It seems the

[jira] [Commented] (FLINK-24794) AZP kills docker containers with exit code 137 (maybe OOM)

[ https://issues.apache.org/jira/browse/FLINK-24794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452766#comment-17452766 ] Yun Gao commented on FLINK-24794: - It seems the problem has been reproduced: 

[jira] [Closed] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-23525. --- Resolution: Duplicate > Docker command fails on Azure: Exit code 137 returned from process: file name >

[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=17452765#comment-17452765 ] ZhuoYu Chen commented on FLINK-24396: - [~twalthr] One module, one subtask? > Add @Public

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452764#comment-17452764 ] Yun Gao commented on FLINK-23525: - I'll close this issue since it should be duplicated with

[jira] [Reopened] (FLINK-24794) AZP kills docker containers with exit code 137 (maybe OOM)

[ https://issues.apache.org/jira/browse/FLINK-24794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-24794: - > AZP kills docker containers with exit code 137 (maybe OOM) >

[GitHub] [flink] liufangqi commented on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

liufangqi commented on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-985233869 @AHeise THX for your reply, these were worthy advice for me. I will handle it case by case. Give me some time. -- This is an automated message from the Apache Git Service.

[GitHub] [flink] liufangqi commented on pull request #17958: FLINK-25029: Hadoop Caller Context Setting in Flink

liufangqi commented on pull request #17958: URL: https://github.com/apache/flink/pull/17958#issuecomment-985232979 > @AHeise , Sorry to bother, it seems that i put this option into a wrong file, can I ask for advice what file should I put into? -- This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * e7d585c7aab70989fe340f5f14b359952433ddf2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17919: [FLINK-24419][table-planner] Trim to precision when casting to BINARY/VARBINARY

flinkbot edited a comment on pull request #17919: URL: https://github.com/apache/flink/pull/17919#issuecomment-979659835 ## CI report: * e7d585c7aab70989fe340f5f14b359952433ddf2 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-24959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-24959: Description: BITMAP_AND :{color:#33}Computes the intersection of two input bitmaps and

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

[ https://issues.apache.org/jira/browse/FLINK-24959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-24959: Description: BITMAP_AND :{color:#33}Computes the intersection of two input bitmaps and

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r761651214 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java ## @@ -224,6 +277,153 @@

[jira] [Comment Edited] (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=17452755#comment-17452755 ] ZhuoYu Chen edited comment on FLINK-24959 at 12/3/21, 5:12 AM: --- hi [~jark]

[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=17452755#comment-17452755 ] ZhuoYu Chen commented on FLINK-24959: - hi [~jark] clickhouse，starRocks，doris all support bitmap

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

gaoyunhaii commented on pull request #17924: URL: https://github.com/apache/flink/pull/17924#issuecomment-985221811 LGTM from my side. And @AHeise do you want to also have a look~? Very thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-20873) Upgrade Calcite version to 1.27

[ https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452753#comment-17452753 ] ZhuoYu Chen commented on FLINK-20873: - [~jark] Are there still plans for this to go ahead? If there

[jira] [Commented] (FLINK-12429) Translate the "Generating Timestamps / Watermarks" page into Chinese

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

[jira] [Commented] (FLINK-17203) Add metrics for ClickHouse sink

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

[jira] [Commented] (FLINK-17202) Add SQL for ClickHouse connector

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

[jira] [Commented] (FLINK-17201) Implement Streaming ClickHouseSink

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

[jira] [Updated] (FLINK-25141) Elasticsearch connector customize sink parallelism

[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25141: - Component/s: Table SQL / Ecosystem > Elasticsearch connector customize sink parallelism >

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17892: [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and support HA

flinkbot edited a comment on pull request #17892: URL: https://github.com/apache/flink/pull/17892#issuecomment-977710431 ## CI report: * ef9bf98289409eafd1c3e49e9ae96317a4397a34 Azure:

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

flinkbot edited a comment on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-949170131 ## CI report: * 20b5850a68b1463d36796ccbfb8ea3eae5bf1221 Azure:

[jira] [Comment Edited] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452738#comment-17452738 ] ZhuoYu Chen edited comment on FLINK-24103 at 12/3/21, 4:21 AM: --- Hi

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[jira] [Commented] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452738#comment-17452738 ] ZhuoYu Chen commented on FLINK-24103: - [~twalthr]  我对这个非常感兴趣，我想为flink做一些工作，我可以帮助做吗？ 谢谢你 > Create

[jira] [Commented] (FLINK-24900) Support to run multiple shuffle plugins in one session cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17892: [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and support HA

flinkbot edited a comment on pull request #17892: URL: https://github.com/apache/flink/pull/17892#issuecomment-977710431 ## CI report: * ef9bf98289409eafd1c3e49e9ae96317a4397a34 Azure:

[jira] [Comment Edited] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452738#comment-17452738 ] ZhuoYu Chen edited comment on FLINK-24103 at 12/3/21, 4:20 AM: ---

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

flinkbot edited a comment on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-949170131 ## CI report: * 20b5850a68b1463d36796ccbfb8ea3eae5bf1221 Azure:

[jira] [Commented] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452736#comment-17452736 ] ZhuoYu Chen commented on FLINK-24103: - [~twalthr] Is there a result of the discussion now? > Create

[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_r761636447 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java ## @@ -0,0 +1,243 @@ +/* + * Licensed to the Apache

[GitHub] [flink-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_r761636447 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java ## @@ -0,0 +1,243 @@ +/* + * Licensed to the Apache

[GitHub] [flink-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_r761636447 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java ## @@ -0,0 +1,243 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[jira] [Commented] (FLINK-24910) Propagate the Calcite parser config to SQL Client

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

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[GitHub] [flink] PatrickRen commented on a change in pull request #17892: [FLINK-25038][testutils] Refactor FlinkContainer to split JM and TMs to individual containers and support HA

PatrickRen commented on a change in pull request #17892: URL: https://github.com/apache/flink/pull/17892#discussion_r761634524 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/container/FlinkContainer.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[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-985199167 Hey @twalthr , sorry to bother you, 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

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

[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_r761633170 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java ## @@ -0,0 +1,243 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17979: [FLINK-25122] [flink-dist] Add variable expansion for FLINK_ENV_JAVA_OPTS

flinkbot edited a comment on pull request #17979: URL: https://github.com/apache/flink/pull/17979#issuecomment-983597309 ## CI report: * 98a1592d95ba0ef58c0320f8e62c926950359058 Azure:

  1   2   3   4   5   6   7   8   9   >