[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408993#comment-15408993
]
ASF GitHub Bot commented on FLINK-4035:
---
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/2231#discussion_r73648473
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
---
@@
Github user gallenvara commented on the issue:
https://github.com/apache/flink/pull/2282
@twalthr PR updated.
---
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 s
[
https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408987#comment-15408987
]
ASF GitHub Bot commented on FLINK-3940:
---
Github user gallenvara commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408958#comment-15408958
]
ASF GitHub Bot commented on FLINK-4035:
---
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/2231#discussion_r73646737
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408925#comment-15408925
]
ASF GitHub Bot commented on FLINK-4094:
---
GitHub user ramkrish86 opened a pull reques
GitHub user ramkrish86 opened a pull request:
https://github.com/apache/flink/pull/2336
FLINK-4094 Off heap memory deallocation might not properly work (Ram)
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into conside
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408921#comment-15408921
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2231
Sorry for the delay on the review. Reviewing + testing now ...
@radekg Yup the failure is unrelated to the changes here. Some of the tests
are currently a bit flaky.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408877#comment-15408877
]
ASF GitHub Bot commented on FLINK-4282:
---
Github user aditivin commented on the issue
Github user aditivin commented on the issue:
https://github.com/apache/flink/pull/2333
Hi,
Only the relevant changes are now visible. Pasting the details from the
previous pull request (#2331) here:
Added offset parameter for the following processing time window assigners:
[
https://issues.apache.org/jira/browse/FLINK-4313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408652#comment-15408652
]
Aljoscha Krettek commented on FLINK-4313:
-
Yes, the key-group support is only in t
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408643#comment-15408643
]
ASF GitHub Bot commented on FLINK-4282:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2333
Hi,
it doesn't help to just rebase it. I think you need to take the changes to
the relevant files and create a new commit from that since the commit you have
here contains a lot of other changes
[
https://issues.apache.org/jira/browse/FLINK-4312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408646#comment-15408646
]
Aljoscha Krettek commented on FLINK-4312:
-
+1
> Remove Serializabiliy of Executio
[
https://issues.apache.org/jira/browse/FLINK-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404889#comment-15404889
]
Zhenzhong Xu edited comment on FLINK-4308 at 8/4/16 10:23 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408570#comment-15408570
]
ASF GitHub Bot commented on FLINK-4308:
---
GitHub user zhenzhongxu opened a pull reque
GitHub user zhenzhongxu opened a pull request:
https://github.com/apache/flink/pull/2335
[FLINK-4308] Allow uploaded jar directory to be configurable
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2298
+1 for sticking to Java DataSet / DataStream for the reasons @twalthr gave.
The methods should be tagged with the `@Internal` annotation when we add them
to the Table API.
I would not rename
[
https://issues.apache.org/jira/browse/FLINK-4247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408524#comment-15408524
]
ASF GitHub Bot commented on FLINK-4247:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-3318:
-
Assignee: Ivan Mushketyk
> Add support for quantifiers to CEP's pattern API
> ---
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-3703:
-
Assignee: Ivan Mushketyk
> Add sequence matching semantics to discard matched events
> --
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408274#comment-15408274
]
ramkrishna.s.vasudevan commented on FLINK-4094:
---
I created the log related m
Stephan Ewen created FLINK-4313:
---
Summary: Inconsistent code for Key/Value in the
CheckpointCoordinator
Key: FLINK-4313
URL: https://issues.apache.org/jira/browse/FLINK-4313
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408106#comment-15408106
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2305
@zentol I think that works only in theory. In practice, probably no user is
going to realize that this trick is possible (even if we put it into the
JavaDocs). It also seems pretty mean thing to
[
https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408097#comment-15408097
]
ASF GitHub Bot commented on FLINK-4310:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2334
The added benefit is that this increases build stability on Travis, because
it relies on fewer flink-specific JARs to be downloaded and cached.
---
If your project is set up for it, you can repl
[
https://issues.apache.org/jira/browse/FLINK-4310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408080#comment-15408080
]
ASF GitHub Bot commented on FLINK-4310:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2334
[FLINK-4310] [build] Selectively run API compatibility checks in API
projects.
This moves the API compatibility checks into the API projects that use
stability annotations.
Previously, ever
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15408008#comment-15408008
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2305
I'm not so sure about breaking compatibility. Let's keep in mind that users
can work around this by casting the returned `DataStream` to a
`SingleOutputStreamOperator`.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407910#comment-15407910
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2305
As I said, I think it would be very good to change the return type to
`SingleOutputStreamOperator`. However, breaking binary compatibility should
also not be taken lightly.
---
If your project is
Stephan Ewen created FLINK-4312:
---
Summary: Remove Serializabiliy of ExecutionGraph
Key: FLINK-4312
URL: https://issues.apache.org/jira/browse/FLINK-4312
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407870#comment-15407870
]
Stephan Ewen commented on FLINK-4256:
-
[~zjwang] Preventing downstream restarts would
[
https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407866#comment-15407866
]
Stephan Ewen commented on FLINK-4256:
-
[~wenlong.lwl] True, one has to find the entire
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-3398:
--
Assignee: Tzu-Li (Gordon) Tai
> Flink Kafka consumer should support auto-commit
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407822#comment-15407822
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4280 at 8/4/16 2:08 PM:
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407822#comment-15407822
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4280 at 8/4/16 2:10 PM:
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407822#comment-15407822
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4280 at 8/4/16 2:08 PM:
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407822#comment-15407822
]
Tzu-Li (Gordon) Tai commented on FLINK-4280:
[~StephanEwen]
I'd like to start
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-4280:
--
Assignee: Tzu-Li (Gordon) Tai
> New Flink-specific option to set starting posit
[
https://issues.apache.org/jira/browse/FLINK-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407747#comment-15407747
]
ASF GitHub Bot commented on FLINK-3839:
---
Github user thormanrd commented on the issu
Github user thormanrd commented on the issue:
https://github.com/apache/flink/pull/2114
I do have them. I need to make time to re-do the PR. What is the best way
to sync my fork with the apache master? I can pull from apache master, push to
my forked master? Or should I create a P
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2251
Checked it out locally and all processes start up as expected. @greghogan I
think it's good to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
[
https://issues.apache.org/jira/browse/FLINK-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407715#comment-15407715
]
ASF GitHub Bot commented on FLINK-4212:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407678#comment-15407678
]
ASF GitHub Bot commented on FLINK-3839:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2114
I think we unfortunately need to redo this pull request.
It is almost impossible to review, because 90% of the changes in the diff
are code re-formattings. It is very hard to spot lines with a
[
https://issues.apache.org/jira/browse/FLINK-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407661#comment-15407661
]
ASF GitHub Bot commented on FLINK-4219:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2253
Looks good to me.
+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
enable
[
https://issues.apache.org/jira/browse/FLINK-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407660#comment-15407660
]
ASF GitHub Bot commented on FLINK-4212:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2251
This works on my machine (Ubuntu Linux 14.04)
Can someone verify it for MacOS? (@uce, @aljoscha, @tillrohrmann)?
---
If your project is set up for it, you can reply to this email and hav
[
https://issues.apache.org/jira/browse/FLINK-2042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407650#comment-15407650
]
Stephan Ewen commented on FLINK-2042:
-
I think this is still relevant, yes
> Increase
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2288
Thank you for this contribution.
Can you help us a bit so we can review this?
- Remove the template text for the Pull Request
- Tag the pull request with the JIRA issue it addresses
GitHub user aditivin opened a pull request:
https://github.com/apache/flink/pull/2333
[FLINK-4282] [streaming] Add Offset Parameter to WindowAssigners
I seem to be getting all these changes however I rebase it :/
It is currently rebased with the latest code of apache/master, and
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407569#comment-15407569
]
ASF GitHub Bot commented on FLINK-4282:
---
GitHub user aditivin opened a pull request:
Github user aditivin closed the pull request at:
https://github.com/apache/flink/pull/2331
---
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-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407547#comment-15407547
]
ASF GitHub Bot commented on FLINK-4282:
---
Github user aditivin closed the pull reques
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2324
---
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 StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2324
I already merged it before you appended the commit, needed it locally to
prevent always overwriting my cache with different versions. I basically pushed
the same thing now spread over two commits
[
https://issues.apache.org/jira/browse/FLINK-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4161.
---
> Quickstarts can exclude more flink-dist dependencies
> -
[
https://issues.apache.org/jira/browse/FLINK-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4161.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via 745b393f83563aa0efe95a0433aeb7a05c9263cc
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2309
---
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-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407475#comment-15407475
]
ASF GitHub Bot commented on FLINK-4161:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407443#comment-15407443
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user nielsbasjes commented on the is
Github user nielsbasjes commented on the issue:
https://github.com/apache/flink/pull/2330
I had another look at the "multiple tables" question. The name of the table
comes from the getTableName method that is to be implemented by the subclass. I
consider it to be extremely unlikely th
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407427#comment-15407427
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on the issue:
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
Hi, this is my second PR to Flink, any comments or suggestions will be very
appreciated :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407422#comment-15407422
]
ASF GitHub Bot commented on FLINK-2055:
---
GitHub user delding opened a pull request:
GitHub user delding opened a pull request:
https://github.com/apache/flink/pull/2332
[FLINK-2055] Implement Streaming HBaseSink
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes ta
Github user nielsbasjes commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r73482199
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
---
@@ -328,7 +328,11 @@ p
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407410#comment-15407410
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user nielsbasjes commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407394#comment-15407394
]
ASF GitHub Bot commented on FLINK-4311:
---
Github user nielsbasjes commented on a diff
Github user nielsbasjes commented on a diff in the pull request:
https://github.com/apache/flink/pull/2330#discussion_r73480826
--- Diff:
flink-batch-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
---
@@ -237,7 +244,7 @@ private void logSp
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2109
The build was failing because Jenkins couldn't merge my changes. I rebased
them to current master.
---
If your project is set up for it, you can reply to this email and have your
reply appear on G
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15407357#comment-15407357
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on the issu
78 matches
Mail list logo
