[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860888#comment-15860888
]
ASF GitHub Bot commented on FLINK-5739:
---
GitHub user clarkyzl opened a pull request:
GitHub user clarkyzl opened a pull request:
https://github.com/apache/flink/pull/3292
[FLINK-5739] [client] fix NullPointerException in CliFrontend
Type: Bug
Priority: Major
Problem Definition: CliFrontEnd throws a NullPointerException
Design:
see https://issues.apach
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860886#comment-15860886
]
shijinkui commented on FLINK-4252:
--
org.apache.flink.table.examples.java.WordCountTable.j
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860870#comment-15860870
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r100483661
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package org.apache.fl
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3278#discussion_r100482362
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBaseTest.java
---
@@ -293
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860859#comment-15860859
]
ASF GitHub Bot commented on FLINK-5701:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuoluo Yang updated FLINK-5739:
Description:
I've run a simple program on a local cluster. It always fails with code
Version: 1.3-S
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r100478286
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package org.apache.
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860828#comment-15860828
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user godfreyhe commented on a diff i
zhangrucong1982 created FLINK-5770:
--
Summary: Flink yarn session stop in non-detached model
Key: FLINK-5770
URL: https://issues.apache.org/jira/browse/FLINK-5770
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-5517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-5517.
Resolution: Fixed
Assignee: Ted Yu
Fix Version/s: 1.3.0
Resolved for
[
https://issues.apache.org/jira/browse/FLINK-5517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860781#comment-15860781
]
ASF GitHub Bot commented on FLINK-5517:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3235
---
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
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860696#comment-15860696
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r100470762
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package org.apache.fl
Github user godfreyhe commented on a diff in the pull request:
https://github.com/apache/flink/pull/3176#discussion_r100469073
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UserDefinedFunction.scala
---
@@ -24,4 +24,19 @@ package org.apache.
[
https://issues.apache.org/jira/browse/FLINK-5571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860677#comment-15860677
]
ASF GitHub Bot commented on FLINK-5571:
---
Github user godfreyhe commented on a diff i
Shaoxuan Wang created FLINK-5768:
Summary: Apply new aggregation functions and aggregate DataStream
API for streaming tables
Key: FLINK-5768
URL: https://issues.apache.org/jira/browse/FLINK-5768
Proje
Shaoxuan Wang created FLINK-5769:
Summary: Apply new aggregation functions for dataset tables
Key: FLINK-5769
URL: https://issues.apache.org/jira/browse/FLINK-5769
Project: Flink
Issue Type:
Shaoxuan Wang created FLINK-5767:
Summary: Add a new aggregate function interface
Key: FLINK-5767
URL: https://issues.apache.org/jira/browse/FLINK-5767
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5546:
-
Affects Version/s: (was: 1.3.0)
(was: 1.2.0)
> java.io.tmpdir setted as pro
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5546:
-
Fix Version/s: 1.2.1
> java.io.tmpdir setted as project build directory in surefire plugin
> -
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui reassigned FLINK-4562:
Assignee: shijinkui
> table examples make an divided module in flink-examples
> ---
[
https://issues.apache.org/jira/browse/FLINK-5217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5217:
-
Fix Version/s: 1.2.1
Description:
package org.apache.flink.streaming.api.checkpoint;
@Deprecated
@Pu
[
https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-4562:
-
Fix Version/s: 1.2.1
> table examples make an divided module in flink-examples
> -
[
https://issues.apache.org/jira/browse/FLINK-5640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5640:
-
Affects Version/s: (was: 1.2.1)
Fix Version/s: 1.2.1
> configure the explicit Unit Test file s
[
https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5650:
-
Affects Version/s: 1.2.0
Priority: Critical (was: Major)
Fix Version/s: 1.2.1
> Flin
[
https://issues.apache.org/jira/browse/FLINK-5705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5705:
-
Fix Version/s: 1.2.1
> webmonitor's request/response use UTF-8 explicitly
> --
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860633#comment-15860633
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui reassigned FLINK-5705:
Assignee: shijinkui
> webmonitor's request/response use UTF-8 explicitly
>
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3273
updated!
---
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 fe
[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860629#comment-15860629
]
shijinkui commented on FLINK-5754:
--
I need checkout a branch from 1.2.0 tag. And work on
[
https://issues.apache.org/jira/browse/FLINK-5749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860563#comment-15860563
]
ASF GitHub Bot commented on FLINK-5749:
---
Github user wenlong88 commented on the issu
Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/3288
hi @StephanEwen, the cases in flink-filesystem-connector will fail first in
our building machine. I have go through the cases in flink-fs-tests, I think
they will fail too if I remove the change fr
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860549#comment-15860549
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860547#comment-15860547
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100458026
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -138,4 +141,160 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860548#comment-15860548
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100458059
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -44,15 +47,15 @@ import org.apache.flink.tab
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3273
Thank you for your advice. I will update the PR soon.
---
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 thi
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100458044
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -138,4 +141,160 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860546#comment-15860546
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860543#comment-15860543
]
Zhijiang Wang commented on FLINK-5132:
--
Thank you, [~StephanEwen]. Yeah, it also make
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860518#comment-15860518
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100455645
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -138,4 +141,160 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860515#comment-15860515
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100455433
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -44,15 +47,15 @@ import org.apache.flink.t
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860513#comment-15860513
]
ASF GitHub Bot commented on FLINK-1526:
---
Github user xccui commented on a diff in th
Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3284#discussion_r100455274
--- Diff: docs/dev/libs/gelly/library_methods.md ---
@@ -242,6 +242,28 @@ The algorithm takes a directed, vertex (and possibly
edge) attributed graph as i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100454106
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -138,4 +141,160 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860504#comment-15860504
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860495#comment-15860495
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100453644
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala
---
@@ -138,4 +141,160 @@ class CsvTableSource(
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860490#comment-15860490
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100452676
--- Diff: docs/dev/table_api.md ---
@@ -253,56 +253,51 @@ Table result =
tableEnvironment.ingest("kafka-source");
The `CsvTableSource` is alread
[
https://issues.apache.org/jira/browse/FLINK-5714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860488#comment-15860488
]
ASF GitHub Bot commented on FLINK-5714:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3273#discussion_r100452526
--- Diff: docs/dev/table_api.md ---
@@ -253,56 +253,51 @@ Table result =
tableEnvironment.ingest("kafka-source");
The `CsvTableSource` is alread
[
https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860369#comment-15860369
]
Patrick Lucas commented on FLINK-5751:
--
I've identified the links as these using wget
[
https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860330#comment-15860330
]
Riccardo Diomedi commented on FLINK-5611:
-
Hi [~uce], I would like to contribute w
[
https://issues.apache.org/jira/browse/FLINK-4896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860296#comment-15860296
]
ASF GitHub Bot commented on FLINK-4896:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2733
@vasia Running on a c4.xlarge with 4 slots and a 4 GB preallocated
TaskManager heap. EdgeList measures the time to simplify the graph since the
library PageRank using Scatter-Gather ("PageRankSG")
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860271#comment-15860271
]
ASF GitHub Bot commented on FLINK-1526:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3284#discussion_r100421801
--- Diff: docs/dev/libs/gelly/library_methods.md ---
@@ -242,6 +242,28 @@ The algorithm takes a directed, vertex (and possibly
edge) attributed graph as i
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860265#comment-15860265
]
ASF GitHub Bot commented on FLINK-1526:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3284#discussion_r100421089
--- Diff: docs/dev/libs/gelly/library_methods.md ---
@@ -242,6 +242,28 @@ The algorithm takes a directed, vertex (and possibly
edge) attributed graph as i
[
https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860222#comment-15860222
]
Patrick Lucas commented on FLINK-5751:
--
I've actually run into quite a few broken lin
[
https://issues.apache.org/jira/browse/FLINK-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860217#comment-15860217
]
Haohui Mai commented on FLINK-5731:
---
One related but off-topic questions: Are there any
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-5624:
--
Issue Type: Improvement (was: Bug)
> Support tumbling window on streaming tables in the SQL API
> -
[
https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582930#comment-15582930
]
Ted Yu edited comment on FLINK-4848 at 2/9/17 8:04 PM:
---
There is sim
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860047#comment-15860047
]
Haohui Mai commented on FLINK-5654:
---
I may not fully get the question -- Is it possible
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15860036#comment-15860036
]
Haohui Mai commented on FLINK-5710:
---
Just FYI: FLINK-5624 implements the {{rowTime()}} f
[
https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859955#comment-15859955
]
ASF GitHub Bot commented on FLINK-1579:
---
Github user uce commented on the issue:
Stephan Ewen created FLINK-5766:
---
Summary: Unify NoAvailableResourceException handling on
ExecutionGraph
Key: FLINK-5766
URL: https://issues.apache.org/jira/browse/FLINK-5766
Project: Flink
Is
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3286
Thanks for this PR. I think it's super cool (and long overdue) to finally
have this. I think the general approach is sound and has good things going for
it.
But I see two problems with maintaini
[
https://issues.apache.org/jira/browse/FLINK-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859874#comment-15859874
]
ASF GitHub Bot commented on FLINK-5762:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3291
I think this works for now.
What would be great is in the long run to actually start the timer service
only in/after open() so that timers that are registered cannot fire.
That w
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3251
Thanks for the screenshots. My job was simple too narrow (not enough
operators). After trying with a job that has more operators, I could reproduce
the fix. Initially, I though that redrawing meant "zoom
[
https://issues.apache.org/jira/browse/FLINK-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859831#comment-15859831
]
ASF GitHub Bot commented on FLINK-2908:
---
Github user uce commented on the issue:
Ufuk Celebi created FLINK-5765:
--
Summary: Add noindex meta tag for older docs
Key: FLINK-5765
URL: https://issues.apache.org/jira/browse/FLINK-5765
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859817#comment-15859817
]
Ufuk Celebi commented on FLINK-5764:
Furthermore, we should look into explicitly remov
Ufuk Celebi created FLINK-5764:
--
Summary: Don't serve ancient docs
Key: FLINK-5764
URL: https://issues.apache.org/jira/browse/FLINK-5764
Project: Flink
Issue Type: Improvement
Componen
[
https://issues.apache.org/jira/browse/FLINK-5183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859800#comment-15859800
]
ASF GitHub Bot commented on FLINK-5183:
---
Github user GEOFBOT commented on the issue:
Github user GEOFBOT commented on the issue:
https://github.com/apache/flink/pull/3232
It may have worked with a smaller file, but there may be issues with
heavier jobs. When I ran a more computationally intensive and time consuming
job, the first job of the Python file ran successfull
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859785#comment-15859785
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859782#comment-15859782
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
> Results :
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0
This is what I get as test result.
---
If your project is set up for it, you can reply to this email and have your
re
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
It is CentOS Linux release 7.0.1406 (Core).
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859763#comment-15859763
]
ASF GitHub Bot commented on FLINK-5762:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3291
[FLINK-5762] Protect initializeState() and open() by the same lock
The description is in the related jira:
https://issues.apache.org/jira/browse/FLINK-5762
You can merge this pull request in
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2733
Running on a c4.xlarge with 4 slots and a 4 GB preallocated TaskManager
heap. EdgeList measures the time to simplify the graph since the library
PageRank using Scatter-Gather ("PageRankSG") require
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859758#comment-15859758
]
radu commented on FLINK-5654:
-
I have another dilemma for the implementation. When we build th
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859753#comment-15859753
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user tonycox commented on the issue:
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 what is your environment?
---
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-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859733#comment-15859733
]
ASF GitHub Bot commented on FLINK-5759:
---
GitHub user StephanEwen opened a pull reque
[
https://issues.apache.org/jira/browse/FLINK-4896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859749#comment-15859749
]
ASF GitHub Bot commented on FLINK-4896:
---
Github user greghogan commented on the issu
Ufuk Celebi created FLINK-5763:
--
Summary: Make savepoints self-contained and relocatable
Key: FLINK-5763
URL: https://issues.apache.org/jira/browse/FLINK-5763
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-5623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859736#comment-15859736
]
Greg Hogan commented on FLINK-5623:
---
The error does not occur when the graph is simplifi
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
I tried even that. The test runs fine for me. No OOME I get.
---
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 no
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/3290
[FLINK-5759] [jobmanager] Set UncaughtExceptionHandlers for JobManager's
Future and I/O thread pools
Currently, the thread pools of the `JobManager` do not have any
`UncaughtExceptionHandler`.
1 - 100 of 213 matches
Mail list logo
