[GitHub] [flink] flinkbot edited a comment on pull request #17810: [BP-1.13][FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17810: URL: https://github.com/apache/flink/pull/17810#issuecomment-970348193 ## CI report: * 6feab49fae2754d12ad4d40a317cd9eeda8f46f2 Azure:

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

2021-11-17 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445711#comment-17445711 ] Fabian Paul commented on FLINK-16419: - [~qzhzm173227] every transaction is closed when the

[jira] [Created] (FLINK-24950) Use Hive Dialect execute Hive DDL, But throw a NullPointerException

2021-11-17 Thread xiaojunchen (Jira)
xiaojunchen created FLINK-24950: --- Summary: Use Hive Dialect execute Hive DDL, But throw a NullPointerException Key: FLINK-24950 URL: https://issues.apache.org/jira/browse/FLINK-24950 Project: Flink

[GitHub] [flink] AHeise commented on a change in pull request #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

2021-11-17 Thread GitBox
AHeise commented on a change in pull request #17792: URL: https://github.com/apache/flink/pull/17792#discussion_r751969408 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/LimitableBulkFormat.java ## @@ -105,8 +111,16 @@ private

[jira] [Commented] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

2021-11-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445703#comment-17445703 ] Yun Gao commented on FLINK-10737: - {code:java} Nov 18 00:02:56 [ERROR] Tests run: 15, Failures: 0,

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

2021-11-17 Thread GitBox
Airblader commented on pull request #17808: URL: https://github.com/apache/flink/pull/17808#issuecomment-972611394 @AHeise And the CI has passed again now, too. :-) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] RocMarshal edited a comment on pull request #17692: [FLINK-24489][CEP] The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the n

2021-11-17 Thread GitBox
RocMarshal edited a comment on pull request #17692: URL: https://github.com/apache/flink/pull/17692#issuecomment-969035044 > The situation is a bit odd. I think we shouldn't have a cache on top of rocks DB at all. We could think about having a cache in rocks DB itself. > >

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

2021-11-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445695#comment-17445695 ] Yun Gao commented on FLINK-24949: - Hi [~becket_qin] This issue seems to reproduced after fixed for a

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

2021-11-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24949: Affects Version/s: 1.14.1 > KafkaITCase.testBigRecordJob fails on azure >

[jira] [Reopened] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

2021-11-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-10737: - > FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis >

[jira] [Updated] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

2021-11-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-10737: Affects Version/s: 1.14.1 > FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

[jira] [Commented] (FLINK-24936) Python test_data_stream.py hangs on azure

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

[GitHub] [flink] flinkbot edited a comment on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17685: URL: https://github.com/apache/flink/pull/17685#issuecomment-961148655 ## CI report: * 8c1def7a1d20b4440e0d6fdb3b9beeeb200e85f8 Azure:

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

2021-11-17 Thread Yun Gao (Jira)
Yun Gao created FLINK-24949: --- Summary: KafkaITCase.testBigRecordJob fails on azure Key: FLINK-24949 URL: https://issues.apache.org/jira/browse/FLINK-24949 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #17809: [BP-1.14][FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17809: URL: https://github.com/apache/flink/pull/17809#issuecomment-970332023 ## CI report: * 6c854a3c03d213703bb94d904e822b2239deef1c Azure:

[jira] [Commented] (FLINK-24948) Special character in column names breaks JDBC statement parsing

2021-11-17 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445685#comment-17445685 ] Paul Lin commented on FLINK-24948: -- Working on the fix. Please assign this issue to me. > Special

[jira] [Created] (FLINK-24948) Special character in column names breaks JDBC statement parsing

2021-11-17 Thread Paul Lin (Jira)
Paul Lin created FLINK-24948: Summary: Special character in column names breaks JDBC statement parsing Key: FLINK-24948 URL: https://issues.apache.org/jira/browse/FLINK-24948 Project: Flink

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

2021-11-17 Thread liuzhuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445684#comment-17445684 ] liuzhuo commented on FLINK-24947: - Within our company, we have completed the implementation of

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

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

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

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

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

