[GitHub] [flink] flinkbot edited a comment on pull request #14591: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14591: URL: https://github.com/apache/flink/pull/14591#issuecomment-756825239 ## CI report: * 35947579b06f3b4d67e151e2fc38565813076008 Azure:

[jira] [Updated] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-01-31 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-20663: --- Priority: Critical (was: Major) > Managed memory may not be released in time when operators use

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

2021-01-31 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276114#comment-17276114 ] Caizhi Weng commented on FLINK-20663: - Hi, I've tested the patch [~xintongsong] provided on some

[jira] [Assigned] (FLINK-21150) Introduce ExecEdge to connect two ExecNodes

2021-01-31 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21150: -- Assignee: godfrey he > Introduce ExecEdge to connect two ExecNodes >

[GitHub] [flink] wuchong commented on a change in pull request #14822: [FLINK-21005][table-api] Introduce new provider for unified Sink API and implement in planner

2021-01-31 Thread GitBox
wuchong commented on a change in pull request #14822: URL: https://github.com/apache/flink/pull/14822#discussion_r567614908 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java ## @@ -123,6

[jira] [Created] (FLINK-21224) Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge

2021-01-31 Thread godfrey he (Jira)
godfrey he created FLINK-21224: -- Summary: Remove BatchExecExchange and StreamExecExchange, and replace their functionality with ExecEdge Key: FLINK-21224 URL: https://issues.apache.org/jira/browse/FLINK-21224

[GitHub] [flink] wuchong commented on a change in pull request #14822: [FLINK-21005][table-api] Introduce new provider for unified Sink API and implement in planner

2021-01-31 Thread GitBox
wuchong commented on a change in pull request #14822: URL: https://github.com/apache/flink/pull/14822#discussion_r567614908 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java ## @@ -123,6

[GitHub] [flink] wuchong commented on a change in pull request #14822: [FLINK-21005][table-api] Introduce new provider for unified Sink API and implement in planner

2021-01-31 Thread GitBox
wuchong commented on a change in pull request #14822: URL: https://github.com/apache/flink/pull/14822#discussion_r567610927 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/SinkProvider.java ## @@ -0,0 +1,36 @@ +/* + * Licensed

[GitHub] [flink] wuchong commented on a change in pull request #14822: [FLINK-21005][table-api] Introduce new provider for unified Sink API and implement in planner

2021-01-31 Thread GitBox
wuchong commented on a change in pull request #14822: URL: https://github.com/apache/flink/pull/14822#discussion_r567610927 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/SinkProvider.java ## @@ -0,0 +1,36 @@ +/* + * Licensed

[GitHub] [flink] dianfu merged pull request #14825: [FLINK-21216][python] Limit numpy version in setup.py

2021-01-31 Thread GitBox
dianfu merged pull request #14825: URL: https://github.com/apache/flink/pull/14825 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

[GitHub] [flink] flinkbot edited a comment on pull request #14826: [FLINK-12358][docs] Add IT case to verify REST docs corresponding to the code

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14826: URL: https://github.com/apache/flink/pull/14826#issuecomment-770627972 ## CI report: * ce1c42b9e4162b61553f3fadd02d30107047f91d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14647: URL: https://github.com/apache/flink/pull/14647#issuecomment-760154591 ## CI report: * 80e3121418e741d9bebf3e849817a0c4225a86dd Azure:

[jira] [Updated] (FLINK-21221) Deduplication of ResourceCounter

2021-01-31 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21221: - Labels: starter (was: ) > Deduplication of ResourceCounter > > >

[jira] [Updated] (FLINK-21220) Change the type of cpuCores in ResourceProfile to CPUResource

2021-01-31 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-21220: - Labels: starter (was: ) > Change the type of cpuCores in ResourceProfile to CPUResource >

[jira] [Created] (FLINK-21223) Support to specify the input/output types of Python UDFs via string

2021-01-31 Thread Dian Fu (Jira)
Dian Fu created FLINK-21223: --- Summary: Support to specify the input/output types of Python UDFs via string Key: FLINK-21223 URL: https://issues.apache.org/jira/browse/FLINK-21223 Project: Flink

