[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15322006#comment-15322006
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/1962
Hi @sbcd90,
Gave the changes a quick review and commented. please let me know your
opinion on them. Hope they'll be helpful to get you going.
---
If your project is set up for it, you can
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/1962#discussion_r66388852
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321996#comment-15321996
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321994#comment-15321994
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/1962#discussion_r66388796
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/1962#discussion_r66388492
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321989#comment-15321989
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321935#comment-15321935
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/1962#discussion_r66385681
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321931#comment-15321931
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/1962#discussion_r66385603
--- Diff:
flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/ElasticsearchSink.java
--
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321852#comment-15321852
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user sbcd90 commented on the issue:
Github user sbcd90 commented on the issue:
https://github.com/apache/flink/pull/1962
Hello @StephanEwen ,
I have removed a timer & doing the retry logic directly now. The backoff is
3s. Please have a look.
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-3725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321682#comment-15321682
]
Ankit Chaudhary commented on FLINK-3725:
I did have this issue with my setup but a
Elias Levy created FLINK-4035:
-
Summary: Bump Kafka producer in Kafka sink to Kafka 0.10.0.0
Key: FLINK-4035
URL: https://issues.apache.org/jira/browse/FLINK-4035
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321354#comment-15321354
]
ASF GitHub Bot commented on FLINK-1979:
---
Github user skavulya commented on the issue
Github user skavulya commented on the issue:
https://github.com/apache/flink/pull/1985
@chiwanpark The PR is ready. Let me know if I need to do anything else.
---
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 proje
[
https://issues.apache.org/jira/browse/FLINK-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321245#comment-15321245
]
ASF GitHub Bot commented on FLINK-3530:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2080
These are the relevant logs of the task:
```
20:11:35,397 INFO org.apache.flink.runtime.taskmanager.Task
- Attempting to cancel task Source: Custom Source -> Map -> Map (
[
https://issues.apache.org/jira/browse/FLINK-3958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-3958.
---
Resolution: Not A Problem
> Access to MetricRegistry doesn't have proper synchronization in some classes
> ---
[
https://issues.apache.org/jira/browse/FLINK-3958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321232#comment-15321232
]
Stephan Ewen commented on FLINK-3958:
-
I agree with Chesnay.
Since the reporter is not
[
https://issues.apache.org/jira/browse/FLINK-3977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321226#comment-15321226
]
ASF GitHub Bot commented on FLINK-3977:
---
GitHub user rvdwenden opened a pull request
GitHub user rvdwenden opened a pull request:
https://github.com/apache/flink/pull/2086
[FLINK-3977] initialize FoldApplyWindowFunction properly
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rvdwenden/flink master
Alterna
Vladislav Pernin created FLINK-4034:
---
Summary: Dependency convergence on com.101tec:zkclient and
com.esotericsoftware.kryo:kryo
Key: FLINK-4034
URL: https://issues.apache.org/jira/browse/FLINK-4034
[
https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321130#comment-15321130
]
ASF GitHub Bot commented on FLINK-3937:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2085
[FLINK-3937] programmatic resuming of clusters
These changes are based on #1978 and #2034. More specifically, they port
resuming of running Yarn clusters from #2034 to the refactoring of #1978. The
abs
[
https://issues.apache.org/jira/browse/FLINK-3471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler resolved FLINK-3471.
-
Resolution: Fixed
Fix Version/s: 1.1.0
With the latest refactoring of the JDBCInput
[
https://issues.apache.org/jira/browse/FLINK-3553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-3553:
---
Assignee: Chesnay Schepler
> Don't include watermarks in record count
> -
[
https://issues.apache.org/jira/browse/FLINK-3958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321053#comment-15321053
]
Chesnay Schepler commented on FLINK-3958:
-
Why? no other method will be called on
[
https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320990#comment-15320990
]
Stephan Ewen commented on FLINK-2733:
-
Upon connection loss, can the client not try to
Tzu-Li (Gordon) Tai created FLINK-4033:
--
Summary: Missing Scala example snippets for the Kinesis Connector
documentation
Key: FLINK-4033
URL: https://issues.apache.org/jira/browse/FLINK-4033
Proj
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2082
---
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-4031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4031.
-
Resolution: Fixed
Fixed via fce64e193e32c9f639755f5b57222e6d7e89f150
> Nightly Jenkins jo
[
https://issues.apache.org/jira/browse/FLINK-4031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320878#comment-15320878
]
ASF GitHub Bot commented on FLINK-4031:
---
Github user asfgit closed the pull request
Chesnay Schepler created FLINK-4032:
---
Summary: Replace all usage of Guava Preconditions
Key: FLINK-4032
URL: https://issues.apache.org/jira/browse/FLINK-4032
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-4032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320716#comment-15320716
]
ASF GitHub Bot commented on FLINK-4032:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/2084
[FLINK-4032] Replace all usages Guava preconditions
This PR replaces every usage of the Guava Preconditions in Flink with our
own Preconditions class.
In addition,
- the guava dependenc
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2082
+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 this feature
enabled and wishes so, or if th
[
https://issues.apache.org/jira/browse/FLINK-4031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320674#comment-15320674
]
ASF GitHub Bot commented on FLINK-4031:
---
Github user rmetzger commented on the issue
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2083
[FLINK-3713] [clients, runtime] Use user code class loader when disposing
savepoints
Disposing savepoints via the JobManager fails for state handles or
descriptors, which contain user classes (for exam
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320670#comment-15320670
]
ASF GitHub Bot commented on FLINK-3713:
---
GitHub user uce opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320546#comment-15320546
]
ASF GitHub Bot commented on FLINK-4031:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2082
[FLINK-4031] include sources in Maven snapshot deployment
As per user request.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink FLINK-4031
Maximilian Michels created FLINK-4031:
-
Summary: Nightly Jenkins job doesn't deploy sources
Key: FLINK-4031
URL: https://issues.apache.org/jira/browse/FLINK-4031
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2832.
---
> Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement
> --
[
https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2832.
-
Resolution: Fixed
Fix Version/s: (was: 1.0.0)
1.1.0
Fixed via 297d75
[
https://issues.apache.org/jira/browse/FLINK-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3922.
---
> Infinite recursion on TypeExtractor
> ---
>
> Key: FLINK
[
https://issues.apache.org/jira/browse/FLINK-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3922.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed via e1b55f033d18b22e8a3f07920fa7c9e5623d6922
[
https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3405.
-
Resolution: Fixed
Fix Version/s: (was: 1.0.4)
Fixed via 38362c40bdd2e9a350630988c534b28
[
https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3405.
---
> Extend NiFiSource with interface StoppableFunction
> --
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4000.
---
> Exception: Could not restore checkpointed state to operators and functions;
> during Job Restart (Job
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4000.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed via ae679bb2aa1e0e239770605e049709fbc6b9962c
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320527#comment-15320527
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320529#comment-15320529
]
ASF GitHub Bot commented on FLINK-2832:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320526#comment-15320526
]
ASF GitHub Bot commented on FLINK-3922:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2062
---
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-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320528#comment-15320528
]
ASF GitHub Bot commented on FLINK-3405:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2076
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2011
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2047
---
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-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320516#comment-15320516
]
ASF GitHub Bot commented on FLINK-3869:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320515#comment-15320515
]
ASF GitHub Bot commented on FLINK-3869:
---
Github user aljoscha commented on the issue
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1973
---
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/1973
Kk, I added it to our "breaking changes for Flink 2.0" umbrella ticket.
Closing this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320511#comment-15320511
]
ASF GitHub Bot commented on FLINK-3869:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/1973
I would say so
---
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
Maximilian Michels created FLINK-4030:
-
Summary: ScalaShellITCase
Key: FLINK-4030
URL: https://issues.apache.org/jira/browse/FLINK-4030
Project: Flink
Issue Type: Bug
Components
[
https://issues.apache.org/jira/browse/FLINK-4020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320388#comment-15320388
]
ASF GitHub Bot commented on FLINK-4020:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/2081
[FLINK-4020][streaming-connectors] Move shard list querying to open() for
Kinesis consumer
Remove shard list querying from the constructor, and let all subtasks
independently discover which shards
Rami created FLINK-4029:
---
Summary: Multi-field "sum" function just like "keyBy"
Key: FLINK-4029
URL: https://issues.apache.org/jira/browse/FLINK-4029
Project: Flink
Issue Type: Improvement
Co
Github user uce commented on the pull request:
https://github.com/apache/flink/commit/0cf04108f70375d41ebb7c39629db3a081bd2876#commitcomment-17784955
Just noticed that `SubtaskState` cleanup only catches and logs exceptions
(`TaskForState` before, too). Does anyone recall what the rea
[
https://issues.apache.org/jira/browse/FLINK-4011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320297#comment-15320297
]
ASF GitHub Bot commented on FLINK-4011:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4011.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Resolved in http://git-wip-us.apache.org/repos/a
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2065
---
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-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320293#comment-15320293
]
ASF GitHub Bot commented on FLINK-4025:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4025.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Merged in http://git-wip-us.apache.org/repos/asf
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2073
---
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-3867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15320279#comment-15320279
]
Julius Neuffer commented on FLINK-3867:
---
The corresponding pull request can be found
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3869:
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-3957
> WindowedStream.apply w
80 matches
Mail list logo