2021-11-17 Thread liuzhuo (Jira)
liuzhuo created FLINK-24947: --- Summary: Flink on k8s support HostNetWork model Key: FLINK-24947 URL: https://issues.apache.org/jira/browse/FLINK-24947 Project: Flink Issue Type: New Feature

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

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

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

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

[jira] [Commented] (FLINK-24495) Python installdeps hangs

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

[jira] [Updated] (FLINK-24945) The exception location on the WebUI should contain TM's ResourceID

2021-11-17 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-24945: --- Description: Currently, the exception location on WebUI only contains hostname and port, as shown

[jira] [Created] (FLINK-24946) KafkaSourceLegacyITCase.testBigRecordJob fails on azure

2021-11-17 Thread Yun Gao (Jira)
Yun Gao created FLINK-24946: --- Summary: KafkaSourceLegacyITCase.testBigRecordJob fails on azure Key: FLINK-24946 URL: https://issues.apache.org/jira/browse/FLINK-24946 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure

2021-11-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445676#comment-17445676 ] Yun Gao commented on FLINK-24800: - Very thanks [~akalashnikov] for backporting the fix! I'll try having

[jira] [Updated] (FLINK-24945) The exception location on the WebUI should contain TM's ResourceID

2021-11-17 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-24945: --- Description: Currently, the exception location on WebUI only contains hostname and port, as shown

[jira] [Created] (FLINK-24945) The exception location on the WebUI should contain TM's ResourceID

2021-11-17 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-24945: -- Summary: The exception location on the WebUI should contain TM's ResourceID Key: FLINK-24945 URL: https://issues.apache.org/jira/browse/FLINK-24945 Project: Flink

[jira] [Commented] (FLINK-24936) Python test_data_stream.py hangs on azure

2021-11-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445672#comment-17445672 ] Yun Gao commented on FLINK-24936: - Got that, very thanks [~hxbks2ks] for attending the issue! > Python

[jira] [Commented] (FLINK-24944) Flink job on k8s mode supports pod scheduling according to priority

2021-11-17 Thread liuzhuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445667#comment-17445667 ] liuzhuo commented on FLINK-24944: - I have an idea to add some functions that can dynamically set

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

2021-11-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445664#comment-17445664 ] Yang Wang commented on FLINK-24897: --- Thanks for addressing the comments.   # The {{usrlib}} should

[GitHub] [flink] flinkbot edited a comment on pull request #17823: [FLINK-24937][e2e] Return correct exit code in build_image

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17823: URL: https://github.com/apache/flink/pull/17823#issuecomment-972474977 ## CI report: * fc2c92648891940ca961617c5a7715d3e8137689 Azure:

[jira] [Commented] (FLINK-24924) TO_TIMESTAMP and TO_DATE should fail

2021-11-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445660#comment-17445660 ] Jark Wu commented on FLINK-24924: - > I agree that exceptions are not optimal for streaming pipelines.

[jira] [Commented] (FLINK-24944) Flink job on k8s mode supports pod scheduling according to priority

