[jira] [Issue Comment Deleted] (FLINK-3298) Streaming connector for ActiveMQ

2016-08-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-3298: --- Comment: was deleted (was: Formally defining how we deal with new connector

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

2016-08-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15410496#comment-15410496 ] Tzu-Li (Gordon) Tai commented on FLINK-3298: Formally defining how we deal with new connector

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

2016-08-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15410494#comment-15410494 ] Tzu-Li (Gordon) Tai commented on FLINK-3298: Formally defining how we deal with new connector

[jira] [Commented] (FLINK-4266) Remote Database Statebackend

2016-08-05 Thread Chen Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15410474#comment-15410474 ] Chen Qin commented on FLINK-4266: -

[jira] [Commented] (FLINK-1638) SimpleKafkaSource connector

2016-08-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15410471#comment-15410471 ] Tzu-Li (Gordon) Tai commented on FLINK-1638: Can we close this, as it seems to be resolved

[jira] [Updated] (FLINK-4266) Remote Storage Statebackend

2016-08-05 Thread Chen Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-4266: Description: Current FileSystem statebackend limits whole state size to disk space. Dealing with scale out

[jira] [Updated] (FLINK-4266) Remote Database Statebackend

2016-08-05 Thread Chen Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-4266: Summary: Remote Database Statebackend (was: Remote Storage Statebackend) > Remote Database Statebackend >

[jira] [Updated] (FLINK-4266) Remote Storage Statebackend

2016-08-05 Thread Chen Qin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen Qin updated FLINK-4266: Summary: Remote Storage Statebackend (was: Cassandra StateBackend) > Remote Storage Statebackend >

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15410447#comment-15410447 ] ASF GitHub Bot commented on FLINK-2055: --- Github user delding commented on the issue:

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-05 Thread delding
Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 Hi @tzulitai Thank you for all the comments :-) I will update the PR and add an example in next a few days --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-05 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2332 @delding Thank you for working on this contribution. Since I'm not that familiar with the HBase client API, I've only skimmed through the code for now. Will try to review in detail later.

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-05 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r73779379 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseSink.java --- @@ -0,0 +1,100 @@

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-05 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r73779331 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseClient.java --- @@ -0,0 +1,66 @@

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-05 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r73779327 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseMapper.java --- @@ -0,0 +1,97 @@

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-05 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r73779299 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseSink.java --- @@ -0,0 +1,100 @@

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-05 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r73779290 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseSink.java --- @@ -0,0 +1,100 @@

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-05 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r73779255 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseSink.java --- @@ -0,0 +1,100 @@

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-05 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r73779190 --- Diff: flink-streaming-connectors/flink-connector-hbase/pom.xml --- @@ -0,0 +1,68 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15410381#comment-15410381 ] ASF GitHub Bot commented on FLINK-2055: --- Github user delding commented on the issue:

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-05 Thread delding
Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 BTW, failing tests are results of 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] [Created] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

2016-08-05 Thread Elias Levy (JIRA)
Elias Levy created FLINK-4326: - Summary: Flink start-up scripts should optionally start services on the foreground Key: FLINK-4326 URL: https://issues.apache.org/jira/browse/FLINK-4326 Project: Flink

[jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409961#comment-15409961 ] Stephan Ewen commented on FLINK-4322: - I would like to make some more radical changes to the current

[jira] [Updated] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4322: Issue Type: Improvement (was: Bug) > Unify CheckpointCoordinator and SavepointCoordinator >

[jira] [Created] (FLINK-4325) Implement Web UI HTTPS

2016-08-05 Thread Suresh Krishnappa (JIRA)
Suresh Krishnappa created FLINK-4325: Summary: Implement Web UI HTTPS Key: FLINK-4325 URL: https://issues.apache.org/jira/browse/FLINK-4325 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4324) Enable Akka SSL

2016-08-05 Thread Suresh Krishnappa (JIRA)
Suresh Krishnappa created FLINK-4324: Summary: Enable Akka SSL Key: FLINK-4324 URL: https://issues.apache.org/jira/browse/FLINK-4324 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4323. --- > Checkpoint Coordinator Removes HA Checkpoints in Shutdown >

[jira] [Resolved] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4323. - Resolution: Invalid Shutdown hook is only installed in "standalone" mode, which in the

[jira] [Created] (FLINK-4323) Checkpoint Coordinator Removes HA Checkpoints in Shutdown

2016-08-05 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4323: --- Summary: Checkpoint Coordinator Removes HA Checkpoints in Shutdown Key: FLINK-4323 URL: https://issues.apache.org/jira/browse/FLINK-4323 Project: Flink Issue

[jira] [Closed] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4297. --- > Yarn client can't determine fat jar location if path contains spaces >

[jira] [Resolved] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4297. - Resolution: Fixed Fixed for - 1.2.0 via c7a85545ba73e93e4a55ef8886362badaa2e2147 - 1.1.1 via

[jira] [Resolved] (FLINK-4312) Remove Serializabiliy of ExecutionGraph

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4312. - Resolution: Fixed Fixed via c9b0dad89b79f11ce13fe78f8a0823b8266f930f (Commit has JIRA issue tag

[jira] [Closed] (FLINK-4312) Remove Serializabiliy of ExecutionGraph

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4312. --- > Remove Serializabiliy of ExecutionGraph > --- > >

[jira] [Commented] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

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

[jira] [Commented] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

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

[GitHub] flink pull request #2320: [FLINK-4297][yarn] decode URL encoded fat jar path

2016-08-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2320 --- 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 pull request #2334: [FLINK-4310] [build] Selectively run API compatibi...

2016-08-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2334 --- 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-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-05 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409799#comment-15409799 ] ramkrishna.s.vasudevan commented on FLINK-4322: --- bq.jobs should be able to resume from

[jira] [Created] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-05 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4322: --- Summary: Unify CheckpointCoordinator and SavepointCoordinator Key: FLINK-4322 URL: https://issues.apache.org/jira/browse/FLINK-4322 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

2016-08-05 Thread Aditi Viswanathan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409770#comment-15409770 ] Aditi Viswanathan commented on FLINK-4282: -- I had to do that because the processing time triggers

[jira] [Created] (FLINK-4321) Initialize TaskExecutions directly with their starting state

2016-08-05 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4321: --- Summary: Initialize TaskExecutions directly with their starting state Key: FLINK-4321 URL: https://issues.apache.org/jira/browse/FLINK-4321 Project: Flink

[jira] [Commented] (FLINK-4318) Make master docs build target version-specific

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409616#comment-15409616 ] Stephan Ewen commented on FLINK-4318: - I think this idea sounds good. Can we still have a

[jira] [Created] (FLINK-4320) Fix misleading ScheduleMode names

2016-08-05 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4320: --- Summary: Fix misleading ScheduleMode names Key: FLINK-4320 URL: https://issues.apache.org/jira/browse/FLINK-4320 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4319) Rework Cluster Management (FLIP-6)

2016-08-05 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4319: --- Summary: Rework Cluster Management (FLIP-6) Key: FLINK-4319 URL: https://issues.apache.org/jira/browse/FLINK-4319 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

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

[GitHub] flink issue #2333: [FLINK-4282] [streaming] Add Offset Parameter to WindowAs...

2016-08-05 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2333 IMHO, the offset should not be added to `TimeWindow`. It is only the assigners that would shift the start time/end time of a window. This way, other parts of the code don't need to be aware of

[GitHub] flink issue #2338: [FLINK-4316] [core] [hadoop compatibility] Make flink-cor...

2016-08-05 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2338 @StephanEwen that's exactly what I was just going to suggest for Scala. 👍 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-4316) Make flink-core independent of Hadoop

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

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409491#comment-15409491 ] Stephan Ewen commented on FLINK-4094: - The warning has been added in

[jira] [Resolved] (FLINK-4308) Allow uploaded jar directory to be configurable

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4308. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 8d4a64d7afd33bfe56135c06501adffd241348bd

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

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

[jira] [Commented] (FLINK-4308) Allow uploaded jar directory to be configurable

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

[jira] [Closed] (FLINK-4308) Allow uploaded jar directory to be configurable

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4308. --- > Allow uploaded jar directory to be configurable > > >

[GitHub] flink pull request #2335: [FLINK-4308] Allow uploaded jar directory to be co...

2016-08-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2335 --- 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 pull request #2336: FLINK-4094 Off heap memory deallocation might not ...

2016-08-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2336 --- 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-4291) No log entry for unscheduled reporters

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

[GitHub] flink issue #2318: [FLINK-4291] Add log entry for scheduled reporters

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2318 +1 to merge this --- 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,

[jira] [Commented] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

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

[GitHub] flink issue #2320: [FLINK-4297][yarn] decode URL encoded fat jar path

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2320 Will address the comment and merge this... --- 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-3138) Method References are not supported as lambda expressions

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

[GitHub] flink issue #2329: [FLINK-3138] [types] Method References are not supported ...

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2329 Looks good to me. Has nice tests and the Travis CI failures are cache/jar file issues, i.e., unrelated. +1 to merge this --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

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

[GitHub] flink issue #2334: [FLINK-4310] [build] Selectively run API compatibility ch...

2016-08-05 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2334 Changes look good and make sense. +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

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

