[jira] [Commented] (FLINK-6749) Table API / SQL Docs: SQL Page

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042625#comment-16042625 ] ASF GitHub Bot commented on FLINK-6749: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4046: [FLINK-6749] [table] Table API / SQL Docs: SQL Page

2017-06-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4046 I've seen several questions on the mailing list and Stack Overflow related to breaking changes in the 1.3 release (mostly about the time indicator). That's why I would like to update the

[jira] [Commented] (FLINK-6652) Problem with DelimitedInputFormat

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042612#comment-16042612 ] ASF GitHub Bot commented on FLINK-6652: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request #4088: [FLINK-6652] [core] Fix handling of delimiters spl...

2017-06-08 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/4088 [FLINK-6652] [core] Fix handling of delimiters split by buffers in DelimitedInputFormat This PR fixes a bug introduced by fix FLINK-5771 / PR #3316. That fix resets the read position if a

[jira] [Closed] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

2017-06-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6783. --- Resolution: Fixed Fix Version/s: 1.4.0 Fixed on release-1.3 in

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

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

[GitHub] flink issue #4039: [FLINK-6783] Changed passing index of type argument while...

2017-06-08 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4039 @dawidwys Could you please close this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

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

[GitHub] flink pull request #4039: [FLINK-6783] Changed passing index of type argumen...

2017-06-08 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4039#discussion_r120860095 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java --- @@ -507,12 +505,41 @@ public

[jira] [Commented] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

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

[GitHub] flink pull request #4049: [FLINK-6643] [JobManager] Flink restarts job in HA...

2017-06-08 Thread zhangminglei
Github user zhangminglei closed the pull request at: https://github.com/apache/flink/pull/4049 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

2017-06-08 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042536#comment-16042536 ] mingleizhang commented on FLINK-6643: - That makes sense better now. Just the logging statement make

[jira] [Commented] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

2017-06-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042503#comment-16042503 ] Till Rohrmann commented on FLINK-6643: -- The logging statement just says that the respective restart

[jira] [Resolved] (FLINK-6643) Flink restarts job in HA even if NoRestartStrategy is set

2017-06-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6643. -- Resolution: Not A Problem > Flink restarts job in HA even if NoRestartStrategy is set >

[jira] [Commented] (FLINK-6783) Wrongly extracted TypeInformations for WindowedStream::aggregate

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

[GitHub] flink issue #4039: [FLINK-6783] Changed passing index of type argument while...

2017-06-08 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4039 @dawidwys I merged to master, now I rebased on `release-1.3` and running tests before merging there as well. Thanks for fixing this so quickly! 👌 --- If your project is set up for it,

[jira] [Updated] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

2017-06-08 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6866: Component/s: Scala API > ClosureCleaner.clean fails for scala's JavaConverters wrapper

[GitHub] flink issue #3776: [FLINK-6376]when deploy flink cluster on the yarn, it is ...

2017-06-08 Thread Rucongzhang
Github user Rucongzhang commented on the issue: https://github.com/apache/flink/pull/3776 @StephanEwen ,@tzulitai , please review the code ,if it is ok. Please help me to merge the PR. Thanks! --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token.

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042418#comment-16042418 ] ASF GitHub Bot commented on FLINK-6376: --- Github user Rucongzhang commented on the issue:

[jira] [Commented] (FLINK-6833) Race condition: Asynchronous checkpointing task can fail completed StreamTask

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042408#comment-16042408 ] ASF GitHub Bot commented on FLINK-6833: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #4058: [FLINK-6833] [task] Fail StreamTask only due to async exc...

2017-06-08 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4058 LGTM +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-6742) Improve error message when savepoint migration fails due to task removal

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042403#comment-16042403 ] ASF GitHub Bot commented on FLINK-6742: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #4083: [FLINK-6742] Improve savepoint migration failure error me...

2017-06-08 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/4083 Change looks good to merge! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-6806) rocksdb is not listed as state backend in doc

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042366#comment-16042366 ] ASF GitHub Bot commented on FLINK-6806: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4045: [FLINK-6806] [docs] rocksdb is not listed as state backen...

2017-06-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4045 +1. Will merge this, thanks for the contribution! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-6806) rocksdb is not listed as state backend in doc

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042363#comment-16042363 ] ASF GitHub Bot commented on FLINK-6806: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #4045: [FLINK-6806] [docs] rocksdb is not listed as state backen...

