[
https://issues.apache.org/jira/browse/FLINK-3923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317860#comment-15317860
]
Tzu-Li (Gordon) Tai commented on FLINK-3923:
I'm wondering whether or not it m
[
https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317678#comment-15317678
]
ASF GitHub Bot commented on FLINK-2985:
---
Github user gallenvara commented on the iss
Github user gallenvara commented on the issue:
https://github.com/apache/flink/pull/2078
@twalthr @fhueske can you help with reviewing this PR? Thanks! :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317673#comment-15317673
]
GaoLun edited comment on FLINK-2985 at 6/7/16 2:12 AM:
---
The refactor
[
https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317673#comment-15317673
]
GaoLun commented on FLINK-2985:
---
The refactoring work has been finished and i will go on wit
[
https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317665#comment-15317665
]
ASF GitHub Bot commented on FLINK-2985:
---
GitHub user gallenvara opened a pull reques
GitHub user gallenvara opened a pull request:
https://github.com/apache/flink/pull/2078
[FLINK-2985] Allow different field names for unionAll() in Table API
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consider
Github user chiwanpark commented on the issue:
https://github.com/apache/flink/pull/2076
Failing Travis is not related to this PR. Looks good to me!
---
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
[
https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317663#comment-15317663
]
ASF GitHub Bot commented on FLINK-2832:
---
Github user chiwanpark commented on the iss
Github user gallenvara closed the pull request at:
https://github.com/apache/flink/pull/2074
---
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
[
https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317664#comment-15317664
]
ASF GitHub Bot commented on FLINK-2985:
---
Github user gallenvara closed the pull requ
[
https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317661#comment-15317661
]
ASF GitHub Bot commented on FLINK-2832:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/2076#discussion_r6588
--- Diff: flink-java/src/test/resources/logback-test.xml ---
@@ -0,0 +1,34 @@
+
+
+
+
+
+%d{HH:mm:ss.SSS} [%
[
https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317662#comment-15317662
]
ASF GitHub Bot commented on FLINK-2832:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/2076#discussion_r6573
--- Diff: flink-java/src/test/resources/log4j-test.properties ---
@@ -0,0 +1,27 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
Github user mans2singh commented on the issue:
https://github.com/apache/flink/pull/2031
Hey @rmetzger, @StephanEwen, Flink Folks:
Just wanted to let you know that the rethinkdb java driver that I used for
Flink integration is available under Apache License 2.0
(https://gi
[
https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317469#comment-15317469
]
ASF GitHub Bot commented on FLINK-3967:
---
Github user mans2singh commented on the iss
Elias Levy created FLINK-4027:
-
Summary: FlinkKafkaProducer09 sink can lose messages
Key: FLINK-4027
URL: https://issues.apache.org/jira/browse/FLINK-4027
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317087#comment-15317087
]
ASF GitHub Bot commented on FLINK-4002:
---
Github user omaralvarez commented on the is
Github user omaralvarez commented on the issue:
https://github.com/apache/flink/pull/2063
Yes, I had the same thought looking at the code, I could not figure out why
it worked with HDFS...
---
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-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317078#comment-15317078
]
ASF GitHub Bot commented on FLINK-4002:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2063
looking at the code right now; i may have figured out why the files aren't
copied, but i find it odd that it supposedly works with hdfs. it actually
should never copy additional files if no parameters
[
https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3753:
--
Description:
{code}
// this is harsh, but this watchdog is a last resort
if (toKill.isAlive()) {
t
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3734:
--
Description:
{code}
DataInputView in = inputState.getState(getUserCodeClassloader());
final long nextEv
[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently y
[
https://issues.apache.org/jira/browse/FLINK-4024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317071#comment-15317071
]
Chesnay Schepler commented on FLINK-4024:
-
it also starts the function regardless
[
https://issues.apache.org/jira/browse/FLINK-3998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3998:
--
Description:
{code}
for (Map.Entry, String> entry : gauges.entrySet()) {
reportGauge(entry.getValue(),
[
https://issues.apache.org/jira/browse/FLINK-3958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3958:
--
Description:
In GraphiteReporter#getReporter():
{code} com.codahale.metrics.graphite.GraphiteReporter.Builder b
[
https://issues.apache.org/jira/browse/FLINK-4024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317064#comment-15317064
]
Fabian Hueske commented on FLINK-4024:
--
It appears that {{FileSourceFunction}} doesn'
[
https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317053#comment-15317053
]
ASF GitHub Bot commented on FLINK-4002:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2063
you can add it to this PR as a separate commit.
---
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 featu
[
https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317012#comment-15317012
]
ASF GitHub Bot commented on FLINK-4016:
---
Github user rvdwenden commented on the issu
Github user rvdwenden commented on the issue:
https://github.com/apache/flink/pull/2070
I checked in this change with this commit comment:
[FLINK-3977] initialize FoldApplyWindowFunction properly
Hopefully thatâs enough, however, on Travis CI I see that on my commit,
th
Github user omaralvarez commented on the issue:
https://github.com/apache/flink/pull/2063
I can confirm that there is a bug in `PythonPlanBinder.java`. When you pass
packages to the `runPlan()` function, they are not copied to the temp directory
in which `plan.py` file is generated. I
[
https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15317000#comment-15317000
]
ASF GitHub Bot commented on FLINK-4002:
---
Github user omaralvarez commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316643#comment-15316643
]
ASF GitHub Bot commented on FLINK-4026:
---
GitHub user dyanarose opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316599#comment-15316599
]
Chesnay Schepler commented on FLINK-3777:
-
small addition: there's some work being
[
https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Subhankar Biswas updated FLINK-3769:
Comment: was deleted
(was: IMO user should be able to build different configuration for queu
[
https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Subhankar Biswas updated FLINK-3769:
Comment: was deleted
(was: IMO user should be able to build different configuration for queu
[
https://issues.apache.org/jira/browse/FLINK-4026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316665#comment-15316665
]
Dyana Rose commented on FLINK-4026:
---
oh the indignity, I fixed my own misspellings in th
[
https://issues.apache.org/jira/browse/FLINK-4026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dyana Rose updated FLINK-4026:
--
Description: The streaming API section of the documentation has issues with
grammar that make it hard to
GitHub user dyanarose opened a pull request:
https://github.com/apache/flink/pull/2077
[FLINK-4026] Fix code, grammar, and link issues in the Streaming
documentation
* fixing grammar issues with he streaming API section of the documentation
that make it hard to follow in places.
[
https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316636#comment-15316636
]
Till Rohrmann commented on FLINK-2733:
--
The problem seems to be a connection loss to
[
https://issues.apache.org/jira/browse/FLINK-4026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316631#comment-15316631
]
Dyana Rose commented on FLINK-4026:
---
I've a branch for this that I'll PR shortly
> Fix
Dyana Rose created FLINK-4026:
-
Summary: Fix code, grammar, and link issues in the Streaming
documentation
Key: FLINK-4026
URL: https://issues.apache.org/jira/browse/FLINK-4026
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316571#comment-15316571
]
Dominik Bruhn commented on FLINK-4025:
--
No, actually they address different problems
[
https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316557#comment-15316557
]
Till Rohrmann commented on FLINK-2733:
--
Another instance:
https://s3.amazonaws.com/a
[
https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-2733:
Assignee: Till Rohrmann
> ZooKeeperLeaderElectionTest.testZooKeeperReelection fails
> -
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2076
[FLINK-2832] [tests] Hardens RandomSamplerTest
Increase the level of significance from p=0.01 to p=0.001 and add retry
annotations
to random sampler tests. This should decrease the probabil
[
https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316541#comment-15316541
]
ASF GitHub Bot commented on FLINK-2832:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-2832:
Assignee: Till Rohrmann
> Failing test: RandomSamplerTest.testReservoirSamplerWithReplaceme
[
https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316536#comment-15316536
]
Till Rohrmann commented on FLINK-2832:
--
Here is another instance of the failure (this
GitHub user kl0u reopened a pull request:
https://github.com/apache/flink/pull/2020
[FLINK-2314] Make Streaming File Sources Persistent
This PR solves FLINK-2314 and combines a number of sub-tasks. In addition,
it solves FLINK-3896 which was introduced as part of this task.
[
https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316529#comment-15316529
]
ASF GitHub Bot commented on FLINK-2314:
---
GitHub user kl0u reopened a pull request:
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/2020
---
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 enable
[
https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316527#comment-15316527
]
ASF GitHub Bot commented on FLINK-2314:
---
Github user kl0u closed the pull request at
[
https://issues.apache.org/jira/browse/FLINK-3960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3960.
-
Resolution: Fixed
Reverted in
https://github.com/apache/flink/commit/cfffdc87e3a3ac8aa7e3
[
https://issues.apache.org/jira/browse/FLINK-3948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3948.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in
https://github.com/apache/flink/co
[
https://issues.apache.org/jira/browse/FLINK-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316384#comment-15316384
]
Robert Metzger edited comment on FLINK-4025 at 6/6/16 11:51 AM:
[
https://issues.apache.org/jira/browse/FLINK-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316384#comment-15316384
]
Robert Metzger commented on FLINK-4025:
---
I guess this issue is subsumed by / duplica
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/1856
@zentol , @tillrohrmann , @fhueske
Any chance of review here. Sorry for regular reminders :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316380#comment-15316380
]
ASF GitHub Bot commented on FLINK-3650:
---
Github user ramkrish86 commented on the iss
Github user techmaniack commented on a diff in the pull request:
https://github.com/apache/flink/pull/2066#discussion_r65873361
--- Diff: flink-contrib/docker-flink/base/Dockerfile ---
@@ -38,12 +38,12 @@ ENV JAVA_HOME /usr/java/default/
RUN echo 'root:secret' | chpasswd
Github user gallenvara commented on the issue:
https://github.com/apache/flink/pull/2074
@twalthr @fhueske Can you help with review work? Thanks. :)
---
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 gallenvara opened a pull request:
https://github.com/apache/flink/pull/2074
[FLINK-2985] [Table API] Allow different field names for unionAll() in
Table API.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
[
https://issues.apache.org/jira/browse/FLINK-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Subhankar Biswas updated FLINK-3769:
Comment: was deleted
(was: IMO user should be able to build different configuration for queu
[
https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316320#comment-15316320
]
Flavio Pompermaier commented on FLINK-3777:
---
Hi Stephan,
we decided to introduce
[
https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316318#comment-15316318
]
Flavio Pompermaier commented on FLINK-3777:
---
Hi Stephan,
we decided to introduce
[
https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316302#comment-15316302
]
Chesnay Schepler commented on FLINK-3777:
-
these methods allow sharing resources a
[
https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316289#comment-15316289
]
ASF GitHub Bot commented on FLINK-4016:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2070
Hi,
I wrote in the issue that you opened. This is a duplicate of
https://issues.apache.org/jira/browse/FLINK-3977 and the way to fix it is to
make `InternalWindowFunction` properly forward calls
[
https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4016.
---
Resolution: Duplicate
This is a duplicate of FLINK-3977.
> FoldApplyWindowFunction is not pro
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2072
---
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-3769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316252#comment-15316252
]
Subhankar Biswas commented on FLINK-3769:
-
IMO user should be able to build differ
74 matches
Mail list logo
