[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

Github user stefanobaghino commented on the pull request: https://github.com/apache/flink/pull/1581#issuecomment-180985129 I'm not sure of why some tests keep failing. I've also noticed that the build of our fork failed differently. They don't seem to affect `flink-batch-examples`,

[jira] [Commented] (FLINK-3120) Set number of event loop thread and number of buffer pool arenas to same number

[ https://issues.apache.org/jira/browse/FLINK-3120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136268#comment-15136268 ] ASF GitHub Bot commented on FLINK-3120: --- Github user uce commented on the pull request:

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-181040537 I don't see much of a difference here. (1) Of course, we can have a stoppable flag instead of the `JobType`; but I don't see any advantage. Why should it be bad to add

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

[ https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136264#comment-15136264 ] Dongwon Kim commented on FLINK-1502: Anyone making progress in this issue? I found that Hadoop's

[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1581#issuecomment-180994099 The first test failed because some files on travis were corrupted, the two other tests failed probably because the YARN tests became unstable recently. I think

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136221#comment-15136221 ] ASF GitHub Bot commented on FLINK-2021: --- Github user stefanobaghino commented on the pull request:

[GitHub] flink pull request: [FLINK-2721] [Storm Compatibility] Add Tuple m...

Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1591#issuecomment-181032182 Extended `VerifyMetaDataBolt.java` to check if the message ID is of "type" unanchored and fixed the typos. Merging this. --- If your project is set up for it,

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

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

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136216#comment-15136216 ] ASF GitHub Bot commented on FLINK-2021: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3120] [runtime] Manually configure Nett...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1593 --- 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-2721) Add Tuple meta information

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

[jira] [Created] (FLINK-3359) Make RocksDB file copies asynchronous

Stephan Ewen created FLINK-3359: --- Summary: Make RocksDB file copies asynchronous Key: FLINK-3359 URL: https://issues.apache.org/jira/browse/FLINK-3359 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-3312) Add convenience accessor methods for extended state interface

[ https://issues.apache.org/jira/browse/FLINK-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3312. - Resolution: Fixed Fixed via 180cd3f608731208f5b5ed71e3eb80ae5ccdf5fc > Add convenience accessor

[jira] [Commented] (FLINK-3358) Create constructors for FsStateBackend in RocksDBBackens

[ https://issues.apache.org/jira/browse/FLINK-3358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136408#comment-15136408 ] Gyula Fora commented on FLINK-3358: --- I think this is a good idea but I am not completely sure about the

[jira] [Assigned] (FLINK-3357) Drop JobId.toShortString()

[ https://issues.apache.org/jira/browse/FLINK-3357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-3357: -- Assignee: Ufuk Celebi > Drop JobId.toShortString() > -- > >

[GitHub] flink pull request:

Github user alexeyegorov commented on the pull request: https://github.com/apache/flink/commit/21a715867d655bb61df9a9f7eef37e42b99e206a#commitcomment-15941109 @StephanEwen ok, I'm sorry. I was able to build everything only after removing .m2/repository and clearing all caches. Seems

[GitHub] flink pull request: [FLINK-1870] Reintroduce indexed reader functi...

Github user mjsax closed the pull request at: https://github.com/apache/flink/pull/1483 --- 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-1870) Reintroduce Indexed reader functionality to streaming

[ https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136495#comment-15136495 ] ASF GitHub Bot commented on FLINK-1870: --- Github user mjsax closed the pull request at:

[jira] [Created] (FLINK-3358) Create constructors for FsStateBackend in RocksDBBackens

Stephan Ewen created FLINK-3358: --- Summary: Create constructors for FsStateBackend in RocksDBBackens Key: FLINK-3358 URL: https://issues.apache.org/jira/browse/FLINK-3358 Project: Flink Issue

[GitHub] flink pull request: [FLINK-3310] [runtime, runtime-web] Add back p...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/1578#issuecomment-181127247 I've addressed the comments and moved the code to the runtime monitor, which now starts the sample coordinator with an actor to receive the responses (instead of going

[jira] [Commented] (FLINK-3310) Add back pressure statistics to web frontend

[ https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136469#comment-15136469 ] ASF GitHub Bot commented on FLINK-3310: --- Github user uce commented on the pull request:

[jira] [Closed] (FLINK-1870) Reintroduce Indexed reader functionality to streaming

[ https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-1870. -- Resolution: Not A Problem > Reintroduce Indexed reader functionality to streaming >

[jira] [Created] (FLINK-3357) Drop JobId.toShortString()

Stephan Ewen created FLINK-3357: --- Summary: Drop JobId.toShortString() Key: FLINK-3357 URL: https://issues.apache.org/jira/browse/FLINK-3357 Project: Flink Issue Type: Bug Components:

[jira] [Closed] (FLINK-3312) Add convenience accessor methods for extended state interface

[ https://issues.apache.org/jira/browse/FLINK-3312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3312. --- > Add convenience accessor methods for extended state interface >

[jira] [Commented] (FLINK-3357) Drop JobId.toShortString()

[ https://issues.apache.org/jira/browse/FLINK-3357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136415#comment-15136415 ] Ufuk Celebi commented on FLINK-3357: I agree. We had a discussion about this on the ML once with a

[jira] [Commented] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously

[ https://issues.apache.org/jira/browse/FLINK-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136372#comment-15136372 ] Matthias J. Sax commented on FLINK-2504: Again: https://travis-ci.org/mjsax/flink/jobs/107597700

[jira] [Commented] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase

[ https://issues.apache.org/jira/browse/FLINK-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136374#comment-15136374 ] Matthias J. Sax commented on FLINK-2915: One more:

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136357#comment-15136357 ] ASF GitHub Bot commented on FLINK-2111: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-181072411 We have managed to far to not make a distinction between batch and streaming jobs, which was very good. Given that the future plan is that streaming jobs subsume

[jira] [Commented] (FLINK-3351) RocksDB Backend cannot determine correct local db path

[ https://issues.apache.org/jira/browse/FLINK-3351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136348#comment-15136348 ] Stephan Ewen commented on FLINK-3351: - Agreed, the {{FsStateBackend}} does it like that. The

[GitHub] flink pull request: [FLINK-2721] [Storm Compatibility] Add Tuple m...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1591 --- 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-3339) Checkpointing NPE when using filterWithState

[ https://issues.apache.org/jira/browse/FLINK-3339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136347#comment-15136347 ] ASF GitHub Bot commented on FLINK-3339: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-3339] Make ValueState.update(null) act ...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1594#issuecomment-181069421 +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

[jira] [Created] (FLINK-3356) JobClientActorRecoveryITCase.testJobClientRecovery

Matthias J. Sax created FLINK-3356: -- Summary: JobClientActorRecoveryITCase.testJobClientRecovery Key: FLINK-3356 URL: https://issues.apache.org/jira/browse/FLINK-3356 Project: Flink Issue

[jira] [Closed] (FLINK-2721) Add Tuple meta information

[ https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2721. -- Resolution: Fixed > Add Tuple meta information > -- > >

[jira] [Commented] (FLINK-2721) Add Tuple meta information

[ https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136376#comment-15136376 ] ASF GitHub Bot commented on FLINK-2721: --- Github user asfgit closed the pull request at:

[jira] [Created] (FLINK-3362) Potential overflow in NettyBufferPool#getNumberOfAllocatedBytes

Ted Yu created FLINK-3362: - Summary: Potential overflow in NettyBufferPool#getNumberOfAllocatedBytes Key: FLINK-3362 URL: https://issues.apache.org/jira/browse/FLINK-3362 Project: Flink Issue Type: