[jira] [Updated] (FLINK-17307) Add collector to DeserializationSchema

2020-11-08 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17307: - Description: Additionally add support in connectors: * Kafka -* Kinesis- * PubSub *

[jira] [Created] (FLINK-20055) Datadog API Key exposed in Flink JobManager logs

2020-11-08 Thread Florian Szabo (Jira)
Florian Szabo created FLINK-20055: - Summary: Datadog API Key exposed in Flink JobManager logs Key: FLINK-20055 URL: https://issues.apache.org/jira/browse/FLINK-20055 Project: Flink Issue

[jira] [Assigned] (FLINK-20054) 3 Level List is not supported in ParquetInputFormat

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20054: -- Assignee: Zhenqiu Huang > 3 Level List is not supported in ParquetInputFormat >

[jira] [Commented] (FLINK-20013) BoundedBlockingSubpartition may leak network buffer if task is failed or canceled

2020-11-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228387#comment-17228387 ] Zhu Zhu commented on FLINK-20013: - Hi [~nicholasjiang], I can see that [~pnowojski] has assigned this

[GitHub] [flink] HuangZhenQiu opened a new pull request #13994: [FLINK-20054][formats] Fix ParquetInputFormat 3 level List handling

2020-11-08 Thread GitBox
HuangZhenQiu opened a new pull request #13994: URL: https://github.com/apache/flink/pull/13994 # What is the purpose of the change Fix the 3 level List handling in ParquetInputFormat ## Brief change log 1) Add the 3 level List schema conversion logic in ParquetSchemaConverter.

[jira] [Updated] (FLINK-20054) 3 Level List is not supported in ParquetInputFormat

2020-11-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20054: --- Labels: pull-request-available (was: ) > 3 Level List is not supported in

[GitHub] [flink] flinkbot edited a comment on pull request #13989: [FLINK-19448][connector/common] Synchronize fetchers.isEmpty status to SourceReaderBase using elementsQueue.notifyAvailable()

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13989: URL: https://github.com/apache/flink/pull/13989#issuecomment-723709607 ## CI report: * 7769826c671c1c7e081128ab1a5cf74819808456 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13972: [FLINK-19912][json] Fix JSON format fails to serialize map value with…

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13972: URL: https://github.com/apache/flink/pull/13972#issuecomment-723244452 ## CI report: * 18bd1620f55d1363b4d3173dc2e9c14e83ba859b UNKNOWN * 951191135eee7d3f7fddea2a5e296dbd36716dd3 Azure:

[GitHub] [flink] flinkbot commented on pull request #13993: [hotfix][hbase] Add missed ITCase in hbase2 connector

2020-11-08 Thread GitBox
flinkbot commented on pull request #13993: URL: https://github.com/apache/flink/pull/13993#issuecomment-723825860 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] [Comment Edited] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

2020-11-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228381#comment-17228381 ] Zhu Zhu edited comment on FLINK-19964 at 11/9/20, 7:37 AM: --- The change

[GitHub] [flink] leonardBang opened a new pull request #13993: [hotfix][hbase] Add missed ITCase in hbase2 connector

2020-11-08 Thread GitBox
leonardBang opened a new pull request #13993: URL: https://github.com/apache/flink/pull/13993 ## What is the purpose of the change * This pull request add the missed `@Test` in hbase2 connector, I think this test is missed in FLINK-18795 ## Brief change log -

[jira] [Commented] (FLINK-19882) E2E: SQLClientHBaseITCase crash

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228382#comment-17228382 ] Robert Metzger commented on FLINK-19882: Okay, the problem seems to be the following: 1. the

[jira] [Updated] (FLINK-19882) E2E: SQLClientHBaseITCase crash

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19882: --- Affects Version/s: 1.12.0 > E2E: SQLClientHBaseITCase crash >

[jira] [Commented] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

2020-11-08 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228381#comment-17228381 ] Zhu Zhu commented on FLINK-19964: - The change FLINK-19189 to "enable pipelined region scheduling by

