[GitHub] [flink] flinkbot edited a comment on issue #10222: [FLINK-14788][configuration] Add configure method to CheckpointConfig

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10222: [FLINK-14788][configuration] Add configure method to CheckpointConfig URL: https://github.com/apache/flink/pull/10222#issuecomment-554372384 ## CI report: * a7a80b60af90a66251ef5772cc55cf15bd4df55e : SUCCESS

[jira] [Commented] (FLINK-14617) Dataset Parquet ClassCastException for SpecificRecord

2019-11-21 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979408#comment-16979408 ] Aljoscha Krettek commented on FLINK-14617: -- Is there are longer stacktrace around that

[GitHub] [flink] flinkbot edited a comment on issue #10197: [FLINK-14503][coordination] Add partition report to heartbeat

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10197: [FLINK-14503][coordination] Add partition report to heartbeat URL: https://github.com/apache/flink/pull/10197#issuecomment-553936869 ## CI report: * 54b8b75440349b05c289881cd6b94491f7dca21b : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535.

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. URL: https://github.com/apache/flink/pull/10184#issuecomment-553705209 ## CI report: * 5e70c5d16330d5d3af7018cb71837d578c844dc9 : SUCCESS

[GitHub] [flink] aljoscha commented on issue #10205: [FLINK-14797][tests] Remove power mockito from RemoteStreamExecutionEnvironmentTest

2019-11-21 Thread GitBox
aljoscha commented on issue #10205: [FLINK-14797][tests] Remove power mockito from RemoteStreamExecutionEnvironmentTest URL: https://github.com/apache/flink/pull/10205#issuecomment-557166081 @TisonKun I think the executor work from @kl0u will also change the `RemoteStreamEnvironment` so

[GitHub] [flink] aljoscha closed pull request #10205: [FLINK-14797][tests] Remove power mockito from RemoteStreamExecutionEnvironmentTest

2019-11-21 Thread GitBox
aljoscha closed pull request #10205: [FLINK-14797][tests] Remove power mockito from RemoteStreamExecutionEnvironmentTest URL: https://github.com/apache/flink/pull/10205 This is an automated message from the Apache Git

[jira] [Created] (FLINK-14907) Support to Configure Azure Storage Key via Environment Variable

2019-11-21 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-14907: Summary: Support to Configure Azure Storage Key via Environment Variable Key: FLINK-14907 URL: https://issues.apache.org/jira/browse/FLINK-14907 Project:

[jira] [Updated] (FLINK-14907) Support to Configure Azure Storage Key via Environment Variable

2019-11-21 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14907: - Description: >From a security perspective it would often be preferable pass the Azure

[jira] [Updated] (FLINK-14907) Support to Configure Azure Storage Key via Environment Variable

2019-11-21 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14907: - Description: >From a security perspective it would often be prefferable pass the Azure

[jira] [Updated] (FLINK-14906) Add function related method in CatalogManager

2019-11-21 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-14906: -- Description: 1) Add a temporary function hashmap to store temporary functions 2) Add create,

[GitHub] [flink] sjwiesman commented on issue #10281: [FLINK-14898] Enable background cleanup of state with TTL by default

2019-11-21 Thread GitBox
sjwiesman commented on issue #10281: [FLINK-14898] Enable background cleanup of state with TTL by default URL: https://github.com/apache/flink/pull/10281#issuecomment-557162681 @azagrebin there is an issue with the docs, the mean header section `Cleanup of Expired State` still says that

[jira] [Created] (FLINK-14906) Add function related method in CatalogManager

2019-11-21 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14906: - Summary: Add function related method in CatalogManager Key: FLINK-14906 URL: https://issues.apache.org/jira/browse/FLINK-14906 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #10280: [FLINK-14891][python] Set the default chaining strategy to ALWAYS for Python operators

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10280: [FLINK-14891][python] Set the default chaining strategy to ALWAYS for Python operators URL: https://github.com/apache/flink/pull/10280#issuecomment-557080349 ## CI report: * 87d9b9c26d73f9ea20dabdd88c73e802c0c9c7fc : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10284: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