2016-08-05 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan reassigned FLINK-4253: - Assignee: ramkrishna.s.vasudevan > Rename "recovery.mode" config key to

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

2016-08-05 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409453#comment-15409453 ] ramkrishna.s.vasudevan commented on FLINK-4253: --- I can take this up. > Rename

[jira] [Commented] (FLINK-4276) TextInputFormatTest.testNestedFileRead fails on Windows OS

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

[GitHub] flink issue #2312: [FLINK-4276] Fix TextInputFormatTest#testNestedFileRead

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2312 +1 to merge this --- 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,

[jira] [Commented] (FLINK-4316) Make flink-core independent of Hadoop

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

[GitHub] flink issue #2338: [FLINK-4316] [core] [hadoop compatibility] Make flink-cor...

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2338 The Scala type extraction has now also been addressed. --- 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

[jira] [Created] (FLINK-4318) Make master docs build target version-specific

2016-08-05 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4318: -- Summary: Make master docs build target version-specific Key: FLINK-4318 URL: https://issues.apache.org/jira/browse/FLINK-4318 Project: Flink Issue Type:

[jira] [Created] (FLINK-4317) Restructure documentation

2016-08-05 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4317: -- Summary: Restructure documentation Key: FLINK-4317 URL: https://issues.apache.org/jira/browse/FLINK-4317 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4316) Make flink-core independent of Hadoop

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

[GitHub] flink pull request #2338: [FLINK-4316] [core] [hadoop compatibility] Make fl...

2016-08-05 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2338 [FLINK-4316] [core] [hadoop compatibility] Make flink-core independent of Hadoop This pull request moves all 'Writable' related code to the 'flink-hadoop-compatibility' project and uses

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

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

[GitHub] flink issue #2336: FLINK-4094 Off heap memory deallocation might not properl...

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2336 Looks good, will merge this... --- 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] [Commented] (FLINK-4316) Make flink-core independent of Hadoop

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409384#comment-15409384 ] Stephan Ewen commented on FLINK-4316: - An alternative would be to copy the Hadoop {{Writable}} type

[jira] [Created] (FLINK-4316) Make flink-core independent of Hadoop

2016-08-05 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4316: --- Summary: Make flink-core independent of Hadoop Key: FLINK-4316 URL: https://issues.apache.org/jira/browse/FLINK-4316 Project: Flink Issue Type: Bug

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

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

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

2016-08-05 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2337 [FLINK-3042] [FLINK-3060] [types] Define a way to let types create their own TypeInformation Thanks for contributing to Apache Flink. Before you open your pull request, please take the following

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-05 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409350#comment-15409350 ] ramkrishna.s.vasudevan commented on FLINK-4094: --- Updated the PR. Pls check. [~StephanEwen]

[jira] [Created] (FLINK-4315) Remove Hadoop Dependency from flink-java

2016-08-05 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4315: --- Summary: Remove Hadoop Dependency from flink-java Key: FLINK-4315 URL: https://issues.apache.org/jira/browse/FLINK-4315 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-4310) Move BinaryCompatibility Check plugin to relevant projects

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

[GitHub] flink issue #2334: [FLINK-4310] [build] Selectively run API compatibility ch...

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2334 True, the `flink-metrics-core` would not need it right now. I added it because it is somehow part of the public API. We would need to re-add the annotations dependency - for that, let's

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

2016-08-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15409290#comment-15409290 ] Stephan Ewen commented on FLINK-3950: - What kind of Meter do we want to add here? Two possible options

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

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

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

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

[GitHub] flink issue #2336: FLINK-4094 Off heap memory deallocation might not properl...

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2336 Two small comments, otherwise this looks good. --- 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

[GitHub] flink pull request #2336: FLINK-4094 Off heap memory deallocation might not ...

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2336#discussion_r73670793 --- Diff: docs/setup/config.md --- @@ -83,7 +83,8 @@ The default fraction for managed memory can be adjusted using the `taskmanager.m -

[GitHub] flink pull request #2336: FLINK-4094 Off heap memory deallocation might not ...

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2336#discussion_r73670834 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java --- @@ -53,6 +55,7 @@ */ public class MemoryManager

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

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

[jira] [Commented] (FLINK-4308) Allow uploaded jar directory to be configurable

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

[GitHub] flink issue #2335: [FLINK-4308] Allow uploaded jar directory to be configura...

2016-08-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2335 Looks good to me. +1, will merge this --- 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] [Closed] (FLINK-4314) Test instability in JobManagerHAJobGraphRecoveryITCase.testJobPersistencyWhenJobManagerShutdown

2016-08-05 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4314. -- Resolution: Fixed Fix Version/s: 1.1.1 1.2.0 Fixed in 0870007 (master),

  1   2   >