[jira] [Created] (FLINK-20054) 3 Level List is not supported in ParquetInputFormat

2020-11-08 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-20054: - Summary: 3 Level List is not supported in ParquetInputFormat Key: FLINK-20054 URL: https://issues.apache.org/jira/browse/FLINK-20054 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #13972: [FLINK-19912][json] Fix JSON format fails to serialize map value with…

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13972: URL: https://github.com/apache/flink/pull/13972#issuecomment-723244452 ## CI report: * 18bd1620f55d1363b4d3173dc2e9c14e83ba859b UNKNOWN * 951191135eee7d3f7fddea2a5e296dbd36716dd3 Azure:

[jira] [Commented] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

2020-11-08 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228379#comment-17228379 ] Leonard Xu commented on FLINK-19635: I checked the failed tests in this ticket and   

[jira] [Commented] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228375#comment-17228375 ] Robert Metzger commented on FLINK-20011:

[jira] [Commented] (FLINK-20052) kafka/gelly pre-commit test failed due to process hang

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228374#comment-17228374 ] Robert Metzger commented on FLINK-20052: >From the stacktraces, it looks like

[jira] [Closed] (FLINK-20052) kafka/gelly pre-commit test failed due to process hang

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20052. -- Fix Version/s: (was: 1.12.0) Resolution: Duplicate > kafka/gelly pre-commit test

[GitHub] [flink] flinkbot edited a comment on pull request #13972: [FLINK-19912][json] Fix JSON format fails to serialize map value with…

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13972: URL: https://github.com/apache/flink/pull/13972#issuecomment-723244452 ## CI report: * 18bd1620f55d1363b4d3173dc2e9c14e83ba859b UNKNOWN * 951191135eee7d3f7fddea2a5e296dbd36716dd3 Azure:

[jira] [Commented] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

2020-11-08 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228363#comment-17228363 ] Kostas Kloudas commented on FLINK-19973: Thanks a lot [~zhisheng]! > 【Flink-Deployment】YARN CLI

[jira] [Commented] (FLINK-15959) Add min number of slots configuration to limit total number of slots

2020-11-08 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228359#comment-17228359 ] Yangze Guo commented on FLINK-15959: [~trohrmann] Sorry for the belated reply. No, I'll change the

[jira] [Updated] (FLINK-15959) Add min number of slots configuration to limit total number of slots

2020-11-08 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15959: --- Fix Version/s: (was: 1.12.0) 1.13.0 > Add min number of slots configuration

[jira] [Updated] (FLINK-20050) SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20050: --- Priority: Critical (was: Major) > SourceCoordinatorProviderTest.testCheckpointAndReset

[GitHub] [flink] rmetzger commented on a change in pull request #13978: [FLINK-20033] Ensure that stopping a JobMaster will suspend the running job

2020-11-08 Thread GitBox
rmetzger commented on a change in pull request #13978: URL: https://github.com/apache/flink/pull/13978#discussion_r519570415 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ## @@ -1212,23 +1208,13 @@ protected void

[jira] [Commented] (FLINK-20051) SourceReaderTestBase.testAddSplitToExistingFetcher failed with NullPointerException

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228355#comment-17228355 ] Robert Metzger commented on FLINK-20051: [~becket_qin] can you take a look at this failure? >

[jira] [Updated] (FLINK-20051) SourceReaderTestBase.testAddSplitToExistingFetcher failed with NullPointerException

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20051: --- Priority: Critical (was: Major) > SourceReaderTestBase.testAddSplitToExistingFetcher

[GitHub] [flink] flinkbot edited a comment on pull request #13992: [FLINK-20035][tests] Use random port for rest endpoint in BlockingShuffleITCase and ShuffleCompressionITCase

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13992: URL: https://github.com/apache/flink/pull/13992#issuecomment-723768653 ## CI report: * 7bde630b8b67c9c31c49ec590ce58c09741f5a3c Azure:

[jira] [Commented] (FLINK-19964) Gelly ITCase stuck on Azure in HITSITCase.testPrintWithRMatGraph

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228354#comment-17228354 ] Robert Metzger commented on FLINK-19964: The iterations deadlocks are happening quite frequently

