[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613380#comment-14613380 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33877140 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +1

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33874602 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +17,1

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613324#comment-14613324 ] ASF GitHub Bot commented on FLINK-1967: --- Github user mjsax commented on a diff in th

[jira] [Commented] (FLINK-2288) Setup ZooKeeper for distributed coordination

[ https://issues.apache.org/jira/browse/FLINK-2288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613238#comment-14613238 ] ASF GitHub Bot commented on FLINK-2288: --- GitHub user uce opened a pull request:

[GitHub] flink pull request: [wip] [FLINK-2288] [FLINK-2302] Setup ZooKeepe...

GitHub user uce opened a pull request: https://github.com/apache/flink/pull/886 [wip] [FLINK-2288] [FLINK-2302] Setup ZooKeeper for distributed coordination - FLINK-2288: Setup ZooKeeper for distributed coordination * Add FlinkZooKeeperQuorumPeer to wrap ZooKeeper's quorum peer

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33868988 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +1

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613233#comment-14613233 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613226#comment-14613226 ] ASF GitHub Bot commented on FLINK-1967: --- Github user mjsax commented on a diff in th

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33868446 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +17,1

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613221#comment-14613221 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33868015 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +1

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613205#comment-14613205 ] ASF GitHub Bot commented on FLINK-1967: --- Github user mjsax commented on a diff in th

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33865507 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +17,1

[GitHub] flink pull request: [FLINK-2304] Add named attribute access to Sto...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-118356433 Ok. So this PR in put on hold and #884 can be merged "right way". --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer

[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613199#comment-14613199 ] ASF GitHub Bot commented on FLINK-2304: --- Github user mjsax commented on the pull req

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613194#comment-14613194 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33864328 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +1

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613192#comment-14613192 ] ASF GitHub Bot commented on FLINK-1967: --- Github user mjsax commented on a diff in th

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33864243 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +17,1

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33864220 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +1

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613190#comment-14613190 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33864229 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +1

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613189#comment-14613189 ] ASF GitHub Bot commented on FLINK-1967: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613186#comment-14613186 ] ASF GitHub Bot commented on FLINK-1967: --- Github user mjsax commented on a diff in th

[jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming

[ https://issues.apache.org/jira/browse/FLINK-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613187#comment-14613187 ] ASF GitHub Bot commented on FLINK-1967: --- Github user mjsax commented on a diff in th

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33864125 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +17,1

[GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin...

Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/879#discussion_r33864108 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamRecord.java --- @@ -17,87 +17,1

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

Github user aalexandrov commented on a diff in the pull request: https://github.com/apache/flink/pull/885#discussion_r33858475 --- Diff: docs/apis/programming_guide.md --- @@ -187,7 +187,17 @@ that creates the type information for Flink operations. + Scala

[jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613146#comment-14613146 ] ASF GitHub Bot commented on FLINK-2200: --- Github user aalexandrov commented on a diff

[jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613145#comment-14613145 ] ASF GitHub Bot commented on FLINK-2200: --- Github user aalexandrov commented on a diff

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

Github user aalexandrov commented on a diff in the pull request: https://github.com/apache/flink/pull/885#discussion_r33858383 --- Diff: docs/apis/programming_guide.md --- @@ -187,7 +187,17 @@ that creates the type information for Flink operations. + Scala

[jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613141#comment-14613141 ] ASF GitHub Bot commented on FLINK-2200: --- Github user aalexandrov commented on the pu

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/885#issuecomment-118326627 I think that a cleaner solution would be to 1. Add a `scala.suffix` to the Scala profiles. This should be set as the empty string for 2.10 and as `_${scala.b

[jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613136#comment-14613136 ] ASF GitHub Bot commented on FLINK-2200: --- Github user aalexandrov commented on a diff

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

Github user aalexandrov commented on a diff in the pull request: https://github.com/apache/flink/pull/885#discussion_r33857654 --- Diff: docs/apis/programming_guide.md --- @@ -136,7 +136,7 @@ mvn archetype:generate / -The archetypes are working for stable relea

[jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613104#comment-14613104 ] ASF GitHub Bot commented on FLINK-2200: --- GitHub user chiwanpark opened a pull reques

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

GitHub user chiwanpark opened a pull request: https://github.com/apache/flink/pull/885 [FLINK-2200] Add Flink with Scala 2.11 in Maven Repository Hi, This PR contains following changes: * Add a suffix `_2.11` to all maven modules by profile setting. (`-Pscala-2.11`) * A

[jira] [Commented] (FLINK-2312) Random Splits

[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613059#comment-14613059 ] Maximilian Alber commented on FLINK-2312: - I'm sorry, but I don't have the time.

[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer

[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613057#comment-14613057 ] ASF GitHub Bot commented on FLINK-2304: --- Github user gyfora commented on the pull re

[GitHub] flink pull request: [FLINK-2304] Add named attribute access to Sto...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-118291459 And it is also related to #879 which we should probably wait before merging these. It is probably a change of 2-3 lines here but it might stall the other PR long if we are

[jira] [Commented] (FLINK-2305) Add documenation about Storm compatibility layer

[ https://issues.apache.org/jira/browse/FLINK-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613053#comment-14613053 ] ASF GitHub Bot commented on FLINK-2305: --- Github user mjsax commented on the pull req

[GitHub] flink pull request: [FLINK-2305] Add documenation about Storm comp...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/884#issuecomment-118287253 FYI: this PR is related to #878 -> if #878 is merged before, this PR needs an update. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer

[ https://issues.apache.org/jira/browse/FLINK-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14613050#comment-14613050 ] ASF GitHub Bot commented on FLINK-2304: --- Github user mjsax commented on the pull req

[GitHub] flink pull request: [FLINK-2304] Add named attribute access to Sto...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/878#issuecomment-118286784 FYI: this PR is "related" to #884 -> if #884 is merged before, this PR needs an update. --- If your project is set up for it, you can reply to this email and have your rep

[GitHub] flink pull request: [Flink-Gelly] [example] added missing assumpti...

GitHub user samk3211 reopened a pull request: https://github.com/apache/flink/pull/883 [Flink-Gelly] [example] added missing assumption to the pageRank example: this is a simplified version of the algorithm so pages must have at least one incoming and one outgoing link You can m

[jira] [Created] (FLINK-2317) Stream Jobs with Windows Leave Lingering State

Aljoscha Krettek created FLINK-2317: --- Summary: Stream Jobs with Windows Leave Lingering State Key: FLINK-2317 URL: https://issues.apache.org/jira/browse/FLINK-2317 Project: Flink Issue Type

[jira] [Resolved] (FLINK-2257) Open and close of RichWindowFunctions is not called

[ https://issues.apache.org/jira/browse/FLINK-2257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park resolved FLINK-2257. Resolution: Fixed Resolved in https://github.com/apache/flink/pull/855 :) > Open and close of RichW

[GitHub] flink pull request: [Flink-Gelly] [example] added missing assumpti...

Github user samk3211 closed the pull request at: https://github.com/apache/flink/pull/883 --- 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 ena

[jira] [Commented] (FLINK-1645) Move StreamingClassloaderITCase to flink-streaming

[ https://issues.apache.org/jira/browse/FLINK-1645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14612966#comment-14612966 ] Robert Metzger commented on FLINK-1645: --- What happened to the test? I can not find i