[jira] [Created] (FLINK-3804) Update YARN documentation

Till Rohrmann created FLINK-3804: Summary: Update YARN documentation Key: FLINK-3804 URL: https://issues.apache.org/jira/browse/FLINK-3804 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1729) Assess performance of classification algorithms

[ https://issues.apache.org/jira/browse/FLINK-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253665#comment-15253665 ] Till Rohrmann commented on FLINK-1729: -- Hi [~h...@insightdatascience.com], great to hear that you

[jira] [Updated] (FLINK-1729) Assess performance of classification algorithms

[ https://issues.apache.org/jira/browse/FLINK-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1729: - Assignee: hoa nguyen (was: Till Rohrmann) > Assess performance of classification algorithms >

[jira] [Assigned] (FLINK-1729) Assess performance of classification algorithms

[ https://issues.apache.org/jira/browse/FLINK-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-1729: Assignee: Till Rohrmann > Assess performance of classification algorithms >

[jira] [Updated] (FLINK-1743) Add multinomial logistic regression to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1743: - Assignee: David E Drummond (was: Ozturk Gokal) > Add multinomial logistic regression to machine

[jira] [Commented] (FLINK-1743) Add multinomial logistic regression to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253594#comment-15253594 ] Till Rohrmann commented on FLINK-1743: -- I haven't seen any updates on this issue for a long time.

[jira] [Commented] (FLINK-1746) Add linear discriminant analysis to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253654#comment-15253654 ] Till Rohrmann commented on FLINK-1746: -- Hi [~ronaknnath...@gmail.com], great to hear that you want

[jira] [Updated] (FLINK-1746) Add linear discriminant analysis to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1746: - Assignee: Ronak Nathani (was: Raghav Chalapathy) > Add linear discriminant analysis to machine

[jira] [Commented] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type

[ https://issues.apache.org/jira/browse/FLINK-3444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263952#comment-15263952 ] Till Rohrmann commented on FLINK-3444: -- The common nearest super type would be the intersection type

[jira] [Resolved] (FLINK-3809) Missing break in ZooKeeperLeaderRetrievalService#handleStateChange()

[ https://issues.apache.org/jira/browse/FLINK-3809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3809. -- Resolution: Fixed Fixed via 4a69f72a3fa3cfc17cdc473a0c45099416a0ecb8 > Missing break in

[jira] [Resolved] (FLINK-3810) Missing break in ZooKeeperLeaderElectionService#handleStateChange()

[ https://issues.apache.org/jira/browse/FLINK-3810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3810. -- Resolution: Fixed Fixed via 55a88a4bffd5f2ebdae48e5d96d4e9663f0cabdc > Missing break in

[jira] [Closed] (FLINK-3756) Introduce state hierarchy in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-3756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3756. Resolution: Fixed Fixed via 0cf04108f70375d41ebb7c39629db3a081bd2876 > Introduce state hierarchy

[jira] [Closed] (FLINK-3775) Flink Scala shell does not respect Flink configuration

[ https://issues.apache.org/jira/browse/FLINK-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3775. Resolution: Fixed Fixed via 7abf8ef774f14d688213c41b6986ee64aba98740 > Flink Scala shell does not

[jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found.

[ https://issues.apache.org/jira/browse/FLINK-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15257837#comment-15257837 ] Till Rohrmann commented on FLINK-3741: -- I might have found a cure for the problem. I've replaced the

[jira] [Commented] (FLINK-3212) JobManagerCheckpointRecoveryITCase

[ https://issues.apache.org/jira/browse/FLINK-3212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15257835#comment-15257835 ] Till Rohrmann commented on FLINK-3212: -- This time the test case

[jira] [Created] (FLINK-3820) ScalaShellITCase.testPreventRecreationBatch deadlocks on Travis

Till Rohrmann created FLINK-3820: Summary: ScalaShellITCase.testPreventRecreationBatch deadlocks on Travis Key: FLINK-3820 URL: https://issues.apache.org/jira/browse/FLINK-3820 Project: Flink

[jira] [Created] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis

Till Rohrmann created FLINK-3813: Summary: YARNSessionFIFOITCase.testDetachedMode failed on Travis Key: FLINK-3813 URL: https://issues.apache.org/jira/browse/FLINK-3813 Project: Flink Issue

[jira] [Commented] (FLINK-1284) Uniform random sampling operator over windows

[ https://issues.apache.org/jira/browse/FLINK-1284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15259748#comment-15259748 ] Till Rohrmann commented on FLINK-1284: -- Hi [~aouyang1], glad to hear that you wanna work on this

[jira] [Resolved] (FLINK-3708) Scala API for CEP

[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3708. -- Resolution: Fixed Added via e29ac036a76cc78ea608ffe1f0784ec15e351c60 > Scala API for CEP >

[jira] [Closed] (FLINK-3800) ExecutionGraphs can become orphans

[ https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3800. Resolution: Fixed Fixed via 28c57c3a57cbd7a02e756ee98c0b1168cec69feb > ExecutionGraphs can become

[jira] [Updated] (FLINK-3825) Update CEP documentation to include Scala API

[ https://issues.apache.org/jira/browse/FLINK-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3825: - Assignee: Stefan Richter > Update CEP documentation to include Scala API >

[jira] [Created] (FLINK-3825) Update CEP documentation to include Scala API

Till Rohrmann created FLINK-3825: Summary: Update CEP documentation to include Scala API Key: FLINK-3825 URL: https://issues.apache.org/jira/browse/FLINK-3825 Project: Flink Issue Type:

[jira] [Created] (FLINK-3833) flink-test-utils

Till Rohrmann created FLINK-3833: Summary: flink-test-utils Key: FLINK-3833 URL: https://issues.apache.org/jira/browse/FLINK-3833 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-3834) flink-statebackend-rocksdb

Till Rohrmann created FLINK-3834: Summary: flink-statebackend-rocksdb Key: FLINK-3834 URL: https://issues.apache.org/jira/browse/FLINK-3834 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3831) flink-streaming-java

Till Rohrmann created FLINK-3831: Summary: flink-streaming-java Key: FLINK-3831 URL: https://issues.apache.org/jira/browse/FLINK-3831 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3832) flink-streaming-scala

Till Rohrmann created FLINK-3832: Summary: flink-streaming-scala Key: FLINK-3832 URL: https://issues.apache.org/jira/browse/FLINK-3832 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3827) Flink modules include unused dependencies

Till Rohrmann created FLINK-3827: Summary: Flink modules include unused dependencies Key: FLINK-3827 URL: https://issues.apache.org/jira/browse/FLINK-3827 Project: Flink Issue Type:

[jira] [Updated] (FLINK-1284) Uniform random sampling operator over windows

[ https://issues.apache.org/jira/browse/FLINK-1284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1284: - Assignee: Austin Ouyang > Uniform random sampling operator over windows >

[jira] [Created] (FLINK-3829) flink-java

Till Rohrmann created FLINK-3829: Summary: flink-java Key: FLINK-3829 URL: https://issues.apache.org/jira/browse/FLINK-3829 Project: Flink Issue Type: Sub-task Reporter: Till

[jira] [Created] (FLINK-3828) flink-runtime

Till Rohrmann created FLINK-3828: Summary: flink-runtime Key: FLINK-3828 URL: https://issues.apache.org/jira/browse/FLINK-3828 Project: Flink Issue Type: Sub-task Reporter: Till

[jira] [Created] (FLINK-3830) flink-scala

Till Rohrmann created FLINK-3830: Summary: flink-scala Key: FLINK-3830 URL: https://issues.apache.org/jira/browse/FLINK-3830 Project: Flink Issue Type: Sub-task Reporter: Till

[jira] [Commented] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type

[ https://issues.apache.org/jira/browse/FLINK-3444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15260115#comment-15260115 ] Till Rohrmann commented on FLINK-3444: -- I'm wondering why the above described problem was solved by

[jira] [Commented] (FLINK-3199) KafkaITCase.testOneToOneSources

[ https://issues.apache.org/jira/browse/FLINK-3199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15258317#comment-15258317 ] Till Rohrmann commented on FLINK-3199: -- Found another instance:

[jira] [Created] (FLINK-3807) FastFailuresITCase deadlocks on Travis

Till Rohrmann created FLINK-3807: Summary: FastFailuresITCase deadlocks on Travis Key: FLINK-3807 URL: https://issues.apache.org/jira/browse/FLINK-3807 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15286201#comment-15286201 ] Till Rohrmann commented on FLINK-1873: -- Great to hear that you've made good progress with the

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15288605#comment-15288605 ] Till Rohrmann commented on FLINK-1873: -- I fear that you have to make a fake commit to trigger a new

[jira] [Commented] (FLINK-3897) why does jobmanager process has too many ForkJoinTask object

[ https://issues.apache.org/jira/browse/FLINK-3897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15281428#comment-15281428 ] Till Rohrmann commented on FLINK-3897: -- I think that they originate from the different

[jira] [Updated] (FLINK-3862) Restructure community website

[ https://issues.apache.org/jira/browse/FLINK-3862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3862: - Summary: Restructure community website (was: Restructure community slide) > Restructure

[jira] [Created] (FLINK-3862) Restructure community slide

Till Rohrmann created FLINK-3862: Summary: Restructure community slide Key: FLINK-3862 URL: https://issues.apache.org/jira/browse/FLINK-3862 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-3865) ExecutionConfig NullPointerException with second execution

[ https://issues.apache.org/jira/browse/FLINK-3865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270360#comment-15270360 ] Till Rohrmann commented on FLINK-3865: -- Hi Greg, I think your issue is a duplicate of FLINK-3701. >

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15274229#comment-15274229 ] Till Rohrmann commented on FLINK-1873: -- I think it's good to use Flink's matrix and vector

[jira] [Resolved] (FLINK-3825) Update CEP documentation to include Scala API

[ https://issues.apache.org/jira/browse/FLINK-3825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3825. -- Resolution: Fixed Added via 97470aac7c25a1c6f20638afc64fd343239847fb > Update CEP

[jira] [Created] (FLINK-3778) ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration

Till Rohrmann created FLINK-3778: Summary: ScalaShellRemoteStreamEnvironment cannot be forwarded a user configuration Key: FLINK-3778 URL: https://issues.apache.org/jira/browse/FLINK-3778 Project:

[jira] [Assigned] (FLINK-3775) Flink Scala shell does not respect Flink configuration

[ https://issues.apache.org/jira/browse/FLINK-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3775: Assignee: Till Rohrmann > Flink Scala shell does not respect Flink configuration >

[jira] [Commented] (FLINK-3701) Cant call execute after first execution

[ https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247847#comment-15247847 ] Till Rohrmann commented on FLINK-3701: -- Yes that should work. > Cant call execute after first

[jira] [Created] (FLINK-3776) Flink Scala shell does not allow to set configuration for local execution

Till Rohrmann created FLINK-3776: Summary: Flink Scala shell does not allow to set configuration for local execution Key: FLINK-3776 URL: https://issues.apache.org/jira/browse/FLINK-3776 Project:

[jira] [Created] (FLINK-3775) Flink Scala shell does not respect Flink configuration

Till Rohrmann created FLINK-3775: Summary: Flink Scala shell does not respect Flink configuration Key: FLINK-3775 URL: https://issues.apache.org/jira/browse/FLINK-3775 Project: Flink Issue

[jira] [Created] (FLINK-3756) Introduce state hierarchy in CheckpointCoordinator

Till Rohrmann created FLINK-3756: Summary: Introduce state hierarchy in CheckpointCoordinator Key: FLINK-3756 URL: https://issues.apache.org/jira/browse/FLINK-3756 Project: Flink Issue Type:

[jira] [Created] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling

Till Rohrmann created FLINK-3755: Summary: Introduce key groups for key-value state to support dynamic scaling Key: FLINK-3755 URL: https://issues.apache.org/jira/browse/FLINK-3755 Project: Flink

[jira] [Updated] (FLINK-3708) Scala API for CEP

[ https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3708: - Assignee: Stefan Richter > Scala API for CEP > - > > Key:

[jira] [Created] (FLINK-3761) Introduce key group state backend

Till Rohrmann created FLINK-3761: Summary: Introduce key group state backend Key: FLINK-3761 URL: https://issues.apache.org/jira/browse/FLINK-3761 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis

Till Rohrmann created FLINK-3764: Summary: LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis Key: FLINK-3764 URL: https://issues.apache.org/jira/browse/FLINK-3764

[jira] [Updated] (FLINK-3764) LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-3764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3764: - Description: The {{LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification}}

[jira] [Created] (FLINK-3765) ScalaShellITCase deadlocks spuriously

Till Rohrmann created FLINK-3765: Summary: ScalaShellITCase deadlocks spuriously Key: FLINK-3765 URL: https://issues.apache.org/jira/browse/FLINK-3765 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-3762) Kryo StackOverflowError due to disabled Kryo Reference tracking

[ https://issues.apache.org/jira/browse/FLINK-3762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3762: - Assignee: Andrew Palumbo > Kryo StackOverflowError due to disabled Kryo Reference tracking >

[jira] [Created] (FLINK-3800) ExecutionGraphs can become orphans

Till Rohrmann created FLINK-3800: Summary: ExecutionGraphs can become orphans Key: FLINK-3800 URL: https://issues.apache.org/jira/browse/FLINK-3800 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3787) Yarn client does not report unfulfillable container constraints

Till Rohrmann created FLINK-3787: Summary: Yarn client does not report unfulfillable container constraints Key: FLINK-3787 URL: https://issues.apache.org/jira/browse/FLINK-3787 Project: Flink

[jira] [Created] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

Till Rohrmann created FLINK-3774: Summary: Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment Key: FLINK-3774 URL: https://issues.apache.org/jira/browse/FLINK-3774

[jira] [Commented] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type

[ https://issues.apache.org/jira/browse/FLINK-3444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15261720#comment-15261720 ] Till Rohrmann commented on FLINK-3444: -- What kind of cases would that be? I mean the pure var arg

[jira] [Commented] (FLINK-1873) Distributed matrix implementation

[ https://issues.apache.org/jira/browse/FLINK-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15276091#comment-15276091 ] Till Rohrmann commented on FLINK-1873: -- I wouldn't like to bake in the dependency on Breeze, because

[jira] [Resolved] (FLINK-3881) Error in Java 8 Documentation Sample

[ https://issues.apache.org/jira/browse/FLINK-3881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3881. -- Resolution: Fixed Fixed via afd0f16b89683212104e7f41dbd3b557b1f02cc5 > Error in Java 8

[jira] [Created] (FLINK-3885) Revisit parallelism logic

Till Rohrmann created FLINK-3885: Summary: Revisit parallelism logic Key: FLINK-3885 URL: https://issues.apache.org/jira/browse/FLINK-3885 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4152) TaskManager registration exponential backoff doesn't work

[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375296#comment-15375296 ] Till Rohrmann commented on FLINK-4152: -- [~mxm]The restarted registration attempts are the observable

[jira] [Comment Edited] (FLINK-4152) TaskManager registration exponential backoff doesn't work

[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375296#comment-15375296 ] Till Rohrmann edited comment on FLINK-4152 at 7/13/16 4:24 PM: --- The

[jira] [Created] (FLINK-4198) Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time

Till Rohrmann created FLINK-4198: Summary: Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time Key: FLINK-4198 URL:

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

[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402004#comment-15402004 ] Till Rohrmann commented on FLINK-4094: -- I think that having in both cases (preallocate and no

[jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition

[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402000#comment-15402000 ] Till Rohrmann commented on FLINK-3414: -- Hi [~ivan.mushketyk], great to hear that you want to work on

[jira] [Commented] (FLINK-4154) Correction of murmur hash breaks backwards compatibility

[ https://issues.apache.org/jira/browse/FLINK-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15401989#comment-15401989 ] Till Rohrmann commented on FLINK-4154: -- +1 for introducing the correct murmur hash function. >

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402332#comment-15402332 ] Till Rohrmann commented on FLINK-4283: -- I tried to reproduce this issue locally but I was not

[jira] [Commented] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402303#comment-15402303 ] Till Rohrmann commented on FLINK-4296: -- I found the issue. The problem is that a scheduling failure

[jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition

[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15403722#comment-15403722 ] Till Rohrmann commented on FLINK-3414: -- Hi [~ivan.mushketyk], I think it would be a good idea to

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

[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15404095#comment-15404095 ] Till Rohrmann commented on FLINK-4094: -- Is {{preallocate == false}} really supposed to return the

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

[ https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15405660#comment-15405660 ] Till Rohrmann commented on FLINK-3703: -- Hi [~ivan.mushketyk], I think this feature should be part of

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

[ https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15405664#comment-15405664 ] Till Rohrmann commented on FLINK-3318: -- Hi [~ivan.mushketyk], yes I think we need some API calls

[jira] [Resolved] (FLINK-4368) Eagerly initialize RrcProtocol members

[ https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4368. -- Resolution: Done Added via 08af7def60d54c22126b902e6fa57101d5fbb8fa > Eagerly initialize

[jira] [Updated] (FLINK-4368) Eagerly initialize RrcProtocol members

[ https://issues.apache.org/jira/browse/FLINK-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4368: - Assignee: Stephan Ewen > Eagerly initialize RrcProtocol members >

[jira] [Created] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message

Till Rohrmann created FLINK-4383: Summary: Check parameters for serializability before sending a remote RpcInvocation message Key: FLINK-4383 URL: https://issues.apache.org/jira/browse/FLINK-4383

[jira] [Created] (FLINK-4382) Buffer rpc calls until RpcEndpoint is properly started

Till Rohrmann created FLINK-4382: Summary: Buffer rpc calls until RpcEndpoint is properly started Key: FLINK-4382 URL: https://issues.apache.org/jira/browse/FLINK-4382 Project: Flink Issue

[jira] [Assigned] (FLINK-4383) Check parameters for serializability before sending a remote RpcInvocation message

[ https://issues.apache.org/jira/browse/FLINK-4383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4383: Assignee: Till Rohrmann > Check parameters for serializability before sending a remote

[jira] [Created] (FLINK-4395) Eager processing of late arrivals in CEP operator

Till Rohrmann created FLINK-4395: Summary: Eager processing of late arrivals in CEP operator Key: FLINK-4395 URL: https://issues.apache.org/jira/browse/FLINK-4395 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4384: - Assignee: Stephan Ewen (was: Till Rohrmann) > Add a "scheduleRunAsync()" feature to the

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

[ https://issues.apache.org/jira/browse/FLINK-4384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4384: - Assignee: Stephan Ewen > Add a "scheduleRunAsync()" feature to the RpcEndpoint >

[jira] [Commented] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-4072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15418714#comment-15418714 ] Till Rohrmann commented on FLINK-4072: -- {{testTumblingWindow}} failed this time:

[jira] [Resolved] (FLINK-4362) Auto generate message sender classes via Java Proxies

[ https://issues.apache.org/jira/browse/FLINK-4362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4362. -- Resolution: Done Added via 4cde59141688dc12713cd0f41e21b27cd6fa3657 > Auto generate message

[jira] [Created] (FLINK-4390) Add throws clause verification to RpcCompletenessTest

Till Rohrmann created FLINK-4390: Summary: Add throws clause verification to RpcCompletenessTest Key: FLINK-4390 URL: https://issues.apache.org/jira/browse/FLINK-4390 Project: Flink Issue

[jira] [Updated] (FLINK-4386) Add as way to assert that code runs in the RpcEndpoint's Main Thread

[ https://issues.apache.org/jira/browse/FLINK-4386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4386: - Assignee: Stephan Ewen > Add as way to assert that code runs in the RpcEndpoint's Main Thread >

[jira] [Commented] (FLINK-4386) Add as way to assert that code runs in the RpcEndpoint's Main Thread

[ https://issues.apache.org/jira/browse/FLINK-4386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15418851#comment-15418851 ] Till Rohrmann commented on FLINK-4386: -- That will be a really useful feature :-) > Add as way to

[jira] [Updated] (FLINK-4346) Implement basic RPC abstraction

[ https://issues.apache.org/jira/browse/FLINK-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4346: - Description: As part of refactoring of the cluster management, we can introduce a new RPC

[jira] [Commented] (FLINK-4006) ExecutionGraph.restartStrategy field can't be serialized

[ https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15372874#comment-15372874 ] Till Rohrmann commented on FLINK-4006: -- Thanks for spotting this issue [~bowen.zheng]. I think you're

[jira] [Created] (FLINK-4240) Cannot use expressions in Scala Table API's groupBy method

Till Rohrmann created FLINK-4240: Summary: Cannot use expressions in Scala Table API's groupBy method Key: FLINK-4240 URL: https://issues.apache.org/jira/browse/FLINK-4240 Project: Flink

[jira] [Created] (FLINK-4241) Cryptic expression parser exceptions

Till Rohrmann created FLINK-4241: Summary: Cryptic expression parser exceptions Key: FLINK-4241 URL: https://issues.apache.org/jira/browse/FLINK-4241 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-4241) Cryptic expression parser exceptions

[ https://issues.apache.org/jira/browse/FLINK-4241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4241: - Description: The exceptions thrown when giving wrong SQL syntax to Flink's SQL parser is very

[jira] [Closed] (FLINK-4202) Add JM metric which shows the restart duration

[ https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4202. Resolution: Done Added via 5dd85e2867a639e10891209dd59be0136a19ecfa > Add JM metric which shows

[jira] [Created] (FLINK-4242) Improve validation exception messages

Till Rohrmann created FLINK-4242: Summary: Improve validation exception messages Key: FLINK-4242 URL: https://issues.apache.org/jira/browse/FLINK-4242 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4244) Field names for union operator do not have to be equal

Till Rohrmann created FLINK-4244: Summary: Field names for union operator do not have to be equal Key: FLINK-4244 URL: https://issues.apache.org/jira/browse/FLINK-4244 Project: Flink Issue

[jira] [Created] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

Till Rohrmann created FLINK-4248: Summary: CsvTableSource does not support reading SqlTimeTypeInfo types Key: FLINK-4248 URL: https://issues.apache.org/jira/browse/FLINK-4248 Project: Flink

[jira] [Created] (FLINK-4249) CsvTableSource does not support reading SqlTimeTypeInfo types

Till Rohrmann created FLINK-4249: Summary: CsvTableSource does not support reading SqlTimeTypeInfo types Key: FLINK-4249 URL: https://issues.apache.org/jira/browse/FLINK-4249 Project: Flink

[jira] [Created] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment

Till Rohrmann created FLINK-4247: Summary: CsvTableSource.getDataSet() expects Java ExecutionEnvironment Key: FLINK-4247 URL: https://issues.apache.org/jira/browse/FLINK-4247 Project: Flink

[jira] [Created] (FLINK-4235) ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis

Till Rohrmann created FLINK-4235: Summary: ClassLoaderITCase.testDisposeSavepointWithCustomKvState timed out on Travis Key: FLINK-4235 URL: https://issues.apache.org/jira/browse/FLINK-4235 Project:

[jira] [Created] (FLINK-4234) CassandraConnectorTest causes travis build to time out

Till Rohrmann created FLINK-4234: Summary: CassandraConnectorTest causes travis build to time out Key: FLINK-4234 URL: https://issues.apache.org/jira/browse/FLINK-4234 Project: Flink Issue

<    3   4   5   6   7   8   9   10   11   12   >