[jira] [Commented] (FLINK-20035) BlockingShuffleITCase unstable with "Could not start rest endpoint on any port in port range 8081"

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228353#comment-17228353 ] Robert Metzger commented on FLINK-20035: Thanks a lot for looking into it. I assigned you to the

[jira] [Assigned] (FLINK-20035) BlockingShuffleITCase unstable with "Could not start rest endpoint on any port in port range 8081"

2020-11-08 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20035: -- Assignee: Yingjie Cao > BlockingShuffleITCase unstable with "Could not start rest

[GitHub] [flink] flinkbot commented on pull request #13992: [FLINK-20035][tests] Use random port for rest endpoint in BlockingShuffleITCase and ShuffleCompressionITCase

2020-11-08 Thread GitBox
flinkbot commented on pull request #13992: URL: https://github.com/apache/flink/pull/13992#issuecomment-723768653 ## CI report: * 7bde630b8b67c9c31c49ec590ce58c09741f5a3c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13992: [FLINK-20035][tests] Use random port for rest endpoint in BlockingShuffleITCase and ShuffleCompressionITCase

2020-11-08 Thread GitBox
flinkbot commented on pull request #13992: URL: https://github.com/apache/flink/pull/13992#issuecomment-723763452 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-19983) ShuffleCompressionITCase.testDataCompressionForSortMergeBlockingShuffle unstable

2020-11-08 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-19983: Fix Version/s: 1.12.0 > ShuffleCompressionITCase.testDataCompressionForSortMergeBlockingShuffle

[jira] [Updated] (FLINK-20035) BlockingShuffleITCase unstable with "Could not start rest endpoint on any port in port range 8081"

2020-11-08 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-20035: Fix Version/s: 1.12.0 > BlockingShuffleITCase unstable with "Could not start rest endpoint on any

[jira] [Commented] (FLINK-20035) BlockingShuffleITCase unstable with "Could not start rest endpoint on any port in port range 8081"

2020-11-08 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228349#comment-17228349 ] Yingjie Cao commented on FLINK-20035: - This failure is caused by port bind exception. I have

[jira] [Updated] (FLINK-20035) BlockingShuffleITCase unstable with "Could not start rest endpoint on any port in port range 8081"

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

[GitHub] [flink] wsry opened a new pull request #13992: [FLINK-20035][tests] Use random port for rest endpoint in BlockingShuffleITCase and ShuffleCompressionITCase

2020-11-08 Thread GitBox
wsry opened a new pull request #13992: URL: https://github.com/apache/flink/pull/13992 ## What is the purpose of the change Use random port for rest endpoint in BlockingShuffleITCase and ShuffleCompressionITCase to make the cases more stable. ## Brief change log -

[jira] [Assigned] (FLINK-20016) Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

2020-11-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20016: --- Assignee: Shuiqiang Chen > Support TimestampAssigner and WatermarkGenerator for Python DataStream

[jira] [Closed] (FLINK-20016) Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

2020-11-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20016. --- Resolution: Fixed Merged to master via f24cb3f3b7e773706188ae92998b3e1ffbf1829e > Support

[GitHub] [flink] dianfu closed pull request #13986: [FLINK-20016][python] Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

2020-11-08 Thread GitBox
dianfu closed pull request #13986: URL: https://github.com/apache/flink/pull/13986 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 #13990: [FLINK-20053][table][doc] Add document for file compaction

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13990: URL: https://github.com/apache/flink/pull/13990#issuecomment-723733200 ## CI report: * bcabafeacefca7370b3c2f3569ff8608704a282b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13988: [FLINK-19265][FLINK-20049][core] Source API final adjustments

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13988: URL: https://github.com/apache/flink/pull/13988#issuecomment-723691966 ## CI report: * 1d621a3f57b64dbbd9f645347267aef8b245ca74 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13991: [FLINK-19983][network] Remove wrong state checking in SortMergeSubpartitionReader

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13991: URL: https://github.com/apache/flink/pull/13991#issuecomment-723737863 ## CI report: * 9d1b60190d1e7c588b225301792b63789227a91b Azure:

