[GitHub] [flink] Airblader commented on pull request #17898: [FLINK-25047][table] Resolve architectural violations

2021-11-28 Thread GitBox
Airblader commented on pull request #17898: URL: https://github.com/apache/flink/pull/17898#issuecomment-981374898 Thanks @wenlong88. Although I think chances are small that anyone is using these exceptions, I would like this to be a non-breaking PR, so it makes sense to do that. --

[GitHub] [flink] MartijnVisser commented on pull request #17845: [FLINK-24352] [flink-table-planner] Add null check for temporal table check on SqlSnapshot

2021-11-28 Thread GitBox
MartijnVisser commented on pull request #17845: URL: https://github.com/apache/flink/pull/17845#issuecomment-981374790 Should we create a follow-up ticket for the issue you've mentioned @godfreyhe ? -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] AHeise merged pull request #17538: [FLINK-24325][connectors/elasticsearch] Create Elasticsearch 6 Sink

2021-11-28 Thread GitBox
AHeise merged pull request #17538: URL: https://github.com/apache/flink/pull/17538 -- 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] AHeise commented on a change in pull request #17870: [FLINK-24596][kafka] Fix buffered KafkaUpsert sink

2021-11-28 Thread GitBox
AHeise commented on a change in pull request #17870: URL: https://github.com/apache/flink/pull/17870#discussion_r758107290 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/TopicSelector.java ## @@ -18,14 +18,12 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17924: [FLINK-25072][streaming] Introduce description on Transformation and …

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17924: URL: https://github.com/apache/flink/pull/17924#issuecomment-979870210 ## CI report: * 07174990a0a73184286f32792dda356ea71d96a6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17924: [FLINK-25072][streaming] Introduce description on Transformation and …

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17924: URL: https://github.com/apache/flink/pull/17924#issuecomment-979870210 ## CI report: * 07174990a0a73184286f32792dda356ea71d96a6 Azure:

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

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-981363546 ## CI report: * d29e331ebbccb61bbb784d4b0e41cf1e591cb9c0 Azure:

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

2021-11-28 Thread GitBox
flinkbot commented on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-981364305 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 #17938: [Flink-25073][streaming] Introduce TreeMode description for vertices

2021-11-28 Thread GitBox
flinkbot commented on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-981363546 ## CI report: * d29e331ebbccb61bbb784d4b0e41cf1e591cb9c0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] wenlong88 opened a new pull request #17938: [Flink-25073][streaming] Introduce TreeMode description for vertices

2021-11-28 Thread GitBox
wenlong88 opened a new pull request #17938: URL: https://github.com/apache/flink/pull/17938 ## What is the purpose of the change This PR is a following up PR of FLINK-25072, inits the operatorPrettyName of JobVertex according to the description of operators introduced in FLINK-25072

[GitHub] [flink] flinkbot edited a comment on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-968179643 ## CI report: * 4e6d4e3bab6c9fe8caf2363177e74011a175ee72 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17867: [FLINK-24592][Table SQL/Client] FlinkSQL Client multiline parser improvements

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17867: URL: https://github.com/apache/flink/pull/17867#issuecomment-975551530 ## CI report: * ed90e252cfa8e3fd725ca71473339aafe213a4b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-968179643 ## CI report: * 4e6d4e3bab6c9fe8caf2363177e74011a175ee72 Azure:

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

2021-11-28 Thread GitBox
shenzhu removed a comment on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-969976164 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[GitHub] [flink] flinkbot edited a comment on pull request #17867: [FLINK-24592][Table SQL/Client] FlinkSQL Client multiline parser improvements

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17867: URL: https://github.com/apache/flink/pull/17867#issuecomment-975551530 ## CI report: * ed90e252cfa8e3fd725ca71473339aafe213a4b3 Azure:

[jira] [Assigned] (FLINK-25044) Add More Unit Test For Pulsar Source

2021-11-28 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-25044: --- Assignee: Yufei Zhang > Add More Unit Test For Pulsar Source >

[GitHub] [flink] klion26 commented on a change in pull request #10925: [FLINK-15690][core][configuration] Enable configuring ExecutionConfig & CheckpointConfig from flink-conf.yaml

2021-11-28 Thread GitBox
klion26 commented on a change in pull request #10925: URL: https://github.com/apache/flink/pull/10925#discussion_r75800 ## File path: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ## @@ -99,7 +99,7 @@ private ClosureCleanerLevel

