[GitHub] flink pull request #2573: Refactor StreamOperator Hierachy to make Keys Expl...

2018-03-08 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/2573 ---

[jira] [Comment Edited] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-03-08 Thread yanxiaobin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390914#comment-16390914 ] yanxiaobin edited comment on FLINK-8500 at 3/8/18 8:47 AM: --- Sorry to reply so

[GitHub] flink issue #5637: [FLINK-8860][flip6] stop SlotManager spamming logs for ev...

2018-03-08 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/5637 makes sense, since this is not indicating an error after all ---

[jira] [Commented] (FLINK-8860) SlotManager spamming log files

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390970#comment-16390970 ] ASF GitHub Bot commented on FLINK-8860: --- Github user NicoK commented on the issue:

[jira] [Created] (FLINK-8894) CurrentJobIdsHandler fails to serialize response

2018-03-08 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8894: --- Summary: CurrentJobIdsHandler fails to serialize response Key: FLINK-8894 URL: https://issues.apache.org/jira/browse/FLINK-8894 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8894) CurrentJobIdsHandler fails to serialize response

2018-03-08 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8894: Affects Version/s: 1.6.0 > CurrentJobIdsHandler fails to serialize response >

[jira] [Created] (FLINK-8895) Job failed when one kafka broker shutdown

2018-03-08 Thread godfrey johnson (JIRA)
godfrey johnson created FLINK-8895: -- Summary: Job failed when one kafka broker shutdown Key: FLINK-8895 URL: https://issues.apache.org/jira/browse/FLINK-8895 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

2018-03-08 Thread yanxiaobin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16390914#comment-16390914 ] yanxiaobin commented on FLINK-8500: --- Sorry to reply so late. I see. We really should be careful here. I

[jira] [Closed] (FLINK-4371) Add ability to take savepoints from job manager RESTful API

2018-03-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4371. --- Resolution: Duplicate > Add ability to take savepoints from job manager RESTful API >

[jira] [Assigned] (FLINK-8536) Improve CSVTableSourceFactory to support all descriptor properties

2018-03-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-8536: --- Assignee: (was: Timo Walther) > Improve CSVTableSourceFactory to support all descriptor

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391225#comment-16391225 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391226#comment-16391226 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #5656: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5656#discussion_r173164690 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java --- @@ -0,0 +1,333 @@ +/* + *

[jira] [Updated] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8867: Priority: Blocker (was: Major) > Rocksdb checkpointing failing with fs.default-scheme:

[jira] [Updated] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8867: Fix Version/s: (was: 1.4.3) > Rocksdb checkpointing failing with fs.default-scheme:

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391198#comment-16391198 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173146108 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/NumberGauge.java --- @@ -0,0 +1,26 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391201#comment-16391201 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391199#comment-16391199 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173146558 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/StringGauge.java --- @@ -0,0 +1,26 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391200#comment-16391200 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391224#comment-16391224 ] ASF GitHub Bot commented on FLINK-6053: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173149289 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/reporter/AbstractReporterV2.java --- @@ -0,0 +1,89 @@ +/* + *

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173150593 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala --- @@ -23,6 +23,7 @@ import org.apache.flink.metrics.Gauge

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173148163 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MetricGroup.java --- @@ -87,9 +89,27 @@ * @param gauge gauge

[jira] [Commented] (FLINK-8893) NPE when netty try to allocate directBuffer

2018-03-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391248#comment-16391248 ] Nico Kruber commented on FLINK-8893: I looked at the merged commits in Netty but the fix commit at

[jira] [Assigned] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config

2018-03-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-8867: --- Assignee: Stefan Richter > Rocksdb checkpointing failing with fs.default-scheme:

[jira] [Commented] (FLINK-8785) JobSubmitHandler does not handle JobSubmissionExceptions