[jira] [Commented] (FLINK-19802) Let BulkFormat createReader and restoreReader methods accept Splits directly

2020-11-08 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228338#comment-17228338 ] Steven Zhen Wu commented on FLINK-19802: [~sewen] sorry, I didn't mean that we need this before

[GitHub] [flink] flinkbot commented on pull request #13991: [FLINK-19983][network] Remove wrong state checking in SortMergeSubpartitionReader

2020-11-08 Thread GitBox
flinkbot commented on pull request #13991: URL: https://github.com/apache/flink/pull/13991#issuecomment-723737863 ## CI report: * 9d1b60190d1e7c588b225301792b63789227a91b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13989: [FLINK-19448][connector/common] Synchronize fetchers.isEmpty status to SourceReaderBase using elementsQueue.notifyAvailable()

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13989: URL: https://github.com/apache/flink/pull/13989#issuecomment-723709607 ## CI report: * 5da43fd50d04596217e89f547f97dbb4711ca7ee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13986: [FLINK-20016][python] Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13986: URL: https://github.com/apache/flink/pull/13986#issuecomment-723648682 ## CI report: * 6afd298cd5356502822e36537d7a1c8ba67052b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13990: [FLINK-20053][table][doc] Add document for file compaction

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13990: URL: https://github.com/apache/flink/pull/13990#issuecomment-723733200 ## CI report: * bcabafeacefca7370b3c2f3569ff8608704a282b Azure:

[jira] [Commented] (FLINK-19983) ShuffleCompressionITCase.testDataCompressionForSortMergeBlockingShuffle unstable

2020-11-08 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228333#comment-17228333 ] Yingjie Cao commented on FLINK-19983: - After some investigation, I find that the state check is not

[GitHub] [flink] flinkbot commented on pull request #13991: [FLINK-19983][network] Remove wrong state checking in SortMergeSubpartitionReader

2020-11-08 Thread GitBox
flinkbot commented on pull request #13991: URL: https://github.com/apache/flink/pull/13991#issuecomment-723734174 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-19983) ShuffleCompressionITCase.testDataCompressionForSortMergeBlockingShuffle unstable

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

[GitHub] [flink] becketqin commented on a change in pull request #13988: [FLINK-19265][FLINK-20049][core] Source API final adjustments

2020-11-08 Thread GitBox
becketqin commented on a change in pull request #13988: URL: https://github.com/apache/flink/pull/13988#discussion_r519532305 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/source/SplitEnumerator.java ## @@ -41,12 +43,14 @@ void start();

[GitHub] [flink] wsry opened a new pull request #13991: [FLINK-19983][network] Remove wrong state checking in SortMergeSubpartitionReader

2020-11-08 Thread GitBox
wsry opened a new pull request #13991: URL: https://github.com/apache/flink/pull/13991 ## What is the purpose of the change Remove wrong state checking in SortMergeSubpartitionReader. ## Brief change log - Remove wrong state checking in SortMergeSubpartitionReader.

[GitHub] [flink] flinkbot commented on pull request #13990: [FLINK-20053][table][doc] Add document for file compaction

2020-11-08 Thread GitBox
flinkbot commented on pull request #13990: URL: https://github.com/apache/flink/pull/13990#issuecomment-723733200 ## CI report: * bcabafeacefca7370b3c2f3569ff8608704a282b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13989: [FLINK-19448][connector/common] Synchronize fetchers.isEmpty status to SourceReaderBase using elementsQueue.notifyAvailable()

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13989: URL: https://github.com/apache/flink/pull/13989#issuecomment-723709607 ## CI report: * 5da43fd50d04596217e89f547f97dbb4711ca7ee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13606: [FLINK-19554][e2e] Implement a unified testing framework for connectors

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13606: URL: https://github.com/apache/flink/pull/13606#issuecomment-707535989 ## CI report: * 7f5361cb816e2fd6e3abad7adcf9caaabd126d2e Azure:

