Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2930
Failing test cases are unrelated. Merging 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 t
[
https://issues.apache.org/jira/browse/FLINK-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15719807#comment-15719807
]
ASF GitHub Bot commented on FLINK-5246:
---
Github user tillrohrmann commented on the i
Github user Renkai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2729#discussion_r90775528
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ScalaObjectChecker.java ---
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Found
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15719812#comment-15719812
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user Renkai commented on a diff in t
Ufuk Celebi created FLINK-5248:
--
Summary: SavepointITCase doesn't catch savepoint restore failure
Key: FLINK-5248
URL: https://issues.apache.org/jira/browse/FLINK-5248
Project: Flink
Issue Type:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2930#discussion_r90775412
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1376,6 +1376,24 @@ class JobManager(
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2930#discussion_r90775426
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -735,15 +735,15 @@ else if (checkpoint != null) {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2930#discussion_r90775397
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -1376,6 +1376,24 @@ class JobManager(
[
https://issues.apache.org/jira/browse/FLINK-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15719832#comment-15719832
]
ASF GitHub Bot commented on FLINK-5246:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15719831#comment-15719831
]
ASF GitHub Bot commented on FLINK-5246:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15719833#comment-15719833
]
ASF GitHub Bot commented on FLINK-5246:
---
Github user uce commented on a diff in the
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2927
Thanks for spotting these. It's fine to have both fixes in this PR. Going
to merge this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. I
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2806
Very good changes in general. The following should be addressed before
merging though:
- Add tests to `EventSerializerTest` with all currently available events
(including `OTHER_EVENT` instances).
[
https://issues.apache.org/jira/browse/FLINK-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15719898#comment-15719898
]
ASF GitHub Bot commented on FLINK-5066:
---
Github user uce commented on the issue:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2805#discussion_r90778003
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/writer/RecordWriterTest.java
---
@@ -421,22 +423,19 @@ private ResultPartitionWrite
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2805#discussion_r90777407
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamMockEnvironment.java
---
@@ -215,6 +189,31 @@ public Void answer(Invo
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2805#discussion_r90777958
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
---
@@ -131,35 +132,30 @@ private void sendToTarget(T reco
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2805#discussion_r90777962
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/ResultPartitionWriter.java
---
@@ -71,21 +68,26 @@ public void writeBuffer(B
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15719997#comment-15719997
]
ASF GitHub Bot commented on FLINK-5059:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15719996#comment-15719996
]
ASF GitHub Bot commented on FLINK-5059:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15719998#comment-15719998
]
ASF GitHub Bot commented on FLINK-5059:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15719995#comment-15719995
]
ASF GitHub Bot commented on FLINK-5059:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1571#comment-1571
]
ASF GitHub Bot commented on FLINK-5059:
---
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/2805#discussion_r90777420
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamMockEnvironment.java
---
@@ -215,6 +189,31 @@ public Void answer(Invo
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2829
Good additions with the Javadocs. All changes looks good to me.
---
While looking over the Serializer interface I noticed that `clear` and
`clearCurrentBuffer` are dangerously similar. But looking
GitHub user alpinegizmo opened a pull request:
https://github.com/apache/flink/pull/2931
In the example of rescaling, updated the description to match the figâ¦
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into con
David Anderson created FLINK-5249:
-
Summary: description of datastream rescaling doesn't match the
figure
Key: FLINK-5249
URL: https://issues.apache.org/jira/browse/FLINK-5249
Project: Flink
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2927
---
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-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720057#comment-15720057
]
Ufuk Celebi commented on FLINK-2844:
Removed obsolete config option from docs in 7fbd7
Github user alpinegizmo closed the pull request at:
https://github.com/apache/flink/pull/2931
---
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-5249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720084#comment-15720084
]
ASF GitHub Bot commented on FLINK-5249:
---
GitHub user alpinegizmo opened a pull reque
GitHub user alpinegizmo opened a pull request:
https://github.com/apache/flink/pull/2932
[FLINK-5249] [docs] description of datastream rescaling doesn't matchâ¦
In docs/dev/datastream_api.html#physical-partitioning the figure shows a
parallelism of 2 rescaling to 6 and back to 2 â
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2933
[FLINK-5016] [checkpointing] Split EventTimeWindowCheckpointingITCase
Split EventTimeWindowCheckpointingITCase up into multiple tests in order to
not run into the no output to stdout CI limit (currently
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720093#comment-15720093
]
ASF GitHub Bot commented on FLINK-5016:
---
GitHub user uce opened a pull request:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2786
Closing in favour of #2933.
---
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-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720094#comment-15720094
]
ASF GitHub Bot commented on FLINK-5016:
---
Github user uce commented on the issue:
Github user uce closed the pull request at:
https://github.com/apache/flink/pull/2786
---
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 enabled
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720095#comment-15720095
]
ASF GitHub Bot commented on FLINK-5016:
---
Github user uce closed the pull request at:
Github user ch33hau commented on the issue:
https://github.com/apache/flink/pull/2761
Hi @thvasilo , sorry for the late.
I have updated my PR according to above comments, however, I'm not
confident on the explanations for `GroupedProcessingTimeWindowExample` and
`SessionWindo
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720152#comment-15720152
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user ch33hau commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2933
Tests passed locally (https://travis-ci.org/uce/flink/builds/181127041)
except for one known issue and a test instability. Going to merge this.
---
If your project is set up for it, you can reply to thi
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720312#comment-15720312
]
ASF GitHub Bot commented on FLINK-5016:
---
Github user uce commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2933
---
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-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720315#comment-15720315
]
ASF GitHub Bot commented on FLINK-5016:
---
Github user asfgit closed the pull request
Aljoscha Krettek created FLINK-5250:
---
Summary: Make AbstractUdfStreamOperator aware of WrappingFunction
Key: FLINK-5250
URL: https://issues.apache.org/jira/browse/FLINK-5250
Project: Flink
Kurt Young created FLINK-5251:
-
Summary: Decouple StreamTableSourceScan with TableSourceTable
Key: FLINK-5251
URL: https://issues.apache.org/jira/browse/FLINK-5251
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-5251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720963#comment-15720963
]
ASF GitHub Bot commented on FLINK-5251:
---
GitHub user KurtYoung opened a pull request
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/2934
[FLINK-5251] [Table] Decouple StreamTableSourceScan with TableSourceTable
This jira is actually a supplement of
https://github.com/apache/flink/pull/2921, since it's also make sense for
streaming
Stephan Ewen created FLINK-5252:
---
Summary: Migrate all YARN related configurations to ConfigOptions
Key: FLINK-5252
URL: https://issues.apache.org/jira/browse/FLINK-5252
Project: Flink
Issue Ty
Stephan Ewen created FLINK-5253:
---
Summary: Remove special treatment of "dynamic properties"
Key: FLINK-5253
URL: https://issues.apache.org/jira/browse/FLINK-5253
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720989#comment-15720989
]
ASF GitHub Bot commented on FLINK-4927:
---
Github user StephanEwen commented on the is
Stephan Ewen created FLINK-5254:
---
Summary: Implement Yarn HA Services
Key: FLINK-5254
URL: https://issues.apache.org/jira/browse/FLINK-5254
Project: Flink
Issue Type: Sub-task
Compone
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2744
Manually merged to the FLIP-6 branch.
---
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
en
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2878
Manually merged to the FLIP-6 branch.
---
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
en
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2808
Manually merged to the FLIP-6 branch.
---
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
en
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720990#comment-15720990
]
ASF GitHub Bot commented on FLINK-4928:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15720991#comment-15720991
]
ASF GitHub Bot commented on FLINK-4929:
---
Github user StephanEwen commented on the is
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/2808
---
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 shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/2744
---
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-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721160#comment-15721160
]
ASF GitHub Bot commented on FLINK-4928:
---
Github user shuai-xu closed the pull reques
Github user shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/2878
---
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 shuai-xu closed the pull request at:
https://github.com/apache/flink/pull/2905
---
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-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721159#comment-15721159
]
ASF GitHub Bot commented on FLINK-4927:
---
Github user shuai-xu closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721163#comment-15721163
]
ASF GitHub Bot commented on FLINK-4929:
---
Github user shuai-xu closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721162#comment-15721162
]
ASF GitHub Bot commented on FLINK-5190:
---
Github user shuai-xu closed the pull reques
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/2935
[FLINK-4930] [client, yarn] Implement FLIP-6 YARN client
This pr is for issue
#[4930](https://issues.apache.org/jira/browse/FLINK-4930).
The FLIP-6 YARN client is responsible for:
Set up al
[
https://issues.apache.org/jira/browse/FLINK-4930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721400#comment-15721400
]
ASF GitHub Bot commented on FLINK-4930:
---
GitHub user shuai-xu opened a pull request:
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/2936
[FLINK-4927] [yarn] refine YARN Resource manager according to till's
comments
@StephanEwen , the YarnResourceManager.java you merged to flip-6 seems not
be the lastest version of pr #2808 . Althou
[
https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15721526#comment-15721526
]
ASF GitHub Bot commented on FLINK-4927:
---
GitHub user shuai-xu opened a pull request:
69 matches
Mail list logo
