[GitHub] [flink] wuchong commented on pull request #12090: [FLINK-17622][connectors / jdbc] Remove useless switch for decimal in PostgresCatalog

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

[GitHub] [flink] wuchong merged pull request #12090: [FLINK-17622][connectors / jdbc] Remove useless switch for decimal in PostgresCatalog

2020-05-20 Thread GitBox
wuchong merged pull request #12090: URL: https://github.com/apache/flink/pull/12090 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-17828) AggregateReduceGroupingITCase fails on azure

2020-05-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112129#comment-17112129 ] Chesnay Schepler commented on FLINK-17828: -- Am I blind or is there no visible difference

[jira] [Updated] (FLINK-17842) Performance regression on 19.05.2020

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

[jira] [Closed] (FLINK-17780) Add task name to log statements of ChannelStateWriter

2020-05-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17780. -- Resolution: Fixed merged commit e7f7c5e into apache:master and as 90ece8c119 to release-1.11

[GitHub] [flink] pnowojski commented on a change in pull request #12243: [FLINK-17805][networ] Fix ArrayIndexOutOfBound for rotated input gate indexes

2020-05-20 Thread GitBox
pnowojski commented on a change in pull request #12243: URL: https://github.com/apache/flink/pull/12243#discussion_r428017856 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/InputProcessorUtilTest.java ## @@ -58,4 +79,57 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #12179: [FLINK-16144] get client.timeout for the client, with a fallback to the akka.client…

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

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

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

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

2020-05-20 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-17844: - Summary: Activate japicmp-maven-plugin checks for @PublicEvolving between bug fix releases (x.y.u -> x.y.v) Key: FLINK-17844 URL:

[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: * 0e1d9cde275d0717fb9b32f6d1a3aed600c33166 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12265: [FLINK-16922][table-common] Fix DecimalData.toUnscaledBytes() should be consistent with BigDecimla.unscaledValue.toByteArray()

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

[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:

[jira] [Commented] (FLINK-15534) YARNSessionCapacitySchedulerITCase#perJobYarnClusterWithParallelism failed due to NPE

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

[jira] [Closed] (FLINK-16922) DecimalData.toUnscaledBytes should be consistent with BigDecimla.unscaledValue.toByteArray

2020-05-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16922. --- Resolution: Fixed master (1.12.0): 34671add8a435ee4431f4c1c4da37a8e078b7a8a 1.11.0:

[jira] [Closed] (FLINK-17356) Pass table's primary key to catalog table in PostgresCatalog

2020-05-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17356. --- Fix Version/s: 1.11.0 Resolution: Fixed Add IT cases for inserting group by query into posgres

[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] [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 >

[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

[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] [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] [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] [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 >

[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

[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

[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

[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-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:

[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

[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] [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

[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-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] [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: --- 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] [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

[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

[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

[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:

[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] [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] 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] [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] 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 #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:

[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 #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 #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] [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-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] [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] [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

[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-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:

[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]

[jira] [Commented] (FLINK-17828) AggregateReduceGroupingITCase fails on azure

2020-05-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112123#comment-17112123 ] Jark Wu commented on FLINK-17828: - cc [~godfreyhe]. I can' reproduce this error in my local. >

[GitHub] [flink] flinkbot edited a comment on pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

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

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

2020-05-20 Thread GitBox
tzulitai commented on a change in pull request #12263: URL: https://github.com/apache/flink/pull/12263#discussion_r427970574 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java ## @@ -367,21 +367,21 @@ public int getVersion()

[jira] [Closed] (FLINK-15947) Finish moving scala expression DSL to flink-table-api-scala

2020-05-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-15947. Fix Version/s: (was: 1.12.0) 1.11.0 Release Note: Due to

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

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

[GitHub] [flink] flinkbot edited a comment on pull request #12254: [FLINK-17802][kafka] Set offset commit only if group id is configured for new Kafka Table source

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

[GitHub] [flink] flinkbot edited a comment on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

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

[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: * f33808f833da63c5563b48688053d49dedc46538 Azure:

[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 * 17ee20d6efb84cca02a24b032c9504dcf03ff8a1 Azure:

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #12243: [FLINK-17805][networ] Fix ArrayIndexOutOfBound for rotated input gate indexes

2020-05-20 Thread GitBox
Jiayi-Liao commented on a change in pull request #12243: URL: https://github.com/apache/flink/pull/12243#discussion_r428063945 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputProcessorUtil.java ## @@ -79,11 +80,26 @@ public static

[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] 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:

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

2020-05-20 Thread GitBox
fpompermaier commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427972573 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31

[GitHub] [flink] rkhachatryan commented on a change in pull request #12244: [FLINK-17258][network] Fix couple of ITCases that were failing with enabled unaligned checkpoints

2020-05-20 Thread GitBox
rkhachatryan commented on a change in pull request #12244: URL: https://github.com/apache/flink/pull/12244#discussion_r428043879 ## File path: flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java ## @@ -300,7 +300,8 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #12179: [FLINK-16144] get client.timeout for the client, with a fallback to the akka.client…

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

[GitHub] [flink] flinkbot edited a comment on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

2020-05-20 Thread GitBox
flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 2e339ca93fcf4461ddb3502b49ab34083fc96cf6 UNKNOWN * 1310d3ed1bad9e2356a320128cac125e930831dc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12243: [FLINK-17805][networ] Fix ArrayIndexOutOfBound for rotated input gate indexes

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

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Reset SafetyNetCloseableRegistry#REAPER_THREAD if it fails to start

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

[GitHub] [flink] wuchong closed pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

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

[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] 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-631460366 Thanks @tzulitai. I addressed the remaining comments and will merge this once the build gives green light.

[GitHub] [flink] pnowojski merged pull request #12205: [FLINK-17780][checkpointing] Add task name to log statements of ChannelStateWriter.

2020-05-20 Thread GitBox
pnowojski merged pull request #12205: URL: https://github.com/apache/flink/pull/12205 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] tillrohrmann commented on a change in pull request #12264: [FLINK-17558][netty] Release partitions asynchronously

2020-05-20 Thread GitBox
tillrohrmann commented on a change in pull request #12264: URL: https://github.com/apache/flink/pull/12264#discussion_r428047035 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorPartitionLifecycleTest.java ## @@ -280,7 +273,65 @@

[jira] [Updated] (FLINK-17356) Pass table's primary key to catalog table in PostgresCatalog

2020-05-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17356: Description: At the moment the PostgresCatalog does not create field constraints (at the moment there's

[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

[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] 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 #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:

[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:

[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.

  1   2   3   4   5   >