[jira] [Created] (FLINK-5278) Improve Task and checkpoint logging

Till Rohrmann created FLINK-5278: Summary: Improve Task and checkpoint logging Key: FLINK-5278 URL: https://issues.apache.org/jira/browse/FLINK-5278 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode

Till Rohrmann created FLINK-5285: Summary: CancelCheckpointMarker flood when using at least once mode Key: FLINK-5285 URL: https://issues.apache.org/jira/browse/FLINK-5285 Project: Flink Issu

[jira] [Created] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies

Till Rohrmann created FLINK-5297: Summary: Relocate Flink's Hadoop dependency and its transitive dependencies Key: FLINK-5297 URL: https://issues.apache.org/jira/browse/FLINK-5297 Project: Flink

[jira] [Created] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

Till Rohrmann created FLINK-5300: Summary: FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory Key: FLINK-5300 URL: https://issues.apache.org/jira/browse/FLINK-5300

[jira] [Updated] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

[ https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5300: - Priority: Critical (was: Minor) > FileStateHandle#discard & FsCheckpointStateOutputStream#close t

[jira] [Assigned] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

[ https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-5300: Assignee: Till Rohrmann > FileStateHandle#discard & FsCheckpointStateOutputStream#close tri

[jira] [Commented] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies

[ https://issues.apache.org/jira/browse/FLINK-5297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15735043#comment-15735043 ] Till Rohrmann commented on FLINK-5297: -- Then let's try to first relocate {{aws-java-s

[jira] [Closed] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails

[ https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5193. Resolution: Fixed Fixed in 1.2.0 via add3765d1626a04fb98b8f36cb725eb32806d8b6 Fixed in 1.1.4 via d31

[jira] [Closed] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode

[ https://issues.apache.org/jira/browse/FLINK-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5285. Resolution: Fixed Fixed in 1.2.0 via d3f19a5bead1d0709da733b75d729afa9341c250 Fixed in 1.1.4 via afa

[jira] [Closed] (FLINK-5278) Improve Task and checkpoint logging

[ https://issues.apache.org/jira/browse/FLINK-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5278. Resolution: Fixed Fixed in 1.2.0 via ea7080712f2dcbdf125b806007c80aa3d120f30a Fixed in 1.1.4 via b04

[jira] [Closed] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

[ https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5158. Resolution: Fixed Fixed in 1.2.0 via 0c42d258e9d9d30e7d0f1487ef0ac8b90fa4 Fixed in 1.1.4 via 4b7

[jira] [Assigned] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4973: Assignee: Till Rohrmann (was: Robert Metzger) > Flakey Yarn tests due to recently added la

[jira] [Created] (FLINK-5330) Harden KafkaConsumer08Test

Till Rohrmann created FLINK-5330: Summary: Harden KafkaConsumer08Test Key: FLINK-5330 URL: https://issues.apache.org/jira/browse/FLINK-5330 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-5331) PythonPlanBinderTest idling extremely long

Till Rohrmann created FLINK-5331: Summary: PythonPlanBinderTest idling extremely long Key: FLINK-5331 URL: https://issues.apache.org/jira/browse/FLINK-5331 Project: Flink Issue Type: Improvem

[jira] [Closed] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

[ https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-5300. Resolution: Fixed Fixed in 1.2.0 via 8a7288ea9af6b6822ea1f4022bb08a10b7b82318 Fixed in 1.1.4 via f3d

[jira] [Updated] (FLINK-5331) PythonPlanBinderTest idling extremely long

[ https://issues.apache.org/jira/browse/FLINK-5331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5331: - Attachment: Screen Shot 2016-12-13 at 16.36.38.png Activity monitor showing some of the python pro

[jira] [Resolved] (FLINK-4391) Provide support for asynchronous operations over streams

[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4391. -- Resolution: Fixed Added via f52830763d8f95a955c10265e2c3543a5890e719 > Provide support for asyn

[jira] [Created] (FLINK-5371) Add documentation for async I/O

Till Rohrmann created FLINK-5371: Summary: Add documentation for async I/O Key: FLINK-5371 URL: https://issues.apache.org/jira/browse/FLINK-5371 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable

[ https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15344568#comment-15344568 ] Till Rohrmann commented on FLINK-3704: -- Another instance: https://s3.amazonaws.com/a

[jira] [Assigned] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING

[ https://issues.apache.org/jira/browse/FLINK-4046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4046: Assignee: Till Rohrmann > Failing a restarting job can get stuck in JobStatus.FAILING > ---

[jira] [Closed] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING

[ https://issues.apache.org/jira/browse/FLINK-4046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4046. Resolution: Fixed Fixed via cfe629340205586d54115143ee30428c1f772abc > Failing a restarting job can

[jira] [Created] (FLINK-4112) Replace SuppressRestartException with disabling RestartStrategy

Till Rohrmann created FLINK-4112: Summary: Replace SuppressRestartException with disabling RestartStrategy Key: FLINK-4112 URL: https://issues.apache.org/jira/browse/FLINK-4112 Project: Flink

[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 6420c1c264ed3ce0c32ba164c2cdb85ccdccf265 > ExecutionGraphs can become o

[jira] [Resolved] (FLINK-4113) Always copy first value in ChainedAllReduceDriver

[ https://issues.apache.org/jira/browse/FLINK-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4113. -- Resolution: Fixed Fixed via a6feea32a328f3f3216960298d6c8a5d3f30a234 > Always copy first value

[jira] [Closed] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection

[ https://issues.apache.org/jira/browse/FLINK-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4126. Resolution: Fixed Fixed via dbe41f48745bf52458291290bd2aa0fdc8d18560 > Unstable test ZooKeeperLeade

[jira] [Assigned] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection

[ https://issues.apache.org/jira/browse/FLINK-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4126: Assignee: Till Rohrmann > Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection

[jira] [Commented] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection

[ https://issues.apache.org/jira/browse/FLINK-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15354812#comment-15354812 ] Till Rohrmann commented on FLINK-4126: -- The problem is that the test case times out.

[jira] [Commented] (FLINK-3319) Add or operator to CEP's pattern API

[ https://issues.apache.org/jira/browse/FLINK-3319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15361206#comment-15361206 ] Till Rohrmann commented on FLINK-3319: -- Great to hear :-) I think it's also still eno

[jira] [Assigned] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM

[ https://issues.apache.org/jira/browse/FLINK-4137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4137: Assignee: Till Rohrmann > JobManager web frontend does not shut down on OOM exception on JM

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

Till Rohrmann created FLINK-4154: Summary: Correction of murmur hash breaks backwards compatibility Key: FLINK-4154 URL: https://issues.apache.org/jira/browse/FLINK-4154 Project: Flink Issue

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

[ https://issues.apache.org/jira/browse/FLINK-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4154: - Priority: Blocker (was: Critical) > Correction of murmur hash breaks backwards compatibility > --

[jira] [Commented] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM

[ https://issues.apache.org/jira/browse/FLINK-4137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362690#comment-15362690 ] Till Rohrmann commented on FLINK-4137: -- Do you still have the complete log for the de

[jira] [Comment Edited] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM

[ https://issues.apache.org/jira/browse/FLINK-4137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362690#comment-15362690 ] Till Rohrmann edited comment on FLINK-4137 at 7/5/16 4:06 PM: --

[jira] [Commented] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM

[ https://issues.apache.org/jira/browse/FLINK-4137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362809#comment-15362809 ] Till Rohrmann commented on FLINK-4137: -- I think it is not the problem of the web fron

[jira] [Assigned] (FLINK-4162) Event-Time CEP Job Fails after Restart

[ https://issues.apache.org/jira/browse/FLINK-4162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4162: Assignee: Till Rohrmann > Event-Time CEP Job Fails after Restart >

[jira] [Created] (FLINK-4167) TaskMetricGroup does not close IOMetricGroup

Till Rohrmann created FLINK-4167: Summary: TaskMetricGroup does not close IOMetricGroup Key: FLINK-4167 URL: https://issues.apache.org/jira/browse/FLINK-4167 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4171) StatsD does not accept metrics whose name contains ":"

Till Rohrmann created FLINK-4171: Summary: StatsD does not accept metrics whose name contains ":" Key: FLINK-4171 URL: https://issues.apache.org/jira/browse/FLINK-4171 Project: Flink Issue Ty

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

Till Rohrmann created FLINK-4173: Summary: Replace maven-assembly-plugin by maven-shade-plugin in flink-metrics Key: FLINK-4173 URL: https://issues.apache.org/jira/browse/FLINK-4173 Project: Flink

[jira] [Created] (FLINK-4184) Ganglia and GraphiteReporter report metric names with invalid characters

Till Rohrmann created FLINK-4184: Summary: Ganglia and GraphiteReporter report metric names with invalid characters Key: FLINK-4184 URL: https://issues.apache.org/jira/browse/FLINK-4184 Project: Flink

[jira] [Closed] (FLINK-4171) StatsD does not accept metrics whose name contains ":"

[ https://issues.apache.org/jira/browse/FLINK-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4171. Resolution: Fixed Fixed via 474ec9660c528af8e19898114656fccb3e4747af > StatsD does not accept metri

[jira] [Resolved] (FLINK-3190) Retry rate limits for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3190. -- Resolution: Implemented Added via a7274d5661421a66dcb998efd72b547301e1dc0f > Retry rate limits

[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: https://issues.apache.org/jira/browse/FLINK-41

[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&focusedCommentId=15372874#comment-15372874 ] Till Rohrmann commented on FLINK-4006: -- Thanks for spotting this issue [~bowen.zheng]

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

[ https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4006: Assignee: Till Rohrmann > ExecutionGraph.restartStrategy field can't be serialized > --

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

[ https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4006. Resolution: Fixed Fixed via cc9ee2cc37ed0c7a7f9b0c50cf5edca63e289e1a > ExecutionGraph.restartStrate

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

Till Rohrmann created FLINK-4202: Summary: Add JM metric which shows the restart duration Key: FLINK-4202 URL: https://issues.apache.org/jira/browse/FLINK-4202 Project: Flink Issue Type: Impr

[jira] [Resolved] (FLINK-4123) CassandraWriteAheadSink can hang on cassandra failure

[ https://issues.apache.org/jira/browse/FLINK-4123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4123. -- Resolution: Fixed Fixed via 5c2da21f25741502dd8ca64ce9d314a1ebea1441 > CassandraWriteAheadSink

[jira] [Closed] (FLINK-4167) TaskMetricGroup does not close IOMetricGroup

[ https://issues.apache.org/jira/browse/FLINK-4167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4167. Resolution: Fixed Fixed via d17fe4f636b56f2200444c59a0dead9010dfaa5d > TaskMetricGroup does not clo

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

[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4152: Assignee: Till Rohrmann > TaskManager registration exponential backoff doesn't work > -

[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&focusedCommentId=15375296#comment-15375296 ] Till Rohrmann commented on FLINK-4152: -- [~mxm]The restarted registration attempts are

[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&focusedCommentId=15375296#comment-15375296 ] Till Rohrmann edited comment on FLINK-4152 at 7/13/16 4:24 PM: -

[jira] [Closed] (FLINK-4184) Ganglia and GraphiteReporter report metric names with invalid characters

[ https://issues.apache.org/jira/browse/FLINK-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4184. Resolution: Fixed Fixed via 70094a1818b532f4e0ff31f5debc550ed4336286 > Ganglia and GraphiteReporter

[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 Ty

[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: Fl

[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&focusedCommentId=15386170#comment-15386170 ] Till Rohrmann commented on FLINK-4072: -- Another instance: https://s3.amazonaws.com/a

[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 Issu

[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 cry

[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 Ty

[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 the

[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-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-4250) Cannot select column from CsvTableSource

Till Rohrmann created FLINK-4250: Summary: Cannot select column from CsvTableSource Key: FLINK-4250 URL: https://issues.apache.org/jira/browse/FLINK-4250 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4250) Cannot select column from CsvTableSource

[ https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388074#comment-15388074 ] Till Rohrmann commented on FLINK-4250: -- The problem seems to be more general than the

[jira] [Updated] (FLINK-4250) Cannot select other than first column from Table

[ https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4250: - Summary: Cannot select other than first column from Table (was: Cannot select column from CsvTabl

[jira] [Updated] (FLINK-4250) Cannot select other than first column from Table

[ https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4250: - Priority: Critical (was: Major) > Cannot select other than first column from Table >

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

[ https://issues.apache.org/jira/browse/FLINK-4240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389269#comment-15389269 ] Till Rohrmann commented on FLINK-4240: -- Oh yes, you're right. Sorry stupid mistake. W

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

[ https://issues.apache.org/jira/browse/FLINK-4240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4240. Resolution: Not A Problem > Cannot use expressions in Scala Table API's groupBy method > ---

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

[ https://issues.apache.org/jira/browse/FLINK-4249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389279#comment-15389279 ] Till Rohrmann commented on FLINK-4249: -- Sorry, I must have clicked twice the create i

[jira] [Commented] (FLINK-4250) Cannot select other than first column from Table

[ https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389280#comment-15389280 ] Till Rohrmann commented on FLINK-4250: -- Ah ok that makes sense. And indeed when chang

[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: Fixed Fixed via b3fa459d4c9657e95fdc875d2566b57d48a0a027 > Add JM metric which shows th

[jira] [Closed] (FLINK-4267) Adding async I/O flat map

[ https://issues.apache.org/jira/browse/FLINK-4267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4267. Resolution: Invalid > Adding async I/O flat map > - > > Key:

[jira] [Created] (FLINK-4267) Adding async I/O flat map

Till Rohrmann created FLINK-4267: Summary: Adding async I/O flat map Key: FLINK-4267 URL: https://issues.apache.org/jira/browse/FLINK-4267 Project: Flink Issue Type: New Feature Com

[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&focusedCommentId=15401989#comment-15401989 ] Till Rohrmann commented on FLINK-4154: -- +1 for introducing the correct murmur hash fu

[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&focusedCommentId=15402000#comment-15402000 ] Till Rohrmann commented on FLINK-3414: -- Hi [~ivan.mushketyk], great to hear that you

[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&focusedCommentId=15402004#comment-15402004 ] Till Rohrmann commented on FLINK-4094: -- I think that having in both cases (preallocat

[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&focusedCommentId=15402303#comment-15402303 ] Till Rohrmann commented on FLINK-4296: -- I found the issue. The problem is that a sche

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

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

[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&focusedCommentId=15403722#comment-15403722 ] Till Rohrmann commented on FLINK-3414: -- Hi [~ivan.mushketyk], I think it would be a

[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&focusedCommentId=15404095#comment-15404095 ] Till Rohrmann commented on FLINK-4094: -- Is {{preallocate == false}} really supposed t

[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&focusedCommentId=15405660#comment-15405660 ] Till Rohrmann commented on FLINK-3703: -- Hi [~ivan.mushketyk], I think this feature s

[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&focusedCommentId=15405664#comment-15405664 ] Till Rohrmann commented on FLINK-3318: -- Hi [~ivan.mushketyk], yes I think we need so

[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&focusedCommentId=15411622#comment-15411622 ] Till Rohrmann commented on FLINK-3703: -- Hi [~ivan.mushketyk], Yes you're right with

[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 abstrac

[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 RrcPro

[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-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 Ty

[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 Proj

[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 RpcI

[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 sen

[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] [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 RpcEndpoi

[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&focusedCommentId=15418714#comment-15418714 ] Till Rohrmann commented on FLINK-4072: -- {{testTumblingWindow}} failed this time: htt

[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&focusedCommentId=15418851#comment-15418851 ] Till Rohrmann commented on FLINK-4386: -- That will be a really useful feature :-) > A

[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] [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 Typ

[jira] [Commented] (FLINK-6130) Consider calling resourceManager#getTerminationFuture() with lock held

[ https://issues.apache.org/jira/browse/FLINK-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972620#comment-15972620 ] Till Rohrmann commented on FLINK-6130: -- What is the problem with calling {{getTermina

[jira] [Assigned] (FLINK-1960) Add comments and docs for withForwardedFields and related operators

[ https://issues.apache.org/jira/browse/FLINK-1960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-1960: Assignee: hzhuangzhenxi > Add comments and docs for withForwardedFields and related operato

<    1   2   3   4   5   6   7   8   9   10   >