[jira] [Updated] (FLINK-20052) kafka/gelly pre-commit test failed due to process hang

2020-11-08 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-20052: -- Issue Type: Test (was: Bug) > kafka/gelly pre-commit test failed due to process hang >

[jira] [Comment Edited] (FLINK-20045) ZooKeeperLeaderElectionTest.testZooKeeperLeaderElectionRetrieval failed with "TimeoutException: Contender was not elected as the leader within 200000ms"

2020-11-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228330#comment-17228330 ] Yang Wang edited comment on FLINK-20045 at 11/9/20, 3:12 AM: - I think the

[jira] [Commented] (FLINK-20045) ZooKeeperLeaderElectionTest.testZooKeeperLeaderElectionRetrieval failed with "TimeoutException: Contender was not elected as the leader within 200000ms"

2020-11-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228330#comment-17228330 ] Yang Wang commented on FLINK-20045: --- I think the root cause is the leader was granted too fast and the

[GitHub] [flink] flinkbot commented on pull request #13990: [FLINK-20053][table][doc] Add document for file compaction

2020-11-08 Thread GitBox
flinkbot commented on pull request #13990: URL: https://github.com/apache/flink/pull/13990#issuecomment-723725737 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] JingsongLi opened a new pull request #13990: [FLINK-20053][table][doc] Add document for file compaction

2020-11-08 Thread GitBox
JingsongLi opened a new pull request #13990: URL: https://github.com/apache/flink/pull/13990 ## What is the purpose of the change Add document for file compaction ## Brief change log - In Flink FileSystem document, Add File Compaction

[jira] [Updated] (FLINK-20053) Add document for file compaction

2020-11-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20053: --- Labels: pull-request-available (was: ) > Add document for file compaction >

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-11-08 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228328#comment-17228328 ] Jiangjie Qin commented on FLINK-19717: -- [~sewen] I have merged the patch to master. But

[GitHub] [flink] flinkbot edited a comment on pull request #13606: [FLINK-19554][e2e] Implement a unified testing framework for connectors

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13606: URL: https://github.com/apache/flink/pull/13606#issuecomment-707535989 ## CI report: * 8063b2a34512c8d8e99cdba06a1872d9786832bb Azure:

[jira] [Resolved] (FLINK-19238) RocksDB performance issue with low managed memory and high parallelism

2020-11-08 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li resolved FLINK-19238. --- Fix Version/s: 1.12.0 Resolution: Implemented Merged into master via

[GitHub] [flink] carp84 commented on pull request #13977: [Mirror] [FLINK-19238] Sanity check for RocksDB arena block size

2020-11-08 Thread GitBox
carp84 commented on pull request #13977: URL: https://github.com/apache/flink/pull/13977#issuecomment-723723365 Merged via 93c6256 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] carp84 closed pull request #13977: [Mirror] [FLINK-19238] Sanity check for RocksDB arena block size

2020-11-08 Thread GitBox
carp84 closed pull request #13977: URL: https://github.com/apache/flink/pull/13977 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] carp84 closed pull request #13688: [FLINK-19238] Arena block size sanity

2020-11-08 Thread GitBox
carp84 closed pull request #13688: URL: https://github.com/apache/flink/pull/13688 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] SteNicholas commented on a change in pull request #13986: [FLINK-20016][python] Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

2020-11-08 Thread GitBox
SteNicholas commented on a change in pull request #13986: URL: https://github.com/apache/flink/pull/13986#discussion_r519525532 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/TimestampsAndWatermarksOperator.java ## @@ -0,0 +1,251 @@

[GitHub] [flink] becketqin commented on pull request #13776: [FLINK-19717][connectors/common] Fix spurious InputStatus.END_OF_INPUT from SourceReaderBase.pollNext caused by split reader exception

2020-11-08 Thread GitBox
becketqin commented on pull request #13776: URL: https://github.com/apache/flink/pull/13776#issuecomment-723723065 Merged to master: 2cce1aced0d6a311ff0803b773f1565e7f9d76fc This is an automated message from the Apache

