[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674912#comment-15674912 ] Maximilian Michels commented on FLINK-3133: --- Hi [~AlexanderShoshin]! I've adjust

[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674899#comment-15674899 ] Maximilian Michels commented on FLINK-3133: --- I've made some improvements in the

[jira] [Updated] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3133: -- Description: The DataSet API's methods {{collect()}}, {{count()}}, and {{print()}} shoul

[jira] [Updated] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3133: -- Summary: Introduce collect()/count()/print() methods in DataStream API (was: Introduce

[jira] [Commented] (FLINK-5081) unable to set yarn.maximum-failed-containers with flink one-time YARN setup

[ https://issues.apache.org/jira/browse/FLINK-5081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15674631#comment-15674631 ] Maximilian Michels commented on FLINK-5081: --- Thanks for reporting! I couldn't re

[jira] [Closed] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores

[ https://issues.apache.org/jira/browse/FLINK-4998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4998. - Resolution: Fixed Fix Version/s: 1.1.4 master: e4807621b8f41fc4f9fa69f423f1fbf7bba0

[jira] [Resolved] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3813. --- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 master: e480762

[jira] [Assigned] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-3813: - Assignee: Maximilian Michels > YARNSessionFIFOITCase.testDetachedMode failed on T

[jira] [Commented] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15632822#comment-15632822 ] Maximilian Michels commented on FLINK-3813: --- This is caused by the main thread n

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15632332#comment-15632332 ] Maximilian Michels commented on FLINK-2821: --- Glad to hear it's working, [~philip

[jira] [Commented] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores

[ https://issues.apache.org/jira/browse/FLINK-4998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15629345#comment-15629345 ] Maximilian Michels commented on FLINK-4998: --- This is related to FLINK-2213. > R

[jira] [Created] (FLINK-4998) ResourceManager fails when num task slots > Yarn vcores

Maximilian Michels created FLINK-4998: - Summary: ResourceManager fails when num task slots > Yarn vcores Key: FLINK-4998 URL: https://issues.apache.org/jira/browse/FLINK-4998 Project: Flink

[jira] [Deleted] (FLINK-4931) Implement FLIP-6 YARN client

[ https://issues.apache.org/jira/browse/FLINK-4931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels deleted FLINK-4931: -- > Implement FLIP-6 YARN client > > > Key: FLIN

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

[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4913. - Resolution: Fixed master: 2b600d355f5df9364c634282469acd608d7a2104 release-1.1: ea41b9c56f

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

Maximilian Michels created FLINK-4913: - Summary: Per-job Yarn clusters: include user jar in system class loader Key: FLINK-4913 URL: https://issues.apache.org/jira/browse/FLINK-4913 Project: Flin

[jira] [Closed] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

[ https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4862. - Resolution: Fixed master: 45762162fe7c23fd921db1e0f826b2906bfe1dcd release-1.1: 05a5f460b3

[jira] [Closed] (FLINK-4881) Docker: Remove dependency on shared volumes

[ https://issues.apache.org/jira/browse/FLINK-4881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4881. - Resolution: Fixed Merged with 58a16c1007c97809bdd46c93632abd90c0ce5c4b. > Docker: Remove

[jira] [Created] (FLINK-4881) Docker: Remove dependency on shared volumes

Maximilian Michels created FLINK-4881: - Summary: Docker: Remove dependency on shared volumes Key: FLINK-4881 URL: https://issues.apache.org/jira/browse/FLINK-4881 Project: Flink Issue Typ

[jira] [Commented] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

[ https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594587#comment-15594587 ] Maximilian Michels commented on FLINK-4862: --- Thanks for reporting [~mauzhang]. I

[jira] [Updated] (FLINK-4616) Kafka consumer doesn't store last emmited watermarks per partition in state

[ https://issues.apache.org/jira/browse/FLINK-4616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4616: -- Fix Version/s: (was: 1.1.3) 1.1.4 > Kafka consumer doesn't store

[jira] [Updated] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4574: -- Fix Version/s: (was: 1.1.3) 1.1.4 > Strengthen fetch interval imp

[jira] [Updated] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

[ https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4651: -- Fix Version/s: (was: 1.1.3) 1.1.4 > Re-register processing time t

[jira] [Updated] (FLINK-4540) Detached job execution may prevent cluster shutdown

[ https://issues.apache.org/jira/browse/FLINK-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4540: -- Fix Version/s: (was: 1.1.3) 1.1.4 > Detached job execution may pr

[jira] [Updated] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation

[ https://issues.apache.org/jira/browse/FLINK-4544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4544: -- Fix Version/s: (was: 1.1.3) 1.1.4 > TaskManager metrics are vulne

[jira] [Updated] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

[ https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4862: -- Assignee: Manu Zhang > NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger >

[jira] [Updated] (FLINK-4636) AbstractCEPPatternOperator fails to restore state

[ https://issues.apache.org/jira/browse/FLINK-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4636: -- Fix Version/s: (was: 1.1.3) 1.1.4 > AbstractCEPPatternOperator fa

[jira] [Updated] (FLINK-4619) JobManager does not answer to client when restore from savepoint fails

[ https://issues.apache.org/jira/browse/FLINK-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4619: -- Fix Version/s: (was: 1.1.3) 1.1.4 > JobManager does not answer to

[jira] [Updated] (FLINK-4727) Kafka 0.9 Consumer should also checkpoint auto retrieved offsets even when no data is read

[ https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4727: -- Fix Version/s: (was: 1.1.3) 1.1.4 > Kafka 0.9 Consumer should als

[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 ] Maximilian Michels updated FLINK-4396: -- Fix Version/s: (was: 1.1.3) 1.1.4 > GraphiteReporter class not fo

[jira] [Updated] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

[ https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4862: -- Fix Version/s: (was: 1.14) 1.1.4 > NPE on EventTimeSessionWindows

[jira] [Updated] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

[ https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4862: -- Fix Version/s: 1.2.0 1.14 > NPE on EventTimeSessionWindows with Conti

[jira] [Updated] (FLINK-4862) NPE on EventTimeSessionWindows with ContinuousEventTimeTrigger

[ https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4862: -- Affects Version/s: 1.1.3 1.2.0 > NPE on EventTimeSessionWindows w

[jira] [Comment Edited] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589153#comment-15589153 ] Maximilian Michels edited comment on FLINK-2821 at 10/19/16 6:06 PM: ---

[jira] [Comment Edited] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589153#comment-15589153 ] Maximilian Michels edited comment on FLINK-2821 at 10/19/16 4:21 PM: ---

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589153#comment-15589153 ] Maximilian Michels commented on FLINK-2821: --- Thanks a lot for fast testing! You'

[jira] [Created] (FLINK-4852) ClassCastException when assigning Watermarks with TimeCharacteristic.ProcessingTime

Maximilian Michels created FLINK-4852: - Summary: ClassCastException when assigning Watermarks with TimeCharacteristic.ProcessingTime Key: FLINK-4852 URL: https://issues.apache.org/jira/browse/FLINK-4852

[jira] [Commented] (FLINK-4829) Accumulators are not thread safe

[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585534#comment-15585534 ] Maximilian Michels commented on FLINK-4829: --- To mitigate the problem, we have be

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582605#comment-15582605 ] Maximilian Michels commented on FLINK-2821: --- Thanks for testing [~philipp.bussch

[jira] [Commented] (FLINK-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch

[ https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581973#comment-15581973 ] Maximilian Michels commented on FLINK-4833: --- I think this occurs when the TaskMa

[jira] [Commented] (FLINK-4829) Accumulators are not thread safe

[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581850#comment-15581850 ] Maximilian Michels commented on FLINK-4829: --- Locking on a per-element basis in t

[jira] [Updated] (FLINK-4829) Accumulators are not thread safe

[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4829: -- Fix Version/s: 1.1.4 > Accumulators are not thread safe > --

[jira] [Updated] (FLINK-4829) Accumulators are not thread safe

[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4829: -- Affects Version/s: 1.1.3 > Accumulators are not thread safe > --

[jira] [Commented] (FLINK-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch

[ https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581816#comment-15581816 ] Maximilian Michels commented on FLINK-4833: --- This can also be tracked down to FL

[jira] [Resolved] (FLINK-4405) Implement Blob Server SSL

[ https://issues.apache.org/jira/browse/FLINK-4405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4405. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented with 069de27df67faecad741d8b

[jira] [Resolved] (FLINK-4325) Implement Web UI HTTPS

[ https://issues.apache.org/jira/browse/FLINK-4325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4325. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented with 069de27df67faecad741d8b

[jira] [Resolved] (FLINK-4404) Implement Data Transfer SSL

[ https://issues.apache.org/jira/browse/FLINK-4404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4404. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented with 069de27df67faecad741d8b

[jira] [Resolved] (FLINK-4324) Enable Akka SSL

[ https://issues.apache.org/jira/browse/FLINK-4324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4324. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented with 069de27df67faecad741d8b

[jira] [Resolved] (FLINK-3931) Implement Transport Encryption (SSL/TLS)

[ https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3931. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented with 069de27df67faecad741d8b

[jira] [Updated] (FLINK-4829) Accumulators are not thread safe

[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4829: -- Assignee: (was: Maximilian Michels) > Accumulators are not thread safe > ---

[jira] [Commented] (FLINK-4829) Accumulators are not thread safe

[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15575439#comment-15575439 ] Maximilian Michels commented on FLINK-4829: --- To fix the problem, we will have to

[jira] [Commented] (FLINK-2313) Change Streaming Driver Execution Model

[ https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15575392#comment-15575392 ] Maximilian Michels commented on FLINK-2313: --- +1 this also popped up recently on

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15575240#comment-15575240 ] Maximilian Michels commented on FLINK-2821: --- Forgot to mention, the build is bas

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15575226#comment-15575226 ] Maximilian Michels commented on FLINK-2821: --- [~philipp.bussche] Which version of

[jira] [Commented] (FLINK-4829) Accumulators are not thread safe

[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15574886#comment-15574886 ] Maximilian Michels commented on FLINK-4829: --- Actually, they used to be a synchro

[jira] [Assigned] (FLINK-4829) Accumulators are not thread safe

[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4829: - Assignee: Maximilian Michels > Accumulators are not thread safe > ---

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15574755#comment-15574755 ] Maximilian Michels commented on FLINK-2821: --- Here you can find the custom releas

[jira] [Assigned] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2821: - Assignee: Maximilian Michels > Change Akka configuration to allow accessing actor

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572364#comment-15572364 ] Maximilian Michels commented on FLINK-2821: --- Just out of fun, I actually tried t

[jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572274#comment-15572274 ] Maximilian Michels commented on FLINK-4824: --- I agree that we should differentiat

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15572174#comment-15572174 ] Maximilian Michels commented on FLINK-2821: --- Just to add another option: - Appl

[jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571879#comment-15571879 ] Maximilian Michels commented on FLINK-4824: --- That was recently changed (before w

[jira] [Commented] (FLINK-4813) Having flink-test-utils as a dependency outside Flink fails the build

[ https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15568657#comment-15568657 ] Maximilian Michels commented on FLINK-4813: --- +1 That sounds like a good solution

[jira] [Closed] (FLINK-4799) Re-add build-target symlink to project root

[ https://issues.apache.org/jira/browse/FLINK-4799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4799. - Resolution: Fixed Re-added symlink for Unix systems. master: 15df71ba9b4d6c630a09b1b46d54

[jira] [Commented] (FLINK-4806) ResourceManager stop listening JobManager's leader address

[ https://issues.apache.org/jira/browse/FLINK-4806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15568215#comment-15568215 ] Maximilian Michels commented on FLINK-4806: --- Thank you for your comments [~ykt83

[jira] [Created] (FLINK-4799) Re-add build-target symlink to project root

Maximilian Michels created FLINK-4799: - Summary: Re-add build-target symlink to project root Key: FLINK-4799 URL: https://issues.apache.org/jira/browse/FLINK-4799 Project: Flink Issue Typ

[jira] [Closed] (FLINK-4777) ContinuousFileMonitoringFunction may throw IOException when files are moved

[ https://issues.apache.org/jira/browse/FLINK-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4777. - Resolution: Fixed master: b949d42d9f16fe52126f03a960fdf23ad71e6e63 release-1.1: 7267562bb8

[jira] [Updated] (FLINK-4777) ContinuousFileMonitoringFunction may throw IOException when files are moved

[ https://issues.apache.org/jira/browse/FLINK-4777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4777: -- Description: FileSystem.listStatus(path) may throw an IOException when it lists files an

[jira] [Created] (FLINK-4777) ContinuousFileMonitoringFunction may throw IOException when files are moved

Maximilian Michels created FLINK-4777: - Summary: ContinuousFileMonitoringFunction may throw IOException when files are moved Key: FLINK-4777 URL: https://issues.apache.org/jira/browse/FLINK-4777 P

[jira] [Commented] (FLINK-4765) Migrate ConfigConstants to ConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-4765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1308#comment-1308 ] Maximilian Michels commented on FLINK-4765: --- +1 This will be a cleaner implement

[jira] [Resolved] (FLINK-3204) TaskManagers are not shutting down properly on YARN

[ https://issues.apache.org/jira/browse/FLINK-3204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3204. --- Resolution: Cannot Reproduce This doesn't seem to be relevant anymore. If the containe

[jira] [Resolved] (FLINK-4726) Quickstart: Java API - Broken

[ https://issues.apache.org/jira/browse/FLINK-4726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4726. --- Resolution: Not A Problem Fix Version/s: (was: 1.1.3) You are probably laun

[jira] [Resolved] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file are used

[ https://issues.apache.org/jira/browse/FLINK-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4724. --- Resolution: Not A Problem Thanks for reporting. I agree with [~eronwright], that this

[jira] [Commented] (FLINK-4583) NullPointerException in CliFrontend

[ https://issues.apache.org/jira/browse/FLINK-4583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1268#comment-1268 ] Maximilian Michels commented on FLINK-4583: --- Thanks for marking as duplicate, di

[jira] [Commented] (FLINK-4667) Yarn Session CLI not listening on correct ZK namespace when HA is enabled to use ZooKeeper backend

[ https://issues.apache.org/jira/browse/FLINK-4667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1259#comment-1259 ] Maximilian Michels commented on FLINK-4667: --- Thank you for reporting. > Yarn Se

[jira] [Commented] (FLINK-4326) Flink start-up scripts should optionally start services on the foreground

[ https://issues.apache.org/jira/browse/FLINK-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1215#comment-1215 ] Maximilian Michels commented on FLINK-4326: --- Maybe I'm missing the point here bu

[jira] [Closed] (FLINK-4538) Implement slot allocation protocol with JobMaster

[ https://issues.apache.org/jira/browse/FLINK-4538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4538. - Resolution: Fixed > Implement slot allocation protocol with JobMaster > --

[jira] [Closed] (FLINK-4348) Implement slot allocation protocol with TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4348. - Resolution: Fixed > Implement slot allocation protocol with TaskExecutor > ---

[jira] [Closed] (FLINK-4442) Implement Standalone ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4442. - Resolution: Fixed > Implement Standalone ResourceManager > --

[jira] [Closed] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager

[ https://issues.apache.org/jira/browse/FLINK-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4606. - Resolution: Fixed > Integrate the new ResourceManager with the existing FlinkResourceManag

[jira] [Commented] (FLINK-4318) Make master docs build target version-specific

[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1187#comment-1187 ] Maximilian Michels commented on FLINK-4318: --- Also changed the links on the homep

[jira] [Resolved] (FLINK-4318) Make master docs build target version-specific

[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4318. --- Resolution: Fixed Fix Version/s: 1.2.0 I've changed the code to include an opti

[jira] [Assigned] (FLINK-4318) Make master docs build target version-specific

[ https://issues.apache.org/jira/browse/FLINK-4318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4318: - Assignee: Maximilian Michels > Make master docs build target version-specific > -

[jira] [Closed] (FLINK-4763) Documentation doesn't update nightly

[ https://issues.apache.org/jira/browse/FLINK-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4763. - Resolution: Fixed Turns out, using Bundler's {{--full-index}} method to fetch Gem informat

[jira] [Updated] (FLINK-4763) Documentation doesn't update nightly

[ https://issues.apache.org/jira/browse/FLINK-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4763: -- Description: Nightly documentation builds fail, e.g. https://ci.apache.org/builders/fli

[jira] [Created] (FLINK-4763) Documentation doesn't update nightly

Maximilian Michels created FLINK-4763: - Summary: Documentation doesn't update nightly Key: FLINK-4763 URL: https://issues.apache.org/jira/browse/FLINK-4763 Project: Flink Issue Type: Bug

[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=15549140#comment-15549140 ] Maximilian Michels commented on FLINK-4485: --- Great to hear! :) > Finished jobs

[jira] [Closed] (FLINK-4677) Jars with no job executions produces NullPointerException in ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4677. - Resolution: Fixed master: 8c7c42f0e91aa3fa2016650e541bbb668e6b79db release-1.1: fddd89bcd5

[jira] [Closed] (FLINK-4732) Maven junction plugin security threat

[ https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4732. - Resolution: Fixed master: 5a573c6bc29c313d34981336d5bfc05185d323d2 release-1.1: a31a22ec7f

[jira] [Updated] (FLINK-4732) Maven junction plugin security threat

[ https://issues.apache.org/jira/browse/FLINK-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4732: -- Description: We use the Maven Junction plugin http://pyx4j.com/pyx4j-maven-plugins/mave

[jira] [Created] (FLINK-4732) Maven junction plugin security threat

Maximilian Michels created FLINK-4732: - Summary: Maven junction plugin security threat Key: FLINK-4732 URL: https://issues.apache.org/jira/browse/FLINK-4732 Project: Flink Issue Type: Bug

[jira] [Reopened] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasses

[ https://issues.apache.org/jira/browse/FLINK-4703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-4703: --- > RpcCompletenessTest: Add support for type arguments and subclasses > ---

[jira] [Closed] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasses

[ https://issues.apache.org/jira/browse/FLINK-4703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4703. - Resolution: Fixed > RpcCompletenessTest: Add support for type arguments and subclasses > -

[jira] [Updated] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasses

[ https://issues.apache.org/jira/browse/FLINK-4703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4703: -- Fix Version/s: (was: 1.2.0) > RpcCompletenessTest: Add support for type arguments an

[jira] [Updated] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasses

[ https://issues.apache.org/jira/browse/FLINK-4703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4703: -- Affects Version/s: (was: 1.2.0) > RpcCompletenessTest: Add support for type argument

[jira] [Closed] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasses

[ https://issues.apache.org/jira/browse/FLINK-4703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4703. - Resolution: Fixed Fixed with 87767ab4daf06300aac0e5d969e6e44808657187 > RpcCompletenessTe

[jira] [Updated] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasses

[ https://issues.apache.org/jira/browse/FLINK-4703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4703: -- Summary: RpcCompletenessTest: Add support for type arguments and subclasses (was: RpcCo

[jira] [Created] (FLINK-4703) RpcCompletenessTest: Add support for type arguments and subclasss

Maximilian Michels created FLINK-4703: - Summary: RpcCompletenessTest: Add support for type arguments and subclasss Key: FLINK-4703 URL: https://issues.apache.org/jira/browse/FLINK-4703 Project: Fl

[jira] [Created] (FLINK-4677) Jars with no job executions produces NullPointerException in ClusterClient

Maximilian Michels created FLINK-4677: - Summary: Jars with no job executions produces NullPointerException in ClusterClient Key: FLINK-4677 URL: https://issues.apache.org/jira/browse/FLINK-4677 Pr

[jira] [Comment Edited] (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=15518937#comment-15518937 ] Maximilian Michels edited comment on FLINK-4485 at 9/24/16 12:22 PM: ---

[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=15518941#comment-15518941 ] Maximilian Michels commented on FLINK-4485: --- [~nielsbasjes] Let me know if there

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