[GitHub] [flink] flinkbot edited a comment on pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17666: URL: https://github.com/apache/flink/pull/17666#issuecomment-960514675 ## CI report: * cc426ff491234fd94ff50163786c02f9a0e1e5b5 Azure:

[jira] [Comment Edited] (FLINK-25077) Postgresql connector fails in case column with nested arrays

2021-11-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450228#comment-17450228 ] Sergey Nuyanzin edited comment on FLINK-25077 at 11/29/21, 7:14 AM:

[jira] [Commented] (FLINK-25077) Postgresql connector fails in case column with nested arrays

2021-11-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450228#comment-17450228 ] Sergey Nuyanzin commented on FLINK-25077: - Hi [~jark] thanks for your response. Yes, I think so

[jira] [Updated] (FLINK-25050) Translate "Metrics" page of "Operations" into Chinese

2021-11-28 Thread ZhiJie Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhiJie Yang updated FLINK-25050: Component/s: Documentation > Translate "Metrics" page of "Operations" into Chinese >

[jira] [Commented] (FLINK-25077) Postgresql connector fails in case column with nested arrays

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450222#comment-17450222 ] Jark Wu commented on FLINK-25077: - I think this might because JDBC connector with PG dialect just

[GitHub] [flink] flinkbot edited a comment on pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17937: URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170 ## CI report: * 1fb86a6233a0fab5a0ef858b40566c3cc76f1a82 Azure:

[jira] [Assigned] (FLINK-25065) Update lookup document for jdbc connector

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25065: --- Assignee: Gaurav Miglani > Update lookup document for jdbc connector >

[jira] [Updated] (FLINK-25065) Update lookup document for jdbc connector

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25065: Component/s: Connectors / JDBC > Update lookup document for jdbc connector >

[GitHub] [flink] wuchong commented on pull request #17918: [FLINK-25065][docs] Update document for jdbc connector

2021-11-28 Thread GitBox
wuchong commented on pull request #17918: URL: https://github.com/apache/flink/pull/17918#issuecomment-98154 @gaurav726 , could you update the content for Chinese documentation as well? The file is located in `docs/content.zh/docs/connectors/table/jdbc.md`. -- This is an automated

[jira] [Commented] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

2021-11-28 Thread jocean.shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450220#comment-17450220 ] jocean.shi commented on FLINK-19358: [~trohrmann] I get your concern,  In the other word, Whether

[jira] [Assigned] (FLINK-25050) Translate "Metrics" page of "Operations" into Chinese

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25050: --- Assignee: ZhiJie Yang > Translate "Metrics" page of "Operations" into Chinese >

[jira] [Commented] (FLINK-25055) Support listen and notify mechanism for PartitionRequest

2021-11-28 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450218#comment-17450218 ] Shammon commented on FLINK-25055: - [~trohrmann] Thank you for your rely. Yes, your understanding is

[jira] [Commented] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450217#comment-17450217 ] Jark Wu commented on FLINK-25049: - [~macdoor615], could you share the DDL of the tables used in your

[jira] [Updated] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25049: Component/s: Table SQL / Ecosystem > sql-client.sh execute batch job in async mode failed with >

