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
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
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:
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
[
https://issues.apache.org/jira/browse/FLINK-4032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320716#comment-15320716
]
ASF GitHub Bot commented on FLINK-4032:
---
GitHub user zentol opened a pull request:
[
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
[
https://issues.apache.org/jira/browse/FLINK-4031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320878#comment-15320878
]
ASF GitHub Bot commented on FLINK-4031:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-3958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15321053#comment-15321053
]
Chesnay Schepler commented on FLINK-3958:
-
Why? no other method will be called on the reporter
[
https://issues.apache.org/jira/browse/FLINK-3977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15321226#comment-15321226
]
ASF GitHub Bot commented on FLINK-3977:
---
GitHub user rvdwenden opened a pull request:
[
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=15321232#comment-15321232
]
Stephan Ewen commented on FLINK-3958:
-
I agree with Chesnay.
Since the reporter is not active util
[
https://issues.apache.org/jira/browse/FLINK-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15321245#comment-15321245
]
ASF GitHub Bot commented on FLINK-3530:
---
Github user rmetzger commented on the issue:
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
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
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
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-3725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15321682#comment-15321682
]
Ankit Chaudhary commented on FLINK-3725:
I did have this issue with my setup but after including
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320511#comment-15320511
]
ASF GitHub Bot commented on FLINK-3869:
---
Github user StephanEwen commented on the issue:
[
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320516#comment-15320516
]
ASF GitHub Bot commented on FLINK-3869:
---
Github user aljoscha closed the pull request at:
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
[
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-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-3922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3922.
---
> Infinite recursion on TypeExtractor
> ---
>
> Key:
[
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
[
https://issues.apache.org/jira/browse/FLINK-4031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320546#comment-15320546
]
ASF GitHub Bot commented on FLINK-4031:
---
GitHub user mxm opened a pull request:
Maximilian Michels created FLINK-4030:
-
Summary: ScalaShellITCase
Key: FLINK-4030
URL: https://issues.apache.org/jira/browse/FLINK-4030
Project: Flink
Issue Type: Bug
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,
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
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
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320515#comment-15320515
]
ASF GitHub Bot commented on FLINK-3869:
---
Github user aljoscha commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320527#comment-15320527
]
ASF GitHub Bot commented on FLINK-4000:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320529#comment-15320529
]
ASF GitHub Bot commented on FLINK-2832:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320528#comment-15320528
]
ASF GitHub Bot commented on FLINK-3405:
---
Github user asfgit closed the pull request at:
[
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-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
[
https://issues.apache.org/jira/browse/FLINK-4011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320297#comment-15320297
]
ASF GitHub Bot commented on FLINK-4011:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320279#comment-15320279
]
Julius Neuffer commented on FLINK-3867:
---
The corresponding pull request can be found at
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
[
https://issues.apache.org/jira/browse/FLINK-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320293#comment-15320293
]
ASF GitHub Bot commented on FLINK-4025:
---
Github user asfgit closed the pull request at:
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
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
[
https://issues.apache.org/jira/browse/FLINK-4020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
[
https://issues.apache.org/jira/browse/FLINK-4016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320140#comment-15320140
]
Aljoscha Krettek commented on FLINK-4016:
-
[~rvdwenden] If you have a fix, please open a new PR
[
https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3986:
Summary: Rename readFileStream from the StreamExecutionEnvironment (was:
Rename the
[
https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320145#comment-15320145
]
ASF GitHub Bot commented on FLINK-3869:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/1973
So we shouldn't fix and but keep track of it for Flink 2.0?
---
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-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
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15321931#comment-15321931
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user tzulitai commented on a diff in the pull
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
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=15321935#comment-15321935
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15321852#comment-15321852
]
ASF GitHub Bot commented on FLINK-3857:
---
Github user sbcd90 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320670#comment-15320670
]
ASF GitHub Bot commented on FLINK-3713:
---
GitHub user uce opened a pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-4031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320674#comment-15320674
]
ASF GitHub Bot commented on FLINK-4031:
---
Github user rmetzger commented on the issue:
67 matches
Mail list logo