[jira] [Commented] (FLINK-16224) Refine Hadoop Delegation Token based testing framework

2021-01-31 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276104#comment-17276104 ] Matthias commented on FLINK-16224: -- Hi [~jackwangcs], I don't know of any plans to work on this soon.

[GitHub] [flink] flinkbot commented on pull request #14826: [FLINK-12358][docs] Add IT case to verify REST docs corresponding to the code

2021-01-31 Thread GitBox
flinkbot commented on pull request #14826: URL: https://github.com/apache/flink/pull/14826#issuecomment-770627972 ## CI report: * ce1c42b9e4162b61553f3fadd02d30107047f91d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030 ## CI report: * f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN * e97b4de046ec8231040f2c88b851a3fd69bf647b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721 ## CI report: * cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN * 12652d9c7829d2d26d41f61185cbd7ab8f4ad505 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14647: URL: https://github.com/apache/flink/pull/14647#issuecomment-760154591 ## CI report: * 80e3121418e741d9bebf3e849817a0c4225a86dd Azure:

[jira] [Created] (FLINK-21222) Support loopback mode to allow Python UDF worker and client reuse the same Python VM

2021-01-31 Thread Dian Fu (Jira)
Dian Fu created FLINK-21222: --- Summary: Support loopback mode to allow Python UDF worker and client reuse the same Python VM Key: FLINK-21222 URL: https://issues.apache.org/jira/browse/FLINK-21222 Project:

[GitHub] [flink] flinkbot commented on pull request #14826: [FLINK-12358][docs] Add IT case to verify REST docs corresponding to the code

2021-01-31 Thread GitBox
flinkbot commented on pull request #14826: URL: https://github.com/apache/flink/pull/14826#issuecomment-770608140 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

[jira] [Assigned] (FLINK-21215) UnalignedCheckpointITCase.execute Failed

2021-01-31 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-21215: -- Assignee: Piotr Nowojski > UnalignedCheckpointITCase.execute Failed >

[jira] [Commented] (FLINK-21045) Support 'load module' and 'unload module' SQL syntax

2021-01-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276088#comment-17276088 ] Jark Wu commented on FLINK-21045: - Thanks [~qingyue] for the nice summary. Let's continue the discussion

[jira] [Updated] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

2021-01-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12358: --- Labels: pull-request-available (was: ) > Verify whether rest documenation needs to be

[GitHub] [flink] wuchong commented on a change in pull request #14813: [FLINK-21207] Fix source table with 'csv.disable-quote-character' = 'true' can not take effect

2021-01-31 Thread GitBox
wuchong commented on a change in pull request #14813: URL: https://github.com/apache/flink/pull/14813#discussion_r567589468 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java ## @@ -206,6 +206,29 @@ public void

[GitHub] [flink] Myasuka opened a new pull request #14826: [FLINK-12358][docs] Add IT case to verify REST docs corresponding to the code

2021-01-31 Thread GitBox
Myasuka opened a new pull request #14826: URL: https://github.com/apache/flink/pull/14826 ## What is the purpose of the change Include method/path/query parameter description in the `rest_api_v1.snapshot` so that we could follow the description check. Add IT case

[jira] [Commented] (FLINK-14256) [Umbrella] Introduce FileSystemTableFactory with partitioned support

2021-01-31 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276084#comment-17276084 ] Zili Chen commented on FLINK-14256: --- Plz update FLIP status correspondingly [~lzljs3620320]. >

[jira] [Commented] (FLINK-20722) HiveTableSink should copy the record when converting RowData to Row

2021-01-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276080#comment-17276080 ] Jark Wu commented on FLINK-20722: - Sorry, but shouldn't this be fixed in

[GitHub] [flink] flinkbot edited a comment on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030 ## CI report: * f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN * e97b4de046ec8231040f2c88b851a3fd69bf647b Azure:

[jira] [Commented] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-01-31 Thread wangpeibin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276078#comment-17276078 ] wangpeibin commented on FLINK-21203: +1 for Jark's suggestion > Don’t collect -U&+U Row When they

[jira] [Closed] (FLINK-20216) Move "Configuration" and "Environment Variables" under "Python API" section