2019-11-21 Thread GitBox
flinkbot commented on issue #10284: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10284#issuecomment-557162273 ## CI report: * 55bb7f0c227441d894acdfdea48610e4ccdbf12c

[GitHub] [flink] flinkbot commented on issue #10283: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

2019-11-21 Thread GitBox
flinkbot commented on issue #10283: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10283#issuecomment-55716 ## CI report: * 9bc37b6f7ab760f29d28c3cc9763a19de17fb484

[GitHub] [flink] flinkbot edited a comment on issue #10281: [FLINK-14898] Enable background cleanup of state with TTL by default

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10281: [FLINK-14898] Enable background cleanup of state with TTL by default URL: https://github.com/apache/flink/pull/10281#issuecomment-557105491 ## CI report: * 60066189b2c7aacca40c188ea977220102e1b4d1 : FAILURE

[GitHub] [flink] mxm commented on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

2019-11-21 Thread GitBox
mxm commented on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#issuecomment-557159474 Thanks for the review. I've made the requested changes.

[jira] [Commented] (FLINK-14735) Improve batch schedule check input consumable performance

2019-11-21 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979397#comment-16979397 ] Zhu Zhu commented on FLINK-14735: - Backporting PRs are opened. #10284 is for 1.8 and #10283 is for 1.9.

[GitHub] [flink] flinkbot commented on issue #10284: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

2019-11-21 Thread GitBox
flinkbot commented on issue #10284: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10284#issuecomment-557155939 Thanks a lot for your contribution to the Apache Flink project. I'm

[GitHub] [flink] zhuzhurk opened a new pull request #10284: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

2019-11-21 Thread GitBox
zhuzhurk opened a new pull request #10284: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10284 ## What is the purpose of the change Backports #10278 to release-1.8.

[GitHub] [flink] flinkbot edited a comment on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535.

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. URL: https://github.com/apache/flink/pull/10184#issuecomment-553705209 ## CI report: * 5e70c5d16330d5d3af7018cb71837d578c844dc9 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10283: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

2019-11-21 Thread GitBox
flinkbot commented on issue #10283: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10283#issuecomment-557150056 Thanks a lot for your contribution to the Apache Flink project. I'm

[GitHub] [flink] flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE

[GitHub] [flink] zhuzhurk opened a new pull request #10283: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

2019-11-21 Thread GitBox
zhuzhurk opened a new pull request #10283: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10283 ## What is the purpose of the change Backports #10278 to release-1.9.

[GitHub] [flink] flinkbot edited a comment on issue #10279: [FLINK-14888][python] Move the Python SqlDialect to module table

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10279: [FLINK-14888][python] Move the Python SqlDialect to module table URL: https://github.com/apache/flink/pull/10279#issuecomment-557069220 ## CI report: * d2cf3979637d5cccb190c5ceff376aee262359ad : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10278: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10278: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10278#issuecomment-557049375 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: *

[GitHub] [flink] aljoscha commented on a change in pull request #10153: [FLINK-14709] Allow outputting elements in user defined close method,…

2019-11-21 Thread GitBox
aljoscha commented on a change in pull request #10153: [FLINK-14709] Allow outputting elements in user defined close method,… URL: https://github.com/apache/flink/pull/10153#discussion_r349166153 ## File path:

[GitHub] [flink] aljoscha commented on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,…

2019-11-21 Thread GitBox
aljoscha commented on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,… URL: https://github.com/apache/flink/pull/10153#issuecomment-557146373 This makes me wonder why the reduce/combine driver emit the final batch in `close()` and not `closeTask()`. I

[jira] [Commented] (FLINK-14765) Remove STATE_UPDATER in Execution

