[
https://issues.apache.org/jira/browse/FLINK-2094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15623730#comment-15623730
]
ASF GitHub Bot commented on FLINK-2094:
---
GitHub user kalmanchapman opened a pull request:
Till Rohrmann created FLINK-4986:
Summary: Harden JobMaster logic
Key: FLINK-4986
URL: https://issues.apache.org/jira/browse/FLINK-4986
Project: Flink
Issue Type: Sub-task
GitHub user kalmanchapman opened a pull request:
https://github.com/apache/flink/pull/2735
[FLINK-2094] implements Word2Vec for FlinkML
This pr implements Word2Vec for FlinkML - addressing Jira Issue
[Flink-2094](https://issues.apache.org/jira/browse/FLINK-2094)
Word2Vec
Mike Dias created FLINK-4988:
Summary: Elasticsearch 5.x support
Key: FLINK-4988
URL: https://issues.apache.org/jira/browse/FLINK-4988
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15624238#comment-15624238
]
ASF GitHub Bot commented on FLINK-4174:
---
GitHub user soniclavier opened a pull request:
Till Rohrmann created FLINK-4987:
Summary: Harden slot pool logic
Key: FLINK-4987
URL: https://issues.apache.org/jira/browse/FLINK-4987
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mike Dias closed FLINK-4885.
Resolution: Invalid
I just realized that these optimizations aren't doable because:
- The missing
GitHub user soniclavier opened a pull request:
https://github.com/apache/flink/pull/2736
[FLINK-4174] Enhance evictor functionality
The PR implements
[FLINK-4174](https://issues.apache.org/jira/browse/FLINK-4174) Enhance window
evictor as proposed in
[
https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15624170#comment-15624170
]
ASF GitHub Bot commented on FLINK-4923:
---
Github user zhuhaifengleon commented on a diff in the pull
Github user zhuhaifengleon commented on a diff in the pull request:
https://github.com/apache/flink/pull/2727#discussion_r85869851
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java
---
@@ -80,18 +76,25 @@ public Meter
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621616#comment-15621616
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user tonycox commented on the issue:
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2686
Hi @wuchong , native java implementation of "power" function suits to most
cases. So i deleted POWER_DEC from flink, because it has no proper types.
Actually we don't make user's life harder.
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2728
[hotfix] Improved test stability of RescalingITCase
This PR improves the test stability of RescalingITCase.
You can merge this pull request into a Git repository by running:
$ git pull
radu created FLINK-4969:
---
Summary: TypeInfoParser needs to be extended to parse the
java.sql.* types into the corresponding TypeInfos.
Key: FLINK-4969
URL: https://issues.apache.org/jira/browse/FLINK-4969
[
https://issues.apache.org/jira/browse/FLINK-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621555#comment-15621555
]
ASF GitHub Bot commented on FLINK-4932:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2711
Thanks for the review @uce. @StephanEwen actually discovered this problem.
The problem was related to #2700. When the scheduleOrUpdateConsumers call was
triggered when in state restarting due
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621663#comment-15621663
]
Anton Mushin commented on FLINK-4604:
-
bq. We can later remove these commits once the original PR got
[
https://issues.apache.org/jira/browse/FLINK-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621577#comment-15621577
]
ASF GitHub Bot commented on FLINK-4933:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2701
Will rebase, because this PR is based on the release-1.1 branch which
contained the failing `SpanningRecordSerializerTest`.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621850#comment-15621850
]
ASF GitHub Bot commented on FLINK-4315:
---
Github user kenmy commented on a diff in the pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2418
---
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-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621996#comment-15621996
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622040#comment-15622040
]
ASF GitHub Bot commented on FLINK-4935:
---
Github user zentol commented on a diff in the pull request:
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2686#discussion_r85732582
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarFunctions.scala
---
@@ -153,17 +153,42 @@ object
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2686#discussion_r85732685
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarFunctions.scala
---
@@ -153,17 +153,42 @@ object
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2686#discussion_r85732797
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/PowerCallGen.scala
---
@@ -0,0 +1,51 @@
+/*
+ *
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2686#discussion_r85732909
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarFunctions.scala
---
@@ -153,17 +153,42 @@ object
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2728
---
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-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622290#comment-15622290
]
ASF GitHub Bot commented on FLINK-4932:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622310#comment-15622310
]
ASF GitHub Bot commented on FLINK-4894:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2716
+1
Merging this...
---
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
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1562#comment-1562
]
Stephan Ewen commented on FLINK-3551:
-
If you want to help out with adding the Scala variants of these
[
https://issues.apache.org/jira/browse/FLINK-4960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4960:
--
Summary: Enable testing of different re-scaling scenarios in the
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622095#comment-15622095
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622151#comment-15622151
]
ASF GitHub Bot commented on FLINK-4887:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2699#discussion_r85737501
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java
---
@@ -243,22 +284,29 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4972:
Summary: CoordinatorShutdownTest relies on race condition for success
(was:
[
https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622283#comment-15622283
]
ASF GitHub Bot commented on FLINK-4923:
---
Github user zentol commented on a diff in the pull request:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2710
Good fix! Merging this...
---
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
[
https://issues.apache.org/jira/browse/FLINK-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622304#comment-15622304
]
ASF GitHub Bot commented on FLINK-4932:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2711
Thanks for the fix!
Looks good, merging this...
---
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
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2714#discussion_r85732479
--- Diff:
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarActionHandlerTest.java
---
@@ -0,0 +1,64 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622088#comment-15622088
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622089#comment-15622089
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622087#comment-15622087
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622086#comment-15622086
]
ASF GitHub Bot commented on FLINK-4743:
---
Github user wuchong commented on a diff in the pull
Chesnay Schepler created FLINK-4972:
---
Summary: CoordinatorShutdownTestrelies on race for success
Key: FLINK-4972
URL: https://issues.apache.org/jira/browse/FLINK-4972
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622262#comment-15622262
]
ASF GitHub Bot commented on FLINK-4970:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622278#comment-15622278
]
ASF GitHub Bot commented on FLINK-4450:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622274#comment-15622274
]
Lim Chee Hau commented on FLINK-3551:
-
Wonderful =)
Thanks
> Sync Scala and Java Streaming Examples
>
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2439
I think this is getting into good shape, we can almost merge it.
Two things remaining:
1. Can you rebase/squash all commits into one commit?
2. There is a complilation error,
[
https://issues.apache.org/jira/browse/FLINK-4935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622072#comment-15622072
]
ASF GitHub Bot commented on FLINK-4935:
---
Github user zentol commented on a diff in the pull request:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2686
Hi @tonycox , I agree with what Fabian said, it's the same as I mean in
this
[comment](https://github.com/apache/flink/pull/2686#issuecomment-256963469).
What I'm talking about POWER_DEC
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2728
Looks good. 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. If your project does not have this feature
enabled and
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2699#discussion_r85737529
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/TaskManagerLogHandler.java
---
@@ -243,22 +284,29 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622152#comment-15622152
]
ASF GitHub Bot commented on FLINK-4887:
---
Github user zentol commented on a diff in the pull request:
Stephan Ewen created FLINK-4971:
---
Summary: Unify Stream Sinks and OutputFormats
Key: FLINK-4971
URL: https://issues.apache.org/jira/browse/FLINK-4971
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4972:
Description:
The CoordinatorShutdownTest verifies that the CheckpointCoordinator is
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2730
[FLINK-4970] [gelly] Parameterize vertex value for SSSP
The input vertex values for SingleSourceShortestPaths and
GSASingleSourceShortestPaths are unused and replaced with a parameterized type.
[
https://issues.apache.org/jira/browse/FLINK-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4972:
Description:
The CoordinatorShutdownTest verifies that the CheckpointCoordinator is
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2727#discussion_r85746750
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java
---
@@ -80,18 +76,25 @@ public Meter
[
https://issues.apache.org/jira/browse/FLINK-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621570#comment-15621570
]
ASF GitHub Bot commented on FLINK-4933:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2700
Thanks for the review @uce. This is a problem which is relevant for the
current master. It could make the `ExecutionGraph` go into state `FAILED` when
being in state `RESTARTING` in case that
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2727#discussion_r85698371
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
---
@@ -111,6 +111,11 @@ public int getNumBuffers() {
[
https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621599#comment-15621599
]
ASF GitHub Bot commented on FLINK-4923:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4963:
--
Fix Version/s: 1.2.0
> Tabulate edge direction for directed VertexMetrics
>
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2714
minor comments, otherwise +1
---
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
[
https://issues.apache.org/jira/browse/FLINK-4935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622046#comment-15622046
]
ASF GitHub Bot commented on FLINK-4935:
---
Github user zentol commented on the issue:
GitHub user Renkai opened a pull request:
https://github.com/apache/flink/pull/2729
[FLINK-4883]Prevent UDFs implementations through Scala singleton objects
The code changes should be work, but I was quite a lot confused for these
reasons
1. The Scala wrapper for
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621980#comment-15621980
]
ASF GitHub Bot commented on FLINK-4883:
---
GitHub user Renkai opened a pull request:
Github user kenmy commented on a diff in the pull request:
https://github.com/apache/flink/pull/2637#discussion_r85715921
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/operator/JoinOperatorTest.java
---
@@ -1211,7 +1210,6 @@ public String toString() {
[
https://issues.apache.org/jira/browse/FLINK-4946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-4946:
--
Fix Version/s: 1.2.0
> Load jar files from subdirectories of lib
>
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2714#discussion_r85730733
--- Diff:
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarActionHandlerTest.java
---
@@ -0,0 +1,64 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622052#comment-15622052
]
ASF GitHub Bot commented on FLINK-4935:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622054#comment-15622054
]
ASF GitHub Bot commented on FLINK-4935:
---
Github user uce commented on the issue:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2714#discussion_r85730671
--- Diff: docs/monitoring/rest_api.md ---
@@ -652,3 +657,32 @@ The `savepointPath` points to the external path of the
savepoint, which can be u
"cause":
[
https://issues.apache.org/jira/browse/FLINK-4935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622050#comment-15622050
]
ASF GitHub Bot commented on FLINK-4935:
---
Github user uce commented on a diff in the pull request:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2714
Thanks for the review. I would like to merge this as soon as #2712 is in.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev reassigned FLINK-3848:
Assignee: Anton Solovev
> Add ProjectableTableSource interface and translation rule
>
Github user Makman2 commented on the issue:
https://github.com/apache/flink/pull/2703
Hello :)
Not sure what has gone wrong in the tests (it seems the CI is not really
stable when looking at other PRs, especially on my typo fixing PR), though it
would be good to merge it asap, as
[
https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621823#comment-15621823
]
ASF GitHub Bot commented on FLINK-4900:
---
Github user Makman2 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-4245:
---
Assignee: Chesnay Schepler
> Metric naming improvements
> --
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4245.
---
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2714#discussion_r85729826
--- Diff:
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarActionHandlerTest.java
---
@@ -0,0 +1,64 @@
+/*
+ *
Github user kenmy commented on a diff in the pull request:
https://github.com/apache/flink/pull/2637#discussion_r85715133
--- Diff:
flink-batch-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/FlinkHadoopEnvironment.java
---
@@ -0,0 +1,143
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15621841#comment-15621841
]
ASF GitHub Bot commented on FLINK-4315:
---
Github user kenmy commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622037#comment-15622037
]
ASF GitHub Bot commented on FLINK-4935:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2714#discussion_r85729577
--- Diff: docs/monitoring/rest_api.md ---
@@ -652,3 +657,32 @@ The `savepointPath` points to the external path of the
savepoint, which can be u
Greg Hogan created FLINK-4970:
-
Summary: Parameterize vertex value for SSSP
Key: FLINK-4970
URL: https://issues.apache.org/jira/browse/FLINK-4970
Project: Flink
Issue Type: Improvement
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2713
Going to merge this as #2712 was reviewed and this is essentially the same.
---
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-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622419#comment-15622419
]
ASF GitHub Bot commented on FLINK-4933:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622421#comment-15622421
]
ASF GitHub Bot commented on FLINK-4733:
---
Github user zentol closed the pull request at:
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/2616
---
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 greghogan opened a pull request:
https://github.com/apache/flink/pull/2731
[FLINK-4934] [gelly] Triadic Census
A triad is any three vertices in a graph. The triadic census produces
counts for each of the 4 undirected and 16 directed triad types.
You can merge this pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2637#discussion_r85761498
--- Diff:
flink-batch-connectors/flink-hadoop-compatibility/src/main/scala/org/apache/flink/api/scala/hadoop/FlinkHadoopEnvironment.scala
---
@@ -0,0 +1,165
[
https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-4973:
-
Assignee: Robert Metzger
> Flakey Yarn tests due to recently added latency marker
>
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2712
Thanks for the review. 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. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-4933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15622443#comment-15622443
]
ASF GitHub Bot commented on FLINK-4933:
---
Github user StephanEwen commented on the issue:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2637#discussion_r85762631
--- Diff:
flink-batch-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/HadoopInputs.java
---
@@ -0,0 +1,111 @@
Till Rohrmann created FLINK-4973:
Summary: Flakey Yarn tests due to recently added latency marker
Key: FLINK-4973
URL: https://issues.apache.org/jira/browse/FLINK-4973
Project: Flink
Issue
1 - 100 of 217 matches
Mail list logo
