[jira] [Updated] (FLINK-6105) Properly handle InterruptedException in HadoopInputFormatBase

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6105: -- Summary: Properly handle InterruptedException in HadoopInputFormatBase (was: Properly handle In

[jira] [Updated] (FLINK-6105) Properly handle InterruptedException

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6105: -- Component/s: DataStream API > Properly handle InterruptedException > ---

[jira] [Updated] (FLINK-6089) Implement decoration phase for rewriting predicated logical plan after volcano optimization phase

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6089: -- Component/s: Table API & SQL > Implement decoration phase for rewriting predicated logical plan

[jira] [Updated] (FLINK-5950) create an example for async-io with an http client

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5950: -- Component/s: Examples > create an example for async-io with an http client > ---

[jira] [Updated] (FLINK-5707) Find better keys for backend configuration parameters

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5707: -- Component/s: State Backends, Checkpointing > Find better keys for backend configuration paramete

[jira] [Updated] (FLINK-5786) Add support GetClusterStatus message for standalong flink cluster

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5786: -- Component/s: Distributed Coordination > Add support GetClusterStatus message for standalong flin

[jira] [Updated] (FLINK-5707) Find better keys for backend configuration parameters for state backends

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5707: -- Summary: Find better keys for backend configuration parameters for state backends (was: Find be

[jira] [Updated] (FLINK-5726) Add the RocketMQ plugin for the Apache Flink

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5726: -- Component/s: Streaming Connectors > Add the RocketMQ plugin for the Apache Flink > -

[jira] [Commented] (FLINK-5726) Add the RocketMQ plugin for the Apache Flink

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932693#comment-15932693 ] Robert Metzger commented on FLINK-5726: --- +1 to add a RocketMQ connector to bahir. >

[jira] [Updated] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5943: -- Component/s: YARN > Unprotected access to haServices in > YarnFlinkApplicationMasterRunner#shut

[jira] [Updated] (FLINK-5855) Unprotected access to pendingFilesPerCheckpoint in BucketingSink

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5855: -- Component/s: Streaming Connectors > Unprotected access to pendingFilesPerCheckpoint in Bucketing

[jira] [Updated] (FLINK-6095) Introduce the SlotPoolOptions to config parameters for SlotPool

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6095: -- Component/s: Distributed Coordination > Introduce the SlotPoolOptions to config parameters for S

[jira] [Updated] (FLINK-6080) Unclosed ObjectOutputStream in NFA#serialize()

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6080: -- Component/s: CEP > Unclosed ObjectOutputStream in NFA#serialize() >

[jira] [Updated] (FLINK-6079) Ineffective null check in FlinkKafkaConsumerBase#open()

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6079: -- Component/s: Kafka Connector > Ineffective null check in FlinkKafkaConsumerBase#open() > ---

[jira] [Updated] (FLINK-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint()

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6052: -- Component/s: State Backends, Checkpointing > Potential null access in > ZooKeeperCompletedCheck

[jira] [Updated] (FLINK-6003) Add docker image based on the openjdk one (debian+alpine)

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6003: -- Component/s: Docker Build System > Add docker image based on the openjdk one (d

[jira] [Updated] (FLINK-6052) Potential null access in ZooKeeperCompletedCheckpointStore#getLatestCheckpoint()

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6052: -- Component/s: Distributed Coordination > Potential null access in > ZooKeeperCompletedCheckpoint

[jira] [Updated] (FLINK-6104) Resource leak in ListViaRangeSpeedMiniBenchmark

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6104: -- Component/s: State Backends, Checkpointing > Resource leak in ListViaRangeSpeedMiniBenchmark > -

[jira] [Updated] (FLINK-5742) Breakpoints on documentation website

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5742: -- Component/s: Documentation > Breakpoints on documentation website >

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

2017-03-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932712#comment-15932712 ] Robert Metzger commented on FLINK-5900: --- Thank you [~fhueske] for setting the compon

[jira] [Updated] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

2017-03-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6143: -- Component/s: Client > Unprotected access to this.flink in LocalExecutor#endSession() > -

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

2017-03-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-6084. --- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Resolved for 1.3 in htt

[jira] [Updated] (FLINK-6159) Add Java/Scala FlinkLauncher

2017-03-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6159: -- Component/s: Client > Add Java/Scala FlinkLauncher > > >

[jira] [Commented] (FLINK-6159) Add Java/Scala FlinkLauncher

2017-03-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936228#comment-15936228 ] Robert Metzger commented on FLINK-6159: --- How does this differ from the RemoteExecuti

[jira] [Commented] (FLINK-6159) Add Java/Scala FlinkLauncher

2017-03-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936360#comment-15936360 ] Robert Metzger commented on FLINK-6159: --- thank you for closing the issue. I agree t

[jira] [Updated] (FLINK-6169) yarnClient should be stopped in AbstractYarnClusterDescriptor in case of error

2017-03-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6169: -- Component/s: YARN > yarnClient should be stopped in AbstractYarnClusterDescriptor in case of err

[jira] [Commented] (FLINK-5067) Make Flink compile with 1.8 Java compiler

2017-03-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15937005#comment-15937005 ] Robert Metzger commented on FLINK-5067: --- This JIRA disabled the automatic profile ac

[jira] [Created] (FLINK-6181) Zookeeper scripts use invalid regex

2017-03-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-6181: - Summary: Zookeeper scripts use invalid regex Key: FLINK-6181 URL: https://issues.apache.org/jira/browse/FLINK-6181 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-6181) Zookeeper scripts use invalid regex

2017-03-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6181: -- Component/s: Startup Shell Scripts > Zookeeper scripts use invalid regex > -

[jira] [Assigned] (FLINK-6181) Zookeeper scripts use invalid regex

2017-03-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-6181: - Assignee: Robert Metzger > Zookeeper scripts use invalid regex >

[jira] [Commented] (FLINK-5989) Protobuf in akka needs to be shaded

2017-03-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940291#comment-15940291 ] Robert Metzger commented on FLINK-5989: --- Yes, I've tried doing this some time ago, b

[jira] [Commented] (FLINK-5989) Protobuf in akka needs to be shaded

2017-03-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940292#comment-15940292 ] Robert Metzger commented on FLINK-5989: --- Yes, I've tried doing this some time ago, b

[jira] [Updated] (FLINK-6187) Cancel job failed with option -m on yarn session

2017-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6187: -- Component/s: YARN > Cancel job failed with option -m on yarn session > -

[jira] [Updated] (FLINK-6187) Cancel job failed with option -m on yarn session

2017-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6187: -- Component/s: Client > Cancel job failed with option -m on yarn session > ---

[jira] [Updated] (FLINK-6186) Remove unused import

2017-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6186: -- Component/s: Streaming Scala API > Remove unused import >

[jira] [Updated] (FLINK-6186) Remove unused import

2017-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6186: -- Component/s: DataStream API > Remove unused import > > > Ke

[jira] [Commented] (FLINK-6187) Cancel job failed with option -m on yarn session

2017-03-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15941687#comment-15941687 ] Robert Metzger commented on FLINK-6187: --- Did you configure HA? Are you sure the {{i

[jira] [Updated] (FLINK-6196) Support dynamic schema in Table Function

2017-03-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6196: -- Component/s: Table API & SQL > Support dynamic schema in Table Function > --

[jira] [Updated] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1

2017-03-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6209: -- Component/s: DataStream API > StreamPlanEnvironment always has a parallelism of 1 >

[jira] [Updated] (FLINK-6210) RocksDB instance should be closed in ListViaMergeSpeedMiniBenchmark

2017-03-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6210: -- Component/s: State Backends, Checkpointing > RocksDB instance should be closed in ListViaMergeSp

[jira] [Commented] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1

2017-03-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946794#comment-15946794 ] Robert Metzger commented on FLINK-6209: --- I think a fix for this should go into 1.2.1

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

2017-03-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947065#comment-15947065 ] Robert Metzger commented on FLINK-6125: --- Quick update: I'm still planning to work on

[jira] [Updated] (FLINK-6226) ScalarFunction and TableFunction do not support parameters of byte, short and float

2017-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6226: -- Component/s: Table API & SQL > ScalarFunction and TableFunction do not support parameters of byt

[jira] [Updated] (FLINK-6217) ContaineredTaskManagerParameters sets off heap memory size incorrectly

2017-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6217: -- Component/s: YARN > ContaineredTaskManagerParameters sets off heap memory size incorrectly > ---

[jira] [Updated] (FLINK-6220) Fine-grained copy-on-write for Heap(Map/List)States in CopyOnWriteStateTable

2017-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6220: -- Component/s: State Backends, Checkpointing > Fine-grained copy-on-write for Heap(Map/List)States

[jira] [Updated] (FLINK-6214) WindowAssigners do not allow negative offsets

2017-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6214: -- Component/s: DataStream API > WindowAssigners do not allow negative offsets > --

[jira] [Updated] (FLINK-6172) Potentially unclosed RandomAccessFile in HistoryServerStaticFileServerHandler

2017-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6172: -- Component/s: JobManager > Potentially unclosed RandomAccessFile in HistoryServerStaticFileServer

[jira] [Commented] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions

2016-11-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15658797#comment-15658797 ] Robert Metzger commented on FLINK-5013: --- Thanks a lot for looking into the issue Gor

[jira] [Commented] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions

2016-11-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15668845#comment-15668845 ] Robert Metzger commented on FLINK-5013: --- We only strictly enforce the maven version

[jira] [Resolved] (FLINK-5001) Ensure that the Kafka 0.9+ connector is compatible with kafka-consumer-groups.sh

2016-11-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-5001. --- Resolution: Won't Fix Closing as "Won't fix" since this is an issue of Kafka. > Ensure that t

[jira] [Assigned] (FLINK-4895) Drop support for Hadoop 1

2016-11-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4895: - Assignee: Robert Metzger > Drop support for Hadoop 1 > - > >

[jira] [Commented] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure

2016-11-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1568#comment-1568 ] Robert Metzger commented on FLINK-5049: --- Another instance of the issue: https://api

[jira] [Commented] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

2016-11-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686988#comment-15686988 ] Robert Metzger commented on FLINK-3053: --- On master {code} Caused by: java.lang.Ille

[jira] [Comment Edited] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

2016-11-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686988#comment-15686988 ] Robert Metzger edited comment on FLINK-3053 at 11/22/16 3:13 PM: ---

[jira] [Commented] (FLINK-4941) Show ship strategy in web interface

2016-11-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689818#comment-15689818 ] Robert Metzger commented on FLINK-4941: --- This has been fixed for 1.2 in 3a4fc537dcff

[jira] [Updated] (FLINK-4941) Show ship strategy in web interface

2016-11-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4941: -- Fix Version/s: 1.2.0 > Show ship strategy in web interface > ---

[jira] [Commented] (FLINK-4941) Show ship strategy in web interface

2016-11-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15690180#comment-15690180 ] Robert Metzger commented on FLINK-4941: --- I tried backporting the fixes, but it seems

[jira] [Created] (FLINK-5153) Allow setting custom application tags for Flink on YARN

2016-11-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5153: - Summary: Allow setting custom application tags for Flink on YARN Key: FLINK-5153 URL: https://issues.apache.org/jira/browse/FLINK-5153 Project: Flink Issue

[jira] [Resolved] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

2016-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4913. --- Resolution: Fixed I removed fix for version 1.1.4 again. > Per-job Yarn clusters: include use

[jira] [Updated] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

2016-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4913: -- Fix Version/s: (was: 1.1.4) > Per-job Yarn clusters: include user jar in system class loader

[jira] [Reopened] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

2016-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-4913: --- Reverted in 1.1.4: http://git-wip-us.apache.org/repos/asf/flink/commit/3b5d3c6f > Per-job Yarn cl

[jira] [Created] (FLINK-5208) Increase application attempt timeout for the YARN tests on Travis

2016-11-29 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5208: - Summary: Increase application attempt timeout for the YARN tests on Travis Key: FLINK-5208 URL: https://issues.apache.org/jira/browse/FLINK-5208 Project: Flink

[jira] [Commented] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

2016-11-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15708611#comment-15708611 ] Robert Metzger commented on FLINK-3053: --- https://api.travis-ci.org/jobs/179840673/lo

[jira] [Resolved] (FLINK-4895) Drop support for Hadoop 1

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

[jira] [Commented] (FLINK-5108) Remove ClientShutdownHook during job execution

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714809#comment-15714809 ] Robert Metzger commented on FLINK-5108: --- Cool, thank you. When do you think the pull

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

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714813#comment-15714813 ] Robert Metzger commented on FLINK-5048: --- Do we want to backport the changes to 1.1.4

[jira] [Commented] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714833#comment-15714833 ] Robert Metzger commented on FLINK-5017: --- I'm wondering whether this is really a bloc

[jira] [Updated] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5011: -- Component/s: Scala API > TraversableSerializer does not perform a deep copy of the elements it i

[jira] [Commented] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714847#comment-15714847 ] Robert Metzger commented on FLINK-5011: --- Thank you for reporting the issue. We'll lo

[jira] [Commented] (FLINK-4859) Clearly Separate Responsibilities of StreamOperator and StreamTask

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714853#comment-15714853 ] Robert Metzger commented on FLINK-4859: --- I see the value of refactoring this, but I

[jira] [Updated] (FLINK-4632) when yarn nodemanager lost, flink hung

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4632: -- Priority: Major (was: Blocker) > when yarn nodemanager lost, flink hung >

[jira] [Commented] (FLINK-4632) when yarn nodemanager lost, flink hung

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15714931#comment-15714931 ] Robert Metzger commented on FLINK-4632: --- If its okay for everybody, I'm setting the

[jira] [Commented] (FLINK-4492) Cleanup files from canceled snapshots

2016-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715217#comment-15715217 ] Robert Metzger commented on FLINK-4492: --- [~srichter] do you know the status of the i

[jira] [Created] (FLINK-5233) Upgrade Jackson version because of class loader leak

2016-12-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5233: - Summary: Upgrade Jackson version because of class loader leak Key: FLINK-5233 URL: https://issues.apache.org/jira/browse/FLINK-5233 Project: Flink Issue Ty

[jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken

2016-12-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721865#comment-15721865 ] Robert Metzger commented on FLINK-5039: --- Thanks a lot for looking into the issue. I

[jira] [Commented] (FLINK-5035) Don't Write TypeSerializer to Heap State Snapshot

2016-12-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15726517#comment-15726517 ] Robert Metzger commented on FLINK-5035: --- What's the status here? > Don't Write Type

[jira] [Commented] (FLINK-5233) Upgrade Jackson version because of class loader leak

2016-12-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15726521#comment-15726521 ] Robert Metzger commented on FLINK-5233: --- I'll put more effort into reproducing it at

[jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken

2016-12-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15726541#comment-15726541 ] Robert Metzger commented on FLINK-5039: --- Just using the Avro serializer doesn't solv

[jira] [Created] (FLINK-5286) Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed

2016-12-08 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5286: - Summary: Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed Key: FLINK-5286 URL: https://issues.apache.org/jira/browse/FLINK-5286

[jira] [Commented] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731886#comment-15731886 ] Robert Metzger commented on FLINK-5049: --- Again: https://api.travis-ci.org/jobs/18200

[jira] [Created] (FLINK-5287) Test randomly fails with wrong result: testWithAtomic2[Execution mode = CLUSTER](org.apache.flink.api.scala.operators.JoinITCase)

2016-12-08 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5287: - Summary: Test randomly fails with wrong result: testWithAtomic2[Execution mode = CLUSTER](org.apache.flink.api.scala.operators.JoinITCase) Key: FLINK-5287 URL: https://issues.a

[jira] [Commented] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731899#comment-15731899 ] Robert Metzger commented on FLINK-5147: --- This seems a frequent issue ;) https://api

[jira] [Updated] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5206: -- Component/s: Python API > Flakey PythonPlanBinderTest > --- > >

[jira] [Updated] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5206: -- Affects Version/s: 1.2.0 > Flakey PythonPlanBinderTest > --- > >

[jira] [Commented] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731901#comment-15731901 ] Robert Metzger commented on FLINK-5206: --- I got the same again: https://api.travis-c

[jira] [Updated] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5206: -- Labels: test-stability (was: ) > Flakey PythonPlanBinderTest > --- > >

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

2016-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15734938#comment-15734938 ] Robert Metzger commented on FLINK-5297: --- I'm wondering if it would be sufficient for

[jira] [Created] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab

2016-12-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5306: - Summary: Display checkpointing configuration details in web UI "Configuration" tab Key: FLINK-5306 URL: https://issues.apache.org/jira/browse/FLINK-5306 Project: Fl

[jira] [Commented] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab

2016-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15735078#comment-15735078 ] Robert Metzger commented on FLINK-5306: --- Perfect :) Is this a duplicate then? > Dis

[jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15741452#comment-15741452 ] Robert Metzger commented on FLINK-3398: --- [~aljoscha] You've changed the priority of

[jira] [Resolved] (FLINK-5035) Don't Write TypeSerializer to Heap State Snapshot

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-5035. --- Resolution: Won't Fix Closed issue. Thank you for your responses! > Don't Write TypeSerialize

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15741478#comment-15741478 ] Robert Metzger commented on FLINK-5041: --- What's the relationship of this JIRA and FL

[jira] [Commented] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742521#comment-15742521 ] Robert Metzger commented on FLINK-4858: --- Are we going to remove the Checkpointing in

[jira] [Updated] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4858: -- Fix Version/s: (was: 1.2.0) > Remove Legacy Checkpointing Interfaces > -

[jira] [Comment Edited] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742647#comment-15742647 ] Robert Metzger edited comment on FLINK-4858 at 12/12/16 6:11 PM: ---

[jira] [Updated] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4858: -- Component/s: State Backends, Checkpointing > Remove Legacy Checkpointing Interfaces > --

[jira] [Commented] (FLINK-4858) Remove Legacy Checkpointing Interfaces

2016-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742647#comment-15742647 ] Robert Metzger commented on FLINK-4858: --- Okay, thank you for your input. I'lll remov

[jira] [Created] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

2016-12-13 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5326: - Summary: IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available Key: FLINK-5326 URL: https://i

[jira] [Updated] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels.

2016-12-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4820: -- Component/s: Build System > Slf4j / log4j version upgrade to support dynamic change of log level

[jira] [Commented] (FLINK-4820) Slf4j / log4j version upgrade to support dynamic change of log levels.

2016-12-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15748456#comment-15748456 ] Robert Metzger commented on FLINK-4820: --- Log4j 2 supports dynamic log level changes.

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