2019-11-21 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979378#comment-16979378 ] Andrey Zagrebin commented on FLINK-14765: - STATE_UPDATER looks to be used only in main thread,

[GitHub] [flink] zentol merged pull request #10221: [1.9][FLINK-14104][build] Add opt-in jackson 2.10.1 profile

2019-11-21 Thread GitBox
zentol merged pull request #10221: [1.9][FLINK-14104][build] Add opt-in jackson 2.10.1 profile URL: https://github.com/apache/flink/pull/10221 This is an automated message from the Apache Git Service. To respond to the

[jira] [Comment Edited] (FLINK-14104) Bump Jackson to 2.10.1

2019-11-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979369#comment-16979369 ] Chesnay Schepler edited comment on FLINK-14104 at 11/21/19 3:34 PM:

[jira] [Closed] (FLINK-14104) Bump Jackson to 2.10.1

2019-11-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-14104. Resolution: Fixed 1.8: 51839cbb1bdce9400bc1ed46d49f520bd3cfa939 > Bump Jackson to 2.10.1

[GitHub] [flink] TisonKun commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

2019-11-21 Thread GitBox
TisonKun commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-557137748 @zentol if you mean why `curator.version` and `curator.test.version`, please refer to [this

[GitHub] [flink] flinkbot edited a comment on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535.

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. URL: https://github.com/apache/flink/pull/10184#issuecomment-553705209 ## CI report: * 5e70c5d16330d5d3af7018cb71837d578c844dc9 : SUCCESS

[GitHub] [flink] StephanEwen commented on a change in pull request #10239: [Flink-11491][Test] Support all TPC-DS queries

2019-11-21 Thread GitBox
StephanEwen commented on a change in pull request #10239: [Flink-11491][Test] Support all TPC-DS queries URL: https://github.com/apache/flink/pull/10239#discussion_r349153207 ## File path: flink-end-to-end-tests/flink-tpcds-test/pom.xml ## @@ -0,0 +1,84 @@ + +

[GitHub] [flink] flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE

[jira] [Commented] (FLINK-14735) Improve batch schedule check input consumable performance

2019-11-21 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979361#comment-16979361 ] Zhu Zhu commented on FLINK-14735: - Ok. Will do that. > Improve batch schedule check input consumable

[GitHub] [flink] flinkbot edited a comment on issue #10282: [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10282: [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection URL: https://github.com/apache/flink/pull/10282#issuecomment-557119462 ## CI report: * 3b564b3abfdf77f6385d896fffe8eacbd135756e :

[jira] [Commented] (FLINK-14735) Improve batch schedule check input consumable performance

2019-11-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979358#comment-16979358 ] Stephan Ewen commented on FLINK-14735: -- [~zhuzh] Do you want to create a backport of this for 1.8

[jira] [Resolved] (FLINK-14735) Improve batch schedule check input consumable performance

2019-11-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-14735. -- Resolution: Fixed Fixed in 1.10 in 93dfdd05a84f933473c7b22437e12c03239f9462 and

[jira] [Closed] (FLINK-14735) Improve batch schedule check input consumable performance

2019-11-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-14735. > Improve batch schedule check input consumable performance >

[jira] [Assigned] (FLINK-14735) Improve batch schedule check input consumable performance

2019-11-21 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-14735: Assignee: Zhu Zhu > Improve batch schedule check input consumable performance >

[GitHub] [flink] asfgit closed pull request #10278: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

2019-11-21 Thread GitBox
asfgit closed pull request #10278: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10278 This is an automated

[jira] [Created] (FLINK-14905) Unify packaging process

2019-11-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-14905: Summary: Unify packaging process Key: FLINK-14905 URL: https://issues.apache.org/jira/browse/FLINK-14905 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330 ## CI report: * b62006e7cf875fa318b3ce57afb14b0b2679bcb5

[jira] [Comment Edited] (FLINK-11491) Support all TPC-DS queries

2019-11-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979347#comment-16979347 ] Leonard Xu edited comment on FLINK-11491 at 11/21/19 3:05 PM: -- Hi,all As

[jira] [Created] (FLINK-14904) Rename ANY type to RAW type

2019-11-21 Thread Timo Walther (Jira)
Timo Walther created FLINK-14904: Summary: Rename ANY type to RAW type Key: FLINK-14904 URL: https://issues.apache.org/jira/browse/FLINK-14904 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-11491) Support all TPC-DS queries

2019-11-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979347#comment-16979347 ] Leonard Xu commented on FLINK-11491: Hi,all As you known, we skipped 8 result validation in this

[GitHub] [flink] flinkbot edited a comment on issue #10221: [1.9][FLINK-14104][build] Add opt-in jackson 2.10.1 profile

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10221: [1.9][FLINK-14104][build] Add opt-in jackson 2.10.1 profile URL: https://github.com/apache/flink/pull/10221#issuecomment-554361057 ## CI report: * cfdc60b82dc0521d36f743bebb03427566cb45da : SUCCESS

[jira] [Created] (FLINK-14903) Relax structured types constraints

2019-11-21 Thread Timo Walther (Jira)
Timo Walther created FLINK-14903: Summary: Relax structured types constraints Key: FLINK-14903 URL: https://issues.apache.org/jira/browse/FLINK-14903 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-14596) Update MapView and ListView interface to new type system

2019-11-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979341#comment-16979341 ] Timo Walther commented on FLINK-14596: -- fyi: [~jark] I might also look into this topic as part of

[jira] [Assigned] (FLINK-14890) TestHarness for KeyedBroadcastProcessFunction

2019-11-21 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-14890: --- Assignee: Alexander Fedulov > TestHarness for KeyedBroadcastProcessFunction >

[jira] [Updated] (FLINK-14900) output contains null value when a is null in pattern where a <> 'String'

2019-11-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14900: --- Description: the result of TPC-DS query 19 is incorrect, I analyze the simplify the sql as

[GitHub] [flink] flinkbot edited a comment on issue #10281: [FLINK-14898] Enable background cleanup of state with TTL by default

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10281: [FLINK-14898] Enable background cleanup of state with TTL by default URL: https://github.com/apache/flink/pull/10281#issuecomment-557105491 ## CI report: * 60066189b2c7aacca40c188ea977220102e1b4d1 : PENDING

[GitHub] [flink] flinkbot commented on issue #10282: [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection

2019-11-21 Thread GitBox
flinkbot commented on issue #10282: [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection URL: https://github.com/apache/flink/pull/10282#issuecomment-557119462 ## CI report: * 3b564b3abfdf77f6385d896fffe8eacbd135756e : UNKNOWN

[jira] [Commented] (FLINK-14818) StreamNetworkBenchmarkEnvironment incorrectly setups a receiving InputGate

2019-11-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979338#comment-16979338 ] Piotr Nowojski commented on FLINK-14818: I'm not sure. It depends how complicated the mock would

[jira] [Created] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

2019-11-21 Thread hailong wang (Jira)
hailong wang created FLINK-14902: Summary: JDBCTableSource support AsyncLookupFunction Key: FLINK-14902 URL: https://issues.apache.org/jira/browse/FLINK-14902 Project: Flink Issue Type:

[GitHub] [flink] pnowojski commented on a change in pull request #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535.

2019-11-21 Thread GitBox
pnowojski commented on a change in pull request #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. URL: https://github.com/apache/flink/pull/10184#discussion_r349122592 ## File path: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ##

[GitHub] [flink] pnowojski commented on a change in pull request #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535.

2019-11-21 Thread GitBox
pnowojski commented on a change in pull request #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. URL: https://github.com/apache/flink/pull/10184#discussion_r349122479 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535.

2019-11-21 Thread GitBox
pnowojski commented on a change in pull request #10184: [FLINK-14481]Modify the Flink valid socket port check to 0 to 65535. URL: https://github.com/apache/flink/pull/10184#discussion_r349122248 ## File path: flink-core/src/main/java/org/apache/flink/util/NetUtils.java ##

[GitHub] [flink] flinkbot commented on issue #10282: [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection

2019-11-21 Thread GitBox
flinkbot commented on issue #10282: [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection URL: https://github.com/apache/flink/pull/10282#issuecomment-557115395 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-14901) Throw Error in MemoryUtils if there is problem with using system classes over reflection

2019-11-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14901: --- Labels: pull-request-available (was: ) > Throw Error in MemoryUtils if there is problem

[GitHub] [flink] azagrebin opened a new pull request #10282: [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection

2019-11-21 Thread GitBox
azagrebin opened a new pull request #10282: [FLINK-14901] Throw Error in MemoryUtils if there is problem with using system classes over reflection URL: https://github.com/apache/flink/pull/10282 A follow-up hotfix for #9747 and #9997. If something goes wrong using system classes over

[GitHub] [flink] dawidwys commented on a change in pull request #10223: [FLINK-14787][configuration] Add configure method to StreamExecutionEnvironment

2019-11-21 Thread GitBox
dawidwys commented on a change in pull request #10223: [FLINK-14787][configuration] Add configure method to StreamExecutionEnvironment URL: https://github.com/apache/flink/pull/10223#discussion_r349120398 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #10223: [FLINK-14787][configuration] Add configure method to StreamExecutionEnvironment

2019-11-21 Thread GitBox
dawidwys commented on a change in pull request #10223: [FLINK-14787][configuration] Add configure method to StreamExecutionEnvironment URL: https://github.com/apache/flink/pull/10223#discussion_r349120398 ## File path:

[jira] [Closed] (FLINK-14747) Performance regression with latest changes to Mailbox

2019-11-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14747. -- Resolution: Fixed Fixed in master by {{ca0e7b75d3f724604eccf9ddce1d0fdaea130783}} >

[GitHub] [flink] pnowojski merged pull request #10177: [FLINK-14747] Fix performance regression with latest changes to Mailbox

2019-11-21 Thread GitBox
pnowojski merged pull request #10177: [FLINK-14747] Fix performance regression with latest changes to Mailbox URL: https://github.com/apache/flink/pull/10177 This is an automated message from the Apache Git Service. To

[jira] [Created] (FLINK-14901) Throw Error in MemoryUtils if there is problem with using system classes over reflection

2019-11-21 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-14901: --- Summary: Throw Error in MemoryUtils if there is problem with using system classes over reflection Key: FLINK-14901 URL: https://issues.apache.org/jira/browse/FLINK-14901

[jira] [Commented] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

2019-11-21 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979325#comment-16979325 ] Gary Yao commented on FLINK-14505: -- Also failed for me with hash mismatch. However, I had

[GitHub] [flink] flinkbot edited a comment on issue #10222: [FLINK-14788][configuration] Add configure method to CheckpointConfig

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10222: [FLINK-14788][configuration] Add configure method to CheckpointConfig URL: https://github.com/apache/flink/pull/10222#issuecomment-554372384 ## CI report: * a7a80b60af90a66251ef5772cc55cf15bd4df55e : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10197: [FLINK-14503][coordination] Add partition report to heartbeat

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10197: [FLINK-14503][coordination] Add partition report to heartbeat URL: https://github.com/apache/flink/pull/10197#issuecomment-553936869 ## CI report: * 54b8b75440349b05c289881cd6b94491f7dca21b : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10114: [WIP][FLINK -14651][runtime] Enable DefaultScheduler URL: https://github.com/apache/flink/pull/10114#issuecomment-551014940 ## CI report: * c436371614d7db5dfc8c97e01a4594c3139715db : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support partition for temporary table

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 4937b8b139bab4957799947b841fb1ae3758ed48 : FAILURE

[GitHub] [flink] flinkbot commented on issue #10281: [FLINK-14898] Enable background cleanup of state with TTL by default

2019-11-21 Thread GitBox
flinkbot commented on issue #10281: [FLINK-14898] Enable background cleanup of state with TTL by default URL: https://github.com/apache/flink/pull/10281#issuecomment-557105491 ## CI report: * 60066189b2c7aacca40c188ea977220102e1b4d1 : UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10269: [FLINK-14876]Putting xercesImpl related classes into alwaysParentFirstLoaderPatterns to avoid conflicts

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10269: [FLINK-14876]Putting xercesImpl related classes into alwaysParentFirstLoaderPatterns to avoid conflicts URL: https://github.com/apache/flink/pull/10269#issuecomment-555964079 ## CI report: * caaddea342d2bc7d4483baae51525d903d5166d7 :

[jira] [Updated] (FLINK-14900) output contains null value when a is null in pattern where a <> 'String'

2019-11-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14900: --- Summary: output contains null value when a is null in pattern where a <> 'String' (was: output

[GitHub] [flink] flinkbot commented on issue #10281: [FLINK-14898] Enable background cleanup of state with TTL by default

2019-11-21 Thread GitBox
flinkbot commented on issue #10281: [FLINK-14898] Enable background cleanup of state with TTL by default URL: https://github.com/apache/flink/pull/10281#issuecomment-557102779 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Created] (FLINK-14900) output contains null value when a is null where a <> 'String'

2019-11-21 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-14900: -- Summary: output contains null value when a is null where a <> 'String' Key: FLINK-14900 URL: https://issues.apache.org/jira/browse/FLINK-14900 Project: Flink

[GitHub] [flink] azagrebin opened a new pull request #10281: [FLINK-14898] Enable background cleanup of state with TTL by default

2019-11-21 Thread GitBox
azagrebin opened a new pull request #10281: [FLINK-14898] Enable background cleanup of state with TTL by default URL: https://github.com/apache/flink/pull/10281 ## What is the purpose of the change So far, we were conservative about enabling background cleanup strategies for state

[jira] [Updated] (FLINK-14898) Enable background cleanup of state with TTL by default

2019-11-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14898: --- Labels: pull-request-available (was: ) > Enable background cleanup of state with TTL by

[jira] [Commented] (FLINK-14872) Potential deadlock for task reading from blocking ResultPartition.

2019-11-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979304#comment-16979304 ] Piotr Nowojski commented on FLINK-14872: Ok, I see. Do you have a proposal how to actually

[GitHub] [flink] flinkbot edited a comment on issue #10222: [FLINK-14788][configuration] Add configure method to CheckpointConfig

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10222: [FLINK-14788][configuration] Add configure method to CheckpointConfig URL: https://github.com/apache/flink/pull/10222#issuecomment-554372384 ## CI report: * a7a80b60af90a66251ef5772cc55cf15bd4df55e : SUCCESS

[GitHub] [flink] zentol edited a comment on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

2019-11-21 Thread GitBox
zentol edited a comment on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#issuecomment-557096605 you have to regenerate the REST API snapshot for the compatibility test (see below) and the REST API

[GitHub] [flink] flinkbot edited a comment on issue #10197: [FLINK-14503][coordination] Add partition report to heartbeat

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10197: [FLINK-14503][coordination] Add partition report to heartbeat URL: https://github.com/apache/flink/pull/10197#issuecomment-553936869 ## CI report: * 54b8b75440349b05c289881cd6b94491f7dca21b : SUCCESS

[GitHub] [flink] zentol commented on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

2019-11-21 Thread GitBox
zentol commented on issue #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#issuecomment-557096605 you have to regenerate the REST API documentation. ``` 19:27:00.675 [ERROR] Tests run: 1, Failures: 1, Errors: 0,

[GitHub] [flink] zentol commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

2019-11-21 Thread GitBox
zentol commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r349089190 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint

2019-11-21 Thread GitBox
zentol commented on a change in pull request #10238: [FLINK-8949] Add dedicated watermarks metric retrieval endpoint URL: https://github.com/apache/flink/pull/10238#discussion_r349089791 ## File path:

[jira] [Created] (FLINK-14899) can not be translated to StreamExecDeduplicate when PROCTIME is defined in query

2019-11-21 Thread godfrey he (Jira)
godfrey he created FLINK-14899: -- Summary: can not be translated to StreamExecDeduplicate when PROCTIME is defined in query Key: FLINK-14899 URL: https://issues.apache.org/jira/browse/FLINK-14899

[GitHub] [flink] flinkbot edited a comment on issue #10280: [FLINK-14891][python] Set the default chaining strategy to ALWAYS for Python operators

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10280: [FLINK-14891][python] Set the default chaining strategy to ALWAYS for Python operators URL: https://github.com/apache/flink/pull/10280#issuecomment-557080349 ## CI report: * 87d9b9c26d73f9ea20dabdd88c73e802c0c9c7fc : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10278: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

2019-11-21 Thread GitBox
flinkbot edited a comment on issue #10278: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10278#issuecomment-557049375 ## CI report: *

[jira] [Commented] (FLINK-14834) Kerberized YARN on Docker test fails on Travis

2019-11-21 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979280#comment-16979280 ] Gary Yao commented on FLINK-14834: -- 'Running Kerberized YARN on Docker test (default input)' also

[jira] [Updated] (FLINK-14896) Kinesis connector doesn't shade jackson dependency

2019-11-21 Thread Michel Davit (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michel Davit updated FLINK-14896: - Priority: Minor (was: Major) > Kinesis connector doesn't shade jackson dependency >

[jira] [Updated] (FLINK-14834) Kerberized YARN on Docker test fails on Travis

2019-11-21 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14834: - Summary: Kerberized YARN on Docker test fails on Travis (was: Kerberized YARN on Docker test (custom

[jira] [Commented] (FLINK-14896) Kinesis connector doesn't shade jackson dependency

2019-11-21 Thread Michel Davit (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16979278#comment-16979278 ] Michel Davit commented on FLINK-14896: -- After digging deeper, this bug only happens if user make

[jira] [Created] (FLINK-14898) Enable background cleanup of state with TTL by default

2019-11-21 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-14898: --- Summary: Enable background cleanup of state with TTL by default Key: FLINK-14898 URL: https://issues.apache.org/jira/browse/FLINK-14898 Project: Flink

[GitHub] [flink] zentol commented on a change in pull request #10197: [FLINK-14503][coordination] Add partition report to heartbeat

2019-11-21 Thread GitBox
zentol commented on a change in pull request #10197: [FLINK-14503][coordination] Add partition report to heartbeat URL: https://github.com/apache/flink/pull/10197#discussion_r349084393 ## File path:

[jira] [Updated] (FLINK-14897) HiveTableOutputFormat fails to finalize on master

2019-11-21 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-14897: --- Description: Hit this issue with 1.9.1 in a dockerized env where sql-cli, JM, TM run in separated

[jira] [Created] (FLINK-14897) HiveTableOutputFormat fails to finalize on master

2019-11-21 Thread Rui Li (Jira)
Rui Li created FLINK-14897: -- Summary: HiveTableOutputFormat fails to finalize on master Key: FLINK-14897 URL: https://issues.apache.org/jira/browse/FLINK-14897 Project: Flink Issue Type: Bug

[GitHub] [flink] StephanEwen commented on issue #10278: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler

2019-11-21 Thread GitBox
StephanEwen commented on issue #10278: [FLINK-14735][scheduler] Improve scheduling of all-to-all partitions with ALL input constraint for legacy scheduler URL: https://github.com/apache/flink/pull/10278#issuecomment-557080986 Thanks, will merge once the CI gives us green light...

<    1   2   3   4   5   6   7   >