2021-01-31 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20216. --- Fix Version/s: (was: 1.13.0) 1.12.0 Resolution: Fixed > Move "Configuration"

[GitHub] [flink] wuchong commented on a change in pull request #14813: [FLINK-21207] Fix source table with 'csv.disable-quote-character' = 'true' can not take effect

2021-01-31 Thread GitBox
wuchong commented on a change in pull request #14813: URL: https://github.com/apache/flink/pull/14813#discussion_r567584364 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java ## @@ -206,6 +206,29 @@ public void

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-01-31 Thread GitBox
KarmaGYZ commented on a change in pull request #14647: URL: https://github.com/apache/flink/pull/14647#discussion_r567581423 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java ## @@ -0,0 +1,790 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #14825: [FLINK-21216][python] Limit numpy version in setup.py

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14825: URL: https://github.com/apache/flink/pull/14825#issuecomment-770581870 ## CI report: * 291f6797c35037d17e9aeb8ab67da557d5c35b87 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14824: [release-1.12][FLINK-21169][kafka] flink-connector-base dependency should be scope compile

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14824: URL: https://github.com/apache/flink/pull/14824#issuecomment-770512589 ## CI report: * e434ce611d8c12cceb749d22ea24f3e6fb650aeb Azure:

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2021-01-31 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276069#comment-17276069 ] Xintong Song commented on FLINK-20495: --

[jira] [Closed] (FLINK-21171) Introduce TypedValue to the StateFun request-reply protocol

2021-01-31 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21171. --- Resolution: Fixed flink-statefun/master: 69c658ec361682fb3bef50bd810f0646d7332a0c

[GitHub] [flink-statefun] tzulitai closed pull request #195: [FLINK-21171] Wire in TypedValue throughout the runtime as state values and message payloads

2021-01-31 Thread GitBox
tzulitai closed pull request #195: URL: https://github.com/apache/flink-statefun/pull/195 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

[jira] [Commented] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-01-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276066#comment-17276066 ] Jark Wu commented on FLINK-21203: - I think we may not need the configuration. Group Aggregate also has

[GitHub] [flink] flinkbot commented on pull request #14825: [FLINK-21216][python] Fix numpy version in setup.py

2021-01-31 Thread GitBox
flinkbot commented on pull request #14825: URL: https://github.com/apache/flink/pull/14825#issuecomment-770581870 ## CI report: * 291f6797c35037d17e9aeb8ab67da557d5c35b87 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14825: [FLINK-21216][python] Fix numpy version in setup.py

2021-01-31 Thread GitBox
flinkbot commented on pull request #14825: URL: https://github.com/apache/flink/pull/14825#issuecomment-770576435 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

[jira] [Updated] (FLINK-21216) StreamPandasConversionTests Fails

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

[GitHub] [flink] HuangXingBo opened a new pull request #14825: [FLINK-21216][python] Fix numpy version in setup.py

2021-01-31 Thread GitBox
HuangXingBo opened a new pull request #14825: URL: https://github.com/apache/flink/pull/14825 ## What is the purpose of the change *This pull request fix numpy version in setup.py. Currently pyarrow>=0.15.1,<0.18.0 and numpy==1.20.0 have compatibility problem in Python 3.7.*

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * dfd5c341320f3ccb7291c5833ae52a3d3f1632f1 Azure:

[GitHub] [flink] curcur commented on a change in pull request #14799: [WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-01-31 Thread GitBox
curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r567563070 ## File path: flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java ## @@ -44,6 +44,15 @@

[GitHub] [flink] curcur commented on a change in pull request #14799: [WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-01-31 Thread GitBox
curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r567556094 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,306 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030 ## CI report: * f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN * e97b4de046ec8231040f2c88b851a3fd69bf647b Azure:

[GitHub] [flink] sharkdtu commented on a change in pull request #14813: [FLINK-21207] Fix source table with 'csv.disable-quote-character' = 'true' can not take effect

2021-01-31 Thread GitBox
sharkdtu commented on a change in pull request #14813: URL: https://github.com/apache/flink/pull/14813#discussion_r567551672 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java ## @@ -206,6 +206,29 @@ public void

