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
[
https://issues.apache.org/jira/browse/FLINK-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15720057#comment-15720057
]
Ufuk Celebi commented on FLINK-2844:
Removed obsolete config option from docs in 7fbd757 (master),
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
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
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15720315#comment-15720315
]
ASF GitHub Bot commented on FLINK-5016:
---
Github user asfgit closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15719807#comment-15719807
]
ASF GitHub Bot commented on FLINK-5246:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15719832#comment-15719832
]
ASF GitHub Bot commented on FLINK-5246:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15719831#comment-15719831
]
ASF GitHub Bot commented on FLINK-5246:
---
Github user uce commented on a diff in the pull request:
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(
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
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 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
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15720093#comment-15720093
]
ASF GitHub Bot commented on FLINK-5016:
---
GitHub user uce opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-5246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15719833#comment-15719833
]
ASF GitHub Bot commented on FLINK-5246:
---
Github user uce commented on a diff in the pull request:
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.
[
https://issues.apache.org/jira/browse/FLINK-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15719898#comment-15719898
]
ASF GitHub Bot commented on FLINK-5066:
---
Github user uce commented on the issue:
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).
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15719995#comment-15719995
]
ASF GitHub Bot commented on FLINK-5059:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1571#comment-1571
]
ASF GitHub Bot commented on FLINK-5059:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15719998#comment-15719998
]
ASF GitHub Bot commented on FLINK-5059:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15719997#comment-15719997
]
ASF GitHub Bot commented on FLINK-5059:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15719996#comment-15719996
]
ASF GitHub Bot commented on FLINK-5059:
---
Github user uce commented on a diff in the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15720152#comment-15720152
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user ch33hau commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15720084#comment-15720084
]
ASF GitHub Bot commented on FLINK-5249:
---
GitHub user alpinegizmo opened a pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15719812#comment-15719812
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user Renkai commented on a diff in the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15720095#comment-15720095
]
ASF GitHub Bot commented on FLINK-5016:
---
Github user uce closed the pull request at:
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:
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
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15721160#comment-15721160
]
ASF GitHub Bot commented on FLINK-4928:
---
Github user shuai-xu closed the pull request at:
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
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
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
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:
[
https://issues.apache.org/jira/browse/FLINK-5251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15720990#comment-15720990
]
ASF GitHub Bot commented on FLINK-4928:
---
Github user StephanEwen commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15720989#comment-15720989
]
ASF GitHub Bot commented on FLINK-4927:
---
Github user StephanEwen commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15720991#comment-15720991
]
ASF GitHub Bot commented on FLINK-4929:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15721162#comment-15721162
]
ASF GitHub Bot commented on FLINK-5190:
---
Github user shuai-xu closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15721163#comment-15721163
]
ASF GitHub Bot commented on FLINK-4929:
---
Github user shuai-xu closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15721159#comment-15721159
]
ASF GitHub Bot commented on FLINK-4927:
---
Github user shuai-xu closed the pull request at:
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
[
https://issues.apache.org/jira/browse/FLINK-4930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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 .
[
https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15721526#comment-15721526
]
ASF GitHub Bot commented on FLINK-4927:
---
GitHub user shuai-xu opened a 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
68 matches
Mail list logo
