[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15337058#comment-15337058
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2109
I've added a test for an HDFS file. Does this address your comment?
---
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 d
[
https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336994#comment-15336994
]
ASF GitHub Bot commented on FLINK-4053:
---
GitHub user mushketyk opened a pull request
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/2128
[FLINK-4053] Return value from Connection should be checked against null
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consi
[
https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336986#comment-15336986
]
Dominik Bruhn edited comment on FLINK-4091 at 6/17/16 9:24 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336986#comment-15336986
]
Dominik Bruhn commented on FLINK-4091:
--
Ok, I think I was unspecific here:
1. I works
[
https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336967#comment-15336967
]
Chesnay Schepler commented on FLINK-4091:
-
this issue is a bit surprising. the cas
[
https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Bruhn updated FLINK-4091:
-
Description:
The newly merged cassandra streaming connector has an issue with its guava
dependenc
Dominik Bruhn created FLINK-4091:
Summary: flink-connector-cassandra has conflicting guava version
Key: FLINK-4091
URL: https://issues.apache.org/jira/browse/FLINK-4091
Project: Flink
Issue T
Ted Yu created FLINK-4090:
-
Summary: Close of OutputStream should be in finally clause in
FlinkYarnSessionCli#writeYarnProperties()
Key: FLINK-4090
URL: https://issues.apache.org/jira/browse/FLINK-4090
Projec
Ted Yu created FLINK-4089:
-
Summary: Ineffective null check in
YarnClusterClient#getApplicationStatus()
Key: FLINK-4089
URL: https://issues.apache.org/jira/browse/FLINK-4089
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-4088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336349#comment-15336349
]
Flavio Pompermaier commented on FLINK-4088:
---
Do you think you could add a Dataso
[
https://issues.apache.org/jira/browse/FLINK-3641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336328#comment-15336328
]
ASF GitHub Bot commented on FLINK-3641:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2122
Looks good. +1
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336245#comment-15336245
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336248#comment-15336248
]
ASF GitHub Bot commented on FLINK-3864:
---
Github user zentol commented on the issue:
Github user rawkintrevo commented on the issue:
https://github.com/apache/flink/pull/1898
No problem @tillrohrmann ! I know there's been a lot going on. thank you!
---
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
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336257#comment-15336257
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-2259.
--
Resolution: Fixed
Added via bce3550936d9984298cba9f4dd45e9965fc45762
> Support training Estimat
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1898
---
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-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336250#comment-15336250
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user rawkintrevo commented on the is
Fabian Hueske created FLINK-4088:
Summary: Add interface to save and load TableSources
Key: FLINK-4088
URL: https://issues.apache.org/jira/browse/FLINK-4088
Project: Flink
Issue Type: Improve
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2125
the changes themselves look good, but can we change the commit message to
something else? You don't change anything in regards to _whether_ they check
for something, but rather _what_ they check for.
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/1898
Great work @rawkintrevo and thank you very much for your contribution :-)
I'm going to merge your PR now. Sorry for the long waiting time.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-4078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336207#comment-15336207
]
ASF GitHub Bot commented on FLINK-4078:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2116
note that the commit author is not properly set and will thus not be
attributed to your github account.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336201#comment-15336201
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67518000
--- Diff:
flink-metrics/flink-metrics-dropwizard/src/test/java/org/apache/flink/dropwizard/metrics/DropwizardHistogramWrapperTest.java
---
@@ -0,0 +1,319 @@
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336187#comment-15336187
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-2988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2988.
Resolution: Duplicate
FLINK-3901 is about adding a CsvInputFormat for the Row data type. Since there
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67516690
--- Diff:
flink-metrics/flink-metrics-dropwizard/src/test/java/org/apache/flink/dropwizard/metrics/DropwizardHistogramWrapperTest.java
---
@@ -0,0 +1,319 @@
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336184#comment-15336184
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67516462
--- Diff:
flink-metrics/flink-metrics-dropwizard/src/test/java/org/apache/flink/dropwizard/metrics/DropwizardHistogramWrapperTest.java
---
@@ -0,0 +1,319 @@
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336183#comment-15336183
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67516294
--- Diff:
flink-metrics/flink-metrics-dropwizard/src/main/java/org/apache/flink/dropwizard/metrics/HistogramWrapper.java
---
@@ -0,0 +1,52 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336178#comment-15336178
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67515825
--- Diff:
flink-core/src/test/java/org/apache/flink/metrics/reporter/JMXReporterTest.java
---
@@ -51,4 +69,106 @@ public void testGenerateName() {
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3849:
-
Assignee: (was: Fabian Hueske)
> Add FilterableTableSource interface and translation rule
> --
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3848:
-
Assignee: (was: Fabian Hueske)
> Add ProjectableTableSource interface and translation rule
> -
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336173#comment-15336173
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336172#comment-15336172
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67515502
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/reporter/JMXReporter.java ---
@@ -99,8 +100,11 @@ public void notifyOfAddedMetric(Metric metric, St
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67515450
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/reporter/AbstractReporter.java
---
@@ -32,9 +35,11 @@
*/
@PublicEvolving
public ab
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336167#comment-15336167
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67515277
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/groups/UnregisteredMetricsGroup.java
---
@@ -60,7 +61,17 @@ public Counter counter(String name) {
[
https://issues.apache.org/jira/browse/FLINK-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336144#comment-15336144
]
ASF GitHub Bot commented on FLINK-4087:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336160#comment-15336160
]
ASF GitHub Bot commented on FLINK-4078:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336165#comment-15336165
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67515143
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/HistogramStatistics.java ---
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the Apache Software Foun
[
https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336163#comment-15336163
]
ASF GitHub Bot commented on FLINK-3951:
---
Github user zentol commented on a diff in t
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2116
Looks very good! Thanks. The build failure is unrelated. I'll merge this
after you address the inline comments.
---
If your project is set up for it, you can reply to this email and have your
reply appe
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2112#discussion_r67515094
--- Diff:
flink-core/src/main/java/org/apache/flink/metrics/HistogramStatistics.java ---
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the Apache Software Foun
[
https://issues.apache.org/jira/browse/FLINK-4078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336154#comment-15336154
]
ASF GitHub Bot commented on FLINK-4078:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2116#discussion_r67514718
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CoGroupITCase.java
---
@@ -334,6 +335,124 @@ public void
testCoGroupWithMultipleKeyFi
[
https://issues.apache.org/jira/browse/FLINK-4078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336151#comment-15336151
]
ASF GitHub Bot commented on FLINK-4078:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2116#discussion_r67514396
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/CoGroupITCase.java
---
@@ -334,6 +335,124 @@ public void
testCoGroupWithMultipleKeyFi
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336149#comment-15336149
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/1954
Hi @fijolekProjects, sorry for the delayed review. Your work looks really
good :-) I only had some minor comments which we should address before your PR
can be merged. It's a cool feature which
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/2127
[FLINK-4087] [metrics] Improved JMX port handling
This PR modifies the JMX port handling.
Instead of setting a specific configured port on JVM start-up we use an
ephemeral port for the JVM's
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336137#comment-15336137
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1954#discussion_r67513578
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphRestartTest.java
---
@@ -174,71 +140,54 @@ private void vali
Chesnay Schepler created FLINK-4087:
---
Summary: JMXReporter can't handle port conflicts
Key: FLINK-4087
URL: https://issues.apache.org/jira/browse/FLINK-4087
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-4086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336038#comment-15336038
]
ASF GitHub Bot commented on FLINK-4086:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/2126
[FLINK-4086] [tableAPI] Hide internal methods of Expressions from Table API.
Added the `private[flink]` access modifier to all internal methods of
`Expressions`
You can merge this pull request into
Fabian Hueske created FLINK-4086:
Summary: Hide internal Expression methods from Table API
Key: FLINK-4086
URL: https://issues.apache.org/jira/browse/FLINK-4086
Project: Flink
Issue Type: Imp
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336030#comment-15336030
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1954#discussion_r67509184
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FailureRateRestartStrategy.java
---
@@ -0,0 +1,108 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336018#comment-15336018
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1954#discussion_r67507706
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FixedDelayRestartStrategy.java
---
@@ -108,22 +87,7 @@ public stat
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15336000#comment-15336000
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1954#discussion_r67506447
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java
---
@@ -54,6 +55,18 @@ public static RestartStrate
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335992#comment-15335992
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335988#comment-15335988
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1954#discussion_r67506020
--- Diff: docs/setup/config.md ---
@@ -139,6 +140,15 @@ Default value is 1.
- `restart-strategy.fixed-delay.delay`: Delay between restart attempts,
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1954#discussion_r67505960
--- Diff: docs/setup/config.md ---
@@ -139,6 +140,15 @@ Default value is 1.
- `restart-strategy.fixed-delay.delay`: Delay between restart attempts,
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335985#comment-15335985
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1954#discussion_r67505611
--- Diff: docs/apis/streaming/fault_tolerance.md ---
@@ -338,6 +342,77 @@ The default value is the value of *akka.ask.timeout*.
{% top %}
[
https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335983#comment-15335983
]
ASF GitHub Bot commented on FLINK-3190:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1954#discussion_r67505399
--- Diff: docs/apis/streaming/fault_tolerance.md ---
@@ -338,6 +342,77 @@ The default value is the value of *akka.ask.timeout*.
{% top %}
[
https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335976#comment-15335976
]
ASF GitHub Bot commented on FLINK-2733:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2103
---
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-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-2733.
Resolution: Fixed
Fixed via 1a6bab3ef76805685044cf4521e32315169f9033
> ZooKeeperLeaderElectionTest.
[
https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335970#comment-15335970
]
ASF GitHub Bot commented on FLINK-2733:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335969#comment-15335969
]
ASF GitHub Bot commented on FLINK-3714:
---
Github user aljoscha commented on the issue
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2103
Ran 10 Travis builds and couldn't reproduce the ZooKeeperLeaderElectionTest
failure. Thus, I assume that this PR fixes/hardens the test case. Will merge it
now.
---
If your project is set up f
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2093
Some tests, such as `testLateness()` still fill the expected output in one
block at the end of the test and not inline with the
`processElement()`/`processWatermark()` calls. Some, such as
`testDro
[
https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335955#comment-15335955
]
ASF GitHub Bot commented on FLINK-3864:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2125
[FLINK-3864] Yarn tests don't check for prohibited strings in log output
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink FLINK-3864
Alter
[
https://issues.apache.org/jira/browse/FLINK-3646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335951#comment-15335951
]
Kostas Kloudas commented on FLINK-3646:
---
The solution to this in included in https:/
[
https://issues.apache.org/jira/browse/FLINK-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335950#comment-15335950
]
ASF GitHub Bot commented on FLINK-3647:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2124
[FLINK-3647] Change StreamSource to use Processing-Time Clock Service
This PR changes the AutomaticWatermarkContext to user a pluggable
processing time clock. This
allows for better testability of
[
https://issues.apache.org/jira/browse/FLINK-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335937#comment-15335937
]
ASF GitHub Bot commented on FLINK-3949:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2119
merging
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-3859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335927#comment-15335927
]
ASF GitHub Bot commented on FLINK-3859:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335929#comment-15335929
]
ASF GitHub Bot commented on FLINK-3977:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2118
Merging
---
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 fea
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2088
Merging
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-4009:
--
Issue Type: Bug (was: Sub-task)
Parent: (was: FLINK-3454)
> Scala Shell fai
[
https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4009.
-
Resolution: Fixed
> Scala Shell fails to find library for inclusion in test
>
[
https://issues.apache.org/jira/browse/FLINK-4009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15335903#comment-15335903
]
Maximilian Michels commented on FLINK-4009:
---
Fixed with 4d8cbec4ffca033f5602a532
1 - 100 of 179 matches
Mail list logo