[GitHub] [flink] sharkdtu commented on a change in pull request #14813: [FLINK-21207] Fix source table with 'csv.disable-quote-character' = 'true' can not take effect

2021-01-31 Thread GitBox
sharkdtu commented on a change in pull request #14813: URL: https://github.com/apache/flink/pull/14813#discussion_r567551672 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java ## @@ -206,6 +206,29 @@ public void

[GitHub] [flink] sharkdtu commented on a change in pull request #14813: [FLINK-21207] Fix source table with 'csv.disable-quote-character' = 'true' can not take effect

2021-01-31 Thread GitBox
sharkdtu commented on a change in pull request #14813: URL: https://github.com/apache/flink/pull/14813#discussion_r567551672 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java ## @@ -206,6 +206,29 @@ public void

[GitHub] [flink] curcur commented on a change in pull request #14799: [WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-01-31 Thread GitBox
curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r567551460 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,306 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on a change in pull request #14799: [WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-01-31 Thread GitBox
curcur commented on a change in pull request #14799: URL: https://github.com/apache/flink/pull/14799#discussion_r567551460 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/proxy/ProxyKeyedStateBackend.java ## @@ -0,0 +1,306 @@ +/* + * Licensed to the

[GitHub] [flink] curcur commented on pull request #14799: [WIP] Wrapped StateBackend to forward state changes to StateChangleLog

2021-01-31 Thread GitBox
curcur commented on pull request #14799: URL: https://github.com/apache/flink/pull/14799#issuecomment-770546162 Thank you so much for reviewing, @rkhachatryan ! This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-21221) Deduplication of ResourceCounter

2021-01-31 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276044#comment-17276044 ] Yangze Guo commented on FLINK-21221: cc: [~trohrmann] [~chesnay] > Deduplication of ResourceCounter

[jira] [Created] (FLINK-21221) Deduplication of ResourceCounter

2021-01-31 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-21221: -- Summary: Deduplication of ResourceCounter Key: FLINK-21221 URL: https://issues.apache.org/jira/browse/FLINK-21221 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-21207) 'csv.disable-quote-character' can not take effect during deserialization

2021-01-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21207: Component/s: Table SQL / Ecosystem Formats (JSON, Avro, Parquet, ORC, SequenceFile) >

[GitHub] [flink] wuchong commented on a change in pull request #14813: [FLINK-21207] Fix source table with 'csv.disable-quote-character' = 'true' can not take effect

2021-01-31 Thread GitBox
wuchong commented on a change in pull request #14813: URL: https://github.com/apache/flink/pull/14813#discussion_r567548368 ## File path: flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFactoryTest.java ## @@ -206,6 +206,29 @@ public void

[jira] [Comment Edited] (FLINK-21216) StreamPandasConversionTests Fails

2021-01-31 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276042#comment-17276042 ] Guowei Ma edited comment on FLINK-21216 at 2/1/21, 3:37 AM:

[jira] [Commented] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-01-31 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276043#comment-17276043 ] Leonard Xu commented on FLINK-21203: +1 for the ticket, [~wangpeibin] About the config option,

[jira] [Commented] (FLINK-21216) StreamPandasConversionTests Fails

2021-01-31 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276042#comment-17276042 ] Guowei Ma commented on FLINK-21216: ---

[jira] [Commented] (FLINK-21215) UnalignedCheckpointITCase.execute Failed

2021-01-31 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276041#comment-17276041 ] Guowei Ma commented on FLINK-21215: ---

[GitHub] [flink] flinkbot edited a comment on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030 ## CI report: * f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN * fe9b0d8824da2e50712f599978a4586bfe8f28a4 Azure:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14647: [FLINK-20835] Implement FineGrainedSlotManager

2021-01-31 Thread GitBox
KarmaGYZ commented on a change in pull request #14647: URL: https://github.com/apache/flink/pull/14647#discussion_r567546171 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/WorkerResourceSpec.java ## @@ -70,6 +71,17 @@ public static

[jira] [Created] (FLINK-21220) Change the type of cpuCores in ResourceProfile to CPUResource

