[
https://issues.apache.org/jira/browse/FLINK-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263641#comment-15263641
]
ASF GitHub Bot commented on FLINK-3845:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1949#issuecomment-215641753
I would add a test case to verify the fix here, too. Otherwise, +1 and
thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appea
[
https://issues.apache.org/jira/browse/FLINK-3846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263637#comment-15263637
]
ASF GitHub Bot commented on FLINK-3846:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1948#issuecomment-215641198
Thanks for the fix! Can you also add a test case that verifies that the bug
is fixed? You can simply extend `GraphMutationsITCase`. And +1 to merge.
---
If your project i
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263517#comment-15263517
]
ramkrishna.s.vasudevan commented on FLINK-2168:
---
Can I take this issue now?
[
https://issues.apache.org/jira/browse/FLINK-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263140#comment-15263140
]
ASF GitHub Bot commented on FLINK-2946:
---
Github user fhueske commented on the pull r
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
enable
[
https://issues.apache.org/jira/browse/FLINK-3790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263095#comment-15263095
]
Gyula Fora commented on FLINK-3790:
---
Ah sorry, will try to fix it tomorrow if nobody did
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263021#comment-15263021
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user rawkintrevo commented on a diff
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 t
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263007#comment-15263007
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user rawkintrevo commented on a diff
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 w
[
https://issues.apache.org/jira/browse/FLINK-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 configuratio
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 enab
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 consideration.
[
https://issues.apache.org/jira/browse/FLINK-3790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262806#comment-15262806
]
Ufuk Celebi commented on FLINK-3790:
Yes, just noticed after creating the release arti
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262736#comment-15262736
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on the pull r
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 equali
[
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
---
@@ -0
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262697#comment-15262697
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262708#comment-15262708
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on the pull r
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-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262707#comment-15262707
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262706#comment-15262706
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user tzulitai commented on a diff in
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 Apa
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&focusedCommentId=15262690#comment-15262690
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on a diff in
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 Apa
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262687#comment-15262687
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on a diff in
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 Apa
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262665#comment-15262665
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on a diff in
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 Apa
Github user tzulitai commented on the pull request:
https://github.com/apache/flink/pull/1911#issuecomment-215512609
@rmetzger
No problem. In the meantime, I've made a few more changes, including more
test coverage for the consumer, minor refactoring, and user configuration
chang
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262638#comment-15262638
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user tzulitai commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262607#comment-15262607
]
ASF GitHub Bot commented on FLINK-3846:
---
GitHub user greghogan opened a pull request
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 into
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262599#comment-15262599
]
ASF GitHub Bot commented on FLINK-3277:
---
Github user vasia commented on the pull req
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 not
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262588#comment-15262588
]
ASF GitHub Bot commented on FLINK-3277:
---
Github user greghogan commented on the pull
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 previ
[
https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262538#comment-15262538
]
Vijay Srinivasaraghavan commented on FLINK-3239:
Thanks [~stefanobaghino]
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262521#comment-15262521
]
ASF GitHub Bot commented on FLINK-3277:
---
Github user vasia commented on the pull req
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 dif
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262500#comment-15262500
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61462874
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigIntComparator.java
---
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262496#comment-15262496
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in
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 Apa
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 Apa
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262491#comment-15262491
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262490#comment-15262490
]
Fabian Hueske commented on FLINK-2167:
--
I updated the title and description of this J
[
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 TableE
[
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 regis
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262485#comment-15262485
]
Konstantin Knauf commented on FLINK-3669:
-
[[~aljoscha] Thanks, will do the next t
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&focusedCommentId=15262468#comment-15262468
]
Fabian Hueske commented on FLINK-2170:
--
Updated the issue title and description to re
[
https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262470#comment-15262470
]
Fabian Hueske commented on FLINK-2169:
--
Updated the issue title and description to re
[
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}} should
[
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 ParquetTableS
[
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 {{ParquetTa
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262456#comment-15262456
]
Fabian Hueske commented on FLINK-2168:
--
Updated the issue description to reflect the
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2168:
-
Description:
Add a {{HBaseTableSource}} to read data from a HBase table. The
{{HBaseTableSource}}
[
https://issues.apache.org/jira/browse/FLINK-3447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262443#comment-15262443
]
Greg Hogan commented on FLINK-3447:
---
asm is short for [assembly
language|https://en.wik
[
https://issues.apache.org/jira/browse/FLINK-3447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262431#comment-15262431
]
Vasia Kalavri commented on FLINK-3447:
--
For implementations whose performance highly
[
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 `CsvTableSour
[
https://issues.apache.org/jira/browse/FLINK-2166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262413#comment-15262413
]
ASF GitHub Bot commented on FLINK-2166:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/939#issuecomment-215480471
This PR can be closed. A `CsvTableSource` has been implemented with PR
#1939.
---
If your project is set up for it, you can reply to this email and have your
reply appea
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 s
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3848:
-
Issue Type: New Feature (was: Task)
> Add ProjectableTableSource interface and translation rule
>
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&focusedCommentId=15262391#comment-15262391
]
Greg Hogan commented on FLINK-3447:
---
Thoughts on this, [~vkalavri]? Flink algorithms see
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
Issue
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
[
https://issues.apache.org/jira/browse/FLINK-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262378#comment-15262378
]
ASF GitHub Bot commented on FLINK-3277:
---
Github user greghogan commented on the pull
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 algorith
[
https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262368#comment-15262368
]
Stefano Baghino commented on FLINK-3239:
Thanks for reminding me [~vijikarthi], I'
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&focusedCommentId=15262363#comment-15262363
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on the pull r
[
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&focusedCommentId=15262366#comment-15262366
]
ASF GitHub Bot commented on FLINK-3454:
---
Github user greghogan commented on the pull
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 yo
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 ve
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262358#comment-15262358
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in
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 Apa
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262354#comment-15262354
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in
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-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3845:
--
Fix Version/s: 1.1.0
> Gelly allows duplicate vertices in Graph.addVertices
> --
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262355#comment-15262355
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262349#comment-15262349
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61449593
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigIntSerializer.java
---
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262346#comment-15262346
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in
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 Apa
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1928#discussion_r61449715
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BigDecSerializer.java
---
@@ -0,0 +1,137 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/FLINK-3786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262348#comment-15262348
]
ASF GitHub Bot commented on FLINK-3786:
---
Github user fhueske commented on a diff in
1 - 100 of 263 matches
Mail list logo