2018-03-08 Thread Wind (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391274#comment-16391274 ] Wind commented on FLINK-8785: - [~Zentol] You mean the exception should be caught instead of being thrown ? >

[jira] [Resolved] (FLINK-8834) Job fails to restart due to some tasks stuck in cancelling state

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8834. - Resolution: Fixed Subsumed by FLINK-8856 > Job fails to restart due to some tasks stuck in

[jira] [Closed] (FLINK-8834) Job fails to restart due to some tasks stuck in cancelling state

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8834. --- > Job fails to restart due to some tasks stuck in cancelling state >

[jira] [Updated] (FLINK-8686) Improve basic embedded SQL client

2018-03-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8686: Description: This issue describes follow-up issues that should be fixes in order to make the SQL

[GitHub] flink pull request #5661: [FLINK-8896][kafka08] fix Kafka08Fetcher trying to...

2018-03-08 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5661 [FLINK-8896][kafka08] fix Kafka08Fetcher trying to look up topic "n/a" on partiton "-1" ## What is the purpose of the change `Kafka08Fetcher` uses a `MARKER` to make sure the main thread

[jira] [Commented] (FLINK-8896) Kafka08Fetcher trying to look up topic "n/a" on partiton "-1"

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1639#comment-1639 ] ASF GitHub Bot commented on FLINK-8896: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #5662: [FLINK-8854] [table] Fix schema mapping with time ...

2018-03-08 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5662 [FLINK-8854] [table] Fix schema mapping with time attributes ## What is the purpose of the change This PR fixes the invalid field mapping and improves the mapping of time attributes in

[jira] [Commented] (FLINK-8854) Mapping of SchemaValidator.deriveFieldMapping() is incorrect.

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391163#comment-16391163 ] ASF GitHub Bot commented on FLINK-8854: --- GitHub user twalthr opened a pull request:

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391167#comment-16391167 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5654: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5654#discussion_r173142759 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java --- @@ -0,0 +1,387 @@ +/* + *

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173146575 --- Diff: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/NumberGauge.java --- @@ -0,0 +1,26 @@ +/* + * Licensed to the

[GitHub] flink pull request #5501: [FLINK-6053][metrics] Add new Number-/StringGauge ...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/5501#discussion_r173147513 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java --- @@ -460,4 +474,77 @@ protected

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391261#comment-16391261 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #5654: [FLINK-8487] Verify ZooKeeper checkpoint store behaviour ...

2018-03-08 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5654 @StephanEwen pushed some changes ---

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391268#comment-16391268 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8882) flink-tests fails with core dump

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391060#comment-16391060 ] Stephan Ewen commented on FLINK-8882: - After some debugging and discussions, this seems to be caused

[jira] [Resolved] (FLINK-8839) Table source factory discovery is broken in SQL Client

2018-03-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8839. - Resolution: Fixed Fix Version/s: 1.6.0 Fixed in 1.6.0:

[jira] [Created] (FLINK-8896) Kafka08Fetcher trying to look up topic "n/a" on partiton "-1"

2018-03-08 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8896: -- Summary: Kafka08Fetcher trying to look up topic "n/a" on partiton "-1" Key: FLINK-8896 URL: https://issues.apache.org/jira/browse/FLINK-8896 Project: Flink

[GitHub] flink issue #5441: [FLINK-8607] [table] Add a basic embedded SQL CLI client

2018-03-08 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5441 Hi @hzyuemeng1, in your terms we translate this as "sql -> table api -> runtime". But actually it is more like "sql api with calcite -> runtime". In the long-term view we will further optimize the

[jira] [Commented] (FLINK-8607) Add a basic embedded SQL CLI client

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391151#comment-16391151 ] ASF GitHub Bot commented on FLINK-8607: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-8893) NPE when netty try to allocate directBuffer

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391045#comment-16391045 ] Stephan Ewen commented on FLINK-8893: - [~NicoK] [~till.rohrmann] This would be an argument for bumping

[jira] [Commented] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391075#comment-16391075 ] ASF GitHub Bot commented on FLINK-8856: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5658: [FLINK-8856] [TaskManager] Move all cancellation interrup...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5658 CI failure unrelated, due to https://issues.apache.org/jira/browse/FLINK-8882 ---

[jira] [Commented] (FLINK-8839) Table source factory discovery is broken in SQL Client

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391082#comment-16391082 ] ASF GitHub Bot commented on FLINK-8839: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5654: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5654#discussion_r173134300 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java --- @@ -0,0 +1,387 @@ +/* + *

[GitHub] flink pull request #5654: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5654#discussion_r173134402 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java --- @@ -0,0 +1,387 @@ +/* + *

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391117#comment-16391117 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391115#comment-16391115 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8895) Job failed when one kafka broker shutdown

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391186#comment-16391186 ] Stephan Ewen commented on FLINK-8895: - I don't think we need to do anything special here. It should be

[jira] [Commented] (FLINK-8895) Job failed when one kafka broker shutdown

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391039#comment-16391039 ] Stephan Ewen commented on FLINK-8895: - The Kafka Consumer 0.8 connects to new brokers on exceptions

[GitHub] flink issue #5342: [FLINK-8479] Timebounded stream join

2018-03-08 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5342 Changes look good to me! I will let it run on Travis and then merge. ---

[jira] [Commented] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391037#comment-16391037 ] ASF GitHub Bot commented on FLINK-8479: --- Github user kl0u commented on the issue:

[jira] [Deleted] (FLINK-8892) Travis Build: Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.18.1:test (integration-tests) on project flink-tests_2.11

2018-03-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler deleted FLINK-8892: > Travis Build: Failed to execute goal >

[jira] [Commented] (FLINK-8895) Job failed when one kafka broker shutdown

2018-03-08 Thread godfrey johnson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391079#comment-16391079 ] godfrey johnson commented on FLINK-8895: [~StephanEwen] It's a good way to add 

[GitHub] flink pull request #5640: [FLINK-8839] [sql-client] Fix table source factory...

2018-03-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5640 ---

[GitHub] flink pull request #5654: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5654#discussion_r173143151 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java --- @@ -0,0 +1,387 @@ +/* + *

[GitHub] flink pull request #5654: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5654#discussion_r173142937 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ZooKeeperHighAvailabilityITCase.java --- @@ -0,0 +1,387 @@ +/* + *

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391169#comment-16391169 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391171#comment-16391171 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8839) Table source factory discovery is broken in SQL Client

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391064#comment-16391064 ] ASF GitHub Bot commented on FLINK-8839: --- Github user twalthr commented on the issue:

[GitHub] flink issue #5640: [FLINK-8839] [sql-client] Fix table source factory discov...

2018-03-08 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5640 Merging... ---

[jira] [Assigned] (FLINK-8882) flink-tests fails with core dump

2018-03-08 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-8882: - Assignee: Stefan Richter > flink-tests fails with core dump >

[jira] [Commented] (FLINK-8607) Add a basic embedded SQL CLI client

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391138#comment-16391138 ] ASF GitHub Bot commented on FLINK-8607: --- Github user hzyuemeng1 commented on the issue:

[GitHub] flink issue #5441: [FLINK-8607] [table] Add a basic embedded SQL CLI client

2018-03-08 Thread hzyuemeng1
Github user hzyuemeng1 commented on the issue: https://github.com/apache/flink/pull/5441 @twalthr ,do we implement this base on table api such as sql -> table api -> runtime, or new plan:sql -> calcite->whole stage codegen -runtime. ---

[GitHub] flink pull request #5658: [FLINK-8856] [TaskManager] Move all cancellation i...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5658#discussion_r173171090 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/DispatcherThreadFactory.java --- @@ -18,6 +18,8 @@ package

[GitHub] flink pull request #5658: [FLINK-8856] [TaskManager] Move all cancellation i...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5658#discussion_r173170798 --- Diff: flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java --- @@ -81,12 +81,15 @@ public static String stringifyException(final

[jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391304#comment-16391304 ] ASF GitHub Bot commented on FLINK-5479: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5327: [FLINK-8428] [table] Implement stream-stream non-window l...

2018-03-08 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/5327 Hi @twalthr @walterddr The latest update refactors interfaces and functions to make code more friendly to right/full joins. The code of right/full joins are also ready and can be reached from

[GitHub] flink issue #5634: [FLINK-5479] [kafka] Idleness detection for periodic per-...

2018-03-08 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5634 Just saw a good comment from @EronWright > I think the ideal would be that idleness would occur only for tail reads, i.e. due to a timeout from `kafkaConsumer.poll(pollTimeout)`. In

[jira] [Commented] (FLINK-8882) flink-tests fails with core dump

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391311#comment-16391311 ] Stephan Ewen commented on FLINK-8882: - Seems strange indeed. Feels also not good to not understand why

[jira] [Commented] (FLINK-8428) Implement stream-stream non-window left outer join

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391333#comment-16391333 ] ASF GitHub Bot commented on FLINK-8428: --- Github user hequn8128 commented on the issue:

[jira] [Commented] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391297#comment-16391297 ] ASF GitHub Bot commented on FLINK-8856: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391298#comment-16391298 ] ASF GitHub Bot commented on FLINK-8856: --- Github user aljoscha commented on a diff in the pull

[jira] [Commented] (FLINK-8882) flink-tests fails with core dump

2018-03-08 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391300#comment-16391300 ] Stefan Richter commented on FLINK-8882: --- It seems like the problem was introduced by the changes

[jira] [Commented] (FLINK-8882) flink-tests fails with core dump

2018-03-08 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391314#comment-16391314 ] Stefan Richter commented on FLINK-8882: --- Got to double check again, maybe the problem is also

[jira] [Closed] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8856. --- > Move all interrupt() calls to TaskCanceler > -- > >

[jira] [Resolved] (FLINK-8856) Move all interrupt() calls to TaskCanceler

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8856. - Resolution: Fixed Fixed in - 1.5.0 via 36dccdc520c676ca2c53046cad4ec80c351068b7 - 1.6.0 via

[jira] [Updated] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-03-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8900: --- Labels: flip-6 (was: ) > YARN FinalStatus always shows as KILLED with Flip-6 >

[jira] [Updated] (FLINK-8902) Re-scaling job sporadically fails with KeeperException

2018-03-08 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8902: Description: *Description* Re-scaling a job with {{bin/flink modify -p }} sporadically fails with a

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391619#comment-16391619 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on the issue:

[jira] [Updated] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-03-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8900: --- Labels: (was: flip-6) > YARN FinalStatus always shows as KILLED with Flip-6 >

[jira] [Created] (FLINK-8901) YARN application name for Flink (per-job) submissions claims it is using only 1 TaskManager

2018-03-08 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8901: -- Summary: YARN application name for Flink (per-job) submissions claims it is using only 1 TaskManager Key: FLINK-8901 URL: https://issues.apache.org/jira/browse/FLINK-8901

[jira] [Commented] (FLINK-8900) YARN FinalStatus always shows as KILLED with Flip-6

2018-03-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391566#comment-16391566 ] Nico Kruber commented on FLINK-8900: Let me elaborate a bit more since this also partly affects the

[GitHub] flink issue #5656: [FLINK-8487] Verify ZooKeeper checkpoint store behaviour ...

2018-03-08 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5656 rebased ---

[jira] [Closed] (FLINK-8884) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8884. --- > The DispatcherThreadFactory should register uncaught exception handlers >

[jira] [Closed] (FLINK-8883) ExceptionUtils.rethrowIfFatalError should treat ThreadDeath as fatal

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-8883. --- > ExceptionUtils.rethrowIfFatalError should treat ThreadDeath as fatal >

[jira] [Resolved] (FLINK-8884) The DispatcherThreadFactory should register uncaught exception handlers

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8884. - Resolution: Fixed Fixed in - 1.5.0 via 071e29143c303d63e9908fb1ef6faa447c48d27e - 1.6.0 via

[jira] [Resolved] (FLINK-8883) ExceptionUtils.rethrowIfFatalError should treat ThreadDeath as fatal

2018-03-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-8883. - Resolution: Fixed Fixed in - 1.5.0 via afd2404d634a03cc4cd017b63745c74e5281896c - 1.6.0 via

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391556#comment-16391556 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #5655: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/5655 ---

[jira] [Commented] (FLINK-8487) State loss after multiple restart attempts

2018-03-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16391512#comment-16391512 ] ASF GitHub Bot commented on FLINK-8487: --- Github user aljoscha closed the pull request at:

[GitHub] flink pull request #5656: [FLINK-8487] Verify ZooKeeper checkpoint store beh...

2018-03-08 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5656#discussion_r173227736 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java --- @@ -223,6 +224,81 @@ } }

[GitHub] flink issue #5589: [FLINK-8797] Port AbstractOperatorRestoreTestBase to Mini...

2018-03-08 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5589 @zentol rebased ---

  1   2   >