[jira] [Updated] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25049: Environment: (was: {code:java} //代码占位符 {code}) > sql-client.sh execute batch job in async mode failed

[jira] [Updated] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25049: Component/s: Connectors / FileSystem (was: Table SQL / Client) > sql-client.sh

[jira] [Commented] (FLINK-25054) Improve exception message for unsupported hashLength for SHA2 function

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450215#comment-17450215 ] Jark Wu commented on FLINK-25054: - Yes, I think the exception message should be improved. > Improve

[jira] [Commented] (FLINK-25054) Improve exception message for unsupported hashLength for SHA2 function

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450216#comment-17450216 ] Jark Wu commented on FLINK-25054: - Yes, I think the exception message should be improved. > Improve

[jira] [Updated] (FLINK-25054) Improve exception message for unsupported hashLength for SHA2 function

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25054: Language: (was: JAVA) > Improve exception message for unsupported hashLength for SHA2 function >

[jira] [Updated] (FLINK-25054) Improve exception message for unsupported hashLength for SHA2 function

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25054: Summary: Improve exception message for unsupported hashLength for SHA2 function (was: flink sql System

[jira] [Updated] (FLINK-25054) Improve exception message for unsupported hashLength for SHA2 function

2021-11-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25054: Component/s: Table SQL / API (was: Build System) > Improve exception message for

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

2021-11-28 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450209#comment-17450209 ] 刘方奇 commented on FLINK-25029: - Sorry to bother. Could someone help to look this issue? In my opinion, this

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

2021-11-28 Thread GitBox
yunfengzhou-hub commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r758054855 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayesModelData.java ## @@ -0,0 +1,148 @@ +/* + *

[jira] [Created] (FLINK-25089) KafkaSourceITCase.testBasicRead hangs on azure

2021-11-28 Thread Yun Gao (Jira)
Yun Gao created FLINK-25089: --- Summary: KafkaSourceITCase.testBasicRead hangs on azure Key: FLINK-25089 URL: https://issues.apache.org/jira/browse/FLINK-25089 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24764) pyflink/table/tests/test_udf.py hang on Azure

2021-11-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450202#comment-17450202 ] Yun Gao commented on FLINK-24764: -

[jira] [Created] (FLINK-25088) KafkaSinkITCase failed on azure due to Container did not start correctly

2021-11-28 Thread Yun Gao (Jira)
Yun Gao created FLINK-25088: --- Summary: KafkaSinkITCase failed on azure due to Container did not start correctly Key: FLINK-25088 URL: https://issues.apache.org/jira/browse/FLINK-25088 Project: Flink

[jira] [Commented] (FLINK-24935) Python module failed to compile due to "Could not create local repository"

2021-11-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450200#comment-17450200 ] Yun Gao commented on FLINK-24935: -

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2021-11-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450198#comment-17450198 ] Yun Gao commented on FLINK-23391: -

[jira] [Reopened] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2021-11-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-23391: - > KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure >

[GitHub] [flink] flinkbot edited a comment on pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17666: URL: https://github.com/apache/flink/pull/17666#issuecomment-960514675 ## CI report: * 51b6f01db6e073d4f943fca2d0aba057bbabac72 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17666: URL: https://github.com/apache/flink/pull/17666#issuecomment-960514675 ## CI report: * 51b6f01db6e073d4f943fca2d0aba057bbabac72 Azure:

[GitHub] [flink] flinkbot commented on pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2021-11-28 Thread GitBox
flinkbot commented on pull request #17937: URL: https://github.com/apache/flink/pull/17937#issuecomment-981288048 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 edited a comment on pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2021-11-28 Thread GitBox
flinkbot edited a comment on pull request #17937: URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170 ## CI report: * 1fb86a6233a0fab5a0ef858b40566c3cc76f1a82 Azure:

[GitHub] [flink] flinkbot commented on pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2021-11-28 Thread GitBox
flinkbot commented on pull request #17937: URL: https://github.com/apache/flink/pull/17937#issuecomment-981287170 ## CI report: * 1fb86a6233a0fab5a0ef858b40566c3cc76f1a82 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25044) Add More Unit Test For Pulsar Source

2021-11-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25044: --- Labels: pull-request-available testing (was: testing) > Add More Unit Test For Pulsar

[GitHub] [flink] imaffe opened a new pull request #17937: [FLINK-25044][testing][Pulsar Connector] Add More Unit Test For Pulsar Source

2021-11-28 Thread GitBox
imaffe opened a new pull request #17937: URL: https://github.com/apache/flink/pull/17937 ## What is the purpose of the change Enhance the pulsar source unit test for the following classes - PulsarSourceReader - PulsarPartitionSplitReader - PulsarSourceEnumerator -

[jira] [Created] (FLINK-25087) Move heartbeats from akka to the dedicated thread pool in JM

2021-11-28 Thread Shammon (Jira)
Shammon created FLINK-25087: --- Summary: Move heartbeats from akka to the dedicated thread pool in JM Key: FLINK-25087 URL: https://issues.apache.org/jira/browse/FLINK-25087 Project: Flink Issue

[jira] [Created] (FLINK-25086) Move resource timeout checkers in JM from akka executors to the dedicated thread pool

2021-11-28 Thread Shammon (Jira)
Shammon created FLINK-25086: --- Summary: Move resource timeout checkers in JM from akka executors to the dedicated thread pool Key: FLINK-25086 URL: https://issues.apache.org/jira/browse/FLINK-25086 Project:

[jira] [Created] (FLINK-25085) Add a scheduled thread pool in JM and close it when job terminates

2021-11-28 Thread Shammon (Jira)
Shammon created FLINK-25085: --- Summary: Add a scheduled thread pool in JM and close it when job terminates Key: FLINK-25085 URL: https://issues.apache.org/jira/browse/FLINK-25085 Project: Flink

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

2021-11-28 Thread GitBox
zhipeng93 commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r758021592 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayesModelData.java ## @@ -0,0 +1,148 @@ +/* + * Licensed to

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

2021-11-28 Thread GitBox
beyond1920 commented on a change in pull request #17666: URL: https://github.com/apache/flink/pull/17666#discussion_r758020898 ## File path:

[jira] [Commented] (FLINK-25057) Streaming File Sink writing to HDFS

2021-11-28 Thread hanjie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450177#comment-17450177 ] hanjie commented on FLINK-25057: [~zhisheng]  Task start with savepoint. Task often throw

[jira] [Assigned] (FLINK-24897) Enable application mode on YARN to use usrlib

2021-11-28 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-24897: - Assignee: Biao Geng > Enable application mode on YARN to use usrlib >

[jira] [Commented] (FLINK-17782) Add array,map,row types support for parquet row writer

2021-11-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450174#comment-17450174 ] Jingsong Lee commented on FLINK-17782: -- CC:  [~jark]  > Add array,map,row types support for

[jira] [Commented] (FLINK-15826) Add renameFunction() to Catalog

2021-11-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450175#comment-17450175 ] Jingsong Lee commented on FLINK-15826: -- CC: [~jark]  > Add renameFunction() to Catalog >

[jira] [Commented] (FLINK-17782) Add array,map,row types support for parquet row writer

2021-11-28 Thread Runkang He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450173#comment-17450173 ] Runkang He commented on FLINK-17782: Hi, [~sujun1020], I am interested in your contribution and need

[jira] [Commented] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

2021-11-28 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450172#comment-17450172 ] Yang Wang commented on FLINK-19358: --- IIUC, whether to recover or submit a new job is determined in

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

2021-11-28 Thread GitBox
JingsongLi merged pull request #17699: URL: https://github.com/apache/flink/pull/17699 -- 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] JingsongLi commented on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

2021-11-28 Thread GitBox
JingsongLi commented on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-981247459 Maybe in `HiveCatalogUdfITCase`? -- 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] JingsongLi commented on a change in pull request #17897: [FLINK-24687][table] Move FileSystemTableSource/Sink in flink-connector-files

2021-11-28 Thread GitBox
JingsongLi commented on a change in pull request #17897: URL: https://github.com/apache/flink/pull/17897#discussion_r758008970 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/BatchPhysicalLegacySinkRule.scala

[jira] [Closed] (FLINK-21823) RocksDB on FreeBSD

2021-11-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-21823. Resolution: Information Provided Closing this issue due to inactivity. > RocksDB on FreeBSD >

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

2021-11-28 Thread GitBox
Myasuka commented on a change in pull request #17874: URL: https://github.com/apache/flink/pull/17874#discussion_r758006843 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackend.java ##

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

2021-11-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23798: - Release Note: (was: Merged master: 7d7a97477a50753e38e5b499effc62bb00dfcfe2 release-1.14:

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

2021-11-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450169#comment-17450169 ] Yun Tang commented on FLINK-23798: -- Merged master: 7d7a97477a50753e38e5b499effc62bb00dfcfe2

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

2021-11-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23798. -- Release Note: Merged master: 7d7a97477a50753e38e5b499effc62bb00dfcfe2 release-1.14:

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

2021-11-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23798: - Fix Version/s: 1.14.1 > Avoid using reflection to get filter when partition filter is enabled >

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

2021-11-28 Thread GitBox
Myasuka merged pull request #17921: URL: https://github.com/apache/flink/pull/17921 -- 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-25084) Field names must be unique. Found duplicates

2021-11-28 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang closed FLINK-25084. -- Fix Version/s: 1.15.0 1.14.1 1.13.4 Resolution: Fixed >

[jira] [Commented] (FLINK-25084) Field names must be unique. Found duplicates

2021-11-28 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450167#comment-17450167 ] Jing Zhang commented on FLINK-25084: [~ibuda] Thanks for reporting this BUG. It seems to be a

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

2021-11-28 Thread GitBox
godfreyhe commented on a change in pull request #17666: URL: https://github.com/apache/flink/pull/17666#discussion_r758001359 ## File path:

[GitHub] [flink] wuchong merged pull request #17707: [hotfix][datastream][docs]

2021-11-28 Thread GitBox
wuchong merged pull request #17707: URL: https://github.com/apache/flink/pull/17707 -- 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] mans2singh commented on pull request #17707: [hotfix][datastream][docs]

2021-11-28 Thread GitBox
mans2singh commented on pull request #17707: URL: https://github.com/apache/flink/pull/17707#issuecomment-981234896 @wuchong - Can you please review this doc PR ? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

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

2021-11-28 Thread GitBox
lindong28 commented on pull request #30: URL: https://github.com/apache/flink-ml/pull/30#issuecomment-981232579 Thanks for the update! The PR looks good overall. I have only two remaining comments regarding the `TRANSFER_BUFFER_SIZE ` and the support for AllRound. Let's wait for

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

2021-11-28 Thread GitBox
lindong28 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r757997408 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/common/datastream/AllReduceUtilsTest.java ## @@ -0,0 +1,145 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-22240) Sanity/phrasing pass for ExternalResourceUtils

2021-11-28 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-22240: --- Labels: pull-request-available (was: auto-deprioritized-major pull-request-available

[GitHub] [flink] ZhijieYang commented on pull request #17902: [FLINK-25050][docs-zh] Translate "Metrics" page of "Operations" into Chinese

2021-11-28 Thread GitBox
ZhijieYang commented on pull request #17902: URL: https://github.com/apache/flink/pull/17902#issuecomment-981223568 @RocMarshal Hi, can you review it? thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

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

2021-11-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-24763. Resolution: Fixed Ignore case in: master(1.15): c1b119290bea3bcf8de85b357a357e6181edb040 >

[GitHub] [flink] JingsongLi merged pull request #17923: [FLINK-24763][parquet] Ignore ParquetFileSystemITCase.testLimitableBulkFormat

2021-11-28 Thread GitBox
JingsongLi merged pull request #17923: URL: https://github.com/apache/flink/pull/17923 -- 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] [Updated] (FLINK-25066) Support using multi hdfs cluster to resolved dependences when submitting job to yarn

2021-11-28 Thread jocean.shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jocean.shi updated FLINK-25066: --- Summary: Support using multi hdfs cluster to resolved dependences when submitting job to yarn

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

2021-11-28 Thread Shen Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450161#comment-17450161 ] Shen Zhu commented on FLINK-24939: -- Thanks for your explanation [~liyubin117] ! Hey [~jark] , I

[jira] [Comment Edited] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

2021-11-28 Thread Adrian Vasiliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450147#comment-17450147 ] Adrian Vasiliu edited comment on FLINK-22014 at 11/28/21, 10:54 PM:

[jira] [Comment Edited] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

2021-11-28 Thread Adrian Vasiliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450147#comment-17450147 ] Adrian Vasiliu edited comment on FLINK-22014 at 11/28/21, 10:53 PM:

[jira] [Comment Edited] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

2021-11-28 Thread Adrian Vasiliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450147#comment-17450147 ] Adrian Vasiliu edited comment on FLINK-22014 at 11/28/21, 10:52 PM:

[jira] [Comment Edited] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

2021-11-28 Thread Adrian Vasiliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450147#comment-17450147 ] Adrian Vasiliu edited comment on FLINK-22014 at 11/28/21, 10:51 PM:

[jira] [Comment Edited] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

2021-11-28 Thread Adrian Vasiliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450147#comment-17450147 ] Adrian Vasiliu edited comment on FLINK-22014 at 11/28/21, 10:50 PM:

[jira] [Commented] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

2021-11-28 Thread Adrian Vasiliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450147#comment-17450147 ] Adrian Vasiliu commented on FLINK-22014: [~mlushchytski] or anyone knowing: In our company, we

[jira] [Updated] (FLINK-8380) Dynamic BucketingSink paths based on ingested Kafka topics

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

[jira] [Updated] (FLINK-8377) Document DataViews for user-defined aggregate functions

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

[jira] [Updated] (FLINK-8526) When use parallelism equals to half of the number of cpu, join and shuffle operators will easly cause deadlock.

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

[jira] [Updated] (FLINK-8542) Do not indefinitely store closed shard's state in the FlinkKinesisConsumer

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

[jira] [Updated] (FLINK-8444) Rework dependency setup docs

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

[jira] [Updated] (FLINK-8534) if insert too much BucketEntry into one bucket in join of iteration will cause a error (Caused : java.io.FileNotFoundException release file error)

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

[jira] [Updated] (FLINK-8457) Documentation for Building from Source is broken

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

  1   2   >