[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263517#comment-15263517
]
ramkrishna.s.vasudevan commented on FLINK-2168:
---
Can I take this issue now? Will come with a
[
https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263140#comment-15263140
]
ASF GitHub Bot commented on FLINK-2946:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1926#issuecomment-215579092
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-3790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263095#comment-15263095
]
Gyula Fora commented on FLINK-3790:
---
Ah sorry, will try to fix it tomorrow if nobody did already.
>
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263021#comment-15263021
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user rawkintrevo commented on a diff in the pull
Github user rawkintrevo commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r61504020
--- Diff:
flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/preprocessing/SplitterITSuite.scala
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263007#comment-15263007
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user rawkintrevo commented on a diff in the pull
Github user rawkintrevo commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r61503436
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to the
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1949
[FLINK-3845] [gelly] Gelly allows duplicate vertices in Graph.addVertices
Vertex sets are now merged with a cogroup so that a new Vertex is only
added to the Graph when no existing Vertex exists
[
https://issues.apache.org/jira/browse/FLINK-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262995#comment-15262995
]
ASF GitHub Bot commented on FLINK-3845:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-3790:
---
Fix Version/s: 1.0.3
1.1.0
> Rolling File sink does not pick up hadoop
Github user knaufk closed the pull request at:
https://github.com/apache/flink/pull/1944
---
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 knaufk reopened a pull request:
https://github.com/apache/flink/pull/1944
Timer coalescing across keys and cleanup of unused trigger tasks
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
[
https://issues.apache.org/jira/browse/FLINK-3790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262806#comment-15262806
]
Ufuk Celebi commented on FLINK-3790:
Yes, just noticed after creating the release artifacts that it
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262736#comment-15262736
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1928#issuecomment-215527988
Thanks for the update and the explanations @twalthr.
I think it would be good to leave comments about the "intentional bugs"
(missing null check and reference
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-2167:
Assignee: (was: Timo Walther)
> Register HCatalog as external catalog in TableEnvironment
>
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/1911#discussion_r61480982
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262697#comment-15262697
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262707#comment-15262707
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in the pull
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1928#issuecomment-215524424
@fhueske Thank you very much for reviewing this bitshifting monster ;-)
I have fixed the unintentional bugs.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262706#comment-15262706
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user tzulitai commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61481048
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigIntComparator.java
---
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61480212
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BigDecComparatorTest.java
---
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262690#comment-15262690
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61479446
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigIntSerializer.java
---
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262687#comment-15262687
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61478906
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigIntComparator.java
---
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262665#comment-15262665
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61476314
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigIntComparator.java
---
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1948
[FLINK-3846] [gelly] Graph.removeEdges also removes duplicate edges
All original edges are now emitted when no matching edge is found in the
edge removal set.
You can merge this pull request
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262599#comment-15262599
]
ASF GitHub Bot commented on FLINK-3277:
---
Github user vasia commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1671#issuecomment-215506281
I see. Thanks for the explanation!
---
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
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1671#issuecomment-215503980
The two implementations have small differences but the algorithm is the
same. I'll be removing the two steps which are concerned with degree skew since
I had not
[
https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262538#comment-15262538
]
Vijay Srinivasaraghavan commented on FLINK-3239:
Thanks [~stefanobaghino]
I believe the
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262521#comment-15262521
]
ASF GitHub Bot commented on FLINK-3277:
---
Github user vasia commented on the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1671#issuecomment-215494415
But was the difference you saw because of the different logic of the
algorithm or because of using Value types? I was under the impression that the
algorithm was quite
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262500#comment-15262500
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61462468
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigIntComparator.java
---
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61461901
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigIntComparator.java
---
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262491#comment-15262491
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262490#comment-15262490
]
Fabian Hueske commented on FLINK-2167:
--
I updated the title and description of this JIRA to reflect
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2167:
-
Summary: Register HCatalog as external catalog in TableEnvironment (was:
Add fromHCat() to
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2167:
-
Description: Register Hive's HCatalog as external catalog in the
{{TableEnvironment}}. After
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262485#comment-15262485
]
Konstantin Knauf commented on FLINK-3669:
-
[[~aljoscha] Thanks, will do the next time.
I tried
Fabian Hueske created FLINK-3851:
Summary: Add interface to register external catalogs in the
TableEnvironment
Key: FLINK-3851
URL: https://issues.apache.org/jira/browse/FLINK-3851
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262468#comment-15262468
]
Fabian Hueske commented on FLINK-2170:
--
Updated the issue title and description to reflect the new
[
https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262470#comment-15262470
]
Fabian Hueske commented on FLINK-2169:
--
Updated the issue title and description to reflect the new
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2170:
-
Description: Add a {{OrcTableSource}} to read data from an ORC file. The
{{OrcTableSource}}
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2170:
-
Summary: Add OrcTableSource (was: Add fromOrcFile() to TableEnvironment)
> Add OrcTableSource
>
[
https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2169:
-
Summary: Add ParquetTableSource (was: Add fromParquet() to
TableEnvironment)
> Add
[
https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2169:
-
Description: Add a {{ParquetTableSource}} to read data from a Apache
Parquet file. The
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262456#comment-15262456
]
Fabian Hueske commented on FLINK-2168:
--
Updated the issue description to reflect the new
[
https://issues.apache.org/jira/browse/FLINK-3447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262431#comment-15262431
]
Vasia Kalavri commented on FLINK-3447:
--
For implementations whose performance highly depends on the
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2168:
-
Summary: Add HBaseTableSource (was: Add fromHBase() to TableEnvironment)
> Add HBaseTableSource
[
https://issues.apache.org/jira/browse/FLINK-2166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2166.
Resolution: Implemented
Assignee: Fabian Hueske
Fix Version/s: 1.1.0
A
[
https://issues.apache.org/jira/browse/FLINK-2166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262413#comment-15262413
]
ASF GitHub Bot commented on FLINK-2166:
---
Github user fhueske commented on the pull request:
Fabian Hueske created FLINK-3850:
Summary: Add forward field annotations to DataSet operators
generated by the Table API
Key: FLINK-3850
URL: https://issues.apache.org/jira/browse/FLINK-3850
Project:
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3848:
-
Description:
Add a {{ProjectableTableSource}} interface for {{TableSource}} implementation
that
Fabian Hueske created FLINK-3849:
Summary: Add FilterableTableSource interface and translation rule
Key: FLINK-3849
URL: https://issues.apache.org/jira/browse/FLINK-3849
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262391#comment-15262391
]
Greg Hogan commented on FLINK-3447:
---
Thoughts on this, [~vkalavri]? Flink algorithms seem to be added,
Fabian Hueske created FLINK-3848:
Summary: Add ProjectableTableSource interface and translation rule
Key: FLINK-3848
URL: https://issues.apache.org/jira/browse/FLINK-3848
Project: Flink
Fabian Hueske created FLINK-3847:
Summary: Reorganize package structure of flink-table
Key: FLINK-3847
URL: https://issues.apache.org/jira/browse/FLINK-3847
Project: Flink
Issue Type: Task
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1671#issuecomment-215474401
@StephanEwen in [FLINK-3768](https://github.com/apache/flink/pull/1896) I
compared an optimal algorithm to the current implementation in Gelly and the
optimal
[
https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262368#comment-15262368
]
Stefano Baghino commented on FLINK-3239:
Thanks for reminding me [~vijikarthi], I've attached the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61450318
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BigIntComparatorTest.java
---
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262363#comment-15262363
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefano Baghino updated FLINK-3239:
---
Attachment: flink3239-prototype.patch
This is the first rough prototype to make Kafka work on
[
https://issues.apache.org/jira/browse/FLINK-3454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262366#comment-15262366
]
ASF GitHub Bot commented on FLINK-3454:
---
Github user greghogan commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1928#issuecomment-215471977
Thanks for the PR @twalthr. I added a few comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1698#issuecomment-215472110
@tillrohrmann I count three issues:
1) this current PR guarantees that for a full parallel the jar will be
built before the dependent test
2) when testing or
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61450677
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigIntComparator.java
---
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262354#comment-15262354
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61450218
--- Diff:
flink-core/src/test/java/org/apache/flink/api/common/typeutils/base/BigDecComparatorTest.java
---
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3846:
--
Fix Version/s: 1.1.0
> Graph.removeEdges also removes duplicate edges
>
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61449670
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigDecSerializer.java
---
@@ -0,0 +1,137 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262348#comment-15262348
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262341#comment-15262341
]
Vijay Srinivasaraghavan commented on FLINK-3239:
[~stefanobaghino] Could you please share
[
https://issues.apache.org/jira/browse/FLINK-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-3845:
-
Assignee: Greg Hogan
> Gelly allows duplicate vertices in Graph.addVertices
>
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1895#issuecomment-215460466
This looks good! ð I just had one inline question where I was hoping
that you already checked it out and can provide some insights.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262318#comment-15262318
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61446453
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigIntComparator.java
---
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262311#comment-15262311
]
ASF GitHub Bot commented on FLINK-3717:
---
Github user aljoscha commented on the pull request:
Greg Hogan created FLINK-3846:
-
Summary: Graph.removeEdges also removes duplicate edges
Key: FLINK-3846
URL: https://issues.apache.org/jira/browse/FLINK-3846
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262302#comment-15262302
]
ASF GitHub Bot commented on FLINK-3717:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1895#discussion_r61445422
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java
---
@@ -427,18 +434,37 @@ public void open(FileInputSplit
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1895#discussion_r61444801
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java
---
@@ -284,18 +322,24 @@ public T nextRecord(T record) throws
[
https://issues.apache.org/jira/browse/FLINK-3717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262298#comment-15262298
]
ASF GitHub Bot commented on FLINK-3717:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262292#comment-15262292
]
Stefano Baghino commented on FLINK-3239:
I've been able to come to a working prototype. The big
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262284#comment-15262284
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262285#comment-15262285
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61443708
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigDecComparator.java
---
@@ -0,0 +1,120 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262286#comment-15262286
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61443733
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigDecComparator.java
---
@@ -0,0 +1,120 @@
+/*
+ * Licensed to the
Greg Hogan created FLINK-3845:
-
Summary: Gelly allows duplicate vertices in Graph.addVertices
Key: FLINK-3845
URL: https://issues.apache.org/jira/browse/FLINK-3845
Project: Flink
Issue Type: Bug
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1947#discussion_r61443660
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -683,6 +688,9 @@ else if (STATE_UPDATER.compareAndSet(this,
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262277#comment-15262277
]
ASF GitHub Bot commented on FLINK-1502:
---
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/1947#discussion_r61443006
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -683,6 +688,9 @@ else if (STATE_UPDATER.compareAndSet(this,
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262259#comment-15262259
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user rmetzger commented on a diff in the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1900#issuecomment-215451225
One can now choose between:
`graph.translateEdgeValues(new LongValueToStringValue()))`
`graph.run(new TranslateEdgeValues<>(new LongValueToStringValue()))`
1 - 100 of 220 matches
Mail list logo