2021-01-31 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-21220: -- Summary: Change the type of cpuCores in ResourceProfile to CPUResource Key: FLINK-21220 URL: https://issues.apache.org/jira/browse/FLINK-21220 Project: Flink

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-31 Thread GitBox
guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r567541421 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -563,7 +554,7 @@ private void

[GitHub] [flink] guoweiM commented on a change in pull request #14734: [FLINK-21066][runtime][checkpoint] Refactor CheckpointCoordinator to compute tasks to trigger/ack/commit dynamically

2021-01-31 Thread GitBox
guoweiM commented on a change in pull request #14734: URL: https://github.com/apache/flink/pull/14734#discussion_r567528797 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointBriefCalculator.java ## @@ -0,0 +1,127 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-21207) 'csv.disable-quote-character' can not take effect during deserialization

2021-01-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21207: Description: source table with 'csv.disable-quote-character' = 'true' can not take effect.   {code}

[jira] [Assigned] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-01-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21203: --- Assignee: wangpeibin > Don’t collect -U&+U Row When they are equals In the LastRowFunction >

[jira] [Commented] (FLINK-21203) Don’t collect -U&+U Row When they are equals In the LastRowFunction

2021-01-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276038#comment-17276038 ] Jark Wu commented on FLINK-21203: - Sounds good to me. What do you think [~Leonard Xu]? > Don’t

[jira] [Comment Edited] (FLINK-18312) SavepointStatusHandler and StaticFileServerHandler not redirect

2021-01-31 Thread Yu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139087#comment-17139087 ] Yu Wang edited comment on FLINK-18312 at 2/1/21, 3:04 AM: -- [~chesnay],

[GitHub] [flink] flinkbot edited a comment on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030 ## CI report: * f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN * fe9b0d8824da2e50712f599978a4586bfe8f28a4 Azure:

[GitHub] [flink] HuangZhenQiu commented on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
HuangZhenQiu commented on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770523596 @xintongsong Thanks. Your changes are reasonable and needed. This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721 ## CI report: * cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN * 11651466eb13c5c05d2cd0eed0ac08b9bf617185 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14824: [release-1.12][FLINK-21169][kafka] flink-connector-base dependency should be scope compile

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14824: URL: https://github.com/apache/flink/pull/14824#issuecomment-770512589 ## CI report: * e434ce611d8c12cceb749d22ea24f3e6fb650aeb Azure:

[jira] [Commented] (FLINK-16224) Refine Hadoop Delegation Token based testing framework

