[jira] [Commented] (FLINK-14592) FlinkKafkaInternalProducerITCase fails with BindException

[ https://issues.apache.org/jira/browse/FLINK-14592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024924#comment-17024924 ] Yu Li commented on FLINK-14592: --- Another instance: https://api.travis-ci.org/v3/job/642477

[jira] [Commented] (FLINK-14332) add flink-metrics-signalfx to flink-metrics

[ https://issues.apache.org/jira/browse/FLINK-14332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024922#comment-17024922 ] Luke Sun commented on FLINK-14332: -- # current metric full name is from MetricGroup getS

[jira] [Commented] (FLINK-15694) Remove HDFS Section of Configuration Page

[ https://issues.apache.org/jira/browse/FLINK-15694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024920#comment-17024920 ] Bastien DINE commented on FLINK-15694: -- [~sewen] Hello Stephan, as a daily user of

[GitHub] [flink] flinkbot commented on issue #10953: [FLINK-15143][doc] Create documents for FLIP-49.

flinkbot commented on issue #10953: [FLINK-15143][doc] Create documents for FLIP-49. URL: https://github.com/apache/flink/pull/10953#issuecomment-579118220 ## CI report: * 03569ac61c7b6cfd65f0afc788fd494d470f5ad2 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot commented on issue #10953: [FLINK-15143][doc] Create documents for FLIP-49.

flinkbot commented on issue #10953: [FLINK-15143][doc] Create documents for FLIP-49. URL: https://github.com/apache/flink/pull/10953#issuecomment-579114007 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request

[GitHub] [flink] xintongsong opened a new pull request #10953: [FLINK-15143][doc] Create documents for FLIP-49.

xintongsong opened a new pull request #10953: [FLINK-15143][doc] Create documents for FLIP-49. URL: https://github.com/apache/flink/pull/10953 ## What is the purpose of the change This PR adds documents for FLIP-49. ## Brief change log - Add "Internals -> Task Executor

[jira] [Updated] (FLINK-15143) Create document for FLIP-49 TM memory model and configuration guide

[ https://issues.apache.org/jira/browse/FLINK-15143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15143: --- Labels: pull-request-available (was: ) > Create document for FLIP-49 TM memory model and co

[jira] [Updated] (FLINK-15777) Truncate not working with plugins (as expected)

[ https://issues.apache.org/jira/browse/FLINK-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15777: - Fix Version/s: 1.10.0 > Truncate not working with plugins (as expected) > --

[jira] [Commented] (FLINK-15773) ClosureCleaner fails with joda DateTimeZone

[ https://issues.apache.org/jira/browse/FLINK-15773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024871#comment-17024871 ] Jozef Vilcek commented on FLINK-15773: -- [~chesnay], actually it does matter, becaus

[jira] [Commented] (FLINK-15393) Change 'ReturnExpiredIfNotCleanedUp' to 'NeverReturnExpired' in JoinRecordStateViews#createTtlConfig

[ https://issues.apache.org/jira/browse/FLINK-15393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024734#comment-17024734 ] hailong wang commented on FLINK-15393: -- Hi [~Fred Shi], you should set TableConfig#

[jira] [Assigned] (FLINK-15685) org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs

[ https://issues.apache.org/jira/browse/FLINK-15685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-15685: Assignee: Chesnay Schepler > org.apache.flink.tests.util.kafka.SQLClientKafkaITCa

[jira] [Commented] (FLINK-15685) org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs

[ https://issues.apache.org/jira/browse/FLINK-15685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024724#comment-17024724 ] Chesnay Schepler commented on FLINK-15685: -- I will fix this tomorrow. We just h

[jira] [Commented] (FLINK-15773) ClosureCleaner fails with joda DateTimeZone

[ https://issues.apache.org/jira/browse/FLINK-15773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024721#comment-17024721 ] Chesnay Schepler commented on FLINK-15773: -- Shouldn't matter what {{DateTimeZon

[jira] [Comment Edited] (FLINK-15777) Truncate not working with plugins (as expected)

[ https://issues.apache.org/jira/browse/FLINK-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024385#comment-17024385 ] Kostas Kloudas edited comment on FLINK-15777 at 1/27/20 9:05 PM: -

[GitHub] [flink] flinkbot edited a comment on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl…

flinkbot edited a comment on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl… URL: https://github.com/apache/flink/pull/10947#issuecomment-578346458 ## CI report: * 1dcb22b1aa05daac90455fa4ddf293e4ae453ee5 UNKNOWN * d62dc06fbd3e73c1769501bb4

[GitHub] [flink] flinkbot edited a comment on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl…

flinkbot edited a comment on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl… URL: https://github.com/apache/flink/pull/10947#issuecomment-578346458 ## CI report: * 1dcb22b1aa05daac90455fa4ddf293e4ae453ee5 UNKNOWN * d62dc06fbd3e73c1769501bb4

[jira] [Commented] (FLINK-15773) ClosureCleaner fails with joda DateTimeZone

[ https://issues.apache.org/jira/browse/FLINK-15773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024614#comment-17024614 ] Jozef Vilcek commented on FLINK-15773: -- [~aljoscha] thanks for the hint. Joda's Dat

[GitHub] [flink] flinkbot edited a comment on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl…

flinkbot edited a comment on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl… URL: https://github.com/apache/flink/pull/10947#issuecomment-578346458 ## CI report: * 1dcb22b1aa05daac90455fa4ddf293e4ae453ee5 UNKNOWN * d62dc06fbd3e73c1769501bb4

[jira] [Commented] (FLINK-15764) Document why snappy-java is excluded from kafka-clients

[ https://issues.apache.org/jira/browse/FLINK-15764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024571#comment-17024571 ] Igal Shilman commented on FLINK-15764: -- [~chesnay] I will create a PR with a commen

[GitHub] [flink] HuangZhenQiu commented on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl…

HuangZhenQiu commented on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl… URL: https://github.com/apache/flink/pull/10947#issuecomment-578895426 @kl0u Yes, you are right. There is also a compile error in kubernates executor. I already pushed a fix.

[GitHub] [flink] kl0u commented on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl…

kl0u commented on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl… URL: https://github.com/apache/flink/pull/10947#issuecomment-578892790 @HuangZhenQiu It does not seem to be a connection timeout. It seems like a compilation issue related to the changes

[jira] [Commented] (FLINK-15760) ridesharing-example-simulator depends on different parent pom

[ https://issues.apache.org/jira/browse/FLINK-15760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024556#comment-17024556 ] Igal Shilman commented on FLINK-15760: -- This is indeed on propose, the intention wa

[GitHub] [flink] flinkbot edited a comment on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

flinkbot edited a comment on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#issuecomment-578788155 ## CI report: * 35f6da3aae4dd29a8dabb97953a29035d9c9f44a Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r371395301 ## File path: flink-streaming-java/src/main/java/org/apache/f

[GitHub] [flink] HuangZhenQiu commented on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl…

HuangZhenQiu commented on issue #10947: [FLINK-15768] [Client/Job Submission] Consolidate executor related cl… URL: https://github.com/apache/flink/pull/10947#issuecomment-578870846 @kl0u It is a connection timeout in WebFrontendITCase. I will take a look. -

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r371387764 ## File path: flink-fs-tests/src/test/java/org/apache/flink/h

[GitHub] [flink] zentol commented on issue #10944: [FLINK-15739] Fix TypeSerializerUpgradeTestBase on Java 12

zentol commented on issue #10944: [FLINK-15739] Fix TypeSerializerUpgradeTestBase on Java 12 URL: https://github.com/apache/flink/pull/10944#issuecomment-578860300 @aljoscha Why would you need separate modules per test? Couldn't there be 1 module containing all the old version? --

[GitHub] [flink] flinkbot edited a comment on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

flinkbot edited a comment on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#issuecomment-578788155 ## CI report: * 35f6da3aae4dd29a8dabb97953a29035d9c9f44a Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10945: [FLINK-15274][docs]Added separate plugin page.

flinkbot edited a comment on issue #10945: [FLINK-15274][docs]Added separate plugin page. URL: https://github.com/apache/flink/pull/10945#issuecomment-578211988 ## CI report: * 3f006c04d4c5e5237057a662096dd20742c026ec Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds

[GitHub] [flink] zentol commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

zentol commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r371364467 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes -

[GitHub] [flink] flinkbot edited a comment on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

flinkbot edited a comment on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#issuecomment-578788155 ## CI report: * 35f6da3aae4dd29a8dabb97953a29035d9c9f44a Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10945: [FLINK-15274][docs]Added separate plugin page.

flinkbot edited a comment on issue #10945: [FLINK-15274][docs]Added separate plugin page. URL: https://github.com/apache/flink/pull/10945#issuecomment-578211988 ## CI report: * 3f006c04d4c5e5237057a662096dd20742c026ec Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/

[jira] [Commented] (FLINK-15685) org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs

[ https://issues.apache.org/jira/browse/FLINK-15685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024466#comment-17024466 ] Jark Wu commented on FLINK-15685: - Hi [~trohrmann], if this is not urgent I think I can

[GitHub] [flink] flinkbot edited a comment on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

flinkbot edited a comment on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#issuecomment-578788155 ## CI report: * 35f6da3aae4dd29a8dabb97953a29035d9c9f44a Travis: [SUCCESS](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10945: [FLINK-15274][docs]Added separate plugin page.

flinkbot edited a comment on issue #10945: [FLINK-15274][docs]Added separate plugin page. URL: https://github.com/apache/flink/pull/10945#issuecomment-578211988 ## CI report: * 3f006c04d4c5e5237057a662096dd20742c026ec Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r371324585 ## File path: flink-streaming-java/src/main/java/org/apache/f

[GitHub] [flink] pnowojski commented on a change in pull request #10945: [FLINK-15274][docs]Added separate plugin page.

pnowojski commented on a change in pull request #10945: [FLINK-15274][docs]Added separate plugin page. URL: https://github.com/apache/flink/pull/10945#discussion_r371324965 ## File path: docs/ops/plugins.md ## @@ -0,0 +1,91 @@ +--- +title: "Plugins" +nav-id: plugins +nav-p

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r371319134 ## File path: flink-streaming-java/src/main/java/org/apache/f

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r371311953 ## File path: flink-streaming-java/src/main/java/org/apache/f

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r371311953 ## File path: flink-streaming-java/src/main/java/org/apache/f

[GitHub] [flink] flinkbot edited a comment on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

flinkbot edited a comment on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#issuecomment-578788155 ## CI report: * 35f6da3aae4dd29a8dabb97953a29035d9c9f44a Travis: [PENDING](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10945: [FLINK-15274][docs]Added separate plugin page.

flinkbot edited a comment on issue #10945: [FLINK-15274][docs]Added separate plugin page. URL: https://github.com/apache/flink/pull/10945#issuecomment-578211988 ## CI report: * 3f006c04d4c5e5237057a662096dd20742c026ec Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/

[jira] [Resolved] (FLINK-15617) Remove useless JobRetrievalException

[ https://issues.apache.org/jira/browse/FLINK-15617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-15617. --- Fix Version/s: 1.11.0 Resolution: Fixed Fixed via 95af63408f18e7d559b1cc82d9afd56988c

[GitHub] [flink] tillrohrmann closed pull request #10948: [FLINK-15617] Remove useless JobRetrievalException

tillrohrmann closed pull request #10948: [FLINK-15617] Remove useless JobRetrievalException URL: https://github.com/apache/flink/pull/10948 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Resolved] (FLINK-15681) Remove legacy ExecutionAndAllocationFuture class

[ https://issues.apache.org/jira/browse/FLINK-15681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-15681. --- Fix Version/s: 1.11.0 Resolution: Fixed Fixed via 8e992403f1c7949cfd0b1335e97138b4b1f

[GitHub] [flink] tillrohrmann closed pull request #10949: [FLINK-15681] Remove legacy ExecutionAndAllocationFuture class

tillrohrmann closed pull request #10949: [FLINK-15681] Remove legacy ExecutionAndAllocationFuture class URL: https://github.com/apache/flink/pull/10949 This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-15759) ridesharing-example-simulator does not compile on Java 11

[ https://issues.apache.org/jira/browse/FLINK-15759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024421#comment-17024421 ] Igal Shilman commented on FLINK-15759: -- I will just remove lombok. > ridesharing-e

[jira] [Commented] (FLINK-15757) statefun-kafka-io pom comment is incomplete

[ https://issues.apache.org/jira/browse/FLINK-15757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024419#comment-17024419 ] Igal Shilman commented on FLINK-15757: -- I will remove that comment altogether becau

[jira] [Resolved] (FLINK-15701) Allows transfer.sh to retry when fails to uploads logs

[ https://issues.apache.org/jira/browse/FLINK-15701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-15701. --- Fix Version/s: 1.10.1 1.11.0 Resolution: Fixed Fixed via master:

[GitHub] [flink] AHeise commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

AHeise commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#discussion_r371301769 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/f

[GitHub] [flink] AHeise commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

AHeise commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#discussion_r371300568 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/f

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r371300913 ## File path: flink-streaming-java/src/main/java/org/apache/f

[GitHub] [flink] AHeise commented on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

AHeise commented on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#issuecomment-578797697 Do we need some new test coverage? Yes, but I don't have a good idea for a non-complicated test

[GitHub] [flink] AHeise commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

AHeise commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#discussion_r371300568 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/f

[jira] [Updated] (FLINK-15756) StateFun poms are inconsistent in their scala version usages

[ https://issues.apache.org/jira/browse/FLINK-15756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15756: --- Labels: pull-request-available (was: ) > StateFun poms are inconsistent in their scala vers

[GitHub] [flink-statefun] igalshilman opened a new pull request #2: [FLINK-15756] Use scala.binary.version property

igalshilman opened a new pull request #2: [FLINK-15756] Use scala.binary.version property URL: https://github.com/apache/flink-statefun/pull/2 This PR removes all the hardcoded references to a specific Scala version in all the `pom.xml`s under statefun-flink, and replace them with a proper

[GitHub] [flink] tillrohrmann closed pull request #10951: [FLINK-15701][Travis] Retries when uploading to transfer.sh fails

tillrohrmann closed pull request #10951: [FLINK-15701][Travis] Retries when uploading to transfer.sh fails URL: https://github.com/apache/flink/pull/10951 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] AHeise commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

AHeise commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#discussion_r371299272 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/f

[jira] [Commented] (FLINK-15771) SQLClientKafkaITCase.testKafka failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-15771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024412#comment-17024412 ] Till Rohrmann commented on FLINK-15771: --- [~openinx] could you help with fixing thi

[jira] [Updated] (FLINK-15771) SQLClientKafkaITCase.testKafka failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-15771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15771: -- Fix Version/s: 1.11.0 > SQLClientKafkaITCase.testKafka failed on Travis >

[jira] [Updated] (FLINK-15685) org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs

[ https://issues.apache.org/jira/browse/FLINK-15685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15685: -- Fix Version/s: 1.11.0 > org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traiv

[jira] [Updated] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

[ https://issues.apache.org/jira/browse/FLINK-6968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-6968: --- Component/s: Runtime / Queryable State > Store streaming, updating tables with unique key in queryable state

[jira] [Commented] (FLINK-15685) org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs

[ https://issues.apache.org/jira/browse/FLINK-15685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024408#comment-17024408 ] Till Rohrmann commented on FLINK-15685: --- Do you have time to fix this issue [~jark

[jira] [Commented] (FLINK-15756) StateFun poms are inconsistent in their scala version usages

[ https://issues.apache.org/jira/browse/FLINK-15756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024406#comment-17024406 ] Igal Shilman commented on FLINK-15756: -- I'll replace the hardcoded 2.11 references

[jira] [Commented] (FLINK-15764) Document why snappy-java is excluded from kafka-clients

[ https://issues.apache.org/jira/browse/FLINK-15764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024404#comment-17024404 ] Till Rohrmann commented on FLINK-15764: --- [~igal] could you help with this issue?

[jira] [Commented] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024401#comment-17024401 ] Till Rohrmann commented on FLINK-2646: -- If the task needs to perform operations for

[GitHub] [flink] AHeise commented on a change in pull request #10945: [FLINK-15274][docs]Added separate plugin page.

AHeise commented on a change in pull request #10945: [FLINK-15274][docs]Added separate plugin page. URL: https://github.com/apache/flink/pull/10945#discussion_r371290160 ## File path: docs/ops/plugins.md ## @@ -0,0 +1,91 @@ +--- +title: "Plugins" +nav-id: plugins +nav-pare

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

[ https://issues.apache.org/jira/browse/FLINK-14894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024394#comment-17024394 ] Till Rohrmann edited comment on FLINK-14894 at 1/27/20 3:01 PM: --

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r371289627 ## File path: flink-streaming-java/src/main/java/org/apache/f

[GitHub] [flink] AHeise commented on a change in pull request #10945: [FLINK-15274][docs]Added separate plugin page.

AHeise commented on a change in pull request #10945: [FLINK-15274][docs]Added separate plugin page. URL: https://github.com/apache/flink/pull/10945#discussion_r371289683 ## File path: docs/ops/plugins.md ## @@ -0,0 +1,91 @@ +--- +title: "Plugins" +nav-id: plugins +nav-pare

[jira] [Updated] (FLINK-15758) Investigate potential out-of-memory problems due to managed unsafe memory allocation

[ https://issues.apache.org/jira/browse/FLINK-15758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15758: -- Component/s: (was: Runtime / Task) Runtime / Network API

[jira] [Commented] (FLINK-15758) Investigate potential out-of-memory problems due to managed unsafe memory allocation

[ https://issues.apache.org/jira/browse/FLINK-15758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024400#comment-17024400 ] Till Rohrmann commented on FLINK-15758: --- As https://issues.apache.org/jira/browse

[jira] [Updated] (FLINK-15758) Investigate potential out-of-memory problems due to managed unsafe memory allocation

[ https://issues.apache.org/jira/browse/FLINK-15758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15758: -- Priority: Critical (was: Major) > Investigate potential out-of-memory problems due to managed

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

[ https://issues.apache.org/jira/browse/FLINK-14894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14894: -- Component/s: Runtime / Network API / DataSet > HybridOffHeapUnsafeMemorySegme

[GitHub] [flink] azagrebin commented on issue #10946: [FLINK-15763][Runtime] Running TM checks only necessary resource config, set to default for local execution

azagrebin commented on issue #10946: [FLINK-15763][Runtime] Running TM checks only necessary resource config, set to default for local execution URL: https://github.com/apache/flink/pull/10946#issuecomment-578787950 Thanks a lot @tillrohrmann for the review and addressing the comment -

[GitHub] [flink] flinkbot commented on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

flinkbot commented on issue #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#issuecomment-578788155 ## CI report: * 35f6da3aae4dd29a8dabb97953a29035d9c9f44a UNKNOWN Bot commands The @fli

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

[ https://issues.apache.org/jira/browse/FLINK-14894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-14894: --- Reverting the commits of this issue because they are causing higher memory pressure. Due to thi

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

[ https://issues.apache.org/jira/browse/FLINK-14894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14894: -- Priority: Critical (was: Major) > HybridOffHeapUnsafeMemorySegmentTest#testByteBufferWrap fai

[GitHub] [flink] flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

flinkbot edited a comment on issue #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#issuecomment-577792274 ## CI report: * 91aa4fb6f751281910c9e470aa780fa7abe43aa1 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/

[jira] [Assigned] (FLINK-15777) Truncate not working with plugins (as expected)

[ https://issues.apache.org/jira/browse/FLINK-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-15777: -- Assignee: Arvid Heise > Truncate not working with plugins (as expected) > ---

[jira] [Commented] (FLINK-15777) Truncate not working with plugins (as expected)

[ https://issues.apache.org/jira/browse/FLINK-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024385#comment-17024385 ] Kostas Kloudas commented on FLINK-15777: [~arvid heise] well the checks existed

[GitHub] [flink] pnowojski commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

pnowojski commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#discussion_r371270839 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtim

[GitHub] [flink] pnowojski commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

pnowojski commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#discussion_r371272320 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtim

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r371280381 ## File path: flink-fs-tests/src/test/java/org/apache/flink/h

[GitHub] [flink] pnowojski commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath.

pnowojski commented on a change in pull request #10952: [FLINK-15777][filesystem]Determine Hadoop version with fs classpath. URL: https://github.com/apache/flink/pull/10952#discussion_r371270053 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtim

[GitHub] [flink] tillrohrmann closed pull request #10946: [FLINK-15763][Runtime] Running TM checks only necessary resource config, set to default for local execution

tillrohrmann closed pull request #10946: [FLINK-15763][Runtime] Running TM checks only necessary resource config, set to default for local execution URL: https://github.com/apache/flink/pull/10946 This is an automated messag

[jira] [Resolved] (FLINK-15763) Check or set necessary resource configuration options to defaults for local execution ignoring FLIP-49

[ https://issues.apache.org/jira/browse/FLINK-15763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-15763. --- Resolution: Fixed Fixed via master: 03c7274b9a9fbec2acbe86ba3289c7b9d460ea42 1.10.0: cd42cd

[jira] [Commented] (FLINK-15685) org.apache.flink.tests.util.kafka.SQLClientKafkaITCase failed on traivs

[ https://issues.apache.org/jira/browse/FLINK-15685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024382#comment-17024382 ] Jark Wu commented on FLINK-15685: - It seems that the reason is similar to FLINK-15500 th

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r371271225 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes - Fl

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r371270368 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes - Fl

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r371270287 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes - Fl

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r371268575 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes - Fl

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r371268234 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes - Fl

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r371268234 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes - Fl

[GitHub] [flink] rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model

rkhachatryan commented on a change in pull request #10435: [FLINK-13955][runtime] migrate ContinuousFileReaderOperator to the mailbox execution model URL: https://github.com/apache/flink/pull/10435#discussion_r371267711 ## File path: flink-fs-tests/src/test/java/org/apache/flink/h

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r371267556 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes - Fl

[GitHub] [flink] GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10

GJL commented on a change in pull request #10937: [FLINK-15743][docs] Add release notes for Flink 1.10 URL: https://github.com/apache/flink/pull/10937#discussion_r371267353 ## File path: docs/release-notes/flink-1.10.md ## @@ -0,0 +1,287 @@ +--- +title: "Release Notes - Fl

  1   2   >