[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432553#comment-15432553 ] ASF GitHub Bot commented on FLINK-3702: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432557#comment-15432557 ] ASF GitHub Bot commented on FLINK-3702: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432566#comment-15432566 ] ASF GitHub Bot commented on FLINK-3702: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432569#comment-15432569 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432577#comment-15432577 ] ASF GitHub Bot commented on FLINK-3702: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid

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

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432684#comment-15432684 ] ASF GitHub Bot commented on FLINK-4348: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432682#comment-15432682 ] ASF GitHub Bot commented on FLINK-4348: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4363) Implement TaskManager basic startup of all components in java

[ https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432743#comment-15432743 ] ASF GitHub Bot commented on FLINK-4363: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

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

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

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

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432812#comment-15432812 ] ASF GitHub Bot commented on FLINK-4348: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432821#comment-15432821 ] ASF GitHub Bot commented on FLINK-4348: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432825#comment-15432825 ] ASF GitHub Bot commented on FLINK-4348: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432811#comment-15432811 ] ASF GitHub Bot commented on FLINK-3702: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432834#comment-15432834 ] ASF GitHub Bot commented on FLINK-4348: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4443) Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint

[ https://issues.apache.org/jira/browse/FLINK-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432850#comment-15432850 ] ASF GitHub Bot commented on FLINK-4443: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432886#comment-15432886 ] ASF GitHub Bot commented on FLINK-3702: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't

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

[jira] [Commented] (FLINK-4431) Introduce a "VisibleForTesting" annotation

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-4271) There is no way to set parallelism of operators produced by CoGroupedStreams

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-4436) Unclosed DataOutputBuffer in Utils#setTokensFor()

[ https://issues.apache.org/jira/browse/FLINK-4436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432864#comment-15432864 ] ASF GitHub Bot commented on FLINK-4436: --- Github user tedyu commented on a diff in th

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

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

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't

[ https://issues.apache.org/jira/browse/FLINK-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432950#comment-15432950 ] ASF GitHub Bot commented on FLINK-3866: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

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

[jira] [Commented] (FLINK-4355) Implement TaskManager side of registration at ResourceManager

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

[jira] [Commented] (FLINK-4434) Add a testing RPC service

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

[jira] [Commented] (FLINK-4434) Add a testing RPC service

[ https://issues.apache.org/jira/browse/FLINK-4434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432972#comment-15432972 ] ASF GitHub Bot commented on FLINK-4434: --- Github user StephanEwen closed the pull req

[jira] [Commented] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation

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

[jira] [Commented] (FLINK-4355) Implement TaskManager side of registration at ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432968#comment-15432968 ] ASF GitHub Bot commented on FLINK-4355: --- Github user StephanEwen closed the pull req

[jira] [Commented] (FLINK-4317) Restructure documentation

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

[jira] [Commented] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction

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

[jira] [Commented] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction

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

[jira] [Commented] (FLINK-4431) Introduce a "VisibleForTesting" annotation

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

[jira] [Commented] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction

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

[jira] [Commented] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid

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

[jira] [Commented] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction

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

[jira] [Commented] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction

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

[jira] [Commented] (FLINK-4389) Expose metrics to Webfrontend

[ https://issues.apache.org/jira/browse/FLINK-4389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433097#comment-15433097 ] ASF GitHub Bot commented on FLINK-4389: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-4451) Throw exception when remote connection cannot be resolved

[ https://issues.apache.org/jira/browse/FLINK-4451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433096#comment-15433096 ] ASF GitHub Bot commented on FLINK-4451: --- GitHub user tillrohrmann opened a pull requ

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

[ https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433102#comment-15433102 ] ASF GitHub Bot commented on FLINK-4294: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

[ https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433113#comment-15433113 ] ASF GitHub Bot commented on FLINK-4294: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

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

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

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

[jira] [Commented] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

[ https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433127#comment-15433127 ] ASF GitHub Bot commented on FLINK-4273: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4454) Lookups for JobManager address in config

[ https://issues.apache.org/jira/browse/FLINK-4454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433129#comment-15433129 ] ASF GitHub Bot commented on FLINK-4454: --- GitHub user mxm opened a pull request:

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433133#comment-15433133 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the iss

[jira] [Commented] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

[ https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433140#comment-15433140 ] ASF GitHub Bot commented on FLINK-4273: --- Github user mxm commented on a diff in the

[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&focusedCommentId=15433144#comment-15433144 ] ASF GitHub Bot commented on FLINK-4035: --- Github user rmetzger commented on the issue

[jira] [Commented] (FLINK-4417) Checkpoints should be subsumed by CheckpointID not, by timestamp

[ https://issues.apache.org/jira/browse/FLINK-4417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433145#comment-15433145 ] ASF GitHub Bot commented on FLINK-4417: --- GitHub user ramkrish86 opened a pull reques

[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&focusedCommentId=15433146#comment-15433146 ] ASF GitHub Bot commented on FLINK-4035: --- Github user rmetzger commented on a diff in

[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&focusedCommentId=15433148#comment-15433148 ] ASF GitHub Bot commented on FLINK-4035: --- Github user rmetzger commented on a diff in

[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&focusedCommentId=15433152#comment-15433152 ] ASF GitHub Bot commented on FLINK-4035: --- Github user rmetzger commented on the issue

[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&focusedCommentId=15433151#comment-15433151 ] ASF GitHub Bot commented on FLINK-4035: --- Github user rmetzger commented on a diff in

[jira] [Commented] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

[ https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433169#comment-15433169 ] ASF GitHub Bot commented on FLINK-4273: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4451) Throw exception when remote connection cannot be resolved

[ https://issues.apache.org/jira/browse/FLINK-4451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433174#comment-15433174 ] ASF GitHub Bot commented on FLINK-4451: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-4451) Throw exception when remote connection cannot be resolved

[ https://issues.apache.org/jira/browse/FLINK-4451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433179#comment-15433179 ] ASF GitHub Bot commented on FLINK-4451: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation

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

[jira] [Commented] (FLINK-4451) Throw exception when remote connection cannot be resolved

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

[jira] [Commented] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction

[ https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433186#comment-15433186 ] ASF GitHub Bot commented on FLINK-3899: --- Github user danielblazevski commented on a

[jira] [Commented] (FLINK-4441) RocksDB statebackend makes all operators appear stateful

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

[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&focusedCommentId=15433195#comment-15433195 ] ASF GitHub Bot commented on FLINK-4035: --- Github user eliaslevy commented on the issu

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433196#comment-15433196 ] ASF GitHub Bot commented on FLINK-3702: --- Github user ggevay commented on a diff in t

[jira] [Commented] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

[ https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433199#comment-15433199 ] ASF GitHub Bot commented on FLINK-4273: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction

[ https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433187#comment-15433187 ] ASF GitHub Bot commented on FLINK-3899: --- Github user danielblazevski commented on a

[jira] [Commented] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

[ https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433202#comment-15433202 ] ASF GitHub Bot commented on FLINK-3702: --- Github user ggevay commented on a diff in t

[jira] [Commented] (FLINK-4273) Refactor JobClientActor to watch already submitted jobs

[ https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433204#comment-15433204 ] ASF GitHub Bot commented on FLINK-4273: --- Github user mxm commented on a diff in the

[jira] [Commented] (FLINK-4452) TaskManager network buffer gauges

[ https://issues.apache.org/jira/browse/FLINK-4452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433407#comment-15433407 ] ASF GitHub Bot commented on FLINK-4452: --- GitHub user greghogan opened a pull request

[jira] [Commented] (FLINK-4437) Lock evasion around lastTriggeredCheckpoint may lead to lost updates to related fields

[ https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433417#comment-15433417 ] ASF GitHub Bot commented on FLINK-4437: --- GitHub user tedyu opened a pull request:

[jira] [Commented] (FLINK-4209) Fix issue on docker with multiple NICs and remove supervisord dependency

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

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433498#comment-15433498 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433500#comment-15433500 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433502#comment-15433502 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433501#comment-15433501 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433504#comment-15433504 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433506#comment-15433506 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433505#comment-15433505 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433510#comment-15433510 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433507#comment-15433507 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433508#comment-15433508 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433512#comment-15433512 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433511#comment-15433511 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on a diff i

[jira] [Commented] (FLINK-4231) Switch DistinctOperator from GroupReduce to Reduce

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

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