[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15505669#comment-15505669 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on a diff in the pull

[GitHub] flink pull request #2510: FLINK-3322 Allow drivers and iterators to reuse th...

Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2510#discussion_r79539655 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/operators/JoinDriver.java --- @@ -128,17 +130,22 @@ public void prepare() throws

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15505568#comment-15505568 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the issue:

[GitHub] flink issue #2495: FLINK-3322 - Make sorters to reuse the memory pages alloc...

Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2495 @StephanEwen Thank you. I agree this is a super important piece of FLINK where the memory is involved and that is one reason why I wanted to know its managment and usage and wanted to work

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2452 Sorry for chiming in late. Left some comments on the ML thread. Overall I think it's ok to switch focus on supporting 1.0+ Storm versions only. --- If your project is set up for it, you can

[jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode()

[ https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3222: -- Description: Here is related code: {code} result = 31 * result + (int) (subTaskStats.length ^

[jira] [Updated] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.2 release

[ https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-2765: -- Description: Currently 0.98.11 is used: {code} 0.98.11-hadoop2 {code} Stable release for

[jira] [Updated] (FLINK-3801) Upgrade Joda-Time library to 2.9.3

[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3801: -- Description: Currently yoda-time 2.5 is used which was very old. We should upgrade to 2.9.3 was: Currently

[jira] [Updated] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3734: -- Description: {code} DataInputView in = inputState.getState(getUserCodeClassloader()); final long

[jira] [Updated] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

[ https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4573: -- Description: {code} try {

[jira] [Updated] (FLINK-4533) Unprotected access to meters in StatsDReporter#report()

[ https://issues.apache.org/jira/browse/FLINK-4533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4533: -- Description: Access to meters in AbstractReporter is protected by AbstractReporter.this. Access to meters in

[jira] [Updated] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4534: -- Description: Iteration over state.bucketStates is protected by synchronization in other methods, except for

[GitHub] flink issue #2482: [FLINK-4579] [StateBackend] Add StateBackendFactory for R...

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2482 Hi @StephanEwen , if we want to have a shortcut (`rocksdb`), what should we do? Add the rocksdb dependency into `flink-streaming-java` module ? Or use java reflect ? --- If your project is set

[jira] [Commented] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

[ https://issues.apache.org/jira/browse/FLINK-4579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15505289#comment-15505289 ] ASF GitHub Bot commented on FLINK-4579: --- Github user wuchong commented on the issue:

[jira] [Comment Edited] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15505243#comment-15505243 ] 刘喆 edited comment on FLINK-4632 at 9/20/16 1:26 AM: Yes. The job's status is

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15505243#comment-15505243 ] 刘喆 commented on FLINK-4632: --- Yes. The job's status is canceling, then hung. Web page is ok, client process is

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

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

[GitHub] flink issue #2495: FLINK-3322 - Make sorters to reuse the memory pages alloc...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2495 Is there a section that describes the design that this follows in more detail? I would like to take a look and comment. I am a bit skeptical whether this is going in the right direction.

[jira] [Resolved] (FLINK-4625) Guard Flink processes against blocking shutdown hooks

[ https://issues.apache.org/jira/browse/FLINK-4625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4625. - Resolution: Fixed Fixed via 5066125f9a377d232f77f6fbcac3c22ebea66b39 > Guard Flink processes

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2452 There is not a lot of response on the mailing list. Apparently switching to the newer Storm version does not bother anyone. My guess would be to switch to Strom 1.0+ and remove the storm

[GitHub] flink pull request #2503: [FLINK-4625] [core] Add a safety net to forcibly t...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2503 --- 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-4625) Guard Flink processes against blocking shutdown hooks

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

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79477333 --- Diff: flink-batch-connectors/flink-hbase/src/test/resources/hbase-site.xml --- @@ -1,43 +0,0 @@ - - - - --- End diff -- I'm

[jira] [Commented] (FLINK-4562) table examples make an divided module in flink-examples

[ https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504585#comment-15504585 ] ASF GitHub Bot commented on FLINK-4562: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2460: [FLINK-4562] table examples make an divided module in fli...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2460 I agree. +1 for moving the examples. --- 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

[GitHub] flink issue #2458: [FLINK-4560] enforcer java version as 1.7

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2458 Hi! Can you explain a bit what this pull request fixes? I think Maven complains by itself if the JDK is of a lower version than the compiler target version. So what changes here?

[GitHub] flink issue #2460: [FLINK-4562] table examples make an divided module in fli...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2460 I think this is actually a good idea. The Table API module should not contain the examples. @fhueske @twalthr What do you think about this? --- If your project is set up for it, you

[jira] [Commented] (FLINK-4562) table examples make an divided module in flink-examples

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

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504563#comment-15504563 ] ASF GitHub Bot commented on FLINK-4311: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504565#comment-15504565 ] ASF GitHub Bot commented on FLINK-4311: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504568#comment-15504568 ] ASF GitHub Bot commented on FLINK-4311: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504562#comment-15504562 ] ASF GitHub Bot commented on FLINK-4311: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504569#comment-15504569 ] ASF GitHub Bot commented on FLINK-4311: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504567#comment-15504567 ] ASF GitHub Bot commented on FLINK-4311: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504570#comment-15504570 ] ASF GitHub Bot commented on FLINK-4311: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504566#comment-15504566 ] ASF GitHub Bot commented on FLINK-4311: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-4311) TableInputFormat fails when reused on next split

[ https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504564#comment-15504564 ] ASF GitHub Bot commented on FLINK-4311: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79477173 --- Diff: flink-batch-connectors/flink-hbase/src/test/resources/log4j-test.properties --- @@ -15,9 +15,16 @@ # specific language governing permissions

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79472506 --- Diff: flink-batch-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/TestTableInputFormat.java --- @@ -0,0 +1,112 @@ +/* + *

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79469241 --- Diff: flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -93,32 +102,45 @@ private HTable

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79469197 --- Diff: flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -93,32 +102,45 @@ private HTable

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79469573 --- Diff: flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -131,37 +153,27 @@ public T

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79470876 --- Diff: flink-batch-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/TestTableInputFormat.java --- @@ -0,0 +1,112 @@ +/* + *

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79468879 --- Diff: flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -67,15 +67,24 @@ protected

[GitHub] flink pull request #2330: FLINK-4311 Fixed several problems in TableInputFor...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2330#discussion_r79469513 --- Diff: flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java --- @@ -131,37 +153,27 @@ public T

[jira] [Commented] (FLINK-4560) enforcer java version as 1.7

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

[GitHub] flink issue #2465: [FLINK-4447] [docs] Include NettyConfig options on Config...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2465 I think this is good, please add. It may make sense to have a comment at the top that states that these are advanced network options that one typically does not have to touch. --- If

[jira] [Commented] (FLINK-4447) Include NettyConfig options on Configurations page

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

[jira] [Commented] (FLINK-4447) Include NettyConfig options on Configurations page

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

[jira] [Commented] (FLINK-4510) Always create CheckpointCoordinator

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

[jira] [Commented] (FLINK-4447) Include NettyConfig options on Configurations page

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

[GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2465#discussion_r79476468 --- Diff: docs/setup/config.md --- @@ -169,58 +169,111 @@ Default value is the `akka.ask.timeout`. These parameters configure the default HDFS used

[GitHub] flink issue #2453: [FLINK-4510] [checkpoint] Always create CheckpointCoordin...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2453 Will have a look at this again soon. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-4490) Decouple Slot and Instance

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

[GitHub] flink issue #2447: [FLINK-4490] [distributed coordination] Decouple the JobM...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2447 Was manually merges as of eac6088a75e813a015b778f4cfc4cce0cf2a53ce --- 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

[jira] [Commented] (FLINK-4490) Decouple Slot and Instance

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

[GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2465#discussion_r79476351 --- Diff: docs/setup/config.md --- @@ -169,58 +169,111 @@ Default value is the `akka.ask.timeout`. These parameters configure the default HDFS used

[GitHub] flink pull request #2447: [FLINK-4490] [distributed coordination] Decouple t...

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

[GitHub] flink issue #2369: [FLINK-4035] Add a streaming connector for Apache Kafka 0...

Github user cjstehno commented on the issue: https://github.com/apache/flink/pull/2369 Any thoughts on when this might make it into a release? We are having issues running Flink with Kafka 0.10 and would like to have an idea of whether we can/should wait for this or pull it and try

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504506#comment-15504506 ] ASF GitHub Bot commented on FLINK-4035: --- Github user cjstehno commented on the issue:

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504498#comment-15504498 ] Fabian Hueske commented on FLINK-4624: -- Hmm, that sounds strange. The purpose of the {{Either}} type

[jira] [Commented] (FLINK-4447) Include NettyConfig options on Configurations page

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

[GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2465#discussion_r79474627 --- Diff: docs/setup/config.md --- @@ -169,58 +169,111 @@ Default value is the `akka.ask.timeout`. These parameters configure the default HDFS used

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

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

[GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2467 This is a useful extension. I have pinged someone with more web UI experience to take a look at how it is implemented. Concerning licenses: Where are the png images for the sliders

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

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

[GitHub] flink issue #2508: [FLINK-2662] [dataSet] Translate union with multiple outp...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2508 I think you are right. +1 to merge then --- 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

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504447#comment-15504447 ] Martin Junghanns commented on FLINK-4624: - No, I wanted to have an {{Either}} as

[jira] [Commented] (FLINK-4579) Add StateBackendFactory for RocksDB Backend

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

[GitHub] flink issue #2482: [FLINK-4579] [StateBackend] Add StateBackendFactory for R...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2482 Looks good. I think we could even go one step further and have a shortcut (`rocksdb`) similar to `filesystem` and `jobmanager`. We should then also have dedicated options, like

[jira] [Commented] (FLINK-4594) Validate lower bound in MathUtils.checkedDownCast

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

[GitHub] flink issue #2481: [FLINK-4594] [core] Validate lower bound in MathUtils.che...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2481 Good to merge! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so,

[GitHub] flink pull request #2513: [hotfix] RescalingITCase

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2513#discussion_r79470571 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java --- @@ -670,12 +676,15 @@ public void run(SourceContext

[GitHub] flink pull request #2513: [hotfix] RescalingITCase

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2513#discussion_r79466613 --- Diff: flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java --- @@ -670,12 +676,15 @@ public void run(SourceContext

[jira] [Comment Edited] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504308#comment-15504308 ] Fabian Hueske edited comment on FLINK-4624 at 9/19/16 6:55 PM: --- Did you try

[jira] [Commented] (FLINK-4624) Gelly's summarization algorithm cannot deal with null vertex group values

[ https://issues.apache.org/jira/browse/FLINK-4624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504308#comment-15504308 ] Fabian Hueske commented on FLINK-4624: -- Did you try to ship the {{Either}} types as part of the user

[jira] [Commented] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

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

[GitHub] flink issue #2487: [FLINK-4520][flink-siddhi] Integrate Siddhi as a light-we...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2487 Thank you for that big contribution. Siddhi looks like a cool approach to CEP. Before digging into the details, I would like to start a discussion about whether we should have this as a

[jira] [Commented] (FLINK-4609) Remove redundant check for null in CrossOperator

[ https://issues.apache.org/jira/browse/FLINK-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504283#comment-15504283 ] ASF GitHub Bot commented on FLINK-4609: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2490: [FLINK-4609] Remove redundant check for null in CrossOper...

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2490 This isn't improving performance but moving the null checks before first access and removing the duplicate `DataSet` references. --- If your project is set up for it, you can reply to this email

[jira] [Created] (FLINK-4637) Address Yarn proxy incompatibility with Flink Web UI when service level authorization is enabled

Vijay Srinivasaraghavan created FLINK-4637: -- Summary: Address Yarn proxy incompatibility with Flink Web UI when service level authorization is enabled Key: FLINK-4637 URL:

[jira] [Created] (FLINK-4635) Implement Data Transfer Authentication using shared secret configuration

Vijay Srinivasaraghavan created FLINK-4635: -- Summary: Implement Data Transfer Authentication using shared secret configuration Key: FLINK-4635 URL: https://issues.apache.org/jira/browse/FLINK-4635

[jira] [Created] (FLINK-4636) AbstractCEPPatternOperator fails to restore state

Fabian Hueske created FLINK-4636: Summary: AbstractCEPPatternOperator fails to restore state Key: FLINK-4636 URL: https://issues.apache.org/jira/browse/FLINK-4636 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4609) Remove redundant check for null in CrossOperator

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

[GitHub] flink issue #2490: [FLINK-4609] Remove redundant check for null in CrossOper...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2490 Playing Devil's advocate here: Does this really improve anything meaningful? This is an API-level operator, not anything runtime related, so the additional null check is not really

[jira] [Commented] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504208#comment-15504208 ] Stephan Ewen commented on FLINK-4513: - The fix is to actually edit the Kafka section of the 1.1 docs.

[jira] [Closed] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian closed FLINK-4513. -- Resolution: Not A Problem > Kafka connector documentation refers to Flink

[jira] [Closed] (FLINK-4614) Kafka connector documentation refers to Flink 1.2-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian closed FLINK-4614. -- Resolution: Not A Problem > Kafka connector documentation refers to Flink

[jira] [Commented] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504226#comment-15504226 ] ASF GitHub Bot commented on FLINK-4513: --- Github user nssalian commented on the issue:

[GitHub] flink issue #2493: [FLINK-4513] [Docs]: Kafka connector documentation refers...

Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2493 Thanks @StephanEwen . Closing this one as well. --- 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-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT

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

[jira] [Commented] (FLINK-4610) Replace keySet/getValue with entrySet in UdfAnalyzerUtils

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

[GitHub] flink pull request #2493: [FLINK-4513] [Docs]: Kafka connector documentation...

Github user nssalian closed the pull request at: https://github.com/apache/flink/pull/2493 --- 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 #2491: [FLINK-4610] Replace keySet/getValue with entrySet in Udf...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2491 This change looks reasonable. Merging 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-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT

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

[GitHub] flink issue #2493: [FLINK-4513] [Docs]: Kafka connector documentation refers...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2493 Same here as with the other pull request. The version is correct as it is and should not be changed. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-4609) Remove redundant check for null in CrossOperator

[ https://issues.apache.org/jira/browse/FLINK-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15504184#comment-15504184 ] ASF GitHub Bot commented on FLINK-4609: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2490: [FLINK-4609] Remove redundant check for null in CrossOper...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2490 Thanks for the fast update @apivovarov. PR is good to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[GitHub] flink pull request #2490: [FLINK-4609] Remove redundant check for null in Cr...

Github user apivovarov commented on a diff in the pull request: https://github.com/apache/flink/pull/2490#discussion_r79441284 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/sca/UdfAnalyzerTest.java --- @@ -971,10 +971,7 @@ public void

[jira] [Closed] (FLINK-1151) CollectionDataSource does not provide statistics

[ https://issues.apache.org/jira/browse/FLINK-1151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian closed FLINK-1151. -- Resolution: Information Provided Can solve this by sampling the size of object

  1   2   3   >