[jira] [Created] (FLINK-15913) Add Python Table Function Runner And Operator

2020-02-05 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-15913: Summary: Add Python Table Function Runner And Operator Key: FLINK-15913 URL: https://issues.apache.org/jira/browse/FLINK-15913 Project: Flink Issue Type: New

[jira] [Assigned] (FLINK-15909) Add PyPI release process into the subsequent release of 1.9.x

2020-02-05 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-15909: --- Assignee: Wei Zhong > Add PyPI release process into the subsequent release of 1.9.x >

[jira] [Assigned] (FLINK-15908) Add description of support 'pip install' to 1.9.x documents

2020-02-05 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-15908: --- Assignee: Wei Zhong > Add description of support 'pip install' to 1.9.x documents > ---

[GitHub] [flink] dawidwys closed pull request #10915: [FLINK-15706][table-planner-blink] LastValueAggFunctionWithOrderTest compilation error due to incompatible types

2020-02-05 Thread GitBox
dawidwys closed pull request #10915: [FLINK-15706][table-planner-blink] LastValueAggFunctionWithOrderTest compilation error due to incompatible types URL: https://github.com/apache/flink/pull/10915 This is an automated messa

[jira] [Commented] (FLINK-15841) TimeWindow.intersects return true for consecutive windows

2020-02-05 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030422#comment-17030422 ] Aljoscha Krettek commented on FLINK-15841: -- Sure yes, that would be good. 👌  

[GitHub] [flink] StephanEwen opened a new pull request #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource

2020-02-05 Thread GitBox
StephanEwen opened a new pull request #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource URL: https://github.com/apache/flink/pull/11018 ## What is the purpose of the change Fixes the race condition when releasing `OpaqueMemoryRes

[jira] [Updated] (FLINK-15905) Fix Race Condition when releasing shared memory resource

2020-02-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15905: --- Labels: pull-request-available (was: ) > Fix Race Condition when releasing shared memory re

[jira] [Closed] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types

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

[jira] [Commented] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types

2020-02-05 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030427#comment-17030427 ] Dawid Wysakowicz commented on FLINK-15706: -- Please reopen if you see this reocc

[jira] [Updated] (FLINK-15913) Add Python Table Function Runner And Operator

2020-02-05 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-15913: - Parent: FLINK-14500 Issue Type: Sub-task (was: New Feature) > Add Python Table Function

[GitHub] [flink] flinkbot commented on issue #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource

2020-02-05 Thread GitBox
flinkbot commented on issue #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource URL: https://github.com/apache/flink/pull/11018#issuecomment-582288319 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I h

[jira] [Commented] (FLINK-15706) LastValueAggFunctionWithOrderTest compilation error due to incompatible types

2020-02-05 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030426#comment-17030426 ] Dawid Wysakowicz commented on FLINK-15706: -- The fix restructured the tests in a

[GitHub] [flink] aljoscha commented on issue #11007: [FLINK-15872][javadoc] Remove unnessary javadocs in InputFormat

2020-02-05 Thread GitBox
aljoscha commented on issue #11007: [FLINK-15872][javadoc] Remove unnessary javadocs in InputFormat URL: https://github.com/apache/flink/pull/11007#issuecomment-582289515 Perfect, thanks! I'm merging. The test failure is a known instability.

[jira] [Closed] (FLINK-15872) Remove unnecessary javadocs in InputFormat

2020-02-05 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15872. Fix Version/s: 1.11.0 Resolution: Fixed master: 09056477c45b482fcbd4437750fa3eb9e1d

[GitHub] [flink] aljoscha merged pull request #11007: [FLINK-15872][javadoc] Remove unnessary javadocs in InputFormat

2020-02-05 Thread GitBox
aljoscha merged pull request #11007: [FLINK-15872][javadoc] Remove unnessary javadocs in InputFormat URL: https://github.com/apache/flink/pull/11007 This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-15913) Add Python Table Function Runner And Operator

2020-02-05 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-15913: - Description: This Jira will include two PRs: * Add Python Table Function Runner and Operator in

[jira] [Commented] (FLINK-15740) Remove Deadline#timeLeft()

2020-02-05 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030433#comment-17030433 ] Aljoscha Krettek commented on FLINK-15740: -- Turns out this is not as easy, {{Th

[GitHub] [flink] aljoscha commented on issue #4228: Flink-7035 Automatically identify AWS Region, simplified constructors, added test properties support

