[jira] [Assigned] (FLINK-4407) Implement the trigger DSL

2016-08-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-4407: - Assignee: Kostas Kloudas > Implement the trigger DSL > - > >

[jira] [Created] (FLINK-4407) Implement the trigger DSL

2016-08-17 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4407: - Summary: Implement the trigger DSL Key: FLINK-4407 URL: https://issues.apache.org/jira/browse/FLINK-4407 Project: Flink Issue Type: Bug Reporte

[jira] [Updated] (FLINK-4407) Implement the trigger DSL

2016-08-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4407: -- Description: This issue refers to the implementation of the trigger DSL. The specification of th

[GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a...

2016-08-17 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2342 @uce Updated the PR with suitable doc updates and also renamed the enum > RecoveryMode to > HighAvailabilityMode --- If your project is set up for it, you can rep

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424007#comment-15424007 ] ASF GitHub Bot commented on FLINK-4253: --- Github user ramkrish86 commented on the iss

[jira] [Updated] (FLINK-4407) Implement the trigger DSL

2016-08-17 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4407: -- Description: This issue refers to the implementation of the trigger DSL. The specification of th

[jira] [Assigned] (FLINK-4355) Implement TaskManager side of registration at ResourceManager

2016-08-17 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-4355: Assignee: Stephan Ewen (was: Zhijiang Wang) > Implement TaskManager side of registration a

[GitHub] flink pull request #2377: [Flink-4400][cluster management]Leadership Electio...

2016-08-17 Thread shixiaogang
GitHub user shixiaogang opened a pull request: https://github.com/apache/flink/pull/2377 [Flink-4400][cluster management]Leadership Election among JobManagers - Implement LeaderContender interface in JobMaster. - Create and start the leader election service in JobMaster's bootstr

[jira] [Commented] (FLINK-4363) Implement TaskManager basic startup of all components in java

2016-08-17 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424056#comment-15424056 ] Zhijiang Wang commented on FLINK-4363: -- For yarn and standalone mode, the entrance me

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424065#comment-15424065 ] ASF GitHub Bot commented on FLINK-3298: --- Github user rmetzger commented on the issue

[GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector

2016-08-17 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2314 >>Were there any any dependency issues / conflicts with the user job jar? > >Sorry, what do you mean by the "job jar"? When adding the flink-connector-activemq as a dependency to a ma

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424083#comment-15424083 ] ASF GitHub Bot commented on FLINK-1984: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75080549 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java --- @@ -0,0 +1,755 @@ +/* + *

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75080685 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManager.java --- @@ -0,0 +1,755 @@ +/* + *

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424085#comment-15424085 ] ASF GitHub Bot commented on FLINK-1984: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75080823 --- Diff: flink-dist/pom.xml --- @@ -113,8 +113,13 @@ under the License. flink-metrics-jmx ${project.versi

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424087#comment-15424087 ] ASF GitHub Bot commented on FLINK-1984: --- Github user tillrohrmann commented on a dif

[jira] [Created] (FLINK-4408) JobSubmission

2016-08-17 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-4408: --- Summary: JobSubmission Key: FLINK-4408 URL: https://issues.apache.org/jira/browse/FLINK-4408 Project: Flink Issue Type: Sub-task Components: Cluster

[jira] [Updated] (FLINK-4408) Submit Job and setup ExecutionGraph

2016-08-17 Thread Xiaogang Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaogang Shi updated FLINK-4408: Summary: Submit Job and setup ExecutionGraph (was: JobSubmission) > Submit Job and setup ExecutionG

[GitHub] flink pull request #2314: [FLINK-3298] Implement ActiveMQ streaming connecto...

2016-08-17 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2314#discussion_r75083728 --- Diff: flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java --- @@ -0,0 +1,258

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424131#comment-15424131 ] ASF GitHub Bot commented on FLINK-3298: --- Github user rmetzger commented on a diff in

[GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector

2016-08-17 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2314 @mushketyk: The bahir community is currently setting up a repository for Flink. I think it'll be available in the next days. The connector is almost ready to be merged to bahir. --- If your

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424140#comment-15424140 ] ASF GitHub Bot commented on FLINK-3298: --- Github user rmetzger commented on the issue

[jira] [Commented] (FLINK-4404) Implement Data Transfer SSL

2016-08-17 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424142#comment-15424142 ] Ufuk Celebi commented on FLINK-4404: Feel free to ping me if some input is needed on h

[jira] [Commented] (FLINK-4340) Remove RocksDB Semi-Async Checkpoint Mode

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424162#comment-15424162 ] ASF GitHub Bot commented on FLINK-4340: --- Github user uce commented on the issue:

[GitHub] flink issue #2345: [FLINK-4340] Remove RocksDB Semi-Async Checkpoint Mode

2016-08-17 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2345 +1 to merge this. On a related note: we might want to add information to the checkpoint statistics part of the web frontend saying whether the checkpoints were async or sync. Users might get con

[GitHub] flink pull request #2288: Feature/s3 a fix

2016-08-17 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2288#discussion_r75086582 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/util/HDFSCopyFromLocal.java --- @@ -62,4 +64,34 @@ public void run() {

[GitHub] flink pull request #2288: Feature/s3 a fix

2016-08-17 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2288#discussion_r75086698 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/util/HDFSCopyUtilitiesTest.java --- @@ -70,6 +70,85 @@ public void testCopyFromLocal() th

[jira] [Commented] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection

2016-08-17 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424179#comment-15424179 ] Ufuk Celebi commented on FLINK-4021: After you address the comments (replace return an

[jira] [Commented] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection

2016-08-17 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424183#comment-15424183 ] Zhijiang Wang commented on FLINK-4021: -- got it, i will modify the return and add the

[jira] [Closed] (FLINK-4104) Restructure Gelly docs

2016-08-17 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4104. -- Resolution: Fixed Fix Version/s: 1.2.0 Fixed in b19648e (master). > Restructure Gelly docs > ---

[GitHub] flink pull request #2258: [FLINK-4104] [docs] Restructure Gelly docs

2016-08-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2258 --- 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 enab

[jira] [Commented] (FLINK-4104) Restructure Gelly docs

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424193#comment-15424193 ] ASF GitHub Bot commented on FLINK-4104: --- Github user asfgit closed the pull request

[jira] [Created] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar

2016-08-17 Thread Renkai Ge (JIRA)
Renkai Ge created FLINK-4409: Summary: class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar Key: FLINK-4409 URL: https://issues.apache.org/jira/browse/FLINK-4409 Project: Flink

[GitHub] flink issue #2374: [FLINK-3950] Add Meter Metric Type

2016-08-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2374 I'm not suggesting that they may be useless; my point is that we should not copy/use things without questioning whether they fit the bill. To that end I simply asked questions that came to mind :)

[GitHub] flink pull request #2314: [FLINK-3298] Implement ActiveMQ streaming connecto...

2016-08-17 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/2314#discussion_r75091316 --- Diff: flink-streaming-connectors/flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java --- @@ -0,0 +1,25

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424203#comment-15424203 ] ASF GitHub Bot commented on FLINK-3298: --- Github user mushketyk commented on a diff i

[GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector

2016-08-17 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2314 @rmetzger About the "job jar". Could you suggest how to check this? Is there anything I should do except performing "mvn clean install"? --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424207#comment-15424207 ] ASF GitHub Bot commented on FLINK-3298: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424209#comment-15424209 ] ASF GitHub Bot commented on FLINK-3298: --- Github user mushketyk commented on the issu

[GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector

2016-08-17 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2314 @rmetzger About moving to bahir. Would you (or someone else) merge this into Apache Flink and them move this code with other connectors, or should I create another PR with the AMQ connector for Bah

[GitHub] flink issue #2345: [FLINK-4340] Remove RocksDB Semi-Async Checkpoint Mode

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2345 How about having two times: The "synchronous" component and the "asynchronous" component of the time. Plus probably a total for those that don't want to sum them up themselves. --- If your proj

[jira] [Commented] (FLINK-4340) Remove RocksDB Semi-Async Checkpoint Mode

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424214#comment-15424214 ] ASF GitHub Bot commented on FLINK-4340: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424219#comment-15424219 ] ASF GitHub Bot commented on FLINK-3298: --- Github user rmetzger commented on the issue

[GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector

2016-08-17 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2314 Lets wait for the Bahir GitHub repo being opened and then open a PR there. I can't merge it there myself, because I'm not a committer, but I'm sure they'll merge it once I've done a final review.

[jira] [Assigned] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar

2016-08-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-4409: --- Assignee: Stephan Ewen > class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1

[jira] [Commented] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar

2016-08-17 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424220#comment-15424220 ] Stephan Ewen commented on FLINK-4409: - We want to make Flink independent of Hadoop, so

[jira] [Updated] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar

2016-08-17 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renkai Ge updated FLINK-4409: - Description: It seems all classes in jsr305-1.3.9.jar can be found in flink-shaded-hadoop2-1.1.1.jar,too.

[jira] [Created] (FLINK-4410) Split checkpoint times into synchronous and asynchronous part

2016-08-17 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4410: -- Summary: Split checkpoint times into synchronous and asynchronous part Key: FLINK-4410 URL: https://issues.apache.org/jira/browse/FLINK-4410 Project: Flink Issu

[GitHub] flink pull request #:

2016-08-17 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/commit/68addf39e0e5f9e1656818f923be362680ed93b0#commitcomment-18669730 Really nice abstraction @StephanEwen 👍 . I like it a lot :-) --- If your project is set up for it, you can reply to this e

[GitHub] flink pull request #2378: [FLINK-4409] [build] Exclude JSR 305 from Hadoop d...

2016-08-17 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2378 [FLINK-4409] [build] Exclude JSR 305 from Hadoop dependencies The JSR 305 classes (`javax.annotation`) are already in Flink's core dependencies. I verified that after this patch, the cl

[GitHub] flink issue #2378: [FLINK-4409] [build] Exclude JSR 305 from Hadoop dependen...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2378 @rmetzger If you are okay with this, I'd merge it to 1.2.0 and 1.1.2 --- 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 projec

[jira] [Commented] (FLINK-4363) Implement TaskManager basic startup of all components in java

2016-08-17 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424236#comment-15424236 ] Till Rohrmann commented on FLINK-4363: -- I think you can already start with implementi

[jira] [Commented] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424234#comment-15424234 ] ASF GitHub Bot commented on FLINK-4409: --- GitHub user StephanEwen opened a pull reque

[jira] [Commented] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424235#comment-15424235 ] ASF GitHub Bot commented on FLINK-4409: --- Github user StephanEwen commented on the is

[GitHub] flink pull request #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the...

2016-08-17 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/2360 --- 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

[GitHub] flink issue #2360: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEnd...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2360 Manually merged into the `flip-6` branch in f74f44bb56e50d1714e935df2980a6c8213faf89 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424237#comment-15424237 ] ASF GitHub Bot commented on FLINK-4384: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-4384) Add a "scheduleRunAsync()" feature to the RpcEndpoint

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424238#comment-15424238 ] ASF GitHub Bot commented on FLINK-4384: --- Github user StephanEwen closed the pull req

[GitHub] flink issue #2216: [FLINK-4173] Use shade-plugin in flink-metrics

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2216 Could you recap why do we needs to build fat jars here at all? Simply having the transitive dependencies does not work? --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424240#comment-15424240 ] ASF GitHub Bot commented on FLINK-4173: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2345: [FLINK-4340] Remove RocksDB Semi-Async Checkpoint Mode

2016-08-17 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2345 @StephanEwen That would probably be good, on a side note, time is calculated in the `CheckpointCoordinator` as ` - ` right now. This is somewhat confusing because it does not give the actual

[jira] [Commented] (FLINK-4340) Remove RocksDB Semi-Async Checkpoint Mode

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424244#comment-15424244 ] ASF GitHub Bot commented on FLINK-4340: --- Github user aljoscha commented on the issue

[GitHub] flink issue #2345: [FLINK-4340] Remove RocksDB Semi-Async Checkpoint Mode

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2345 We can keep calculating the total time in the checkpoint coordinator. That way, it included message roundtrips. The state handles (or whatever is the successor to them) should have the s

[jira] [Commented] (FLINK-4340) Remove RocksDB Semi-Async Checkpoint Mode

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424247#comment-15424247 ] ASF GitHub Bot commented on FLINK-4340: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2302: [hotfix] [metrics] Refactor constructors and tests

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2302 Looks good to merge from my side... --- 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 enab

[jira] [Created] (FLINK-4411) [py] Chained dual input children are not properly propagated

2016-08-17 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4411: --- Summary: [py] Chained dual input children are not properly propagated Key: FLINK-4411 URL: https://issues.apache.org/jira/browse/FLINK-4411 Project: Flink

[GitHub] flink pull request #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to ...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2337#discussion_r75097072 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/TypeInfoFactoryTest.java --- @@ -0,0 +1,482 @@ +/* + * Licensed to the Apa

[GitHub] flink pull request #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to ...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2337#discussion_r75097127 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/TypeInfoFactoryTest.java --- @@ -0,0 +1,482 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424257#comment-15424257 ] ASF GitHub Bot commented on FLINK-3042: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424256#comment-15424256 ] ASF GitHub Bot commented on FLINK-3042: --- Github user StephanEwen commented on a diff

[jira] [Assigned] (FLINK-4363) Implement TaskManager basic startup of all components in java

2016-08-17 Thread Zhijiang Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang Wang reassigned FLINK-4363: Assignee: Zhijiang Wang > Implement TaskManager basic startup of all components in java > -

[jira] [Updated] (FLINK-4407) Implement the trigger DSL

2016-08-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4407: Issue Type: Sub-task (was: Bug) Parent: FLINK-3643 > Implement the trigger DSL > --

[GitHub] flink pull request #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to ...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2337#discussion_r75097330 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/TypeInfoFactoryTest.java --- @@ -0,0 +1,482 @@ +/* + * Licensed to the Apa

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424260#comment-15424260 ] ASF GitHub Bot commented on FLINK-3042: --- Github user StephanEwen commented on a diff

[GitHub] flink issue #2216: [FLINK-4173] Use shade-plugin in flink-metrics

2016-08-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2216 It would work but is more work for the user and is less prone to version mismatches. Not using a fat-jar means that the users have to provide the dependencies and put them in the `/libs` folder themse

[jira] [Commented] (FLINK-4173) Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424263#comment-15424263 ] ASF GitHub Bot commented on FLINK-4173: --- Github user zentol commented on the issue:

[GitHub] flink issue #2337: [FLINK-3042] [FLINK-3060] [types] Define a way to let typ...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2337 Looks quite good all in all. Especially since we had quite thorough tests in the type extractor before and they still pass. The only thing this needs is a few more Scala API tests, in my

[GitHub] flink issue #2300: [FLINK-4245] [metrics] Expose all defined variables

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2300 I am taking a look at this now... --- 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 enable

[jira] [Commented] (FLINK-4245) Metric naming improvements

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424266#comment-15424266 ] ASF GitHub Bot commented on FLINK-4245: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-3042) Define a way to let types create their own TypeInformation

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424265#comment-15424265 ] ASF GitHub Bot commented on FLINK-3042: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2353: [FLINK-4355] [cluster management] Implement TaskManager s...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2353 Manually merged into the `flip-6` feature branch in https://github.com/apache/flink/commit/68addf39e0e5f9e1656818f923be362680ed93b0 --- If your project is set up for it, you can reply to this em

[GitHub] flink pull request #2353: [FLINK-4355] [cluster management] Implement TaskMa...

2016-08-17 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/2353 --- 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-4355) Implement TaskManager side of registration at ResourceManager

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424272#comment-15424272 ] ASF GitHub Bot commented on FLINK-4355: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-4355) Implement TaskManager side of registration at ResourceManager

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424271#comment-15424271 ] ASF GitHub Bot commented on FLINK-4355: --- Github user StephanEwen closed the pull req

[jira] [Updated] (FLINK-4411) [py] Chained dual input children are not properly propagated

2016-08-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4411: Fix Version/s: (was: 1.1.1) 1.1.2 > [py] Chained dual input children

[jira] [Created] (FLINK-4412) [py] Chaining does not properly handle broadcast variables

2016-08-17 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4412: --- Summary: [py] Chaining does not properly handle broadcast variables Key: FLINK-4412 URL: https://issues.apache.org/jira/browse/FLINK-4412 Project: Flink

[GitHub] flink issue #2378: [FLINK-4409] [build] Exclude JSR 305 from Hadoop dependen...

2016-08-17 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2378 +1 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 wishes so, or if th

[jira] [Commented] (FLINK-4409) class conflict between jsr305-1.3.9.jar and flink-shaded-hadoop2-1.1.1.jar

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424349#comment-15424349 ] ASF GitHub Bot commented on FLINK-4409: --- Github user rmetzger commented on the issue

[jira] [Closed] (FLINK-4411) [py] Chained dual input children are not properly propagated

2016-08-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4411. --- Resolution: Fixed Fixed in 1050847787b416399a6c03c0568969df93ed4822 and aa50e226c318f6f52ffdf

[jira] [Closed] (FLINK-4412) [py] Chaining does not properly handle broadcast variables

2016-08-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4412. --- Resolution: Fixed Fixed in 84d28ba00f3e63a83132c1666c8dc8deec7800ba and 445eaa986dca59b124582

[GitHub] flink issue #2302: [hotfix] [metrics] Refactor constructors and tests

2016-08-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2302 merging --- 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 feat

[GitHub] flink issue #2349: [FLINK-4365] [metrics] Add documentation to MetricConfig

2016-08-17 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2349 merging --- 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 feat

[jira] [Commented] (FLINK-4365) [metrics] MetricConfig has no documentation

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424379#comment-15424379 ] ASF GitHub Bot commented on FLINK-4365: --- Github user zentol commented on the issue:

[GitHub] flink pull request #2302: [hotfix] [metrics] Refactor constructors and tests

2016-08-17 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2302 --- 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 enab

[jira] [Updated] (FLINK-4302) Add JavaDocs to MetricConfig

2016-08-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4302: Fix Version/s: 1.1.2 1.2.0 > Add JavaDocs to MetricConfig > -

[jira] [Commented] (FLINK-4365) [metrics] MetricConfig has no documentation

2016-08-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424384#comment-15424384 ] ASF GitHub Bot commented on FLINK-4365: --- Github user zentol closed the pull request

[GitHub] flink pull request #2349: [FLINK-4365] [metrics] Add documentation to Metric...

2016-08-17 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/2349 --- 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 enab

[jira] [Closed] (FLINK-4302) Add JavaDocs to MetricConfig

2016-08-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4302. --- Resolution: Fixed Fixed in c5a9a3eb0061014fe59086505130596e924db7f9 and cbce10d100a1924747603

[GitHub] flink pull request #2315: [FLINK-1984] Integrate Flink with Apache Mesos (T1...

2016-08-17 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2315#discussion_r75109625 --- Diff: flink-dist/pom.xml --- @@ -113,8 +113,13 @@ under the License. flink-metrics-jmx ${project.versio

  1   2   3   4   >