Kostas Kloudas created FLINK-3717:
-
Summary: Add functionality to get the current offset of a source
with a FileInputFormat
Key: FLINK-3717
URL: https://issues.apache.org/jira/browse/FLINK-3717
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1862#issuecomment-207438727
Thanks for the PR. I had a few minor comments but otherwise it looks really
good.
There are a few follow up issues, IMO:
- Check if we somehow can get
[
https://issues.apache.org/jira/browse/FLINK-3640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232194#comment-15232194
]
ASF GitHub Bot commented on FLINK-3640:
---
Github user fhueske commented on the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r59027469
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -1734,3 +1734,547 @@ vertex represents a group of vertices and each edge
represents a group of edges
vertex
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r59027618
--- Diff:
flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/examples/Graph500.java
---
@@ -0,0 +1,97 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232213#comment-15232213
]
ASF GitHub Bot commented on FLINK-3444:
---
Github user zentol commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232116#comment-15232116
]
Konstantin Knauf commented on FLINK-3713:
-
Works as expected.
> DisposeSavepoint message uses
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232198#comment-15232198
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3688.
-
Resolution: Fixed
Fix Version/s: 1.0.2
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232204#comment-15232204
]
ASF GitHub Bot commented on FLINK-3688:
---
Github user aljoscha commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1861#issuecomment-207440713
Could you please close if github does not do so automatically.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Aljoscha Krettek created FLINK-3718:
---
Summary: Add Option For Completely Async Backup in RocksDB State
Backend
Key: FLINK-3718
URL: https://issues.apache.org/jira/browse/FLINK-3718
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Niels Basjes closed FLINK-3584.
---
Resolution: Fixed
I double checked: This no longer occurs in 1.0.0.
I opened a new ticket for the
Niels Basjes created FLINK-3719:
---
Summary: WebInterface: Moving the barrier between graph and stats
Key: FLINK-3719
URL: https://issues.apache.org/jira/browse/FLINK-3719
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232183#comment-15232183
]
ASF GitHub Bot commented on FLINK-3640:
---
Github user fhueske commented on a diff in the pull
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r59026824
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -1734,3 +1734,547 @@ vertex represents a group of vertices and each edge
represents a group of edges
vertex
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r59026858
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -1734,3 +1734,547 @@ vertex represents a group of vertices and each edge
represents a group of edges
vertex
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232197#comment-15232197
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r59027355
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -1734,3 +1734,547 @@ vertex represents a group of vertices and each edge
represents a group of edges
vertex
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232206#comment-15232206
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r59027233
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -1734,3 +1734,547 @@ vertex represents a group of vertices and each edge
represents a group of edges
vertex
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232207#comment-15232207
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user vasia commented on a diff in the pull request:
Github user knaufk closed the pull request at:
https://github.com/apache/flink/pull/1861
---
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-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232072#comment-15232072
]
Niels Basjes commented on FLINK-3719:
-
Originally asked here FLINK-3584
> WebInterface: Moving the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1862#discussion_r59025508
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/sql/test/JoinITCase.scala
---
@@ -0,0 +1,239 @@
+/*
+ * Licensed to
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r59027687
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/AbstractGraphGenerator.java
---
@@ -0,0 +1,33 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232054#comment-15232054
]
Niels Basjes commented on FLINK-3670:
-
A while ago I found that part of the problem is in the upstream
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1771#issuecomment-207421723
I've tested the change again on a cluster and locally. The mode without WAL
works fine, the WAL-variant fails on (or quickly after) recovery.
It seems to be an
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232142#comment-15232142
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232179#comment-15232179
]
ASF GitHub Bot commented on FLINK-3640:
---
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/1862#discussion_r59025219
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/sql/test/AggregationsITCase.scala
---
@@ -0,0 +1,264 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-3717:
--
Description: This is the first step in order to make the File Sources
fault-tolerant. We have
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r59027023
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -1734,3 +1734,547 @@ vertex represents a group of vertices and each edge
represents a group of edges
vertex
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232200#comment-15232200
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232201#comment-15232201
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user vasia commented on a diff in the pull request:
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1807#issuecomment-207442760
Really amazing job @greghogan! I left a few suggestions on improving the
docs / usage of the generators. Otherwise, I think it's good to merge. This
will be a great
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232216#comment-15232216
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user vasia commented on the pull request:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r59026954
--- Diff: docs/apis/batch/libs/gelly.md ---
@@ -1734,3 +1734,547 @@ vertex represents a group of vertices and each edge
represents a group of edges
vertex
[
https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232208#comment-15232208
]
ASF GitHub Bot commented on FLINK-3688:
---
Github user knaufk closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232210#comment-15232210
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user vasia commented on a diff in the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1861#issuecomment-207287141
Thanks for your work! I'll merge it today.
---
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-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231813#comment-15231813
]
ASF GitHub Bot commented on FLINK-3688:
---
Github user aljoscha commented on the pull request:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1771#discussion_r58999599
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231910#comment-15231910
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231898#comment-15231898
]
Robert Metzger commented on FLINK-3709:
---
Hi Nick. I agree that showing rates instead of counts is
[
https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-2314:
--
Labels: (was: easyfix starter)
> Make Streaming File Sources Persistent
>
[
https://issues.apache.org/jira/browse/FLINK-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231878#comment-15231878
]
Robert Metzger commented on FLINK-3697:
---
Merged for 1.0.2:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1862#discussion_r59007483
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/AbstractTableEnvironment.scala
---
@@ -83,4 +84,17 @@ class
[
https://issues.apache.org/jira/browse/FLINK-3640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231990#comment-15231990
]
ASF GitHub Bot commented on FLINK-3640:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-3477:
--
Assignee: Gabor Gevay
> Add hash-based combine strategy for ReduceFunction
>
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1771#discussion_r59004103
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231954#comment-15231954
]
ASF GitHub Bot commented on FLINK-3311:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231995#comment-15231995
]
ASF GitHub Bot commented on FLINK-3640:
---
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/1862#discussion_r59007631
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/AbstractTableEnvironment.scala
---
@@ -83,4 +84,17 @@ class
[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232384#comment-15232384
]
Todd Lisonbee commented on FLINK-3716:
--
I opened a pull request with a fix.
By decreasing the
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1858#issuecomment-207507759
+1 to merge
---
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-3469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232466#comment-15232466
]
ASF GitHub Bot commented on FLINK-3469:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232212#comment-15232212
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user vasia commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232228#comment-15232228
]
Konstantin Knauf commented on FLINK-3669:
-
Is WindowCheckpointingIT the right place to put a test
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232286#comment-15232286
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user greghogan commented on a diff in the pull
Trevor Grant created FLINK-3720:
---
Summary: Add warm starts for models
Key: FLINK-3720
URL: https://issues.apache.org/jira/browse/FLINK-3720
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232374#comment-15232374
]
ASF GitHub Bot commented on FLINK-3716:
---
GitHub user tlisonbee opened a pull request:
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/1807#discussion_r59037618
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/generator/AbstractGraphGenerator.java
---
@@ -0,0 +1,33 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Todd Lisonbee updated FLINK-3716:
-
Labels: test-stability (was: )
> Kafka08ITCase.testFailOnNoBroker() timing out before it has a
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1857#issuecomment-207442123
+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-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232211#comment-15232211
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user vasia commented on a diff in the pull request:
GitHub user tlisonbee opened a pull request:
https://github.com/apache/flink/pull/1864
[FLINK-3716] Kafka08ITCase.testFailOnNoBroker() fix
Decreasing socket timeout so that testFailOnNoBroker() will be able to pass
before the JUnit timeout.
You can merge this pull request into a
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1866
[FLINK-3721] Min and max accumulators
Flink already contains DoubleCounter, IntCounter, and LongCounter for
adding numbers. This adds equivalent accumulators for storing the minimum and
maximum
[
https://issues.apache.org/jira/browse/FLINK-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232942#comment-15232942
]
ASF GitHub Bot commented on FLINK-3721:
---
GitHub user greghogan opened a pull request:
Github user danielblazevski commented on the pull request:
https://github.com/apache/flink/pull/1220#issuecomment-207685012
@hsaputra I added apache/flink as upstream, namely:
`git remote add upstream https://github.com/apache/flink.git`
Then I ran what Chiwan above
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15233304#comment-15233304
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user danielblazevski commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan reassigned FLINK-3279:
-
Assignee: Greg Hogan
> Optionally disable DistinctOperator combiner
>
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232661#comment-15232661
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user hsaputra commented on the pull request:
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1220#issuecomment-207547199
@danielblazevski : Sorry, but could you help rebase the conflicts for this
PR? Thanks
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232697#comment-15232697
]
Soila Kavulya commented on FLINK-2544:
--
+1 for documenting this. I ran into this while building the
GitHub user rawkintrevo opened a pull request:
https://github.com/apache/flink/pull/1865
[FLINK][3720] Added Warm Starts
This adds warm start functionality for IterativeSolver and
exposes/implements in Multiple Linear Regression.
Everything in the checklist should be GTG
[
https://issues.apache.org/jira/browse/FLINK-3709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232646#comment-15232646
]
Nick Dimiduk commented on FLINK-3709:
-
Thanks good news Robert. Is there a JIRA I should be following
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1807#issuecomment-207546079
@vasia thank you for the recommendations, the improvements are almost ready
to push. Running the `Graph500` example on an AWS c4.8xlarge (with 36 'virtual
cores')
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232653#comment-15232653
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user greghogan commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-1404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232639#comment-15232639
]
Ovidiu Marcu commented on FLINK-1404:
-
hi, is this related to the 'persistent-blocking-no back
Greg Hogan created FLINK-3721:
-
Summary: Min and max accumulators
Key: FLINK-3721
URL: https://issues.apache.org/jira/browse/FLINK-3721
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15232739#comment-15232739
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user shikhar commented on the pull request:
Github user shikhar commented on the pull request:
https://github.com/apache/flink/pull/1690#issuecomment-207563659
Another thing is that presence of offsets in ZK (0.8) / Kafka (0.9) also
affects what happens when a job is starting without a checkpoint / savepoint.
If they are
Github user rawkintrevo commented on the pull request:
https://github.com/apache/flink/pull/1865#issuecomment-207584968
There is an error in the docs (code isn't in the highlighting)- waiting to
see what else needs to be done (per reviewers comments) to minimize the commits
/
84 matches
Mail list logo