2020-02-05 Thread GitBox
aljoscha commented on issue #4228: Flink-7035 Automatically identify AWS Region, simplified constructors, added test properties support URL: https://github.com/apache/flink/pull/4228#issuecomment-582292746 @tweise Do you think this one is still relevant? You guys must have the most Kinesis

[GitHub] [flink] flinkbot edited a comment on issue #11006: [FLINK-15868][kinesis] Resolve version conflict between jackson-core and jackson-dataformat-cbor

2020-02-05 Thread GitBox
flinkbot edited a comment on issue #11006: [FLINK-15868][kinesis] Resolve version conflict between jackson-core and jackson-dataformat-cbor URL: https://github.com/apache/flink/pull/11006#issuecomment-581673930 ## CI report: * af2a640e770f0fff302ec8d3b8920895a3f40bfb Travis: [SU

[GitHub] [flink] flinkbot commented on issue #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource

2020-02-05 Thread GitBox
flinkbot commented on issue #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource URL: https://github.com/apache/flink/pull/11018#issuecomment-582293770 ## CI report: * 4ea977f18fb6bd5da47b80f96d899ef5d05193a4 UNKNOWN

[jira] [Updated] (FLINK-15910) Add NOTICE and LICENSE files for Stateful Functions

2020-02-05 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-15910: Summary: Add NOTICE and LICENSE files for Stateful Functions (was: Add NOTICE fil

[GitHub] [flink] aljoscha commented on issue #11017: [FLINK-15907] [runtime] [configuration] expose getRawValue as protect…

2020-02-05 Thread GitBox
aljoscha commented on issue #11017: [FLINK-15907] [runtime] [configuration] expose getRawValue as protect… URL: https://github.com/apache/flink/pull/11017#issuecomment-582294418 @dawidwys What do you think about this one? I'm skeptical because making the method `protected` increases the AP

[jira] [Created] (FLINK-15914) Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread zhijiang (Jira)
zhijiang created FLINK-15914: Summary: Miss the barrier alignment metric for the case of two inputs Key: FLINK-15914 URL: https://issues.apache.org/jira/browse/FLINK-15914 Project: Flink Issue T

[jira] [Assigned] (FLINK-15908) Add description of support 'pip install' to 1.9.x documents

2020-02-05 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-15908: --- Assignee: Wei Zhong (was: li412076173) > Add description of support 'pip install' to 1.9.x

[GitHub] [flink] rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

2020-02-05 Thread GitBox
rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r375118760 ## File path: flink-streaming-java/src/m

[jira] [Assigned] (FLINK-15909) Add PyPI release process into the subsequent release of 1.9.x

2020-02-05 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-15909: --- Assignee: Wei Zhong (was: li412076173) > Add PyPI release process into the subsequent rele

[jira] [Commented] (FLINK-15811) StreamSourceOperatorWatermarksTest#testNoMaxWatermarkOnAsyncCancel fails on Travis

2020-02-05 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030448#comment-17030448 ] Aljoscha Krettek commented on FLINK-15811: -- This changed since the test was add

[jira] [Comment Edited] (FLINK-15740) Remove Deadline#timeLeft()

2020-02-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030450#comment-17030450 ] Chesnay Schepler edited comment on FLINK-15740 at 2/5/20 8:42 AM:

[jira] [Commented] (FLINK-15740) Remove Deadline#timeLeft()

2020-02-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030450#comment-17030450 ] Chesnay Schepler commented on FLINK-15740: -- The obvious workaround being to ret

[jira] [Commented] (FLINK-15811) StreamSourceOperatorWatermarksTest#testNoMaxWatermarkOnAsyncCancel fails on Travis

2020-02-05 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030451#comment-17030451 ] Aljoscha Krettek commented on FLINK-15811: -- If the {{InfiniteSource}} that is u

[GitHub] [flink] dawidwys commented on issue #11017: [FLINK-15907] [runtime] [configuration] expose getRawValue as protect…

2020-02-05 Thread GitBox
dawidwys commented on issue #11017: [FLINK-15907] [runtime] [configuration] expose getRawValue as protect… URL: https://github.com/apache/flink/pull/11017#issuecomment-582302171 I agree with you in principle. I am also sceptical about this change for the same reasons. My take is that `Conf

[GitHub] [flink] flinkbot commented on issue #4228: Flink-7035 Automatically identify AWS Region, simplified constructors, added test properties support

2020-02-05 Thread GitBox
flinkbot commented on issue #4228: Flink-7035 Automatically identify AWS Region, simplified constructors, added test properties support URL: https://github.com/apache/flink/pull/4228#issuecomment-582303009 ## CI report: * 9afa9fb8160db3bbebd7bef60d888a9de1a6e72b UNKNOWN

[GitHub] [flink] zentol merged pull request #10959: [FLINK-15335] Replace `add-dependencies-for-IDEA` profile

2020-02-05 Thread GitBox
zentol merged pull request #10959: [FLINK-15335] Replace `add-dependencies-for-IDEA` profile URL: https://github.com/apache/flink/pull/10959 This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] carp84 commented on a change in pull request #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource

2020-02-05 Thread GitBox
carp84 commented on a change in pull request #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource URL: https://github.com/apache/flink/pull/11018#discussion_r375111995 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[GitHub] [flink] carp84 commented on a change in pull request #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource

2020-02-05 Thread GitBox
carp84 commented on a change in pull request #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource URL: https://github.com/apache/flink/pull/11018#discussion_r375122419 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[GitHub] [flink] twalthr closed pull request #10960: [FLINK-15487][table] Update code generation for new type inference

2020-02-05 Thread GitBox
twalthr closed pull request #10960: [FLINK-15487][table] Update code generation for new type inference URL: https://github.com/apache/flink/pull/10960 This is an automated message from the Apache Git Service. To respond to t

[jira] [Closed] (FLINK-15335) add-dependencies-for-IDEA not working anymore and dangerous in general

2020-02-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15335. Resolution: Fixed master: 73017a82d9c13a16b42e5025d5922eb746dd458d 1.10: 4df788ae81e6ed18c

[jira] [Closed] (FLINK-15487) Expose the new type inference for scalar functions

2020-02-05 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-15487. Fix Version/s: 1.11.0 Resolution: Fixed Fixed in 1.11: [FLINK-15487][table] Update code gen

[GitHub] [flink] flinkbot edited a comment on issue #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource

2020-02-05 Thread GitBox
flinkbot edited a comment on issue #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource URL: https://github.com/apache/flink/pull/11018#issuecomment-582293770 ## CI report: * 4ea977f18fb6bd5da47b80f96d899ef5d05193a4 Travis: [PE

[jira] [Updated] (FLINK-15914) Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15914: - Affects Version/s: 1.10.0 > Miss the barrier alignment metric for the case of two inputs > -

[jira] [Updated] (FLINK-15914) Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15914: - Priority: Critical (was: Major) > Miss the barrier alignment metric for the case of two inputs > --

[jira] [Updated] (FLINK-15914) Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15914: - Fix Version/s: 1.10.0 > Miss the barrier alignment metric for the case of two inputs > -

[GitHub] [flink] StephanEwen commented on a change in pull request #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource

2020-02-05 Thread GitBox
StephanEwen commented on a change in pull request #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource URL: https://github.com/apache/flink/pull/11018#discussion_r375133066 ## File path: flink-runtime/src/main/java/org/apache/fli

[jira] [Updated] (FLINK-15811) StreamSourceOperatorWatermarksTest#testNoMaxWatermarkOnAsyncCancel fails on Travis

2020-02-05 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15811: - Component/s: (was: API / DataStream) Runtime / Task > StreamSourceO

[jira] [Commented] (FLINK-15811) StreamSourceOperatorWatermarksTest#testNoMaxWatermarkOnAsyncCancel fails on Travis

2020-02-05 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030469#comment-17030469 ] Aljoscha Krettek commented on FLINK-15811: -- This commit introduced the problem:

[GitHub] [flink] zhijiangW opened a new pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread GitBox
zhijiangW opened a new pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs URL: https://github.com/apache/flink/pull/11019 ## What is the purpose of the change When the `StreamTwoInputSelectableProcessor` was introd

[jira] [Updated] (FLINK-15914) Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15914: --- Labels: pull-request-available (was: ) > Miss the barrier alignment metric for the case of

[GitHub] [flink] flinkbot commented on issue #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread GitBox
flinkbot commented on issue #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs URL: https://github.com/apache/flink/pull/11019#issuecomment-582312163 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Closed] (FLINK-15698) Restructure Configuration Docs to separate "Getting Started", "Common Operations" and "Tuning/Debugging"

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-15698. > Restructure Configuration Docs to separate "Getting Started", "Common > Operations" and "Tuning/Deb

[jira] [Resolved] (FLINK-15698) Restructure Configuration Docs to separate "Getting Started", "Common Operations" and "Tuning/Debugging"

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-15698. -- Fix Version/s: (was: 1.11.0) 1.10.0 Resolution: Fixed Fixed in

[jira] [Closed] (FLINK-15695) Remove outdated section of Configuration Page

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-15695. > Remove outdated section of Configuration Page > - > >

[jira] [Resolved] (FLINK-15695) Remove outdated section of Configuration Page

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-15695. -- Resolution: Fixed Fixed in - 1.10.0 via 5729f237d2c3f01efc3ebc70d051bec09381fcc8 - master

[jira] [Closed] (FLINK-15696) Update description of "RocksDB Configurable Options" for new options

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-15696. > Update description of "RocksDB Configurable Options" for new options > -

[jira] [Resolved] (FLINK-15696) Update description of "RocksDB Configurable Options" for new options

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-15696. -- Assignee: Stephan Ewen Resolution: Fixed Fixed in - 1.10.0 via a9040e79e7fff2acec3a921

[jira] [Created] (FLINK-15915) Bump Jackson to 2.10.1 in flink-table-planner

2020-02-05 Thread Timo Walther (Jira)
Timo Walther created FLINK-15915: Summary: Bump Jackson to 2.10.1 in flink-table-planner Key: FLINK-15915 URL: https://issues.apache.org/jira/browse/FLINK-15915 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #4228: Flink-7035 Automatically identify AWS Region, simplified constructors, added test properties support

2020-02-05 Thread GitBox
flinkbot edited a comment on issue #4228: Flink-7035 Automatically identify AWS Region, simplified constructors, added test properties support URL: https://github.com/apache/flink/pull/4228#issuecomment-582303009 ## CI report: * 9afa9fb8160db3bbebd7bef60d888a9de1a6e72b Travis: [

[jira] [Closed] (FLINK-15824) Generalize CommonOption to support other option groups as well

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-15824. > Generalize CommonOption to support other option groups as well > ---

[jira] [Resolved] (FLINK-15824) Generalize CommonOption to support other option groups as well

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-15824. -- Fix Version/s: 1.10.0 Resolution: Implemented Implemented in 1.10.0 via - e811d13251

[GitHub] [flink] pnowojski commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread GitBox
pnowojski commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs URL: https://github.com/apache/flink/pull/11019#discussion_r375140363 ## File path: flink-streaming-java/src/main/java/org/apa

[GitHub] [flink] aljoscha commented on issue #11017: [FLINK-15907] [runtime] [configuration] expose getRawValue as protect…

2020-02-05 Thread GitBox
aljoscha commented on issue #11017: [FLINK-15907] [runtime] [configuration] expose getRawValue as protect… URL: https://github.com/apache/flink/pull/11017#issuecomment-582316387 To make things easier, we could make the method protected but mark it as `@Internal`, meaning that we can still

[GitHub] [flink] pnowojski commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread GitBox
pnowojski commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs URL: https://github.com/apache/flink/pull/11019#discussion_r375139240 ## File path: flink-streaming-java/src/main/java/org/apa

[jira] [Closed] (FLINK-15697) Remove Options that are not configured in "flink-conf.yaml" from Configuration Docs

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-15697. > Remove Options that are not configured in "flink-conf.yaml" from > Configuration Docs > ---

[jira] [Resolved] (FLINK-15697) Remove Options that are not configured in "flink-conf.yaml" from Configuration Docs

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-15697. -- Fix Version/s: 1.10.0 Resolution: Fixed Fixed in 1.10.0 via - e4ede3f6e8c7e0ad771ec3

[jira] [Updated] (FLINK-15911) Flink does not work over NAT

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-15911: - Priority: Blocker (was: Major) > Flink does not work over NAT > >

[jira] [Closed] (FLINK-15683) Restructure Configuration Docs

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-15683. > Restructure Configuration Docs > -- > > Key: FLINK-15683

[jira] [Resolved] (FLINK-15683) Restructure Configuration Docs

2020-02-05 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-15683. -- Assignee: Stephan Ewen Resolution: Fixed Fixed via resolution of all subtasks. > Restru

[jira] [Commented] (FLINK-15853) Use the new type inference for hive udf

2020-02-05 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030491#comment-17030491 ] Timo Walther commented on FLINK-15853: -- FYI: I would wait a little bit with updatin

[GitHub] [flink] flinkbot edited a comment on issue #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource

2020-02-05 Thread GitBox
flinkbot edited a comment on issue #11018: [FLINK-15905][runtime] Fix race condition between allocation and release of OpaqueMemoryResource URL: https://github.com/apache/flink/pull/11018#issuecomment-582293770 ## CI report: * 4ea977f18fb6bd5da47b80f96d899ef5d05193a4 Travis: [FA

[GitHub] [flink] flinkbot commented on issue #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread GitBox
flinkbot commented on issue #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs URL: https://github.com/apache/flink/pull/11019#issuecomment-582319661 ## CI report: * 012203b66328bc46e9af4d37c585521915f450ca UNKNOWN

[GitHub] [flink-statefun] igalshilman commented on issue #12: [FLINK-15899] [build] Inherit from Apache Parent POM

2020-02-05 Thread GitBox
igalshilman commented on issue #12: [FLINK-15899] [build] Inherit from Apache Parent POM URL: https://github.com/apache/flink-statefun/pull/12#issuecomment-582322537 Thanks @tzulitai ! Can you check if spotless can be configured to conform with that java doc style?

[GitHub] [flink] sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

2020-02-05 Thread GitBox
sunhaibotb commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r375149637 ## File path: flink-streaming-java/src/mai

[jira] [Closed] (FLINK-15915) Bump Jackson to 2.10.1 in flink-table-planner

2020-02-05 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-15915. Resolution: Duplicate Will be fixed as part of FLINK-15868. > Bump Jackson to 2.10.1 in flink-tab

[GitHub] [flink] zhijiangW commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread GitBox
zhijiangW commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs URL: https://github.com/apache/flink/pull/11019#discussion_r375152356 ## File path: flink-streaming-java/src/main/java/org/apa

[GitHub] [flink] twalthr commented on issue #10981: [hotfix][table] Convert FlinkCalciteSqlValidator to Java

2020-02-05 Thread GitBox
twalthr commented on issue #10981: [hotfix][table] Convert FlinkCalciteSqlValidator to Java URL: https://github.com/apache/flink/pull/10981#issuecomment-582325828 Master was broken at that time need to rerun Travis. @flinkbot run travis --

[jira] [Updated] (FLINK-15811) StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsyncCancel fails on Travis

2020-02-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15811: -- Summary: StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsyncCancel fails on Travis (

[GitHub] [flink] zhijiangW commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread GitBox
zhijiangW commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs URL: https://github.com/apache/flink/pull/11019#discussion_r375154315 ## File path: flink-streaming-java/src/main/java/org/apa

[GitHub] [flink] zhijiangW commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread GitBox
zhijiangW commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs URL: https://github.com/apache/flink/pull/11019#discussion_r375154315 ## File path: flink-streaming-java/src/main/java/org/apa

[GitHub] [flink] zhijiangW commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs

2020-02-05 Thread GitBox
zhijiangW commented on a change in pull request #11019: [FLINK-15914][checkpointing][metrics] Miss the barrier alignment metric for the case of two inputs URL: https://github.com/apache/flink/pull/11019#discussion_r375154631 ## File path: flink-streaming-java/src/main/java/org/apa

[jira] [Commented] (FLINK-15811) StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsyncCancel fails on Travis

2020-02-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030500#comment-17030500 ] Till Rohrmann commented on FLINK-15811: --- Another instance: https://api.travis-ci.o

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375152283 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375136323 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-s3/src/main/java/org/apache/flink

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375150750 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375136004 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-s3/src/main/java/org/apache/flink

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375154599 ## File path: flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/resources/log4j-test.pr

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375135147 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-s3/src/main/java/org/apache/flink

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375134537 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common-s3/src/main/java/org/apache/flink

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375150956 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375144972 ## File path: flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375149437 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375142611 ## File path: flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375143604 ## File path: flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375144702 ## File path: flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375141951 ## File path: flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375148829 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375142000 ## File path: flink-end-to-end-tests/flink-streaming-file-sink-test/src/test/java/org/apache/flink/t

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375140867 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/te

[GitHub] [flink] zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest.

2020-02-05 Thread GitBox
zentol commented on a change in pull request #10993: [FLINK-15845][e2e] Added java-based StreamingFileSinkTest. URL: https://github.com/apache/flink/pull/10993#discussion_r375154401 ## File path: flink-end-to-end-tests/flink-streaming-file-sink-test/pom.xml ## @@ -36,10 +3

[jira] [Updated] (FLINK-15811) StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsyncCancel fails on Travis

2020-02-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15811: -- Fix Version/s: 1.11.0 > StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsyncCancel fai

[jira] [Commented] (FLINK-15811) StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsyncCancel fails on Travis

2020-02-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030503#comment-17030503 ] Till Rohrmann commented on FLINK-15811: --- Another instance: https://api.travis-ci.o

[jira] [Updated] (FLINK-15811) StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsyncCancel fails on Travis

2020-02-05 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-15811: -- Labels: test-stability (was: ) > StreamSourceOperatorWatermarksTest.testNoMaxWatermarkOnAsync

  1   2   3   4   5   >