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
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
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
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
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
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
[
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
[
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
[
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
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
[
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
[
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
> ---
[
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
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
[
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
[
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
[
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
[
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
[
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.
[
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
[
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
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
[
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
> --
[
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
[
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:
--
[
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
[
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
>
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
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
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
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
[
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
[
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
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
[
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]
[
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
> --
[
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
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
[
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
[
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
[
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
> -
[
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
[
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:
-
[
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
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
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
[
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
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
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
[
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
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
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
[
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
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
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
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
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
[
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
[
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
[
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
>
[
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
[
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
> ---
[
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
[
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
[
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
[
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:
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
>
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
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
[
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
[
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
[
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
> -
[
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
[
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
[
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
[
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
> --
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
[
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
[
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
201 - 300 of 12848 matches
Mail list logo