[GitHub] [flink] becketqin merged pull request #13776: [FLINK-19717][connectors/common] Fix spurious InputStatus.END_OF_INPUT from SourceReaderBase.pollNext caused by split reader exception

2020-11-08 Thread GitBox
becketqin merged pull request #13776: URL: https://github.com/apache/flink/pull/13776 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

[jira] [Commented] (FLINK-20006) FileSinkITCase.testFileSink: The record 0 should occur 4 times, but only occurs 8time expected:<4> but was:<8>

2020-11-08 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228325#comment-17228325 ] Yun Gao commented on FLINK-20006: - The latter issue should also get fixed now. >

[GitHub] [flink] becketqin commented on a change in pull request #13776: [FLINK-19717][connectors/common] Fix spurious InputStatus.END_OF_INPUT from SourceReaderBase.pollNext caused by split reader ex

2020-11-08 Thread GitBox
becketqin commented on a change in pull request #13776: URL: https://github.com/apache/flink/pull/13776#discussion_r519524957 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/SplitFetcherManager.java ## @@

[GitHub] [flink] dianfu commented on a change in pull request #13986: [FLINK-20016][python] Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

2020-11-08 Thread GitBox
dianfu commented on a change in pull request #13986: URL: https://github.com/apache/flink/pull/13986#discussion_r519516510 ## File path: flink-python/pyflink/datastream/tests/test_data_stream.py ## @@ -601,6 +602,50 @@ def test_basic_array_type_info(self):

[GitHub] [flink] gaoyunhaii closed pull request #13973: [FLINK-19850] Add e2e tests for the new File Sink in the streaming mode

2020-11-08 Thread GitBox
gaoyunhaii closed pull request #13973: URL: https://github.com/apache/flink/pull/13973 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

[jira] [Assigned] (FLINK-18789) Use TableEnvironment#executeSql to execute insert statement in sql client

2020-11-08 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-18789: -- Assignee: godfrey he > Use TableEnvironment#executeSql to execute insert statement in sql

[jira] [Created] (FLINK-20053) Add document for file compaction

2020-11-08 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-20053: Summary: Add document for file compaction Key: FLINK-20053 URL: https://issues.apache.org/jira/browse/FLINK-20053 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #13986: [FLINK-20016][python] Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13986: URL: https://github.com/apache/flink/pull/13986#issuecomment-723648682 ## CI report: * 6afd298cd5356502822e36537d7a1c8ba67052b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13606: [FLINK-19554][e2e] Implement a unified testing framework for connectors

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13606: URL: https://github.com/apache/flink/pull/13606#issuecomment-707535989 ## CI report: * 8063b2a34512c8d8e99cdba06a1872d9786832bb Azure:

[GitHub] [flink] carp84 commented on pull request #13977: [Mirror] [FLINK-19238] Sanity check for RocksDB arena block size

2020-11-08 Thread GitBox
carp84 commented on pull request #13977: URL: https://github.com/apache/flink/pull/13977#issuecomment-723715835 The latest Azure build failed due to FLINK-20052, and comparing the two builds we could make sure the failure is irrelative to changes here, thus I will merge the commits soon.

[GitHub] [flink] flinkbot edited a comment on pull request #13989: [FLINK-19448][connector/common] Synchronize fetchers.isEmpty status to SourceReaderBase using elementsQueue.notifyAvailable()

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13989: URL: https://github.com/apache/flink/pull/13989#issuecomment-723709607 ## CI report: * 5da43fd50d04596217e89f547f97dbb4711ca7ee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13986: [FLINK-20016][python] Support TimestampAssigner and WatermarkGenerator for Python DataStream API.

2020-11-08 Thread GitBox
flinkbot edited a comment on pull request #13986: URL: https://github.com/apache/flink/pull/13986#issuecomment-723648682 ## CI report: * 6afd298cd5356502822e36537d7a1c8ba67052b5 Azure:

[jira] [Created] (FLINK-20052) kafka/gelly pre-commit test failed due to process hang

