[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5546:
-
Summary: java.io.tmpdir setted as project build directory in surefire
plugin (was: When multiple users
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834014#comment-15834014
]
ASF GitHub Bot commented on FLINK-5546:
---
GitHub user shijinkui opened a pull request:
GitHub user shijinkui opened a pull request:
https://github.com/apache/flink/pull/3190
[FLINK-5546][build] When multiple users run test, /tmp/cacheFile confâ¦
Unit test will create file in java.io.tmpdir, default it's `/tmp` which has
capacity limit.
Create temporary in
[
https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834008#comment-15834008
]
ASF GitHub Bot commented on FLINK-3318:
---
Github user chermenin commented on a diff in the pull
Github user chermenin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2361#discussion_r97264252
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/State.java ---
@@ -43,7 +43,14 @@ public State(final String name, final
[
https://issues.apache.org/jira/browse/FLINK-5508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833957#comment-15833957
]
ASF GitHub Bot commented on FLINK-5508:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3158
This is an identical backport / forwardport of the other 3 Mesos fixes,
correct?
If so, since #3155 and #3156 all have +1s, and #3157 is also a +1 once the
minor code style comments are
[
https://issues.apache.org/jira/browse/FLINK-5508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833953#comment-15833953
]
ASF GitHub Bot commented on FLINK-5508:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833949#comment-15833949
]
ASF GitHub Bot commented on FLINK-5508:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833952#comment-15833952
]
ASF GitHub Bot commented on FLINK-5508:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833948#comment-15833948
]
ASF GitHub Bot commented on FLINK-5508:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833951#comment-15833951
]
ASF GitHub Bot commented on FLINK-5508:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833950#comment-15833950
]
ASF GitHub Bot commented on FLINK-5508:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3157#discussion_r97253388
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
---
@@ -394,6 +395,14 @@ protected
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3157#discussion_r97257309
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperUtilityFactory.java
---
@@ -0,0 +1,120 @@
+/*
+ * Licensed to the
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3157#discussion_r97257878
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperUtilityFactory.java
---
@@ -0,0 +1,120 @@
+/*
+ * Licensed to the
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3157#discussion_r97256203
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperVersionedValue.java
---
@@ -0,0 +1,43 @@
+/*
+ * Licensed to the
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3157#discussion_r97255788
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java
---
@@ -376,15 +376,19 @@ public static
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3157#discussion_r97255571
--- Diff:
flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosFlinkResourceManagerTest.java
---
@@ -73,13 +74,16 @@
/**
[
https://issues.apache.org/jira/browse/FLINK-5495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833895#comment-15833895
]
ASF GitHub Bot commented on FLINK-5495:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3155
+1 to merge, LGTM.
---
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,
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3186#discussion_r97246135
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java
---
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833830#comment-15833830
]
ASF GitHub Bot commented on FLINK-5582:
---
Github user shaoxuan-wang commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui reassigned FLINK-5546:
Assignee: shijinkui
> When multiple users run test, /tmp/cacheFile conflicts
>
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui updated FLINK-5546:
-
Assignee: (was: shijinkui)
> When multiple users run test, /tmp/cacheFile conflicts
>
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shijinkui reassigned FLINK-5546:
Assignee: shijinkui
> When multiple users run test, /tmp/cacheFile conflicts
>
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5582.
-
Resolution: Implemented
Implemented in 09380e49256bff924734b9a932808e0f4daa7e5c
> Add a general
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5582.
---
> Add a general distributive aggregate function
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-5590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5590.
---
> Create a proper internal state hierarchy
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-5590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5590.
-
Resolution: Fixed
Fixed in 3b97128f05bacfb80afe4a2a49741c31ff306cd2
> Create a proper internal
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833726#comment-15833726
]
ASF GitHub Bot commented on FLINK-5582:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3186
---
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-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833701#comment-15833701
]
ASF GitHub Bot commented on FLINK-5582:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3186
Since this requires constantly extensive merge conflict resolving with the
master, I want to merge this soon.
@shaoxuan-wang has tested it life and the CI pass as well...
---
If your
[
https://issues.apache.org/jira/browse/FLINK-5608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833696#comment-15833696
]
ASF GitHub Bot commented on FLINK-5608:
---
GitHub user rehevkor5 opened a pull request:
GitHub user rehevkor5 opened a pull request:
https://github.com/apache/flink/pull/3189
[FLINK-5608] [webfrontend] Cancel button stays visible in narrow windows
- Most importantly, the Cancel button has been changed to float
right, and will only wrap downward if pushed out by the
Shannon Carey created FLINK-5608:
Summary: Cancel button not always visible
Key: FLINK-5608
URL: https://issues.apache.org/jira/browse/FLINK-5608
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833675#comment-15833675
]
ASF GitHub Bot commented on FLINK-5582:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3186
@shaoxuan-wang I cannot reproduce the compile error you posted.
The latest commit also gets a green light from Travis CI:
https://travis-ci.org/StephanEwen/incubator-flink/builds/194239397
[
https://issues.apache.org/jira/browse/FLINK-5454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5454.
-
Resolution: Fixed
Fixed in
- 1.2.0 via 099cdd01013c6959d3785088204601b926c04193
- 1.3.0 via
[
https://issues.apache.org/jira/browse/FLINK-5454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5454.
---
> Add Documentation about how to tune Checkpointing for large state
>
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833605#comment-15833605
]
ASF GitHub Bot commented on FLINK-5582:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3186#discussion_r97227451
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java
---
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-5562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833603#comment-15833603
]
ASF GitHub Bot commented on FLINK-5562:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833601#comment-15833601
]
ASF GitHub Bot commented on FLINK-5562:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5376:
--
Description:
The following are two examples where ordered stream element queue is mentioned:
{code}
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3188
Looks good. I would like to merge this tomorrow together with #3187 (which
is time critical for the release).
---
If your project is set up for it, you can reply to this email and have your
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3187
Changes look good to me.
As per Robert's email on the mailing list, he is shooting for a new release
candidate very soon, so we would need to merge this before tomorrow, if
possible.
[
https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4848:
--
Description:
{code}
String keystoreFilePath = sslConfig.getString(
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833598#comment-15833598
]
ASF GitHub Bot commented on FLINK-5582:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3186#discussion_r97227303
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java
---
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833589#comment-15833589
]
ASF GitHub Bot commented on FLINK-5582:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3186#discussion_r97227249
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java
---
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833581#comment-15833581
]
ASF GitHub Bot commented on FLINK-5582:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3186
Update: The first version had an issue with binary compatibility in the
Scala DataStream API:
This Scala API accidentally exposed in Flink 1.0 a public method with an
internal type as a
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833577#comment-15833577
]
ASF GitHub Bot commented on FLINK-5582:
---
Github user shaoxuan-wang commented on a diff in the pull
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3186#discussion_r97226958
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java
---
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833576#comment-15833576
]
ASF GitHub Bot commented on FLINK-5582:
---
Github user shaoxuan-wang commented on a diff in the pull
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3186#discussion_r97226914
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/AggregateFunction.java
---
@@ -0,0 +1,94 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5576.
--
Resolution: Fixed
Fix Version/s: 1.3.0
1.2.0
Fixed in 7a0e3d6 (release-1.2),
[
https://issues.apache.org/jira/browse/FLINK-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5559.
--
Resolution: Fixed
Fix Version/s: 1.3.0
1.2.0
Fixed in ef13f48 fd63981 f592d4c
[
https://issues.apache.org/jira/browse/FLINK-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833539#comment-15833539
]
ASF GitHub Bot commented on FLINK-5576:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833538#comment-15833538
]
ASF GitHub Bot commented on FLINK-5528:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833540#comment-15833540
]
ASF GitHub Bot commented on FLINK-5559:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3172
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/3174
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/3139
---
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
Ufuk Celebi created FLINK-5607:
--
Summary: Move location lookup retry out of
KvStateLocationLookupService
Key: FLINK-5607
URL: https://issues.apache.org/jira/browse/FLINK-5607
Project: Flink
Ufuk Celebi created FLINK-5606:
--
Summary: Remove magic number in key and namespace serialization
Key: FLINK-5606
URL: https://issues.apache.org/jira/browse/FLINK-5606
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-5605:
--
Assignee: Ufuk Celebi
> Make KvStateRequestSerializer package private
>
Ufuk Celebi created FLINK-5605:
--
Summary: Make KvStateRequestSerializer package private
Key: FLINK-5605
URL: https://issues.apache.org/jira/browse/FLINK-5605
Project: Flink
Issue Type:
Ufuk Celebi created FLINK-5604:
--
Summary: Replace QueryableStateClient constructor
Key: FLINK-5604
URL: https://issues.apache.org/jira/browse/FLINK-5604
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-5509:
--
Assignee: Ufuk Celebi
> Replace QueryableStateClient keyHashCode argument
>
Ufuk Celebi created FLINK-5603:
--
Summary: Use Flink's futures in QueryableStateClient
Key: FLINK-5603
URL: https://issues.apache.org/jira/browse/FLINK-5603
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4220.
--
Resolution: Cannot Reproduce
> ClientTest fails after port conflict
>
[
https://issues.apache.org/jira/browse/FLINK-5116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5116.
--
Resolution: Won't Fix
Implemented in >= 1.2
> Missing RocksDB state backend factory
>
[
https://issues.apache.org/jira/browse/FLINK-5436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833467#comment-15833467
]
Ufuk Celebi commented on FLINK-5436:
[~stefanrichte...@gmail.com] and [~aljoscha] should we address
[
https://issues.apache.org/jira/browse/FLINK-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5530.
--
Resolution: Fixed
Fix Version/s: 1.3.0
1.2.0
Fixed in d8222c1 (release-1.2),
[
https://issues.apache.org/jira/browse/FLINK-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833448#comment-15833448
]
ASF GitHub Bot commented on FLINK-5530:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3143
---
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
80 matches
Mail list logo