[jira] (FLINK-838) Implement full Hadoop Compatibility for Apache Flink
Title: Message Title Robert Metzger updated an issue Flink / FLINK-838 Implement full Hadoop Compatibility for Apache Flink Change By: Robert Metzger Component/s: DataSet API Component/s: Batch Connectors and Input/Output Formats Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1730) Add a FlinkTools.persist style method to the Data Set.
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1730 Add a FlinkTools.persist style method to the Data Set. Change By: Robert Metzger Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-720) Forbid catching exceptions only with "e.printStackTrace()" using Checkstyle
Title: Message Title Robert Metzger commented on FLINK-720 Re: Forbid catching exceptions only with "e.printStackTrace()" using Checkstyle I've tried it using the checkstyle plugin, but I could not set it up reliably. I propose to close the issue as won't fix. The effort is not worth the benefit. Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4757 Unify "GlobalJobParameters" and "Configuration" Change By: Robert Metzger Component/s: DataStream API Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5337) Introduce backwards compatible state to task assignment
Title: Message Title Robert Metzger updated an issue Flink / FLINK-5337 Introduce backwards compatible state to task assignment Change By: Robert Metzger Component/s: State Backends, Checkpointing Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4602) Move RocksDB backed to proper package
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4602 Move RocksDB backed to proper package Change By: Robert Metzger Component/s: State Backends, Checkpointing Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5337) Introduce backwards compatible state to task assignment
Title: Message Title Robert Metzger commented on FLINK-5337 Re: Introduce backwards compatible state to task assignment How does this relate to FLINK-5480 ? Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2244) Add ability to start and stop persistent IaaS cluster
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2244 Add ability to start and stop persistent IaaS cluster Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4765) Migrate ConfigConstants to ConfigOptions
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4765 Migrate ConfigConstants to ConfigOptions Change By: Robert Metzger Component/s: Local Runtime Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-720) Forbid catching exceptions only with "e.printStackTrace()" using Checkstyle
Title: Message Title Robert Metzger updated an issue Flink / FLINK-720 Forbid catching exceptions only with "e.printStackTrace()" using Checkstyle Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2816) Memory allocation module as a separate maven artifact
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2816 Memory allocation module as a separate maven artifact Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2273) Register special Writable Kryo serializer
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2273 Register special Writable Kryo serializer Change By: Robert Metzger Component/s: Type Serialization System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4767) Migrate JobManager configuration options
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4767 Migrate JobManager configuration options Change By: Robert Metzger Component/s: Local Runtime Component/s: Distributed Coordination Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4503) Remove with method from CoGroupedStream and JoinedStream, and change apply method return type
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4503 Remove with method from CoGroupedStream and JoinedStream, and change apply method return type Change By: Robert Metzger Component/s: DataStream API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1915) Faulty plan selection by optimizer
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1915 Faulty plan selection by optimizer Change By: Robert Metzger Component/s: Optimizer Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2760) Avoid uploading of already existing jars from the JobClient
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2760 Avoid uploading of already existing jars from the JobClient Change By: Robert Metzger Component/s: Webfrontend Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2273) Register special Writable Kryo serializer
Title: Message Title
Robert Metzger commented on FLINK-2273
Re: Register special Writable Kryo serializer
I propose to close this issue. Users can register a Writable serialzer themselves. Flink now also supports the {{Writable]] type.
Add Comment
This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2772) Introduce dedicated garbage collector config parameter and set default values for batch and streaming
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2772 Introduce dedicated garbage collector config parameter and set default values for batch and streaming Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2760) Avoid uploading of already existing jars from the JobClient
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2760 Avoid uploading of already existing jars from the JobClient Change By: Robert Metzger Component/s: Client Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2973) Add flink-benchmark with compliant licenses again
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2973 Add flink-benchmark with compliant licenses again Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2760) Avoid uploading of already existing jars from the JobClient
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2760 Avoid uploading of already existing jars from the JobClient Change By: Robert Metzger Component/s: Web Client Component/s: Webfrontend Component/s: Distributed Coordination Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2760) Avoid uploading of already existing jars from the JobClient
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2760 Avoid uploading of already existing jars from the JobClient Change By: Robert Metzger Component/s: Web Client Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2193) Partial shuffling
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2193 Partial shuffling Change By: Robert Metzger Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2395) Check Scala catch blocks for Throwable
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2395 Check Scala catch blocks for Throwable Change By: Robert Metzger Component/s: Scala API Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2237) Add hash-based Aggregation
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2237 Add hash-based Aggregation Change By: Robert Metzger Component/s: Local Runtime Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2593) Revisit Flink's shading policy
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2593 Revisit Flink's shading policy Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2592) Rework of FlinkMiniCluster
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2592 Rework of FlinkMiniCluster Change By: Robert Metzger Component/s: Distributed Coordination Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2366) HA Without ZooKeeper
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2366 HA Without ZooKeeper Change By: Robert Metzger Component/s: Distributed Coordination Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2334) IOException: Channel to path could not be opened
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2334 IOException: Channel to path could not be opened Change By: Robert Metzger Component/s: Local Runtime Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3094) FileStateBackend does not clean up job-id checkpoint directory
Title: Message Title Robert Metzger updated an issue Flink / FLINK-3094 FileStateBackend does not clean up job-id checkpoint directory Change By: Robert Metzger Component/s: State Backends, Checkpointing Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2539) More unified code style for Scala code
Title: Message Title Robert Metzger updated an issue Flink / FLINK-2539 More unified code style for Scala code Change By: Robert Metzger Component/s: Scala API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2334) IOException: Channel to path could not be opened
Title: Message Title Robert Metzger resolved as Cannot Reproduce Resolved as cannot reproduce Flink / FLINK-2334 IOException: Channel to path could not be opened Change By: Robert Metzger Resolution: Cannot Reproduce Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3119) Remove dependency on Tuple from HadoopOutputFormat
Title: Message Title Robert Metzger updated an issue Flink / FLINK-3119 Remove dependency on Tuple from HadoopOutputFormat Change By: Robert Metzger Component/s: Batch Connectors and Input/Output Formats Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3839) Support wildcards in classpath parameters
Title: Message Title Robert Metzger updated an issue Flink / FLINK-3839 Support wildcards in classpath parameters Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1702) Authenticate via Kerberos from the client only
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1702 Authenticate via Kerberos from the client only Change By: Robert Metzger Component/s: Security Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations
Title: Message Title Robert Metzger updated an issue Flink / FLINK-3613 Add standard deviation, mean, variance to list of Aggregations Change By: Robert Metzger Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3606) Expose Configuration from RichFunctions
Title: Message Title Robert Metzger updated an issue Flink / FLINK-3606 Expose Configuration from RichFunctions Change By: Robert Metzger Component/s: DataStream API Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4462) Add RUN_TIME retention policy for all the flink annotations
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4462 Add RUN_TIME retention policy for all the flink annotations Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4548) Refactor ContinuousFileMonitoringTest to use OneShotLatch
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4548 Refactor ContinuousFileMonitoringTest to use OneShotLatch Change By: Robert Metzger Component/s: DataStream API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3801) Upgrade Joda-Time library to 2.9.3
Title: Message Title Robert Metzger updated an issue Flink / FLINK-3801 Upgrade Joda-Time library to 2.9.3 Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3875) Add a TableSink for Elasticsearch
Title: Message Title Robert Metzger updated an issue Flink / FLINK-3875 Add a TableSink for Elasticsearch Change By: Robert Metzger Component/s: Table API & SQL Component/s: Streaming Connectors Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4644) Deprecate "flink.base.dir.path" from ConfigConstants
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4644 Deprecate "flink.base.dir.path" from ConfigConstants Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4755) Create ContainerID; Rename ResourceID into ProcessID and InstanceID into RegistrationID
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4755 Create ContainerID; Rename ResourceID into ProcessID and InstanceID into RegistrationID Change By: Robert Metzger Component/s: Distributed Coordination Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3961) Possibility to write output to multiple locations based on partitions
Title: Message Title Robert Metzger updated an issue Flink / FLINK-3961 Possibility to write output to multiple locations based on partitions Change By: Robert Metzger Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4721) Getting exception when using a key of type Option[String] in distinct operation
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4721 Getting exception when using a key of type Option[String] in distinct operation Change By: Robert Metzger Component/s: Type Serialization System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4865) FlinkML - Add EvaluateDataSet operation for LabeledVector
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4865 FlinkML - Add EvaluateDataSet operation for LabeledVector Change By: Robert Metzger Component/s: Machine Learning Library Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4962) Improve exception information about operand type inference failure during UDF SQL validation
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4962 Improve exception information about operand type inference failure during UDF SQL validation Change By: Robert Metzger Component/s: Table API & SQL Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4721) Getting exception when using a key of type Option[String] in distinct operation
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4721 Getting exception when using a key of type Option[String] in distinct operation Change By: Robert Metzger Component/s: Scala API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4848) keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4848 keystoreFilePath should be checked against null in SSLUtils#createSSLServerContext Change By: Robert Metzger Component/s: Security Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4849) trustStorePassword should be checked against null in SSLUtils#createSSLClientContext
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4849 trustStorePassword should be checked against null in SSLUtils#createSSLClientContext Change By: Robert Metzger Component/s: Security Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4964) FlinkML - Add StringIndexer
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4964 FlinkML - Add StringIndexer Change By: Robert Metzger Component/s: Machine Learning Library Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4508) Consolidate DummyEnvironment and MockEnvironment for Tests
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4508 Consolidate DummyEnvironment and MockEnvironment for Tests Change By: Robert Metzger Component/s: Local Runtime Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4508) Consolidate DummyEnvironment and MockEnvironment for Tests
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4508 Consolidate DummyEnvironment and MockEnvironment for Tests Change By: Robert Metzger Component/s: Tests Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-4880) FlinkML - Implement Feature hashing (Data pre-processing)
Title: Message Title Robert Metzger updated an issue Flink / FLINK-4880 FlinkML - Implement Feature hashing (Data pre-processing) Change By: Robert Metzger Component/s: Machine Learning Library Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown()
Title: Message Title Robert Metzger resolved as Invalid Flink / FLINK-5391 Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown() Change By: Robert Metzger Resolution: Invalid Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue
Title: Message Title Robert Metzger updated an issue Flink / FLINK-5376 Misleading log statements in UnorderedStreamElementQueue Change By: Robert Metzger Component/s: DataStream API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5629) Unclosed RandomAccessFile in StaticFileServerHandler#respondAsLeader()
Title: Message Title Robert Metzger updated an issue Flink / FLINK-5629 Unclosed RandomAccessFile in StaticFileServerHandler#respondAsLeader() Change By: Robert Metzger Component/s: Webfrontend Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5545) remove FlinkAggregateExpandDistinctAggregatesRule when we upgrade calcite
Title: Message Title Robert Metzger updated an issue Flink / FLINK-5545 remove FlinkAggregateExpandDistinctAggregatesRule when we upgrade calcite Change By: Robert Metzger Component/s: Table API & SQL Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5541) Missing null check for localJar in FlinkSubmitter#submitTopology()
Title: Message Title Robert Metzger updated an issue Flink / FLINK-5541 Missing null check for localJar in FlinkSubmitter#submitTopology() Change By: Robert Metzger Component/s: Storm Compatibility Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5431) time format for akka status
Title: Message Title Robert Metzger updated an issue Flink / FLINK-5431 time format for akka status Change By: Robert Metzger Component/s: Distributed Coordination Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1256) Use Kryo for user code object serialization
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1256 Use Kryo for user code object serialization Change By: Robert Metzger Component/s: DataStream API Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1337) Create an Amazon EMR Bootstrap Action
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1337 Create an Amazon EMR Bootstrap Action Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1298) Consolidate Handling of User Code ClassLoader
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1298 Consolidate Handling of User Code ClassLoader Change By: Robert Metzger Component/s: Local Runtime Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1240) We cannot use sortGroup on a global reduce
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1240 We cannot use sortGroup on a global reduce Change By: Robert Metzger Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1268) FileOutputFormat with overwrite does not clear local output directories
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1268 FileOutputFormat with overwrite does not clear local output directories Change By: Robert Metzger Component/s: Batch Connectors and Input/Output Formats Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1447) Flink Web Submission Client does not work on Ubuntu 14.04 firefox browser
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1447 Flink Web Submission Client does not work on Ubuntu 14.04 firefox browser Change By: Robert Metzger Component/s: Webfrontend Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1447) Flink Web Submission Client does not work on Ubuntu 14.04 firefox browser
Title: Message Title Robert Metzger resolved as Won't Fix The cleint has been removed from flink Flink / FLINK-1447 Flink Web Submission Client does not work on Ubuntu 14.04 firefox browser Change By: Robert Metzger Resolution: Won't Fix Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1447) Flink Web Submission Client does not work on Ubuntu 14.04 firefox browser
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1447 Flink Web Submission Client does not work on Ubuntu 14.04 firefox browser Change By: Robert Metzger Component/s: Webfrontend Component/s: Web Client Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1513) Remove GlobalConfiguration Singleton
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1513 Remove GlobalConfiguration Singleton Change By: Robert Metzger Component/s: Local Runtime Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1541) GSoC project: Distributed profiling
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1541 GSoC project: Distributed profiling Change By: Robert Metzger Component/s: Local Runtime Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1541) GSoC project: Distributed profiling
Title: Message Title Robert Metzger commented on FLINK-1541 Re: GSoC project: Distributed profiling Till Rohrmann I assume we can close this JIRA? Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1541) GSoC project: Distributed profiling
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1541 GSoC project: Distributed profiling Change By: Robert Metzger Component/s: Distributed Coordination Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-650) Give user functions access to TypeSerializers for their input types?
Title: Message Title Robert Metzger updated an issue Flink / FLINK-650 Give user functions access to TypeSerializers for their input types? Change By: Robert Metzger Component/s: Type Serialization System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-788) Enable combiner for Reduce with Broadcast Variable
Title: Message Title Robert Metzger updated an issue Flink / FLINK-788 Enable combiner for Reduce with Broadcast Variable Change By: Robert Metzger Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1098) flatArray() operator that converts arrays to elements
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1098 flatArray() operator that converts arrays to elements Change By: Robert Metzger Component/s: DataStream API Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-879) Allow empty result in cross function call
Title: Message Title Robert Metzger updated an issue Flink / FLINK-879 Allow empty result in cross function call Change By: Robert Metzger Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-805) Early check of output write permissions
Title: Message Title Robert Metzger updated an issue Flink / FLINK-805 Early check of output write permissions Change By: Robert Metzger Component/s: DataSet API Component/s: Batch Connectors and Input/Output Formats Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-685) Add support for semi-joins
Title: Message Title Robert Metzger updated an issue Flink / FLINK-685 Add support for semi-joins Change By: Robert Metzger Component/s: Java API Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-37) [GitHub] Enable visualization of custom iteration statistics
Title: Message Title Robert Metzger updated an issue Flink / FLINK-37 [GitHub] Enable visualization of custom iteration statistics Change By: Robert Metzger Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-37) [GitHub] Enable visualization of custom iteration statistics
Title: Message Title Robert Metzger resolved as Invalid Flink / FLINK-37 [GitHub] Enable visualization of custom iteration statistics Change By: Robert Metzger Resolution: Invalid Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1398) A new DataSet function: extractElementFromTuple
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1398 A new DataSet function: extractElementFromTuple Change By: Robert Metzger Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1538) GSoC project: Spatial Data Processing Library
Title: Message Title Robert Metzger commented on FLINK-1538 Re: GSoC project: Spatial Data Processing Library Fabian Hueske I assume we can close this JIRA? Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-766) Web interface progress monitoring for DataSources and DataSinks with splits
Title: Message Title Robert Metzger updated an issue Flink / FLINK-766 Web interface progress monitoring for DataSources and DataSinks with splits Change By: Robert Metzger Component/s: Metrics Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3245) KMeans Data Generator writes not the same centroids as it was used for the dataset
Title: Message Title Robert Metzger updated an issue Flink / FLINK-3245 KMeans Data Generator writes not the same centroids as it was used for the dataset Change By: Robert Metzger Component/s: Examples Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1521 Some Chained Drivers do not respect object-reuse/non-reuse flag Change By: Robert Metzger Component/s: Local Runtime Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5659) FileBaseUtils#deleteFileOrDirectory not thread-safe on Windows
Title: Message Title Robert Metzger updated an issue Flink / FLINK-5659 FileBaseUtils#deleteFileOrDirectory not thread-safe on Windows Change By: Robert Metzger Component/s: Local Runtime Component/s: Core Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1497) No documentation on MiniCluster
Title: Message Title Robert Metzger updated an issue Flink / FLINK-1497 No documentation on MiniCluster Change By: Robert Metzger Component/s: Documentation Component/s: Distributed Coordination Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5481) Cannot create Collection of Row
Title: Message Title Robert Metzger updated an issue Flink / FLINK-5481 Cannot create Collection of Row Change By: Robert Metzger Component/s: Table API & SQL Component/s: DataSet API Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-87) Extend collectors to specify target sink
Title: Message Title Robert Metzger resolved as Won't Fix Closing as won't fix. There's not much focus on the DataSet API anymore, and there are good workarounds. Flink / FLINK-87 Extend collectors to specify target sink Change By: Robert Metzger Resolution: Won't Fix Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1055) JM Webfrontend needs unit tests
Title: Message Title Robert Metzger resolved as Fixed Closing JIRA. There are unit tests for the REST calls by the frontend Flink / FLINK-1055 JM Webfrontend needs unit tests Change By: Robert Metzger Resolution: Fixed Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1166) Add a QA bot to Flink that is testing pull requests
Title: Message Title Robert Metzger assigned an issue to Unassigned Flink / FLINK-1166 Add a QA bot to Flink that is testing pull requests Change By: Robert Metzger Assignee: Robert Metzger Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1166) Add a QA bot to Flink that is testing pull requests
Title: Message Title Robert Metzger commented on FLINK-1166 Re: Add a QA bot to Flink that is testing pull requests Unassigning myself. Let me know if you are interested in picking up my work. Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2036) StreamExecutionEnvironment usage in KafkaITcase
Title: Message Title Robert Metzger resolved as Fixed Closing ... The tests are now reusing a remote exec env. Flink / FLINK-2036 StreamExecutionEnvironment usage in KafkaITcase Change By: Robert Metzger Resolution: Fixed Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-1288) YARN ApplicationMaster sometimes fails to allocate the specified number of workers
Title: Message Title Robert Metzger resolved as Fixed This issue doesn't appear anymore in the recent YARN implementations. Most likely it was caused by YARNs scheduler Flink / FLINK-1288 YARN ApplicationMaster sometimes fails to allocate the specified number of workers Change By: Robert Metzger Resolution: Fixed Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2408) Some maven properties are defined in build profiles only
Title: Message Title Robert Metzger resolved as Fixed Resolved in https://github.com/apache/flink/commit/79a7bb213afd942a4a69a5e3906b6bd1f89fc290 (in Flink 0.10) Flink / FLINK-2408 Some maven properties are defined in build profiles only Change By: Robert Metzger Resolution: Fixed Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2491) Operators are not participating in state checkpointing in some cases
Title: Message Title
Robert Metzger updated an issue
Flink / FLINK-2491
Operators are not participating in state checkpointing in some cases
Change By:
Robert Metzger
While implementing a test case for the Kafka Consumer, I came across the following bug:Consider the following topology, with the operator parallelism in parentheses:Source (2) --> Sink (1).In this setup, the {{snapshotState()}} method is called on the source, but not on the Sink.The sink receives the generated data. The only one of the two sources is generating data.I've implemented a test case for this, you can find it here: https://github.com/rmetzger/flink/blob/para_checkpoint_bug/flink-tests/src/test/java/org/apache/flink/test/checkpointing/ParallelismChangeCheckpoinedITCase.java
Add Comment
This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3079) Add utility for measuring the raw read throughput from a Kafka topic
Title: Message Title Robert Metzger resolved as Fixed The metrics in Flink now provide statistics for bytes per second and records per second. Flink / FLINK-3079 Add utility for measuring the raw read throughput from a Kafka topic Change By: Robert Metzger Resolution: Fixed Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-3924) Remove protobuf shading from Kinesis connector
Title: Message Title Robert Metzger assigned an issue to Unassigned Flink / FLINK-3924 Remove protobuf shading from Kinesis connector Change By: Robert Metzger Assignee: Robert Metzger Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-2568) Flink fat jar is missing org.w3c.dom.ElementTraversal in some environments.
Title: Message Title Robert Metzger resolved as Cannot Reproduce Since 2015, no other user reported the issue. I'm closing it. Flink / FLINK-2568 Flink fat jar is missing org.w3c.dom.ElementTraversal in some environments. Change By: Robert Metzger Resolution: Cannot Reproduce Status: Open Resolved Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
[jira] (FLINK-5690) protobuf is not shaded properly
Title: Message Title Robert Metzger updated an issue Flink / FLINK-5690 protobuf is not shaded properly Change By: Robert Metzger Component/s: Build System Add Comment This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)
