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

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

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

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

[jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

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

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

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

[jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

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

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

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

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

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

[jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

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

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[jira] [Commented] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection

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

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

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

[jira] [Commented] (FLINK-4268) Add a parsers for BigDecimal/BigInteger

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

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

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

[jira] [Commented] (FLINK-4268) Add a parsers for BigDecimal/BigInteger

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

[jira] [Commented] (FLINK-4268) Add a parsers for BigDecimal/BigInteger

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

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

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

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

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

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

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

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

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

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

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

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

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

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

[jira] [Commented] (FLINK-4414) Remove restriction on RpcService.getAddress

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

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

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

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

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

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

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

[jira] [Commented] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection

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

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

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

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

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15428099#comment-15428099 ] ASF GitHub Bot commented on FLINK-4222: --- Github user rmetzger commented on the issue

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

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

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

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

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

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

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-3319) Add or operator to CEP's pattern API

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

[jira] [Commented] (FLINK-3319) Add or operator to CEP's pattern API

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

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

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

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

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

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

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

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

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

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

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

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

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

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

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

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

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

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

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

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

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

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

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

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

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

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

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

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

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

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

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

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

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

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

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

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

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

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

[jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos

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

[jira] [Commented] (FLINK-4395) Eager processing of late arrivals in CEP operator

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

[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=15429744#comment-15429744 ] ASF GitHub Bot commented on FLINK-4439: --- GitHub user gheo21 opened a pull request:

[jira] [Commented] (FLINK-4440) Make API for edge/vertex creation less verbose

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

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

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

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

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

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