[jira] [Commented] (FLINK-17820) Memory threshold is ignored for channel state

2020-05-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112643#comment-17112643 ] Stephan Ewen commented on FLINK-17820: -- I would simply avoid flushing here. It makes no difference,

[GitHub] [flink] StephanEwen commented on pull request #12258: [FLINK-17820][task][checkpointing] Don't flush channel state to disk explicitly

2020-05-20 Thread GitBox
StephanEwen commented on pull request #12258: URL: https://github.com/apache/flink/pull/12258#issuecomment-631766209 I left some comments on the jira issue. This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-17852) FlinkSQL support WITH clause in query statement

2020-05-20 Thread sam lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112588#comment-17112588 ] sam lin commented on FLINK-17852: - [~f.pompermaier]: Nope, this is for SELECT statement, the issue you

[jira] [Updated] (FLINK-17852) FlinkSQL support WITH clause in query statement

2020-05-20 Thread sam lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sam lin updated FLINK-17852: Description: Many modern SQL language support WITH clause in query statement.  e.g. ``` WITH myName AS

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #115: [FLINK-17518] [e2e] Add remote module E2E

2020-05-20 Thread GitBox
igalshilman commented on a change in pull request #115: URL: https://github.com/apache/flink-statefun/pull/115#discussion_r428272246 ## File path: statefun-e2e-tests/pom.xml ## @@ -63,11 +63,26 @@ under the License. 1.6.0

[jira] [Created] (FLINK-17853) JobGraph is not getting deleted after Job cancelation

2020-05-20 Thread Fritz Budiyanto (Jira)
Fritz Budiyanto created FLINK-17853: --- Summary: JobGraph is not getting deleted after Job cancelation Key: FLINK-17853 URL: https://issues.apache.org/jira/browse/FLINK-17853 Project: Flink

[jira] [Updated] (FLINK-16998) Add a changeflag to Row type

2020-05-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-16998: - Fix Version/s: 1.11.0 > Add a changeflag to Row type > > >

[jira] [Commented] (FLINK-16998) Add a changeflag to Row type

2020-05-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112566#comment-17112566 ] Timo Walther commented on FLINK-16998: -- Backwards compatibility added. Fixed in 1.11.0:

[GitHub] [flink] twalthr commented on pull request #12263: [FLINK-16998][core] Support backwards compatibility for upgraded RowSerializer

2020-05-20 Thread GitBox
twalthr commented on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631688716 Merged. This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] twalthr closed pull request #12263: [FLINK-16998][core] Support backwards compatibility for upgraded RowSerializer

2020-05-20 Thread GitBox
twalthr closed pull request #12263: URL: https://github.com/apache/flink/pull/12263 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

[jira] [Commented] (FLINK-17852) FlinkSQL support WITH clause in query statement

2020-05-20 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112558#comment-17112558 ] Flavio Pompermaier commented on FLINK-17852: Can this be related to FLINK-17361 ? >

[jira] [Created] (FLINK-17852) FlinkSQL support WITH clause in query statement

2020-05-20 Thread sam lin (Jira)
sam lin created FLINK-17852: --- Summary: FlinkSQL support WITH clause in query statement Key: FLINK-17852 URL: https://issues.apache.org/jira/browse/FLINK-17852 Project: Flink Issue Type: New

[GitHub] [flink-statefun] sjwiesman closed pull request #106: [FLINK-16985] Stateful Functions Examples have their specific job names

2020-05-20 Thread GitBox
sjwiesman closed pull request #106: URL: https://github.com/apache/flink-statefun/pull/106 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

[jira] [Resolved] (FLINK-16985) Specify job names for Stateful Functions examples

2020-05-20 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-16985. -- Fix Version/s: (was: statefun-2.0.1) statefun-2.1.0 Resolution:

[GitHub] [flink-statefun] sjwiesman commented on pull request #106: [FLINK-16985] Stateful Functions Examples have their specific job names

2020-05-20 Thread GitBox
sjwiesman commented on pull request #106: URL: https://github.com/apache/flink-statefun/pull/106#issuecomment-631677707 Merging . . . This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-17850) PostgresCatalogITCase . testGroupByInsert() fails on CI

2020-05-20 Thread Flavio Pompermaier (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112551#comment-17112551 ] Flavio Pompermaier commented on FLINK-17850: I'll try to look into it. This test was

[GitHub] [flink] flinkbot edited a comment on pull request #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #8885: URL: https://github.com/apache/flink/pull/8885#issuecomment-513164005 ## CI report: * 19a0f944f4c8b2177afe5b41df587b89daa0d008 Travis: [FAILURE](https://travis-ci.com/flink-ci/flink/builds/119766396) Bot commands

[GitHub] [flink-statefun] igalshilman commented on pull request #106: [FLINK-16985] Stateful Functions Examples have their specific job names

2020-05-20 Thread GitBox
igalshilman commented on pull request #106: URL: https://github.com/apache/flink-statefun/pull/106#issuecomment-631675361 Hi @abc863377, No worries, thanks a lot for your first contribution to this project! This is an

[GitHub] [flink] corydolphin commented on pull request #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-20 Thread GitBox
corydolphin commented on pull request #8885: URL: https://github.com/apache/flink/pull/8885#issuecomment-631671226 @TengHu have you been successfully using this change in production? We've run into a similar challenge with window alignment, would love to see this change merged and hear

[GitHub] [flink-statefun] igalshilman commented on pull request #114: [FLINK-17611] Add unix domain sockets to remote functions

2020-05-20 Thread GitBox
igalshilman commented on pull request #114: URL: https://github.com/apache/flink-statefun/pull/114#issuecomment-631670579 Hi @slinkydeveloper, I've omitted that commit since it included additional changes beside the test. (Docker files, print statements, etc') I've took the test code

[GitHub] [flink-statefun] abc863377 commented on pull request #106: [FLINK-16985] Stateful Functions Examples have their specific job names

2020-05-20 Thread GitBox
abc863377 commented on pull request #106: URL: https://github.com/apache/flink-statefun/pull/106#issuecomment-631670413 Hi, @igalshilman , Sorry. I am a Git beginner. Now I removed the old commit. and updated the new statefun.flink-job-name configuration to the distribution

[jira] [Updated] (FLINK-15330) HadoopS3RecoverableWriterITCase.testCallingDeleteObjectTwiceDoesNotThroughException() fails with AssertionError

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

[jira] [Updated] (FLINK-15330) HadoopS3RecoverableWriterITCase.testCallingDeleteObjectTwiceDoesNotThroughException() fails with AssertionError

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-15330: --- Fix Version/s: 1.11.0 >

[jira] [Commented] (FLINK-15330) HadoopS3RecoverableWriterITCase.testCallingDeleteObjectTwiceDoesNotThroughException() fails with AssertionError

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112547#comment-17112547 ] Robert Metzger commented on FLINK-15330: {code} 2020-05-20T16:21:33.6126688Z [ERROR]

[GitHub] [flink] flinkbot edited a comment on pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12269: URL: https://github.com/apache/flink/pull/12269#issuecomment-631541996 ## CI report: * 24c44fd00652a6b5859075b3afea1e4e9ca98445 Azure:

[jira] [Commented] (FLINK-17850) PostgresCatalogITCase . testGroupByInsert() fails on CI

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

[jira] [Created] (FLINK-17851) FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord NoSuchElement

2020-05-20 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17851: -- Summary: FlinkKafkaProducerITCase.testResumeTransaction:108->assertRecord NoSuchElement Key: FLINK-17851 URL: https://issues.apache.org/jira/browse/FLINK-17851

[jira] [Commented] (FLINK-17850) PostgresCatalogITCase . testGroupByInsert() fails on CI

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

[GitHub] [flink] fpompermaier commented on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

2020-05-20 Thread GitBox
fpompermaier commented on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-631659010 @wuchong do you have an idea of why the testGroupByInsert is failing? This is an automated message from

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-05-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17444: --- Affects Version/s: (was: 1.10.0) > StreamingFileSink Azure HadoopRecoverableWriter

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-05-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17444: --- Fix Version/s: (was: 1.11.0) > StreamingFileSink Azure HadoopRecoverableWriter class

[jira] [Comment Edited] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-05-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112523#comment-17112523 ] Kostas Kloudas edited comment on FLINK-17444 at 5/20/20, 6:39 PM: -- So

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-05-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17444: --- Priority: Major (was: Critical) > StreamingFileSink Azure HadoopRecoverableWriter class

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-05-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17444: --- Priority: Minor (was: Major) > StreamingFileSink Azure HadoopRecoverableWriter class

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-05-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112523#comment-17112523 ] Kostas Kloudas commented on FLINK-17444: So from the discussion here, I think that this is not a

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

2020-05-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17444: --- Issue Type: New Feature (was: Bug) > StreamingFileSink Azure HadoopRecoverableWriter class

[jira] [Updated] (FLINK-17824) "Resuming Savepoint" e2e stalls indefinitely

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17824: --- Affects Version/s: 1.12.0 > "Resuming Savepoint" e2e stalls indefinitely >

[GitHub] [flink] rmetzger commented on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

2020-05-20 Thread GitBox
rmetzger commented on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-631645770 https://issues.apache.org/jira/browse/FLINK-17850 This is an automated message from the Apache Git Service. To

[GitHub] [flink] rmetzger commented on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

2020-05-20 Thread GitBox
rmetzger commented on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-631643954 I believe this test is permanently failing on master:

[jira] [Closed] (FLINK-16795) End to end tests timeout on Azure

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-16795. -- Resolution: Fixed > End to end tests timeout on Azure > - > >

[jira] [Commented] (FLINK-16795) End to end tests timeout on Azure

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112505#comment-17112505 ] Robert Metzger commented on FLINK-16795: The reason for the slow Kerberized YARN test seems that

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112499#comment-17112499 ] Robert Metzger commented on FLINK-16636: Thanks a lot for looking into this so detailed. How

[jira] [Commented] (FLINK-17850) PostgresCatalogITCase . testGroupByInsert() fails on CI

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112495#comment-17112495 ] Robert Metzger commented on FLINK-17850: also on master:

[jira] [Updated] (FLINK-17850) PostgresCatalogITCase . testGroupByInsert() fails on CI

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17850: --- Labels: test-stability (was: ) > PostgresCatalogITCase . testGroupByInsert() fails on CI >

[jira] [Updated] (FLINK-17850) PostgresCatalogITCase . testGroupByInsert() fails on CI

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17850: --- Fix Version/s: 1.12.0 > PostgresCatalogITCase . testGroupByInsert() fails on CI >

[jira] [Commented] (FLINK-17721) AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry fails with AssertionError

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

[jira] [Closed] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17730. -- Resolution: Fixed >

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112491#comment-17112491 ] Robert Metzger commented on FLINK-17730: Merged to "release-1.11" in

[jira] [Updated] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-17730: --- Fix Version/s: 1.11.0 >

[GitHub] [flink] flinkbot edited a comment on pull request #12270: [FLINK-17822][MemMan] Use private Reference.tryHandlePending|waitForReferenceProcessing to trigger GC cleaner

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12270: URL: https://github.com/apache/flink/pull/12270#issuecomment-631585690 ## CI report: * 5472f93e8f79940941b5ba6637be6810d6b8b46a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12244: [FLINK-17258][network] Fix couple of ITCases that were failing with enabled unaligned checkpoints

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12244: URL: https://github.com/apache/flink/pull/12244#issuecomment-630723509 ## CI report: * d0d2042ea348654430863ccb51084c30714d8a47 Azure:

[jira] [Assigned] (FLINK-17844) Activate japicmp-maven-plugin checks for @PublicEvolving between bug fix releases (x.y.u -> x.y.v)

2020-05-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-17844: Assignee: Chesnay Schepler > Activate japicmp-maven-plugin checks for

[GitHub] [flink] pnowojski commented on a change in pull request #12261: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

2020-05-20 Thread GitBox
pnowojski commented on a change in pull request #12261: URL: https://github.com/apache/flink/pull/12261#discussion_r428179383 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -181,6 +181,14 @@ void

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

2020-05-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112454#comment-17112454 ] Stephan Ewen commented on FLINK-16572: -- One more instance:

[jira] [Created] (FLINK-17850) PostgresCatalogITCase . testGroupByInsert() fails on CI

2020-05-20 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-17850: Summary: PostgresCatalogITCase . testGroupByInsert() fails on CI Key: FLINK-17850 URL: https://issues.apache.org/jira/browse/FLINK-17850 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824 ## CI report: * 69bce2717b0279a894aa66d15cd4b9b72cd5a474 UNKNOWN * 4cf97b2be4447c2d2f94259ad559fefb79a0a727 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12270: [FLINK-17822][MemMan] Use private Reference.tryHandlePending|waitForReferenceProcessing to trigger GC cleaner

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12270: URL: https://github.com/apache/flink/pull/12270#issuecomment-631585690 ## CI report: * 5472f93e8f79940941b5ba6637be6810d6b8b46a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12244: [FLINK-17258][network] Fix couple of ITCases that were failing with enabled unaligned checkpoints

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12244: URL: https://github.com/apache/flink/pull/12244#issuecomment-630723509 ## CI report: * 7fa2068a283b9471384248c1bf301e3d406b5f48 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12268: URL: https://github.com/apache/flink/pull/12268#issuecomment-631512695 ## CI report: * 4ed6888375869e654816264124703e72439c6148 Azure:

[jira] [Created] (FLINK-17849) YARNHighAvailabilityITCase hangs in Azure Pipelines CI

2020-05-20 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-17849: Summary: YARNHighAvailabilityITCase hangs in Azure Pipelines CI Key: FLINK-17849 URL: https://issues.apache.org/jira/browse/FLINK-17849 Project: Flink Issue

[jira] [Commented] (FLINK-17848) Allow scala datastream api to create named sources

2020-05-20 Thread Zack Loebel-Begelman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112437#comment-17112437 ] Zack Loebel-Begelman commented on FLINK-17848: -- I'm happy to cut a PR, ideally backporting

[jira] [Created] (FLINK-17848) Allow scala datastream api to create named sources

2020-05-20 Thread Zack Loebel-Begelman (Jira)
Zack Loebel-Begelman created FLINK-17848: Summary: Allow scala datastream api to create named sources Key: FLINK-17848 URL: https://issues.apache.org/jira/browse/FLINK-17848 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #12270: [FLINK-17822][MemMan] Use private Reference.tryHandlePending|waitForReferenceProcessing to trigger GC cleaner

2020-05-20 Thread GitBox
flinkbot commented on pull request #12270: URL: https://github.com/apache/flink/pull/12270#issuecomment-631585690 ## CI report: * 5472f93e8f79940941b5ba6637be6810d6b8b46a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zhijiangW commented on a change in pull request #12261: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

2020-05-20 Thread GitBox
zhijiangW commented on a change in pull request #12261: URL: https://github.com/apache/flink/pull/12261#discussion_r428139107 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -181,6 +181,14 @@ void

[GitHub] [flink] flinkbot commented on pull request #12270: [FLINK-17822][MemMan] Use private Reference.tryHandlePending|waitForReferenceProcessing to trigger GC cleaner

2020-05-20 Thread GitBox
flinkbot commented on pull request #12270: URL: https://github.com/apache/flink/pull/12270#issuecomment-631574892 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12264: URL: https://github.com/apache/flink/pull/12264#issuecomment-631349883 ## CI report: * 19c5f57b94cc56b70002031618c32d9e6f68effb UNKNOWN * bb313e40f5a72dbf20cd0a8b48267063fd4f00af UNKNOWN *

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

2020-05-20 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112398#comment-17112398 ] Zhijiang commented on FLINK-17826: -- If it is regarded as a bug fix, then it fits the rule to make it in

[GitHub] [flink] azagrebin opened a new pull request #12270: [FLINK-17822][MemMan] Use private Reference.tryHandlePending|waitForReferenceProcessing to trigger GC cleaner

2020-05-20 Thread GitBox
azagrebin opened a new pull request #12270: URL: https://github.com/apache/flink/pull/12270 ## What is the purpose of the change #11109 did not export `jdk.internal.misc` package used by reflection for GC cleaners of managed memory. Our PR CI does not run Java 11 tests atm. The

[jira] [Updated] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

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

[jira] [Updated] (FLINK-17847) ArrayIndexOutOfBoundsException happens when codegen StreamExec operator

2020-05-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17847: --- Description: user case: {code:java} //source table create table json_table( w_es BIGINT, w_type

[jira] [Updated] (FLINK-17847) ArrayIndexOutOfBoundsException happens when codegen StreamExec operator

2020-05-20 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-17847: --- Summary: ArrayIndexOutOfBoundsException happens when codegen StreamExec operator (was:

[jira] [Commented] (FLINK-17817) CollectResultFetcher fails with EOFException in AggregateReduceGroupingITCase

2020-05-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112389#comment-17112389 ] Dawid Wysakowicz commented on FLINK-17817: -- another instance:

[jira] [Created] (FLINK-17847) ArrayIndexOutOfBoundsException happened in when codegen StreamExec operator

2020-05-20 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-17847: -- Summary: ArrayIndexOutOfBoundsException happened in when codegen StreamExec operator Key: FLINK-17847 URL: https://issues.apache.org/jira/browse/FLINK-17847 Project:

[GitHub] [flink-statefun] abc863377 commented on pull request #106: [FLINK-16985] Stateful Functions Examples have their specific job names

2020-05-20 Thread GitBox
abc863377 commented on pull request #106: URL: https://github.com/apache/flink-statefun/pull/106#issuecomment-631562660 Hi @igalshilman , Thanks for the suggestion. I'll follow your advice and keep Dockerfile simple.

[GitHub] [flink] flinkbot edited a comment on pull request #12266: [FLINK-17843][table-api] Check the RowKind when converting a Row from object to an expression

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12266: URL: https://github.com/apache/flink/pull/12266#issuecomment-631427812 ## CI report: * d3268f7bfdf1dfa2c19dc2b38c80a4ee84a5f26c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12244: [FLINK-17258][network] Fix couple of ITCases that were failing with enabled unaligned checkpoints

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12244: URL: https://github.com/apache/flink/pull/12244#issuecomment-630723509 ## CI report: * 3dcc9233af810b8be408665c0083fab404a2dea5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12269: URL: https://github.com/apache/flink/pull/12269#issuecomment-631541996 ## CI report: * 24c44fd00652a6b5859075b3afea1e4e9ca98445 Azure:

[jira] [Comment Edited] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

2020-05-20 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112350#comment-17112350 ] Andrey Zagrebin edited comment on FLINK-17822 at 5/20/20, 3:23 PM: ---

[jira] [Commented] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

2020-05-20 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112350#comment-17112350 ] Andrey Zagrebin commented on FLINK-17822: - FLINK-15758 did not export jdk.internal.misc package

[GitHub] [flink] dawidwys commented on pull request #12189: [FLINK-17376][API/DataStream]Deprecated methods and related code updated

2020-05-20 Thread GitBox
dawidwys commented on pull request #12189: URL: https://github.com/apache/flink/pull/12189#issuecomment-631543033 Hey @mghildiy do you still want to work on this issue? This issue actually blocks the 1.11 release. I see you haven't addressed @aljoscha's comment yet. It's fine, but if you

[GitHub] [flink] flinkbot commented on pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-20 Thread GitBox
flinkbot commented on pull request #12269: URL: https://github.com/apache/flink/pull/12269#issuecomment-631541996 ## CI report: * 24c44fd00652a6b5859075b3afea1e4e9ca98445 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12267: [FLINK-17842][network] Fix performance regression in SpanningWrapper#clear

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12267: URL: https://github.com/apache/flink/pull/12267#issuecomment-631489829 ## CI report: * 0afb379748084b4aef0fdf51c57e24044dfc31df Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12244: [FLINK-17258][network] Fix couple of ITCases that were failing with enabled unaligned checkpoints

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12244: URL: https://github.com/apache/flink/pull/12244#issuecomment-630723509 ## CI report: * 3dcc9233af810b8be408665c0083fab404a2dea5 Azure:

[jira] [Closed] (FLINK-17675) Resolve CVE-2019-11358 from jquery

2020-05-20 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17675. -- Fix Version/s: 1.12.0 1.11.0 Resolution: Fixed Merged to master /

[GitHub] [flink] rmetzger closed pull request #12229: [FLINK-17675][docs] Update jquery dependency to 3.5.1

2020-05-20 Thread GitBox
rmetzger closed pull request #12229: URL: https://github.com/apache/flink/pull/12229 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] [Closed] (FLINK-17846) flink-walkthrough-table-scala failed on azure

2020-05-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-17846. Resolution: Fixed Fixed in: master: 400df32ab2a18a52c8511a901a4dd22cb6827700 1.11:

[GitHub] [flink] flinkbot edited a comment on pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12264: URL: https://github.com/apache/flink/pull/12264#issuecomment-631349883 ## CI report: * 19c5f57b94cc56b70002031618c32d9e6f68effb UNKNOWN * 9dbaf3094c0942b96a01060aba9d4ffbad9d1857 Azure:

[GitHub] [flink] StephanEwen commented on pull request #12234: [FLINK-16986][coordination] Provide exactly-once guaranteed around checkpoints and operator event sending

2020-05-20 Thread GitBox
StephanEwen commented on pull request #12234: URL: https://github.com/apache/flink/pull/12234#issuecomment-631529855 Kindly asking that @flinkbot run azure This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #12268: [FLINK-17375] Refactor travis_watchdog.sh into separate ci and azure scripts.

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12268: URL: https://github.com/apache/flink/pull/12268#issuecomment-631512695 ## CI report: * 4ed6888375869e654816264124703e72439c6148 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12263: [FLINK-16998][core] Support backwards compatibility for upgraded RowSerializer

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631274882 ## CI report: * 320f0a551c635e98c4aff4af6d853d3cf2681fee Azure:

[jira] [Closed] (FLINK-14894) HybridOffHeapUnsafeMemorySegmentTest#testByteBufferWrap failed on Travis

2020-05-20 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-14894. --- Resolution: Fixed should be fixed by FLINK-15758 >

[jira] [Updated] (FLINK-17846) flink-walkthrough-table-scala failed on azure

2020-05-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17846: - Priority: Blocker (was: Major) > flink-walkthrough-table-scala failed on azure >

[jira] [Created] (FLINK-17846) flink-walkthrough-table-scala failed on azure

2020-05-20 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-17846: Summary: flink-walkthrough-table-scala failed on azure Key: FLINK-17846 URL: https://issues.apache.org/jira/browse/FLINK-17846 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-20 Thread GitBox
flinkbot commented on pull request #12269: URL: https://github.com/apache/flink/pull/12269#issuecomment-631524496 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-17351) CheckpointCoordinator and CheckpointFailureManager ignores checkpoint timeouts

2020-05-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17351: --- Labels: pull-request-available (was: ) > CheckpointCoordinator and

[jira] [Commented] (FLINK-17817) CollectResultFetcher fails with EOFException in AggregateReduceGroupingITCase

2020-05-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112304#comment-17112304 ] Dawid Wysakowicz commented on FLINK-17817: -- I will assign you [~TsReaper] the issue, as I think

[jira] [Assigned] (FLINK-17817) CollectResultFetcher fails with EOFException in AggregateReduceGroupingITCase

2020-05-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-17817: Assignee: Caizhi Weng > CollectResultFetcher fails with EOFException in

[GitHub] [flink] curcur opened a new pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-20 Thread GitBox
curcur opened a new pull request #12269: URL: https://github.com/apache/flink/pull/12269 **(The sections below can be removed for hotfixes of typos)** --> ## What is the purpose of the change Before this PR, `CHECKPOINT_EXPIRED` is not counted in

[jira] [Created] (FLINK-17845) Can't remove a table connector property with ALTER TABLE

2020-05-20 Thread Fabian Hueske (Jira)
Fabian Hueske created FLINK-17845: - Summary: Can't remove a table connector property with ALTER TABLE Key: FLINK-17845 URL: https://issues.apache.org/jira/browse/FLINK-17845 Project: Flink

[jira] [Closed] (FLINK-17762) Postgres Catalog should pass table's primary key to catalogTable

2020-05-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17762. --- Fix Version/s: 1.11.0 Resolution: Fixed > Postgres Catalog should pass table's primary key to

<    1   2   3   4   5   >