[
https://issues.apache.org/jira/browse/FLINK-3445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153589#comment-15153589
]
Ken Geis commented on FLINK-3445:
-
Thanks! I'm thinking that JDBC ResultSetMetaData could
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153404#comment-15153404
]
ASF GitHub Bot commented on FLINK-3368:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1623#issuecomment-185987092
The comments are mostly simplifications and faster response. I did not find
a critical issue, so this should be good to go, actually.
---
If your project is s
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1667#issuecomment-185985675
Hmm, I think we should change a few more things:
- Quite a few distribution classes can probably go. The new range
partitioner uses a different interface (@fhue
[
https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153399#comment-15153399
]
ASF GitHub Bot commented on FLINK-3169:
---
Github user StephanEwen commented on the pu
Greg Hogan created FLINK-3447:
-
Summary: Package Gelly algorithms by framework
Key: FLINK-3447
URL: https://issues.apache.org/jira/browse/FLINK-3447
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153144#comment-15153144
]
ASF GitHub Bot commented on FLINK-3446:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1673
[FLINK-3446] [runtime-web] Don't trigger back pressure sample for archived
job
Sampling a back pressure sample when the job has been archived, lead to a
NPE being thrown as reported by @rmetzger. Fix i
[
https://issues.apache.org/jira/browse/FLINK-3445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153132#comment-15153132
]
Chesnay Schepler commented on FLINK-3445:
-
this sounds interesting, can take a loo
Ufuk Celebi created FLINK-3446:
--
Summary: Back pressure tracker throws NPE for archived jobs
Key: FLINK-3446
URL: https://issues.apache.org/jira/browse/FLINK-3446
Project: Flink
Issue Type: Bug
Ken Geis created FLINK-3445:
---
Summary: make JDBCInputFormat implement ResultTypeQueryable
Key: FLINK-3445
URL: https://issues.apache.org/jira/browse/FLINK-3445
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-3224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153077#comment-15153077
]
Nick Dimiduk commented on FLINK-3224:
-
Thanks!
> The Streaming API does not call setI
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153038#comment-15153038
]
ASF GitHub Bot commented on FLINK-3368:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1623#issuecomment-185905274
Awesome, thank you. I'll take your changes from the pull request and
address the remaining issues.
---
If your project is set up for it, you can reply to this email an
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153031#comment-15153031
]
ASF GitHub Bot commented on FLINK-3368:
---
GitHub user StephanEwen opened a pull reque
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1623#issuecomment-185903526
I have made a few changes on top of this, which address some of the
comments above. Have a look at #1672
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153034#comment-15153034
]
ASF GitHub Bot commented on FLINK-3368:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15153030#comment-15153030
]
ASF GitHub Bot commented on FLINK-3368:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1623#issuecomment-185903144
I think this is in okay shape, quite an improvement over the current
version.
There are some things I suggest to re-examine:
Method `commitOffs
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/1672
[FLINK-3368][Kafka 0.8] Improvements to the Kafka Consumer changes
This makes some changes on top of #1623 , as remarked in the comments.
You can merge this pull request into a Git repository by
[
https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3147.
Resolution: Fixed
> HadoopOutputFormatBase should expose fields as protected
> -
[
https://issues.apache.org/jira/browse/FLINK-3224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3224.
Resolution: Fixed
> The Streaming API does not call setInputType if a format implements
> InputType
[
https://issues.apache.org/jira/browse/FLINK-3224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reopened FLINK-3224:
--
Assignee: Nick Dimiduk
> The Streaming API does not call setInputType if a format implements
[
https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reopened FLINK-3147:
--
Assignee: Nick Dimiduk
Sure! I gave you contributor permissions for JIRA as well. So you can a
Vasia Kalavri created FLINK-3444:
Summary: env.fromElements relies on the first input element for
determining the DataSet/DataStream type
Key: FLINK-3444
URL: https://issues.apache.org/jira/browse/FLINK-3444
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1663
---
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 vasia commented on the pull request:
https://github.com/apache/flink/pull/1663#issuecomment-185876066
Thanks, 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
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152917#comment-15152917
]
Jamie Grier edited comment on FLINK-1502 at 2/18/16 7:21 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152917#comment-15152917
]
Jamie Grier commented on FLINK-1502:
To be clear what I meant here is to have the inde
[
https://issues.apache.org/jira/browse/FLINK-3224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152915#comment-15152915
]
Nick Dimiduk commented on FLINK-3224:
-
This one as well.
> The Streaming API does no
[
https://issues.apache.org/jira/browse/FLINK-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152911#comment-15152911
]
Nick Dimiduk commented on FLINK-3147:
-
[~fhueske] would you mind assigning this to me?
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152895#comment-15152895
]
Jamie Grier commented on FLINK-1502:
I'm suggesting that we use Dropwizard Metrics lib
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152873#comment-15152873
]
Jamie Grier commented on FLINK-1502:
[~eastcirclek] Yes, I believe it does. It's impl
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152855#comment-15152855
]
ASF GitHub Bot commented on FLINK-3277:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1671
[FLINK-3277] Use Value types in Gelly API
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
3277_use_value_types_in_gelly_api
[
https://issues.apache.org/jira/browse/FLINK-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152810#comment-15152810
]
ASF GitHub Bot commented on FLINK-3248:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1670
[FLINK-3248] add constructor params and generic ConnectionFactory
This adds more default constructor parameters to the RMQSource. In addition,
users may override the setupConnectionFactory() method
[
https://issues.apache.org/jira/browse/FLINK-3439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152769#comment-15152769
]
Jamie Grier commented on FLINK-3439:
[~aljoscha] Just a quick question on this. In th
[
https://issues.apache.org/jira/browse/FLINK-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152742#comment-15152742
]
ASF GitHub Bot commented on FLINK-3443:
---
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/1669#discussion_r53354572
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -259,7 +259,7 @@ class JobManager(
// shut down the e
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1669
[FLINK-3443] [runtime] Prevent cancelled jobs from restarting
After JobManager shut down, it was possible that jobs were restarted,
because the execution graphs were failed and not cancelled. Although I
[
https://issues.apache.org/jira/browse/FLINK-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152740#comment-15152740
]
ASF GitHub Bot commented on FLINK-3443:
---
GitHub user uce opened a pull request:
Ufuk Celebi created FLINK-3443:
--
Summary: JobManager cancel and clear everything fails jobs instead
of cancelling
Key: FLINK-3443
URL: https://issues.apache.org/jira/browse/FLINK-3443
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152707#comment-15152707
]
ASF GitHub Bot commented on FLINK-3327:
---
Github user kl0u commented on the pull requ
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1583#issuecomment-185830388
Please Review this PR.
---
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 fe
GitHub user senorcarbone opened a pull request:
https://github.com/apache/flink/pull/1668
[FLINK-3257] Add Exactly-Once Processing Guarantees for Iterative
DataStream Jobs
# **[WIP]**
This is a first version of the adapted snapshot algorithm to support
iterations. It is correct
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152692#comment-15152692
]
ASF GitHub Bot commented on FLINK-3257:
---
GitHub user senorcarbone opened a pull requ
Gyula Fora created FLINK-3442:
-
Summary: Expose savepoint button on web ui
Key: FLINK-3442
URL: https://issues.apache.org/jira/browse/FLINK-3442
Project: Flink
Issue Type: Improvement
C
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152504#comment-15152504
]
Gabor Gevay commented on FLINK-3277:
There is one extra indirection (pointer) when som
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152459#comment-15152459
]
Greg Hogan commented on FLINK-3277:
---
That will be a nice feature. Is there reason to thi
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152448#comment-15152448
]
Gabor Gevay commented on FLINK-3277:
Ah, yes, you are right, this wouldn't work with T
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152442#comment-15152442
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1581#issuecomment-185772362
Three build configurations passes, one is currently running, the other
fails and I've spotted this stacktrace:
```
[ERROR] error: error while loading , Err
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152439#comment-15152439
]
Greg Hogan commented on FLINK-3277:
---
Would this not require a new version of Java allowi
[
https://issues.apache.org/jira/browse/FLINK-3417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152435#comment-15152435
]
Aljoscha Krettek commented on FLINK-3417:
-
Keep it open so that we don't lose trac
[
https://issues.apache.org/jira/browse/FLINK-3417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152434#comment-15152434
]
Aljoscha Krettek commented on FLINK-3417:
-
Yes, if they do this it works.
> Add
[
https://issues.apache.org/jira/browse/FLINK-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-2747:
Priority: Major (was: Blocker)
> TypeExtractor does not correctly analyze Scala Immutables
[
https://issues.apache.org/jira/browse/FLINK-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-2747:
Affects Version/s: 1.0.0
> TypeExtractor does not correctly analyze Scala Immutables (AnyVal
[
https://issues.apache.org/jira/browse/FLINK-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152431#comment-15152431
]
Aljoscha Krettek commented on FLINK-2747:
-
Won't be fixed. I'm not sure it can be
[
https://issues.apache.org/jira/browse/FLINK-3439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152428#comment-15152428
]
Aljoscha Krettek commented on FLINK-3439:
-
Yes, that's what I meant. If a source c
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1665#issuecomment-185756748
I'm going into the direction proposed by @StephanEwen, the change looks
trivial.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152413#comment-15152413
]
ASF GitHub Bot commented on FLINK-3438:
---
Github user stefanobaghino commented on the
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152407#comment-15152407
]
Gabor Gevay commented on FLINK-3277:
I think that this issue that new heap objects are
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1707:
-
Assignee: Josep Rubió
> Add an Affinity Propagation Library Method
> -
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1707:
-
Labels: requires-design-doc (was: )
> Add an Affinity Propagation Library Method
> --
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152393#comment-15152393
]
ASF GitHub Bot commented on FLINK-3368:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1623#issuecomment-185748371
So far nobody had this as an issue and during the integration tests and my
cluster tests, this issue never occurred. But I agree, there is no good reason
to fail hard h
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152387#comment-15152387
]
Josep Rubió commented on FLINK-1707:
Ok! I'll start doing a high level design.
> Add
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1660#issuecomment-185745685
Ran it on Ubuntu, and even though there still is the
NotSerializableException, the build still passes. Quite odd.
I may have misinterpreted the results of tests t
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152386#comment-15152386
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user zentol commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-3432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152376#comment-15152376
]
ASF GitHub Bot commented on FLINK-3432:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1664#issuecomment-185741473
The mkdirs() command failed for me on Windows. While debugging i noticed
that mkdirs provides no means of accessing the reason why it failed.
Files.createDirectories() is
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-3277:
-
Assignee: Greg Hogan
> Use Value types in Gelly API
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152355#comment-15152355
]
ASF GitHub Bot commented on FLINK-3169:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1667#issuecomment-185735755
The Pair type was removed as per FLINK-2344
---
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 projec
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152351#comment-15152351
]
ASF GitHub Bot commented on FLINK-3368:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1623#issuecomment-185735036
The `getPartitionsForTopic()` method fails hard immediately, when it does
not find the Topic name or partition. There will be no retries. Is that
desirable, or can i
[
https://issues.apache.org/jira/browse/FLINK-3327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152346#comment-15152346
]
ASF GitHub Bot commented on FLINK-3327:
---
Github user kl0u commented on the pull requ
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1583#issuecomment-185734236
The problem is the CRLF vs LF characters in the committed versions of the
files.
---
If your project is set up for it, you can reply to this email and have your
reply appe
[
https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152344#comment-15152344
]
ASF GitHub Bot commented on FLINK-3169:
---
Github user zentol commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-3433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152345#comment-15152345
]
ASF GitHub Bot commented on FLINK-3433:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1666#issuecomment-185733867
+1, please 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
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1667#issuecomment-185733734
SparseKeySchema and PossPassUtils were removed since they depended on Key,
but were unused.
---
If your project is set up for it, you can reply to this email and have yo
[
https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152332#comment-15152332
]
ASF GitHub Bot commented on FLINK-3169:
---
Github user zentol commented on the pull re
[
https://issues.apache.org/jira/browse/FLINK-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152330#comment-15152330
]
ASF GitHub Bot commented on FLINK-3438:
---
Github user StephanEwen commented on the pu
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1667#issuecomment-185732191
most occurrences of Key were replaced with Value, with casts to comparable
when it was necessary.
---
If your project is set up for it, you can reply to this email and h
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1665#issuecomment-185732111
Should be okay for the tests.
Just make sure you don't try to parse the returned stderr stream, but
simply take non-empty stream as an exception with a copy
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1667#issuecomment-185728371
This could really use some description of what is done in this PR. For
example, what happens to all the classes that depend on `Key`?
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152320#comment-15152320
]
ASF GitHub Bot commented on FLINK-3169:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152319#comment-15152319
]
ASF GitHub Bot commented on FLINK-3169:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/1667
[FLINK-3169] Remove Key class
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zentol/flink 3169_key
Alternatively you can review and apply these
[
https://issues.apache.org/jira/browse/FLINK-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-2917:
Priority: Major (was: Blocker)
> Make non-copying behaviour default for stream operator
> -
[
https://issues.apache.org/jira/browse/FLINK-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-2917:
Fix Version/s: 1.1.0
> Make non-copying behaviour default for stream operator
>
[
https://issues.apache.org/jira/browse/FLINK-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152316#comment-15152316
]
Stephan Ewen commented on FLINK-2917:
-
I think we unfortunately need to retain copying
[
https://issues.apache.org/jira/browse/FLINK-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152314#comment-15152314
]
Stephan Ewen commented on FLINK-2747:
-
Will this be addressed for 1.0? If not, let's r
[
https://issues.apache.org/jira/browse/FLINK-3440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-3440:
Priority: Blocker (was: Major)
> Kafka should also checkpoint partitions where no initial offset wa
[
https://issues.apache.org/jira/browse/FLINK-3441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152288#comment-15152288
]
Stephan Ewen commented on FLINK-3441:
-
Concerning Hadoop, what about a radical approac
[
https://issues.apache.org/jira/browse/FLINK-3441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152287#comment-15152287
]
Stephan Ewen commented on FLINK-3441:
-
One way to solve this is to set the dependencie
Till Rohrmann created FLINK-3441:
Summary: Revisit quickstarts exclusion policy
Key: FLINK-3441
URL: https://issues.apache.org/jira/browse/FLINK-3441
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15152281#comment-15152281
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user zentol commented on the pull re
1 - 100 of 189 matches
Mail list logo
