[jira] [Updated] (FLINK-4205) Implement stratified sampling for DataSet

[ https://issues.apache.org/jira/browse/FLINK-4205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4205: -- Component/s: DataSet API > Implement stratified sampling for DataSet > -

[jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420708#comment-15420708 ] Robert Metzger commented on FLINK-4387: --- I saw this assertion error also in another

[jira] [Commented] (FLINK-4394) RMQSource: The QueueName is not accessible to subclasses

[ https://issues.apache.org/jira/browse/FLINK-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420750#comment-15420750 ] Robert Metzger commented on FLINK-4394: --- Thank you for opening a pull request. I gav

[jira] [Updated] (FLINK-4394) RMQSource: The QueueName is not accessible to subclasses

[ https://issues.apache.org/jira/browse/FLINK-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4394: -- Assignee: Dominik Bruhn > RMQSource: The QueueName is not accessible to subclasses > ---

[jira] [Updated] (FLINK-4393) Failed to serialize accumulators for task

[ https://issues.apache.org/jira/browse/FLINK-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4393: -- Description: Dear Team, I am getting the below exception while trying to use the Table API by

[jira] [Commented] (FLINK-4393) Failed to serialize accumulators for task

[ https://issues.apache.org/jira/browse/FLINK-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420868#comment-15420868 ] Robert Metzger commented on FLINK-4393: --- What's the DataSet size you are trying to c

[jira] [Resolved] (FLINK-4394) RMQSource: The QueueName is not accessible to subclasses

[ https://issues.apache.org/jira/browse/FLINK-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4394. --- Resolution: Fixed Fix Version/s: 1.2.0 Thank you for the contribution. Resolved in http

[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=15421044#comment-15421044 ] Robert Metzger commented on FLINK-4035: --- Thank you for trying this out. I've opened

[jira] [Commented] (FLINK-4393) Failed to serialize accumulators for task

[ https://issues.apache.org/jira/browse/FLINK-4393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15422367#comment-15422367 ] Robert Metzger commented on FLINK-4393: --- 3.6 GB are too much data to transfer using

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15426231#comment-15426231 ] Robert Metzger commented on FLINK-4341: --- The reason why the Kinesis consumer is not

[jira] [Created] (FLINK-4429) Move Redis Sink from Flink to Bahir

Robert Metzger created FLINK-4429: - Summary: Move Redis Sink from Flink to Bahir Key: FLINK-4429 URL: https://issues.apache.org/jira/browse/FLINK-4429 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-4425) "Out Of Memory" during savepoint deserialization

[ https://issues.apache.org/jira/browse/FLINK-4425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4425: -- Component/s: State Backends, Checkpointing > "Out Of Memory" during savepoint deserialization >

[jira] [Commented] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception

[ https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428147#comment-15428147 ] Robert Metzger commented on FLINK-4418: --- Thank you for working on this. I gave you c

[jira] [Updated] (FLINK-4418) ClusterClient/ConnectionUtils#findConnectingAddress fails immediately if InetAddress.getLocalHost throws exception

[ https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4418: -- Assignee: Shannon Carey > ClusterClient/ConnectionUtils#findConnectingAddress fails immediately

[jira] [Updated] (FLINK-4426) Unable to create proxy to the ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4426: -- Description: We have a Mapr cluster on which I am trying to run a single flink job (from exampl

[jira] [Commented] (FLINK-4426) Unable to create proxy to the ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428158#comment-15428158 ] Robert Metzger commented on FLINK-4426: --- Hi, It seems that the MapR cluster is secu

[jira] [Resolved] (FLINK-4402) Wrong metrics parameter names in documentation

[ https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4402. --- Resolution: Resolved Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/3be9a285

[jira] [Created] (FLINK-4432) (YARN) JobManager web port is no longer available in configuration page in web interface

Robert Metzger created FLINK-4432: - Summary: (YARN) JobManager web port is no longer available in configuration page in web interface Key: FLINK-4432 URL: https://issues.apache.org/jira/browse/FLINK-4432

[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=15429735#comment-15429735 ] Robert Metzger commented on FLINK-4439: --- In my opinion, the logging is pretty good.

[jira] [Resolved] (FLINK-4222) Allow Kinesis configuration to get credentials from AWS Metadata

[ https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4222. --- Resolution: Fixed Fix Version/s: 1.2.0 Resolved in http://git-wip-us.apache.org/repos/a

[jira] [Updated] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2055: -- Assignee: (was: Hilmi Yildirim) > Implement Streaming HBaseSink > --

[jira] [Updated] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2055: -- Assignee: Erli Ding > Implement Streaming HBaseSink > - > >

[jira] [Created] (FLINK-4446) Move Flume Sink from Flink to Bahir

Robert Metzger created FLINK-4446: - Summary: Move Flume Sink from Flink to Bahir Key: FLINK-4446 URL: https://issues.apache.org/jira/browse/FLINK-4446 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15433114#comment-15433114 ] Robert Metzger commented on FLINK-4341: --- For the short term: I think we have to disa

[jira] [Closed] (FLINK-3481) KafkaShortRetention08ITCase.testAutoOffsetReset failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-3481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-3481. - Resolution: Cannot Reproduce I'm closing this one since the issue hasn't occurred since February.

[jira] [Closed] (FLINK-3343) Exception while using Kafka 0.9 connector

[ https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-3343. - Resolution: Invalid > Exception while using Kafka 0.9 connector > ---

[jira] [Resolved] (FLINK-3683) Unstable tests: in the Kafka09ITCase, the testMultipleSourcesOnePartition() and the testOneToOneSources()

[ https://issues.apache.org/jira/browse/FLINK-3683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3683. --- Resolution: Cannot Reproduce I'm closing this one since it hasn't occurred since March, and th

[jira] [Closed] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-3823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-3823. - Resolution: Cannot Reproduce I'm closing this one since it hasn't occurred since April, and the Ka

[jira] [Resolved] (FLINK-3531) KafkaShortRetention09ITCase.testAutoOffsetReset fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-3531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3531. --- Resolution: Cannot Reproduce I'm closing this one since it hasn't occurred since February, and

[jira] [Resolved] (FLINK-2049) KafkaSink sporadically fails to send message

[ https://issues.apache.org/jira/browse/FLINK-2049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2049. --- Resolution: Cannot Reproduce I'm closing this one since it hasn't occurred since May 2015, and

[jira] [Resolved] (FLINK-2735) KafkaProducerITCase.testCustomPartitioning sporadically fails

[ https://issues.apache.org/jira/browse/FLINK-2735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2735. --- Resolution: Cannot Reproduce I'm closing this one since it hasn't occurred since November 15,

[jira] [Commented] (FLINK-3146) Expose the Kafka consumer lag as a metric in the web interface for Kafka 0.8.x

[ https://issues.apache.org/jira/browse/FLINK-3146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15434565#comment-15434565 ] Robert Metzger commented on FLINK-3146: --- FLINK-4186 is related, as it exposes the cu

[jira] [Created] (FLINK-4479) Replace trademark (tm) with registered trademark (R) sign on Flink website

Robert Metzger created FLINK-4479: - Summary: Replace trademark (tm) with registered trademark (R) sign on Flink website Key: FLINK-4479 URL: https://issues.apache.org/jira/browse/FLINK-4479 Project: F

[jira] [Commented] (FLINK-3823) Kafka08ITCase.testOffsetInZookeeper failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-3823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436839#comment-15436839 ] Robert Metzger commented on FLINK-3823: --- I pushed a commit to fix the log upload so

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

[ https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15436844#comment-15436844 ] Robert Metzger commented on FLINK-3704: --- The issue still persists: https://s3.amazo

[jira] [Updated] (FLINK-4433) Refactor the StreamSource.

[ https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4433: -- Component/s: DataStream API > Refactor the StreamSource. > -- > >

[jira] [Updated] (FLINK-4433) Refactor the StreamSource.

[ https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4433: -- Issue Type: Improvement (was: Bug) > Refactor the StreamSource. > -- >

[jira] [Commented] (FLINK-4479) Replace trademark (tm) with registered trademark (R) sign on Flink website

[ https://issues.apache.org/jira/browse/FLINK-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437181#comment-15437181 ] Robert Metzger commented on FLINK-4479: --- PR open: https://github.com/apache/flink-we

[jira] [Updated] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3679: -- Component/s: Kafka Connector > DeserializationSchema should handle zero or more outputs for ever

[jira] [Created] (FLINK-4524) JobManagerProcessReapingTest.testReapProcessOnFailure unstable

Robert Metzger created FLINK-4524: - Summary: JobManagerProcessReapingTest.testReapProcessOnFailure unstable Key: FLINK-4524 URL: https://issues.apache.org/jira/browse/FLINK-4524 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445309#comment-15445309 ] Robert Metzger commented on FLINK-3704: --- Another failure: https://s3.amazonaws.com/

[jira] [Resolved] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

[ https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4341. --- Resolution: Fixed Assignee: Tzu-Li (Gordon) Tai (was: Robert Metzger) Resolved for mast

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445493#comment-15445493 ] Robert Metzger commented on FLINK-4485: --- I looked a bit into the issue because I'm w

[jira] [Commented] (FLINK-4485) Finished jobs in yarn session fill /tmp filesystem

[ https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445495#comment-15445495 ] Robert Metzger commented on FLINK-4485: --- Sorry, I didn't refresh before writing a co

[jira] [Commented] (FLINK-3679) DeserializationSchema should handle zero or more outputs for every input

[ https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445795#comment-15445795 ] Robert Metzger commented on FLINK-3679: --- Two users were affected by this recently: h

[jira] [Commented] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

[ https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15445978#comment-15445978 ] Robert Metzger commented on FLINK-4496: --- What's the reasoning behind this change? >

[jira] [Commented] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME

[ https://issues.apache.org/jira/browse/FLINK-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15448470#comment-15448470 ] Robert Metzger commented on FLINK-1914: --- Thank you for your interest in contributing

[jira] [Created] (FLINK-4555) Explicitly kill TaskManager on YARN when ApplicationMaster is shutting down

Robert Metzger created FLINK-4555: - Summary: Explicitly kill TaskManager on YARN when ApplicationMaster is shutting down Key: FLINK-4555 URL: https://issues.apache.org/jira/browse/FLINK-4555 Project:

[jira] [Updated] (FLINK-3930) Implement Service-Level Authorization

[ https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3930: -- Component/s: Security > Implement Service-Level Authorization >

[jira] [Created] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread.

Robert Metzger created FLINK-4569: - Summary: JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread. Key: FLINK-4569 URL: https://issues.apache.org/jira/browse/FLINK-4569 P

[jira] [Updated] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4513: -- Fix Version/s: (was: 1.1.2) 1.1.3 > Kafka connector documentation refers

[jira] [Updated] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

[ https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4396: -- Fix Version/s: (was: 1.1.2) 1.1.3 > GraphiteReporter class not found at s

[jira] [Updated] (FLINK-4329) Fix Streaming File Source Timestamps/Watermarks Handling

[ https://issues.apache.org/jira/browse/FLINK-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4329: -- Fix Version/s: (was: 1.1.2) 1.1.3 > Fix Streaming File Source Timestamps/

[jira] [Resolved] (FLINK-4479) Replace trademark (tm) with registered trademark (R) sign on Flink website

[ https://issues.apache.org/jira/browse/FLINK-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4479. --- Resolution: Fixed Resolved with https://github.com/apache/flink-web/commit/f2053d28b123905392

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15466863#comment-15466863 ] Robert Metzger commented on FLINK-3427: --- Hey [~ivan.mushketyk], how do you plan to v

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15468520#comment-15468520 ] Robert Metzger commented on FLINK-3427: --- Afaik there is already a gauge for getting

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15468531#comment-15468531 ] Robert Metzger commented on FLINK-3427: --- [~ivan.mushketyk] did you already start wor

[jira] [Created] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG

Robert Metzger created FLINK-4590: - Summary: Some Table API tests are failing when debug lvl is set to DEBUG Key: FLINK-4590 URL: https://issues.apache.org/jira/browse/FLINK-4590 Project: Flink

[jira] [Resolved] (FLINK-4585) Fix broken links in index.md

[ https://issues.apache.org/jira/browse/FLINK-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4585. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink-web/commit/bb6d820f

[jira] [Created] (FLINK-4634) TaskStopTest.testStopExecution() times out

Robert Metzger created FLINK-4634: - Summary: TaskStopTest.testStopExecution() times out Key: FLINK-4634 URL: https://issues.apache.org/jira/browse/FLINK-4634 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5998) Un-fat Hadoop from Flink fat jar

[ https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904837#comment-15904837 ] Robert Metzger commented on FLINK-5998: --- [~wheat9] Thanks a lot for assigning that i

[jira] [Created] (FLINK-6022) Improve support for Avro GenericRecord

Robert Metzger created FLINK-6022: - Summary: Improve support for Avro GenericRecord Key: FLINK-6022 URL: https://issues.apache.org/jira/browse/FLINK-6022 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-6022) Improve support for Avro GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904920#comment-15904920 ] Robert Metzger commented on FLINK-6022: --- I think protobuf always works with generate

[jira] [Created] (FLINK-6031) Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader.

Robert Metzger created FLINK-6031: - Summary: Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader. Key: FLINK-6031 URL: https://issues.apache.org/jir

[jira] [Commented] (FLINK-6022) Improve support for Avro GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924180#comment-15924180 ] Robert Metzger commented on FLINK-6022: --- There is actually a way to registering anyt

[jira] [Created] (FLINK-6065) Make TransportClient for ES5 pluggable

Robert Metzger created FLINK-6065: - Summary: Make TransportClient for ES5 pluggable Key: FLINK-6065 URL: https://issues.apache.org/jira/browse/FLINK-6065 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15926820#comment-15926820 ] Robert Metzger commented on FLINK-5048: --- I'm not aware of any user on 1.1 affected b

[jira] [Created] (FLINK-6084) Cassandra connector does not declare all dependencies

Robert Metzger created FLINK-6084: - Summary: Cassandra connector does not declare all dependencies Key: FLINK-6084 URL: https://issues.apache.org/jira/browse/FLINK-6084 Project: Flink Issue T

[jira] [Resolved] (FLINK-6121) Include TravisCI build status to README.md

[ https://issues.apache.org/jira/browse/FLINK-6121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-6121. --- Resolution: Duplicate Assignee: (was: Bowen Li) Fix Version/s: (was: 1.

[jira] [Commented] (FLINK-6122) add TravisCI build status to README.md

[ https://issues.apache.org/jira/browse/FLINK-6122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932329#comment-15932329 ] Robert Metzger commented on FLINK-6122: --- I'm not sure if we want to merge this chang

[jira] [Created] (FLINK-6125) Commons httpclient is not shaded anymore in Flink 1.2

Robert Metzger created FLINK-6125: - Summary: Commons httpclient is not shaded anymore in Flink 1.2 Key: FLINK-6125 URL: https://issues.apache.org/jira/browse/FLINK-6125 Project: Flink Issue T

[jira] [Assigned] (FLINK-6125) Commons httpclient is not shaded anymore in Flink 1.2

[ https://issues.apache.org/jira/browse/FLINK-6125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-6125: - Assignee: Robert Metzger > Commons httpclient is not shaded anymore in Flink 1.2 > --

[jira] [Commented] (FLINK-5998) Un-fat Hadoop from Flink fat jar

[ https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932403#comment-15932403 ] Robert Metzger commented on FLINK-5998: --- [~wheat9] what's the status on this issue?

[jira] [Assigned] (FLINK-6020) Blob Server cannot hanlde multiple job sumits(with same content) parallelly

[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-6020: - Assignee: Robert Metzger (was: Tao Wang) > Blob Server cannot hanlde multiple job sumits

[jira] [Updated] (FLINK-6020) Blob Server cannot hanlde multiple job sumits(with same content) parallelly

[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6020: -- Component/s: Distributed Coordination > Blob Server cannot hanlde multiple job sumits(with same

[jira] [Assigned] (FLINK-6020) Blob Server cannot hanlde multiple job sumits(with same content) parallelly

[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-6020: - Assignee: Tao Wang (was: Robert Metzger) > Blob Server cannot hanlde multiple job sumits

[jira] [Updated] (FLINK-6020) Blob Server cannot handle multiple job submits (with same content) parallelly

[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6020: -- Summary: Blob Server cannot handle multiple job submits (with same content) parallelly (was: Bl

[jira] [Updated] (FLINK-5931) Make Flink highly available even if defaultFS is unavailable

[ https://issues.apache.org/jira/browse/FLINK-5931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5931: -- Component/s: Distributed Coordination > Make Flink highly available even if defaultFS is unavail

[jira] [Updated] (FLINK-5685) Connection leak in Taskmanager

[ https://issues.apache.org/jira/browse/FLINK-5685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5685: -- Component/s: Distributed Coordination > Connection leak in Taskmanager > ---

[jira] [Updated] (FLINK-5761) ClassNotFoundException during cancel job

[ https://issues.apache.org/jira/browse/FLINK-5761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5761: -- Component/s: State Backends, Checkpointing > ClassNotFoundException during cancel job >

[jira] [Updated] (FLINK-5724) Error in the 'Zipping Elements' docs

[ https://issues.apache.org/jira/browse/FLINK-5724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5724: -- Component/s: DataSet API > Error in the 'Zipping Elements' docs > --

[jira] [Updated] (FLINK-5961) Queryable State is broken for HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-5961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5961: -- Component/s: Queryable State > Queryable State is broken for HeapKeyedStateBackend > ---

[jira] [Updated] (FLINK-5839) Flink Security problem collection

[ https://issues.apache.org/jira/browse/FLINK-5839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5839: -- Component/s: Security > Flink Security problem collection > - >

[jira] [Updated] (FLINK-5987) Upgrade zookeeper dependency to 3.4.8

[ https://issues.apache.org/jira/browse/FLINK-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5987: -- Component/s: Build System > Upgrade zookeeper dependency to 3.4.8 >

[jira] [Updated] (FLINK-6060) not exist class referance in the scala function annotation

[ https://issues.apache.org/jira/browse/FLINK-6060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6060: -- Component/s: Scala API > not exist class referance in the scala function annotation > --

[jira] [Commented] (FLINK-5987) Upgrade zookeeper dependency to 3.4.8

[ https://issues.apache.org/jira/browse/FLINK-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932681#comment-15932681 ] Robert Metzger commented on FLINK-5987: --- Our current zookeeper version is 3.4.6, sin

[jira] [Updated] (FLINK-6120) Implement heartbeat logic between JobManager and ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-6120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6120: -- Component/s: Distributed Coordination > Implement heartbeat logic between JobManager and Resourc

[jira] [Updated] (FLINK-6118) Chained operators forward watermark without checking

[ https://issues.apache.org/jira/browse/FLINK-6118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6118: -- Component/s: DataStream API > Chained operators forward watermark without checking > ---

[jira] [Commented] (FLINK-5900) Add non-partial merge Aggregates and unit tests

[ https://issues.apache.org/jira/browse/FLINK-5900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932687#comment-15932687 ] Robert Metzger commented on FLINK-5900: --- To which component does this belong? Is it

[jira] [Updated] (FLINK-6068) Support If() as a built-in function of TableAPI

[ https://issues.apache.org/jira/browse/FLINK-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6068: -- Component/s: Table API & SQL > Support If() as a built-in function of TableAPI > ---

[jira] [Updated] (FLINK-6093) Implement and turn on retraction for table sink

[ https://issues.apache.org/jira/browse/FLINK-6093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6093: -- Component/s: Table API & SQL > Implement and turn on retraction for table sink > --

[jira] [Updated] (FLINK-6094) Implement and turn on retraction for stream-stream inner join

[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6094: -- Component/s: Table API & SQL > Implement and turn on retraction for stream-stream inner join > -

[jira] [Updated] (FLINK-6090) Implement optimizer for retraction and turn on retraction for over window aggregate

[ https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6090: -- Component/s: Table API & SQL > Implement optimizer for retraction and turn on retraction for ove

[jira] [Updated] (FLINK-6033) Support UNNEST query in the stream SQL API

[ https://issues.apache.org/jira/browse/FLINK-6033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6033: -- Component/s: Table API & SQL > Support UNNEST query in the stream SQL API >

[jira] [Updated] (FLINK-5724) Error in the 'Zipping Elements' docs

[ https://issues.apache.org/jira/browse/FLINK-5724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5724: -- Component/s: Python API > Error in the 'Zipping Elements' docs > ---

[jira] [Updated] (FLINK-6047) Add support for Retraction in Table API / SQL

[ https://issues.apache.org/jira/browse/FLINK-6047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6047: -- Component/s: Table API & SQL > Add support for Retraction in Table API / SQL > -

[jira] [Updated] (FLINK-6092) Implement and turn on retraction for table source

[ https://issues.apache.org/jira/browse/FLINK-6092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6092: -- Component/s: Table API & SQL > Implement and turn on retraction for table source >

[jira] [Updated] (FLINK-6091) Implement and turn on the retraction for grouping window aggregate

[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6091: -- Component/s: Table API & SQL > Implement and turn on the retraction for grouping window aggregat

[jira] [Updated] (FLINK-6103) LocalFileSystem rename() uses File.renameTo()

[ https://issues.apache.org/jira/browse/FLINK-6103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6103: -- Component/s: Local Runtime > LocalFileSystem rename() uses File.renameTo() > ---

[jira] [Updated] (FLINK-6083) [TaskManager] Support readiness/liveness probes

[ https://issues.apache.org/jira/browse/FLINK-6083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6083: -- Component/s: Distributed Coordination > [TaskManager] Support readiness/liveness probes > --

  1   2   3   4   5   6   7   8   9   10   >