2021-01-31 Thread jackwangcs (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276033#comment-17276033 ] jackwangcs commented on FLINK-16224: Hi [~rongr] and [~mapohl], is there any progress on this

[jira] [Commented] (FLINK-21216) StreamPandasConversionTests Fails

2021-01-31 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276030#comment-17276030 ] Huang Xingbo commented on FLINK-21216: -- I will take a look asap. > StreamPandasConversionTests

[GitHub] [flink] flinkbot commented on pull request #14824: [release-1.12][FLINK-21169][kafka] flink-connector-base dependency should be scope compile

2021-01-31 Thread GitBox
flinkbot commented on pull request #14824: URL: https://github.com/apache/flink/pull/14824#issuecomment-770512589 ## CI report: * e434ce611d8c12cceb749d22ea24f3e6fb650aeb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14824: [release-1.12][FLINK-21169][kafka] flink-connector-base dependency should be scope compile

2021-01-31 Thread GitBox
flinkbot commented on pull request #14824: URL: https://github.com/apache/flink/pull/14824#issuecomment-770502976 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] tweise opened a new pull request #14824: [release-1.12][FLINK-21169][kafka] flink-connector-base dependency should be scope compile

2021-01-31 Thread GitBox
tweise opened a new pull request #14824: URL: https://github.com/apache/flink/pull/14824 Backport of https://github.com/apache/flink/pull/14783 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #14678: [FLINK-20833][runtime] Add pluggable failure listener in job manager

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14678: URL: https://github.com/apache/flink/pull/14678#issuecomment-761905721 ## CI report: * cade20e85b29ca63c51383dca04976c1d9801042 UNKNOWN * 11651466eb13c5c05d2cd0eed0ac08b9bf617185 Azure:

[jira] [Resolved] (FLINK-21169) Kafka flink-connector-base dependency should be scope compile

2021-01-31 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-21169. -- Fix Version/s: 1.13.0 Resolution: Fixed > Kafka flink-connector-base dependency should

[GitHub] [flink] tweise merged pull request #14783: [FLINK-21169][kafka] flink-connector-base dependency should be scope compile

2021-01-31 Thread GitBox
tweise merged pull request #14783: URL: https://github.com/apache/flink/pull/14783 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

[GitHub] [flink] tweise commented on pull request #14783: [FLINK-21169][kafka] flink-connector-base dependency should be scope compile

2021-01-31 Thread GitBox
tweise commented on pull request #14783: URL: https://github.com/apache/flink/pull/14783#issuecomment-770499151 > Hello @tweise and @becketqin ~ I think putting flink-connector-base JAR under lib directory of Flink distribution might be a better choice. After eventually all connectors are

[jira] [Updated] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

2021-01-31 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21214: -- Affects Version/s: 1.11.0 > FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed >

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

2021-01-31 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276021#comment-17276021 ] Guowei Ma commented on FLINK-21214: ---

[jira] [Commented] (FLINK-21219) FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint.

2021-01-31 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-21219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276020#comment-17276020 ] Dominik Wosiński commented on FLINK-21219: -- I would like to work on that.   >

[jira] [Commented] (FLINK-10407) FLIP-159: Reactive mode

2021-01-31 Thread John Phelan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276016#comment-17276016 ] John Phelan commented on FLINK-10407: - hi [~rmetzger] [~trohrmann] is there some work that an

[jira] [Created] (FLINK-21219) FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint.

2021-01-31 Thread Jira
Dominik Wosiński created FLINK-21219: Summary: FlinkKafkaConsumer ignores offset overrides for new topics when restoring from savepoint. Key: FLINK-21219 URL: https://issues.apache.org/jira/browse/FLINK-21219

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * e7dbab13079f1a1f2350320930cc216c8ed42759 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13912: [FLINK-19466][FLINK-19467][runtime / state backends] Add Flip-142 public interfaces and methods

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #13912: URL: https://github.com/apache/flink/pull/13912#issuecomment-721398037 ## CI report: * e7dbab13079f1a1f2350320930cc216c8ed42759 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030 ## CI report: * f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN * fe9b0d8824da2e50712f599978a4586bfe8f28a4 Azure:

[jira] [Comment Edited] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

2021-01-31 Thread Emilien Kenler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276004#comment-17276004 ] Emilien Kenler edited comment on FLINK-20417 at 1/31/21, 10:37 PM: ---

[jira] [Commented] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

2021-01-31 Thread Emilien Kenler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276004#comment-17276004 ] Emilien Kenler commented on FLINK-20417: This issue happens event when the APIServer is not

[jira] [Comment Edited] (FLINK-20417) Handle "Too old resource version" exception in Kubernetes watch more gracefully

2021-01-31 Thread Emilien Kenler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276004#comment-17276004 ] Emilien Kenler edited comment on FLINK-20417 at 1/31/21, 10:36 PM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030 ## CI report: * f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN * fe9b0d8824da2e50712f599978a4586bfe8f28a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
flinkbot edited a comment on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030 ## CI report: * f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN * fe9b0d8824da2e50712f599978a4586bfe8f28a4 UNKNOWN Bot commands The

[jira] [Commented] (FLINK-21139) ThresholdMeterTest.testMarkMultipleEvents unstable

2021-01-31 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275963#comment-17275963 ] Zhenqiu Huang commented on FLINK-21139: --- [~xintongsong] Make sense. Just created the PR. Please

[GitHub] [flink] flinkbot commented on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
flinkbot commented on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770437030 ## CI report: * f0ba4a5828295c651491d7b031dd6c894375234b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14823: [FLINK-21139][Build] Fix unstable ThresholdMeterTest

2021-01-31 Thread GitBox
flinkbot commented on pull request #14823: URL: https://github.com/apache/flink/pull/14823#issuecomment-770435644 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

  1   2   >