[GitHub] [flink] KurtYoung closed pull request #8058: [FLINK-11959][table-runtime-blink] Introduce window operator for blink streaming runtime

2019-03-30 Thread GitBox
KurtYoung closed pull request #8058: [FLINK-11959][table-runtime-blink] Introduce window operator for blink streaming runtime URL: https://github.com/apache/flink/pull/8058 This is an automated message from the Apache Git

[jira] [Closed] (FLINK-11959) Introduce window operator for blink streaming runtime

2019-03-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11959. -- Resolution: Implemented Fix Version/s: 1.9.0 fixed in 2ef028021f0de602485a27e16f69ec684bbe01a4

[jira] [Assigned] (FLINK-12061) Add more window operator contract tests to table runtime

2019-03-30 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-12061: - Assignee: leesf > Add more window operator contract tests to table runtime >

[jira] [Updated] (FLINK-12061) Add more window operator contract tests to table runtime

2019-03-30 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-12061: --- Component/s: Tests > Add more window operator contract tests to table runtime >

[jira] [Updated] (FLINK-12064) RocksDBKeyedStateBackend snapshot uses incorrect key serializer if reconfigure happens during restore

2019-03-30 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-12064: -- Summary: RocksDBKeyedStateBackend snapshot uses incorrect key serializer if reconfigure happens during

[jira] [Updated] (FLINK-12015) TaskManagerRunnerTest is unstable

2019-03-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-12015: - Fix Version/s: 1.8.1 1.9.0 > TaskManagerRunnerTest is unstable >

[jira] [Closed] (FLINK-12015) TaskManagerRunnerTest is unstable

2019-03-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-12015. Resolution: Fixed Fixed on master in 10bf3b0b754b5eded1f9a18089d2d0c0c053aafb Fixed on

[GitHub] [flink] KurtYoung commented on a change in pull request #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank

2019-03-30 Thread GitBox
KurtYoung commented on a change in pull request #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank URL: https://github.com/apache/flink/pull/8051#discussion_r270618704 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank

2019-03-30 Thread GitBox
KurtYoung commented on a change in pull request #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank URL: https://github.com/apache/flink/pull/8051#discussion_r270618981 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank

2019-03-30 Thread GitBox
KurtYoung commented on a change in pull request #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank URL: https://github.com/apache/flink/pull/8051#discussion_r270618896 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank

2019-03-30 Thread GitBox
KurtYoung commented on a change in pull request #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank URL: https://github.com/apache/flink/pull/8051#discussion_r270618922 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank

2019-03-30 Thread GitBox
KurtYoung commented on a change in pull request #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank URL: https://github.com/apache/flink/pull/8051#discussion_r270618484 ## File path:

[jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"

2019-03-30 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805717#comment-16805717 ] Nico Kruber commented on FLINK-8093: Actually, that's not really a Kafka bug if they are relying on

[jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"

2019-03-30 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805723#comment-16805723 ] Ufuk Celebi commented on FLINK-8093: Yes I agree with [~NicoK]. We need to dynamically set this per

[GitHub] [flink] aljoscha commented on issue #8053: [FLINK-12015] Fix TaskManagerRunnerTest instability

2019-03-30 Thread GitBox
aljoscha commented on issue #8053: [FLINK-12015] Fix TaskManagerRunnerTest instability URL: https://github.com/apache/flink/pull/8053#issuecomment-478241252 Thanks! I'll merge This is an automated message from the Apache Git

[GitHub] [flink] aljoscha closed pull request #8053: [FLINK-12015] Fix TaskManagerRunnerTest instability

2019-03-30 Thread GitBox
aljoscha closed pull request #8053: [FLINK-12015] Fix TaskManagerRunnerTest instability URL: https://github.com/apache/flink/pull/8053 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-12064) RocksDBKeyedStateBackend snapshot uses incorrect key serializer if reconfigure happens during restore

2019-03-30 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805733#comment-16805733 ] Yu Li commented on FLINK-12064: --- bq. but the wrong one is snapshotted in checkpoints, is that correct?

[GitHub] [flink] TisonKun commented on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

2019-03-30 Thread GitBox
TisonKun commented on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#issuecomment-478240902 Big thanks to @zentol ! FYI travis failed on checkstyle, adding a fixup for it...

[GitHub] [flink] TisonKun removed a comment on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

2019-03-30 Thread GitBox
TisonKun removed a comment on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#issuecomment-478259149 https://api.travis-ci.org/v3/job/513442168/log.txt travis reported failure on "connector"

[GitHub] [flink] TisonKun commented on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

2019-03-30 Thread GitBox
TisonKun commented on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#issuecomment-478259149 https://api.travis-ci.org/v3/job/513442168/log.txt travis reported failure on "connect" profile.

[GitHub] [flink] TisonKun edited a comment on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

2019-03-30 Thread GitBox
TisonKun edited a comment on issue #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#issuecomment-478259149 https://api.travis-ci.org/v3/job/513442168/log.txt travis reported failure on "connector"

[jira] [Created] (FLINK-12071) HadoopRecoverableWriterTest fails on Travis

2019-03-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12071: Summary: HadoopRecoverableWriterTest fails on Travis Key: FLINK-12071 URL: https://issues.apache.org/jira/browse/FLINK-12071 Project: Flink Issue

[jira] [Assigned] (FLINK-12071) HadoopRecoverableWriterTest fails on Travis

2019-03-30 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-12071: - Assignee: leesf > HadoopRecoverableWriterTest fails on Travis >