2021-11-17 Thread john (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445657#comment-17445657 ] john commented on FLINK-24944: -- [~wangyang0918] [~guoyangze]  Thank you for your review. > Flink job on

[jira] [Commented] (FLINK-24942) Could not find any factory for identifier 'hive' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath

2021-11-17 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445653#comment-17445653 ] JasonLee commented on FLINK-24942: -- [~fsk119]  After looking at the relevant code, I found that the

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

2021-11-17 Thread GitBox
weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r751928196 ## File path: pom.xml ## @@ -56,6 +56,7 @@ under the License. flink-ml-iteration flink-ml-lib flink-ml-tests +flink-ml-lib Review

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17824: fix testSimpleNFA

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17824: URL: https://github.com/apache/flink/pull/17824#issuecomment-972561439 ## CI report: * 7e2695a4d3ec15a6fb0bdbc55cf2c92794f3aee9 Azure:

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

2021-11-17 Thread GitBox
weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r751927174 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/distance/EuclideanDistance.java ## @@ -0,0 +1,259 @@ +package

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

2021-11-17 Thread GitBox
weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r751927174 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/distance/EuclideanDistance.java ## @@ -0,0 +1,259 @@ +package

[GitHub] [flink] flinkbot commented on pull request #17824: fix testSimpleNFA

2021-11-17 Thread GitBox
flinkbot commented on pull request #17824: URL: https://github.com/apache/flink/pull/17824#issuecomment-972561996 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 #17824: fix testSimpleNFA

2021-11-17 Thread GitBox
flinkbot commented on pull request #17824: URL: https://github.com/apache/flink/pull/17824#issuecomment-972561439 ## CI report: * 7e2695a4d3ec15a6fb0bdbc55cf2c92794f3aee9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] arianacai1997 opened a new pull request #17824: fix testSimpleNFA

2021-11-17 Thread GitBox
arianacai1997 opened a new pull request #17824: URL: https://github.com/apache/flink/pull/17824 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

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

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

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

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

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

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

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

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

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

2021-11-17 Thread GitBox
weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r751920637 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/BatchOperator.java ## @@ -0,0 +1,108 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] flinkbot edited a comment on pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17811: URL: https://github.com/apache/flink/pull/17811#issuecomment-970441907 ## CI report: * 2b885bb3d72eb7489b8aa3211d63a7c1b7ca591d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * 61b8df758969cd93abf497205f4a43c224176efb Azure:

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

2021-11-17 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445631#comment-17445631 ] Biao Geng commented on FLINK-24897: --- Hi [~trohrmann] and [~wangyang0918] thank you very much for your

[jira] [Commented] (FLINK-24941) Cannot report backpressure with DatadogReporter

2021-11-17 Thread Shen Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445628#comment-17445628 ] Shen Zhu commented on FLINK-24941: -- +1. I also encountered this problem. > Cannot report backpressure

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: Flink 24557

2021-11-17 Thread GitBox
lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r751889202 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnParams.java ## @@ -0,0 +1,38 @@ +package

[jira] [Commented] (FLINK-24942) Could not find any factory for identifier 'hive' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath

2021-11-17 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445624#comment-17445624 ] Shengkai Fang commented on FLINK-24942: --- It seems the sql-client doesn't find the hive jar. You

[jira] [Commented] (FLINK-24942) Could not find any factory for identifier 'hive' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath

2021-11-17 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445621#comment-17445621 ] JasonLee commented on FLINK-24942: -- [~ruanhang1993]  SET table.sql-dialect=hive; drop table if exists

[GitHub] [flink-ml] lindong28 edited a comment on pull request #24: Flink 24557

2021-11-17 Thread GitBox
lindong28 edited a comment on pull request #24: URL: https://github.com/apache/flink-ml/pull/24#issuecomment-972499228 -- 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-ml] lindong28 commented on pull request #24: Flink 24557

2021-11-17 Thread GitBox
lindong28 commented on pull request #24: URL: https://github.com/apache/flink-ml/pull/24#issuecomment-972499228 Thanks for the update @weibozhao. Here are some PR review convention that might be useful to make the review easier: - Maybe change the PR title and the commit message

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

2021-11-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445618#comment-17445618 ] Yang Wang commented on FLINK-19358: --- For single-execute application, relying on the {{JobGraphStore}}

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

2021-11-17 Thread GitBox
yunfengzhou-hub commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r751884914 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayes.java ## @@ -0,0 +1,330 @@ +/* + * Licensed to the

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

2021-11-17 Thread GitBox
lindong28 commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r751875906 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayes.java ## @@ -0,0 +1,330 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-24944) Flink job on k8s mode supports pod scheduling according to priority

2021-11-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445615#comment-17445615 ] Yang Wang commented on FLINK-24944: --- I also believe that using the pod template is enough. Actually,

[GitHub] [flink] wangyang0918 commented on pull request #17823: [FLINK-24937][e2e] Return correct exit code in build_image

2021-11-17 Thread GitBox
wangyang0918 commented on pull request #17823: URL: https://github.com/apache/flink/pull/17823#issuecomment-972476539 cc @zentol would you please have a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #17823: [FLINK-24937][e2e] Return correct exit code in build_image

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17823: URL: https://github.com/apache/flink/pull/17823#issuecomment-972474977 ## CI report: * fc2c92648891940ca961617c5a7715d3e8137689 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17759: [FLINK-24608][table-planner][table-runtime] Fix issue with missing timestamp

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17759: URL: https://github.com/apache/flink/pull/17759#issuecomment-965566767 ## CI report: * e6d866bebbfeb98c26e06dc831feb9e21db7ca3e Azure:

[GitHub] [flink] flinkbot commented on pull request #17823: [FLINK-24937][e2e] Return correct exit code in build_image

2021-11-17 Thread GitBox
flinkbot commented on pull request #17823: URL: https://github.com/apache/flink/pull/17823#issuecomment-972475817 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 #17823: [FLINK-24937][e2e] Return correct exit code in build_image

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

[jira] [Updated] (FLINK-24937) "kubernetes application HA test" hangs on azure

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

[GitHub] [flink] wangyang0918 opened a new pull request #17823: [FLINK-24937][e2e] Return correct exit code in build_image

2021-11-17 Thread GitBox
wangyang0918 opened a new pull request #17823: URL: https://github.com/apache/flink/pull/17823 ## What is the purpose of the change Let the `build_image` in `common_docker.sh` return correct exit code. This will make `retry_times build_image` could work normally.

[jira] [Commented] (FLINK-24937) "kubernetes application HA test" hangs on azure

2021-11-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445610#comment-17445610 ] Yun Gao commented on FLINK-24937: - Very thanks [~wangyang0918] for investigating and attending this

[jira] [Updated] (FLINK-24937) "kubernetes application HA test" hangs on azure

2021-11-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-24937: -- Fix Version/s: 1.15.0 1.14.1 1.13.4 > "kubernetes application

[jira] [Updated] (FLINK-24631) Avoiding directly use the labels as selector for deployment and service

2021-11-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-24631: -- Affects Version/s: 1.13.3 > Avoiding directly use the labels as selector for deployment and service >

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

2021-11-17 Thread jocean.shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445608#comment-17445608 ] jocean.shi commented on FLINK-19358: it don't have any disadvantages to add a random jobId, it's

[GitHub] [flink] JingsongLi commented on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

2021-11-17 Thread GitBox
JingsongLi commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-972468104 Hi all, I'll give my understanding. (Correct me if I am wrong) ## Object ArrayList vs Lazy deserialization As long as the objects inside the `ArrayList` do not

[GitHub] [flink] flinkbot edited a comment on pull request #17810: [BP-1.13][FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17810: URL: https://github.com/apache/flink/pull/17810#issuecomment-970348193 ## CI report: * 75185c64d632a7a4ee1e5293773d238781de786e Azure:

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

2021-11-17 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445605#comment-17445605 ] Biao Geng commented on FLINK-24897: --- [~long jiang] , thanks a lot for your advice. I just focus on the

[jira] [Assigned] (FLINK-24937) "kubernetes application HA test" hangs on azure

2021-11-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-24937: - Assignee: Yang Wang > "kubernetes application HA test" hangs on azure >

[GitHub] [flink] flinkbot edited a comment on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17685: URL: https://github.com/apache/flink/pull/17685#issuecomment-961148655 ## CI report: * 164b09750d797e4686133ca89af9f84895eab8a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17810: [BP-1.13][FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17810: URL: https://github.com/apache/flink/pull/17810#issuecomment-970348193 ## CI report: * 75185c64d632a7a4ee1e5293773d238781de786e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17809: [BP-1.14][FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17809: URL: https://github.com/apache/flink/pull/17809#issuecomment-970332023 ## CI report: * e03bc3af99dca743c20766e18eb3ef94b18e98ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17809: [BP-1.14][FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17809: URL: https://github.com/apache/flink/pull/17809#issuecomment-970332023 ## CI report: * e03bc3af99dca743c20766e18eb3ef94b18e98ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17685: URL: https://github.com/apache/flink/pull/17685#issuecomment-961148655 ## CI report: * 164b09750d797e4686133ca89af9f84895eab8a2 Azure:

[GitHub] [flink] wangyang0918 commented on a change in pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

2021-11-17 Thread GitBox
wangyang0918 commented on a change in pull request #17685: URL: https://github.com/apache/flink/pull/17685#discussion_r751862261 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesJobManagerFactory.java ## @@ -120,7 +120,7 @@

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

2021-11-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445602#comment-17445602 ] Jingsong Lee commented on FLINK-24763: -- [~arvid] Hi, Considering the instability of this case, can

[GitHub] [flink] JingsongLi commented on a change in pull request #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

2021-11-17 Thread GitBox
JingsongLi commented on a change in pull request #17792: URL: https://github.com/apache/flink/pull/17792#discussion_r751860456 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/LimitableBulkFormat.java ## @@ -105,8 +111,16 @@

[jira] [Commented] (FLINK-24944) Flink job on k8s mode supports pod scheduling according to priority

2021-11-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445601#comment-17445601 ] Yangze Guo commented on FLINK-24944: cc [~wangyang0918] Can you evaluate this requirement? > Flink

[jira] [Commented] (FLINK-15825) Add renameDatabase() to Catalog

2021-11-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445597#comment-17445597 ] Jingsong Lee commented on FLINK-15825: -- [~shenzhu0127] Thanks! > Add renameDatabase() to Catalog >

[jira] [Assigned] (FLINK-15825) Add renameDatabase() to Catalog

2021-11-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15825: Assignee: Shen Zhu > Add renameDatabase() to Catalog > --- >

[GitHub] [flink] SteNicholas commented on pull request #17814: [FLINK-24899][runtime] Enable data compression for blocking shuffle by default

2021-11-17 Thread GitBox
SteNicholas commented on pull request #17814: URL: https://github.com/apache/flink/pull/17814#issuecomment-972457321 @wsry @zhuzhurk , could you please take a look at this pull request? -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-24942) Could not find any factory for identifier 'hive' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath

2021-11-17 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445587#comment-17445587 ] Hang Ruan commented on FLINK-24942: --- How do you create table `fs_table`? We should make use of

[jira] [Commented] (FLINK-24944) Flink job on k8s mode supports pod scheduling according to priority

2021-11-17 Thread john (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445585#comment-17445585 ] john commented on FLINK-24944: -- [~guoyangze] if I want to specify the priority when submitting a job, I

[jira] [Commented] (FLINK-24944) Flink job on k8s mode supports pod scheduling according to priority

2021-11-17 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445580#comment-17445580 ] Yangze Guo commented on FLINK-24944: Can pod-template[1] meet your requirement? [1]

[jira] [Created] (FLINK-24944) Flink job on k8s mode supports pod scheduling according to priority

2021-11-17 Thread john (Jira)
john created FLINK-24944: Summary: Flink job on k8s mode supports pod scheduling according to priority Key: FLINK-24944 URL: https://issues.apache.org/jira/browse/FLINK-24944 Project: Flink Issue

[jira] [Commented] (FLINK-24943) SequenceNumber class is not POJO type

2021-11-17 Thread Alexander Egorov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445571#comment-17445571 ] Alexander Egorov commented on FLINK-24943: -- The fix should be quite simple, I don't mind to

[jira] [Updated] (FLINK-24943) SequenceNumber class is not POJO type

2021-11-17 Thread Alexander Egorov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Egorov updated FLINK-24943: - Component/s: Connectors / Kinesis Affects Version/s: 1.13.3

[jira] [Created] (FLINK-24943) SequenceNumber class is not POJO type

2021-11-17 Thread Alexander Egorov (Jira)
Alexander Egorov created FLINK-24943: Summary: SequenceNumber class is not POJO type Key: FLINK-24943 URL: https://issues.apache.org/jira/browse/FLINK-24943 Project: Flink Issue Type:

[jira] [Updated] (FLINK-16570) Difficulties to select correct metric with long name in dropdown of Flink UI task menu

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

[jira] [Updated] (FLINK-11862) many differents query on same stream cause second condition of where of second query error

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

[jira] [Updated] (FLINK-11457) PrometheusPushGatewayReporter does not cleanup its metrics

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

[GitHub] [flink] flinkbot edited a comment on pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

2021-11-17 Thread GitBox
flinkbot edited a comment on pull request #17811: URL: https://github.com/apache/flink/pull/17811#issuecomment-970441907 ## CI report: * bb14b0ec0bb661fb900d594dba04ff275a1df664 Azure:

  1   2   3   4   5   >