2017-06-08 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4045 can someone review this please? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6868: Labels: (was: improvement) > Using `scala.binary.version` for `flink-streaming-scala` in

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6868: Component/s: Cassandra Connector > Using `scala.binary.version` for `flink-streaming-scala`

[jira] [Assigned] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6868: --- Assignee: Benedict Jin > Using `scala.binary.version` for `flink-streaming-scala` in

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6868: Priority: Blocker (was: Major) > Using `scala.binary.version` for `flink-streaming-scala`

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6868: Fix Version/s: 1.3.1 > Using `scala.binary.version` for `flink-streaming-scala` in

[jira] [Commented] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042342#comment-16042342 ] ASF GitHub Bot commented on FLINK-6868: --- Github user zentol commented on the issue:

[GitHub] flink issue #4087: [FLINK-6868][build] Using `scala.binary.version` for `fli...

2017-06-08 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4087 +1, nice catch. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Closed] (FLINK-6852) Fix misuse of GCD

2017-06-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6852. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 825721e6f1d8e34234f59d6ffde94af376146956

[jira] [Commented] (FLINK-6859) StateCleaningCountTrigger should not delete timer

2017-06-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042336#comment-16042336 ] Chesnay Schepler commented on FLINK-6859: - 1.4: 92cd736daf65aae10f77bb6e8144623a5c82b5be >

[jira] [Created] (FLINK-6869) Scala serializers do not have the serialVersionUID specified

2017-06-08 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6869: -- Summary: Scala serializers do not have the serialVersionUID specified Key: FLINK-6869 URL: https://issues.apache.org/jira/browse/FLINK-6869 Project:

[jira] [Commented] (FLINK-6852) Fix misuse of GCD

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

[GitHub] flink pull request #4062: [FLINK-6820] Activate checkstyle for runtime/filec...

2017-06-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4062 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Closed] (FLINK-6820) Activate checkstyle for runtime/filecache

2017-06-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6820. --- Resolution: Fixed 1.4: 8ae4f2b0ae103540435244ff75ab4b593670dd76 > Activate checkstyle for

[GitHub] flink pull request #4077: [FLINK-6852] Fix misuse of GCD

2017-06-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4077 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6820) Activate checkstyle for runtime/filecache

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

[jira] [Commented] (FLINK-6834) Over window doesn't support complex calculation

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

[jira] [Commented] (FLINK-6859) StateCleaningCountTrigger should not delete timer

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

[GitHub] flink pull request #4070: [FLINK-6834] [table] Support scalar functions on O...

2017-06-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4070 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Closed] (FLINK-6834) Over window doesn't support complex calculation

2017-06-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6834. --- Resolution: Fixed 1.4: 1cc1bb41e94b585200d9f7179bdeaa0bec0dcc5d > Over window doesn't

[GitHub] flink pull request #4085: [FLINK-6859][table] remove delete useless times fo...

2017-06-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4085 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16042304#comment-16042304 ] ASF GitHub Bot commented on FLINK-6868: --- GitHub user asdf2014 opened a pull request:

[GitHub] flink pull request #4087: [FLINK-6868][build] Using `scala.binary.version` f...

2017-06-08 Thread asdf2014
GitHub user asdf2014 opened a pull request: https://github.com/apache/flink/pull/4087 [FLINK-6868][build] Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector` Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector` You can

[jira] [Created] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Benedict Jin (JIRA)
Benedict Jin created FLINK-6868: --- Summary: Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector` Key: FLINK-6868 URL: https://issues.apache.org/jira/browse/FLINK-6868

[jira] [Updated] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-08 Thread Benedict Jin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benedict Jin updated FLINK-6868: Issue Type: Improvement (was: Bug) > Using `scala.binary.version` for `flink-streaming-scala` in

[jira] [Updated] (FLINK-6867) Elasticsearch 1.x IT test still instable due to embedded node instability

2017-06-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6867: --- Description: The integration tests for Elasticsearch 1.x seems to still be instable,

[jira] [Updated] (FLINK-6867) Elasticsearch 1.x ITCase still instable due to embedded node instability

2017-06-08 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6867: --- Summary: Elasticsearch 1.x ITCase still instable due to embedded node instability

[jira] [Created] (FLINK-6867) Elasticsearch 1.x IT test still instable due to embedded node instability

2017-06-08 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6867: -- Summary: Elasticsearch 1.x IT test still instable due to embedded node instability Key: FLINK-6867 URL: https://issues.apache.org/jira/browse/FLINK-6867

<    1   2