2020-11-08 Thread Yu Li (Jira)
Yu Li created FLINK-20052: - Summary: kafka/gelly pre-commit test failed due to process hang Key: FLINK-20052 URL: https://issues.apache.org/jira/browse/FLINK-20052 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20044) Disposal of RocksDB could last forever

2020-11-08 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228315#comment-17228315 ] Jiayi Liao commented on FLINK-20044: [~sewen] I guess this is not a cancellation situation here

[GitHub] [flink] klion26 commented on pull request #13664: [FLINK-19673] Translate "Standalone Cluster" page into Chinese

2020-11-08 Thread GitBox
klion26 commented on pull request #13664: URL: https://github.com/apache/flink/pull/13664#issuecomment-723712163 Will merge this if no objection occurred in the next few days. This is an automated message from the Apache Git

[GitHub] [flink-web] klion26 commented on pull request #388: Add congxian qiu to community page

2020-11-08 Thread GitBox
klion26 commented on pull request #388: URL: https://github.com/apache/flink-web/pull/388#issuecomment-723712223 @rmetzger thanks for the review, will merge this and regenerate the content. This is an automated message from

[GitHub] [flink] klion26 commented on pull request #13750: [FLINK-19394][docs-zh] Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

2020-11-08 Thread GitBox
klion26 commented on pull request #13750: URL: https://github.com/apache/flink/pull/13750#issuecomment-723711963 @dianfu thanks for the review, will merge this one soon. This is an automated message from the Apache Git

[jira] [Commented] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

2020-11-08 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228314#comment-17228314 ] zhisheng commented on FLINK-19973: -- [~kkl0u] closed > 【Flink-Deployment】YARN CLI Parameter doesn't

[jira] [Closed] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

2020-11-08 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhisheng closed FLINK-19973. Resolution: Not A Bug > 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: >

[GitHub] [flink] flinkbot commented on pull request #13989: [FLINK-19448][connector/common] Synchronize fetchers.isEmpty status to SourceReaderBase using elementsQueue.notifyAvailable()

2020-11-08 Thread GitBox
flinkbot commented on pull request #13989: URL: https://github.com/apache/flink/pull/13989#issuecomment-723709607 ## CI report: * 5da43fd50d04596217e89f547f97dbb4711ca7ee UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-20051) SourceReaderTestBase.testAddSplitToExistingFetcher failed with NullPointerException

2020-11-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20051: Labels: test-stability (was: ) > SourceReaderTestBase.testAddSplitToExistingFetcher failed with >

[jira] [Created] (FLINK-20051) SourceReaderTestBase.testAddSplitToExistingFetcher failed with NullPointerException

2020-11-08 Thread Dian Fu (Jira)
Dian Fu created FLINK-20051: --- Summary: SourceReaderTestBase.testAddSplitToExistingFetcher failed with NullPointerException Key: FLINK-20051 URL: https://issues.apache.org/jira/browse/FLINK-20051 Project:

[jira] [Created] (FLINK-20050) SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException

2020-11-08 Thread Dian Fu (Jira)
Dian Fu created FLINK-20050: --- Summary: SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException Key: FLINK-20050 URL: https://issues.apache.org/jira/browse/FLINK-20050 Project:

[jira] [Updated] (FLINK-20050) SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException

2020-11-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20050: Labels: test-stability (was: ) > SourceCoordinatorProviderTest.testCheckpointAndReset failed with >

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

2020-11-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228309#comment-17228309 ] Dian Fu commented on FLINK-19863: -

[jira] [Commented] (FLINK-19882) E2E: SQLClientHBaseITCase crash

2020-11-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228307#comment-17228307 ] Dian Fu commented on FLINK-19882: -

[jira] [Commented] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs

2020-11-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228306#comment-17228306 ] Dian Fu commented on FLINK-20011: -

[jira] [Updated] (FLINK-20011) PageRankITCase.testPrintWithRMatGraph hangs

2020-11-08 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20011: Priority: Critical (was: Major) > PageRankITCase.testPrintWithRMatGraph hangs >

  1   2   3   >