Mike Dias created FLINK-4885:
Summary: Improve the Elasticsearch configuration flexibility
Key: FLINK-4885
URL: https://issues.apache.org/jira/browse/FLINK-4885
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15597296#comment-15597296
]
Mike Dias commented on FLINK-4491:
--
Hi Flavio, I think that this is better addressed by u
Github user manuzhang commented on the issue:
https://github.com/apache/flink/pull/2645
Any more comments?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so,
[
https://issues.apache.org/jira/browse/FLINK-4838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15596638#comment-15596638
]
ASF GitHub Bot commented on FLINK-4838:
---
Github user manuzhang commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595767#comment-15595767
]
ASF GitHub Bot commented on FLINK-4204:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2670
I pushed a commit to remove the `GraphMetrics` example.
I think providing drivers for all library methods is both desirable and
ambitious. If we like the form and functionality of the curre
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595726#comment-15595726
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3674.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in
https://github.com/apache/fl
[
https://issues.apache.org/jira/browse/FLINK-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-4852.
-
Resolution: Fixed
Fix Version/s: (was: 1.1.4)
Fixed in
https://github.com/apac
[
https://issues.apache.org/jira/browse/FLINK-4877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-4877.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in
https://github.com/apache/fl
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2570
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is en
[
https://issues.apache.org/jira/browse/FLINK-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595703#comment-15595703
]
ASF GitHub Bot commented on FLINK-4852:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595701#comment-15595701
]
ASF GitHub Bot commented on FLINK-4852:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595702#comment-15595702
]
ASF GitHub Bot commented on FLINK-3030:
---
Github user iampeter commented on the issue
Github user iampeter commented on the issue:
https://github.com/apache/flink/pull/2448
@rmetzger will you be merging? if so,
`flink-runtime-web/web-dashboard/web/js/index.js` just needs a `gulp`
---
If your project is set up for it, you can reply to this email and have your
reply app
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2656
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is en
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2656
Manually merged
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or i
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595682#comment-15595682
]
ASF GitHub Bot commented on FLINK-3030:
---
Github user iampeter commented on the issue
Github user iampeter commented on the issue:
https://github.com/apache/flink/pull/2448
@mushketyk could you try `npm view gulp-stylus` ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this f
[
https://issues.apache.org/jira/browse/FLINK-4204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595656#comment-15595656
]
ASF GitHub Bot commented on FLINK-4204:
---
Github user vasia commented on the issue:
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2670
Hi @greghogan,
I really like the cleanup and new organization!
Two thoughts:
- is the plan to add drivers for all library methods?
- shall we remove the `GraphMetrics` example since there
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595581#comment-15595581
]
Fabian Hueske commented on FLINK-4604:
--
Hi [~anmu],
I think we can implement and add
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2669#discussion_r84509867
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java
---
@@ -96,11 +101,20 @@ public void setCommonRpcBindAdd
[
https://issues.apache.org/jira/browse/FLINK-4851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595486#comment-15595486
]
ASF GitHub Bot commented on FLINK-4851:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595559#comment-15595559
]
ASF GitHub Bot commented on FLINK-4871:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595561#comment-15595561
]
ASF GitHub Bot commented on FLINK-4871:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595560#comment-15595560
]
ASF GitHub Bot commented on FLINK-4871:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2669#discussion_r84509754
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java
---
@@ -96,11 +101,20 @@ public void setCommonRpcBindAdd
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2669#discussion_r84508885
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java
---
@@ -162,4 +180,63 @@ public String toString() {
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595552#comment-15595552
]
Evgeny Kincharov commented on FLINK-4315:
-
[~fhueske] , [~greghogan] , could you l
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2655#discussion_r84506385
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerJobMasterTest.java
---
@@ -145,6 +171,10 @@ public void
testRegist
Aljoscha Krettek created FLINK-4884:
---
Summary: Eagerly Store MergingWindowSet in State in WindowOperator
Key: FLINK-4884
URL: https://issues.apache.org/jira/browse/FLINK-4884
Project: Flink
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2655#discussion_r84507291
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingFatalErrorHandler.java
---
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-4851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595485#comment-15595485
]
ASF GitHub Bot commented on FLINK-4851:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595459#comment-15595459
]
ASF GitHub Bot commented on FLINK-4847:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595452#comment-15595452
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2657#discussion_r84501182
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -202,101 +205,125 @@ public void shutDown() throws Exc
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595448#comment-15595448
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595450#comment-15595450
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2657#discussion_r84501742
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -471,6 +498,149 @@ public void shutDownCluster(final A
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595447#comment-15595447
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2657#discussion_r84500048
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -202,101 +205,125 @@ public void shutDown() throws Exc
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2651
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2657#discussion_r84500271
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -202,101 +205,125 @@ public void shutDown() throws Exc
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595453#comment-15595453
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2657#discussion_r84501555
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -471,6 +498,149 @@ public void shutDownCluster(final A
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595451#comment-15595451
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2657#discussion_r84500666
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -202,101 +205,125 @@ public void shutDown() throws Exc
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2657#discussion_r84502118
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -471,6 +498,149 @@ public void shutDownCluster(final A
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595449#comment-15595449
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Shoshin reassigned FLINK-4541:
Assignee: Alexander Shoshin
> Support for SQL NOT IN operator
> ---
[
https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595359#comment-15595359
]
Alexander Shoshin commented on FLINK-2118:
--
Fabian,
thank you for the fast respon
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2678
I think it's fine to make `KafkaTableSource` public.
However, I think users usually want to go for a version-specific
`KafkaTableSource` like `Kafka090TableSource`. The version-specific sources a
[
https://issues.apache.org/jira/browse/FLINK-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595338#comment-15595338
]
ASF GitHub Bot commented on FLINK-4879:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2118.
Resolution: Not A Bug
Hi Alexander,
I agree and will close the issue.
Thanks for looking into this!
Stefan Richter created FLINK-4883:
-
Summary: Prevent UDFs implementations through Scala singleton
objects
Key: FLINK-4883
URL: https://issues.apache.org/jira/browse/FLINK-4883
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595160#comment-15595160
]
ASF GitHub Bot commented on FLINK-4876:
---
GitHub user attachmentgenie opened a pull r
GitHub user attachmentgenie opened a pull request:
https://github.com/apache/flink/pull/2680
[FLINK-4876] Allow web interface to be bound to a specific
ip/interface/inetHost
Currently the web interface automatically binds to all interfaces on
0.0.0.0. IMHO there are some use cases
[
https://issues.apache.org/jira/browse/FLINK-4882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595144#comment-15595144
]
ASF GitHub Bot commented on FLINK-4882:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2679
[FLINK-4882] [flip-6] Remove exceptions from HighAvailabilityServiceswhere
not necessary
Cleanup of the interface `HighAvailabilityServices` so that only methods
which really throw an
exce
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595078#comment-15595078
]
Greg Hogan edited comment on FLINK-3695 at 10/21/16 1:39 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595078#comment-15595078
]
Greg Hogan edited comment on FLINK-3695 at 10/21/16 1:34 PM:
-
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2671#discussion_r84463868
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java
---
@@ -99,8 +111,12 @@ public boo
[
https://issues.apache.org/jira/browse/FLINK-4773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595082#comment-15595082
]
ASF GitHub Bot commented on FLINK-4773:
---
Github user zentol commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2667
Thank you for your contribution!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wis
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2614
Iv'e rebased the branch and will merge it once travis passes.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not h
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2667
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3695:
--
Component/s: (was: Gelly)
Type Serialization System
> ValueArray types
> --
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595078#comment-15595078
]
Greg Hogan commented on FLINK-3695:
---
I have changed this ticket's component to "gelly" s
[
https://issues.apache.org/jira/browse/FLINK-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595076#comment-15595076
]
ASF GitHub Bot commented on FLINK-4864:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2673
Thanks for the PR @wuchong.
I tried to build a Table API program with the flink-table dependency, but
the compilation failed with the following error message:
> Caused by: scala.reflect.i
[
https://issues.apache.org/jira/browse/FLINK-4875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595071#comment-15595071
]
ASF GitHub Bot commented on FLINK-4875:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2676
+1 to merge this change.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishe
[
https://issues.apache.org/jira/browse/FLINK-3695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3695:
--
Component/s: (was: Type Serialization System)
Gelly
> ValueArray types
> --
Github user thvasilo commented on the issue:
https://github.com/apache/flink/pull/2668
Hello Thomas, thank you for your contribution!
I took a brief look so some initial comments:
This seems to be making changes to `MLUtils` which AFAIK is outside the
scope of this is
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2614
I think this is a good refactoring.
+1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have thi
[
https://issues.apache.org/jira/browse/FLINK-4773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595058#comment-15595058
]
ASF GitHub Bot commented on FLINK-4773:
---
Github user rmetzger commented on the issue
Github user manuzhang commented on the issue:
https://github.com/apache/flink/pull/2671
@mxm updated. Thanks for teaching me more about the internals. Ignoring the
old Timer make things much simpler actually.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595061#comment-15595061
]
ASF GitHub Bot commented on FLINK-4862:
---
Github user manuzhang commented on the issu
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2671#discussion_r84465826
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java
---
@@ -88,9 +96,13 @@ public Trig
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595035#comment-15595035
]
ASF GitHub Bot commented on FLINK-4862:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84467266
--- Diff: flink-contrib/docker-flink/bluemix-docker-compose.sh ---
@@ -0,0 +1,4 @@
+#!/bin/sh
--- End diff --
Adding a license file here.
---
If
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595032#comment-15595032
]
ASF GitHub Bot commented on FLINK-4862:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595036#comment-15595036
]
ASF GitHub Bot commented on FLINK-4862:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595056#comment-15595056
]
ASF GitHub Bot commented on FLINK-4563:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2650
correct; we could also use a `String[]` and `CharacterFilter[]`.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does no
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2660
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595040#comment-15595040
]
ASF GitHub Bot commented on FLINK-4833:
---
Github user asfgit closed the pull request
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/2615
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595041#comment-15595041
]
ASF GitHub Bot commented on FLINK-4772:
---
Github user zentol closed the pull request
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2671#discussion_r84465211
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java
---
@@ -88,9 +96,13 @@ public Trig
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595033#comment-15595033
]
ASF GitHub Bot commented on FLINK-4862:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595034#comment-15595034
]
ASF GitHub Bot commented on FLINK-4862:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2671#discussion_r84464275
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java
---
@@ -45,6 +45,12 @@
pri
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2671#discussion_r84464167
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java
---
@@ -88,9 +96,13 @@ public Trig
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595029#comment-15595029
]
Fabian Hueske commented on FLINK-4743:
--
Hi [~tonycox],
Thanks for looking into this
[
https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krishna Prasad Anna Ramesh Kumar updated FLINK-4874:
Description:
The local environment section in the local exec
[
https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15595011#comment-15595011
]
Alexander Shoshin commented on FLINK-2118:
--
I agree with [~RenkaiGe].
{{'name \!
Till Rohrmann created FLINK-4882:
Summary: Cleanup throws exception clause in
HighAvailabilityServices
Key: FLINK-4882
URL: https://issues.apache.org/jira/browse/FLINK-4882
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-4878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15594938#comment-15594938
]
Robert Metzger commented on FLINK-4878:
---
Fixed logging, so that we can understand th
1 - 100 of 204 matches
Mail list logo
