[
https://issues.apache.org/jira/browse/FLINK-2555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711458#comment-14711458
]
ASF GitHub Bot commented on FLINK-2555:
---
Github user mxm commented on the pull reque
Maximilian Michels created FLINK-2573:
-
Summary: Add Kerberos test case
Key: FLINK-2573
URL: https://issues.apache.org/jira/browse/FLINK-2573
Project: Flink
Issue Type: Test
Com
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r37879401
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
---
@@ -4
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711439#comment-14711439
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711432#comment-14711432
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711430#comment-14711430
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user chiwanpark commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-2569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711427#comment-14711427
]
ASF GitHub Bot commented on FLINK-2569:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2538:
---
Fix Version/s: 0.10
> Potential resource leak in ClassLoaderUtil#getUserCodeClassLoaderInfo()
> --
[
https://issues.apache.org/jira/browse/FLINK-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711416#comment-14711416
]
ASF GitHub Bot commented on FLINK-2565:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1043#issuecomment-134618042
@StephanEwen I've reimplemented hashCode() and compare() accordingly.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
[
https://issues.apache.org/jira/browse/FLINK-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2538:
---
Affects Version/s: master
> Potential resource leak in ClassLoaderUtil#getUserCodeClassLoaderInfo()
>
[
https://issues.apache.org/jira/browse/FLINK-2427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reopened FLINK-2427:
I've reopened this issue to track back porting this for 0.9.1.
> Allow the BarrierBuffer to maintain mu
[
https://issues.apache.org/jira/browse/FLINK-2427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2427:
---
Fix Version/s: 0.9.1
> Allow the BarrierBuffer to maintain multiple queues of blocked inputs
> ---
[
https://issues.apache.org/jira/browse/FLINK-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1778:
---
Fix Version/s: (was: 0.9)
0.10
> Improve normalized keys in composite key case
[
https://issues.apache.org/jira/browse/FLINK-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-2542.
Resolution: Won't Fix
I think it's OK to assume that people follow the general Object contract:
{cod
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1049#issuecomment-134592174
Corresponding issue in order to track fixed issues for the upcoming
release: https://issues.apache.org/jira/browse/FLINK-2572
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711388#comment-14711388
]
ASF GitHub Bot commented on FLINK-2200:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/885#discussion_r37874193
--- Diff: flink-staging/flink-gelly/pom.xml ---
@@ -37,17 +37,17 @@ under the License.
org.apache.flink
-
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/1054#issuecomment-134590137
You're right @tillrohrmann. I updated the JIRA to also contain a small
description :)
---
If your project is set up for it, you can reply to this email and have your
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1055#issuecomment-134599517
The tests in this pull request might fail because the fixes to the
BufferBarrier are not backported to 0.9 yet.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711362#comment-14711362
]
Stephan Ewen commented on FLINK-1778:
-
Has not been addressed
> Improve normalized ke
[
https://issues.apache.org/jira/browse/FLINK-2570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711360#comment-14711360
]
ASF GitHub Bot commented on FLINK-2570:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1054#issuecomment-134604410
Thanks for adding this one @andralungu. We really need this algorithm in
the library!
I have a few comments:
- we should clarify what is the expected input graph fo
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1054#discussion_r37867925
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/utils/TriangleCountData.java
---
@@ -0,0 +1,56 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1989:
---
Fix Version/s: (was: 0.9)
0.10
> Sorting of POJO data set from TableEnv yields
[
https://issues.apache.org/jira/browse/FLINK-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711354#comment-14711354
]
ASF GitHub Bot commented on FLINK-2565:
---
Github user StephanEwen commented on the pu
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1054#discussion_r37869769
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSATriangleCount.java
---
@@ -0,0 +1,187 @@
+/*
+ * Licensed to the Ap
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1043#issuecomment-134603166
I think you currently pay quite a performance price for implementing the
compare methods in such a ways that they delegate to the `ByteComparator` and
`FloatComparat
[
https://issues.apache.org/jira/browse/FLINK-1851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1851:
---
Fix Version/s: (was: 0.9)
0.10
> Java Table API does not support Casting
>
[
https://issues.apache.org/jira/browse/FLINK-2570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711345#comment-14711345
]
ASF GitHub Bot commented on FLINK-2570:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-2543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711343#comment-14711343
]
ASF GitHub Bot commented on FLINK-2543:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1702:
---
Fix Version/s: (was: 0.9)
0.10
> Authenticate via Kerberos from the client only
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1048#issuecomment-134600109
I made the SerializedThrowable an Exception and removed the `JobFailure`
message again.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711340#comment-14711340
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-1613.
Resolution: Not A Problem
As pointed out in the comments, the behaviour is expected.
> Cannost sub
[
https://issues.apache.org/jira/browse/FLINK-2570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711338#comment-14711338
]
ASF GitHub Bot commented on FLINK-2570:
---
Github user vasia commented on a diff in th
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1054#discussion_r37869349
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/GSATriangleCount.java
---
@@ -0,0 +1,187 @@
+/*
+ * Licensed to the Ap
[
https://issues.apache.org/jira/browse/FLINK-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1610:
---
Fix Version/s: (was: 0.9)
0.10
> Java docs do not build
> -
[
https://issues.apache.org/jira/browse/FLINK-1278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1278:
---
Fix Version/s: (was: 0.9)
0.10
> Remove the Record special code paths
> ---
[
https://issues.apache.org/jira/browse/FLINK-1278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1278:
---
Assignee: (was: Kostas Tzoumas)
> Remove the Record special code paths
> -
[
https://issues.apache.org/jira/browse/FLINK-1240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1240:
---
Fix Version/s: (was: 0.9)
0.10
> We cannot use sortGroup on a global reduce
> -
[
https://issues.apache.org/jira/browse/FLINK-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2528.
---
> DriverTestBase tests fail spuriously
>
>
> Key: FLI
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1297:
---
Fix Version/s: (was: 0.9)
0.10
> Add support for tracking statistics of interme
[
https://issues.apache.org/jira/browse/FLINK-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711321#comment-14711321
]
Ufuk Celebi commented on FLINK-1675:
(3) has been addressed in 8261ed5438278331c9cd760
[
https://issues.apache.org/jira/browse/FLINK-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2528.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via 6f07c5f3af1b4fd67cb61ad140b99095f7ee6c45
>
[
https://issues.apache.org/jira/browse/FLINK-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1675:
---
Fix Version/s: (was: 0.9)
0.10
> Rework Accumulators
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-1129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711309#comment-14711309
]
Ufuk Celebi commented on FLINK-1129:
This has been fixed with the new runtime interfac
[
https://issues.apache.org/jira/browse/FLINK-2570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711308#comment-14711308
]
ASF GitHub Bot commented on FLINK-2570:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-1129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1129:
---
Fix Version/s: (was: 0.9)
0.10
> The Plan Visualizer Cuts of the Lower Part of
[
https://issues.apache.org/jira/browse/FLINK-987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-987:
--
Fix Version/s: (was: 0.9)
0.10
> Extend TypeSerializers and -Comparators to work d
[
https://issues.apache.org/jira/browse/FLINK-2075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2075:
---
Fix Version/s: (was: 0.9)
0.10
> Shade akka and protobuf dependencies away
> --
[
https://issues.apache.org/jira/browse/FLINK-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-1513:
---
Fix Version/s: (was: 0.9)
0.10
> Remove GlobalConfiguration Singleton
> ---
[
https://issues.apache.org/jira/browse/FLINK-2097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2097:
---
Fix Version/s: (was: 0.9)
0.10
> Add support for JobSessions
>
[
https://issues.apache.org/jira/browse/FLINK-2572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711283#comment-14711283
]
ASF GitHub Bot commented on FLINK-2572:
---
Github user uce commented on the pull reque
Ufuk Celebi created FLINK-2572:
--
Summary: Resolve base path of symlinked executable
Key: FLINK-2572
URL: https://issues.apache.org/jira/browse/FLINK-2572
Project: Flink
Issue Type: Improvement
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1050#discussion_r37865266
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
---
@@ -20,7 +20,7 @@
import org.apache.flink.c
[
https://issues.apache.org/jira/browse/FLINK-2570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711271#comment-14711271
]
ASF GitHub Bot commented on FLINK-2570:
---
Github user andralungu commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-2570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu updated FLINK-2570:
---
Description:
The Gather-Sum-Apply-Scatter version of this algorithm receives an undirected
graph as i
[
https://issues.apache.org/jira/browse/FLINK-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711265#comment-14711265
]
ASF GitHub Bot commented on FLINK-2089:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2386:
---
Fix Version/s: 0.10
> Implement Kafka connector using the new Kafka Consumer API
> ---
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-2386:
---
Fix Version/s: 0.9.1
> Implement Kafka connector using the new Kafka Consumer API
> --
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711257#comment-14711257
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on a diff
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r37864215
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunctionTest.java
--
[
https://issues.apache.org/jira/browse/FLINK-2569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711254#comment-14711254
]
ASF GitHub Bot commented on FLINK-2569:
---
Github user chiwanpark commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711250#comment-14711250
]
ASF GitHub Bot commented on FLINK-2386:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711251#comment-14711251
]
ASF GitHub Bot commented on FLINK-2555:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1039#issuecomment-134584442
I addressed @hsaputra's comments & rebased to the latest master.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711231#comment-14711231
]
ASF GitHub Bot commented on FLINK-2386:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1055
[FLINK-2386] Add new Kafka Consumer for Flink 0.9.1
This is PR https://github.com/apache/flink/pull/1039 against the
**release-0.9** branch!
You can merge this pull request into a Git repository b
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r37861790
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunctionTest.java
--
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1030#issuecomment-134577603
@tillrohrmann
Ok, I will do a update in my branch.
But I cannot go to travis since it is blocked in China.
---
If your project is set up for it, you can repl
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711225#comment-14711225
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711220#comment-14711220
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711218#comment-14711218
]
ASF GitHub Bot commented on FLINK-2089:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1050#discussion_r37861035
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
---
@@ -20,7 +20,7 @@
import org.apach
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711216#comment-14711216
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r37860912
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunctionTest.java
---
@
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1030#issuecomment-134573477
It should be re-triggered every time you push something new to your branch.
For your local CI you should be able to manually restart a build by going
to travi
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r37860800
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunctionTest.java
--
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711213#comment-14711213
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711206#comment-14711206
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on a diff
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r37860526
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunctionTest.java
--
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711200#comment-14711200
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user tillrohrmann commented on the p
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1051#discussion_r37859713
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
---
@@ -167,6 +167,13 @@ public int releas
[
https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2571:
---
Affects Version/s: (was: 0.8.1)
> Add task hooks support in Storm-compatibility
> ---
[
https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated FLINK-2571:
---
Priority: Minor (was: Major)
> Add task hooks support in Storm-compatibility
> -
[
https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2468.
-
Resolution: Fixed
Fixed via 5aa70f70846f021b384c005b3dd3fd5ee3424d00
> StreamCheckpointingITCase
[
https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2468.
---
> StreamCheckpointingITCase failure
> -
>
> Key: FLINK-246
[
https://issues.apache.org/jira/browse/FLINK-2460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711192#comment-14711192
]
ASF GitHub Bot commented on FLINK-2460:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711187#comment-14711187
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user mxm commented on a diff in the
fangfengbin created FLINK-2571:
--
Summary: Add task hooks support in Storm-compatibility
Key: FLINK-2571
URL: https://issues.apache.org/jira/browse/FLINK-2571
Project: Flink
Issue Type: New Feat
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r37859069
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunctionTest.java
---
@
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711183#comment-14711183
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on the pul
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/992#issuecomment-134570319
Hi, I decreased both the waiting time and the retry times since it will
still cost over 10 seconds if only the waiting time is decreased due to the
"Thread.sleep(CONNE
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1054#issuecomment-134570234
Hi @andralungu. Could you please add a slightly more detailed description
of your implementation. This would also be helpful in the JIRA description.
---
If your p
[
https://issues.apache.org/jira/browse/FLINK-2570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711182#comment-14711182
]
ASF GitHub Bot commented on FLINK-2570:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711172#comment-14711172
]
ASF GitHub Bot commented on FLINK-2490:
---
Github user HuangWHWHW commented on a diff
Github user HuangWHWHW commented on a diff in the pull request:
https://github.com/apache/flink/pull/992#discussion_r37858063
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunctionTest.java
--
[
https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14711167#comment-14711167
]
ASF GitHub Bot commented on FLINK-2106:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1052#issuecomment-134567455
Really good work @r-pogalz. I had only some minor comments concerning style
and test cases.
I like your approach to split the implementation of FLINK-687 i
101 - 200 of 325 matches
Mail list logo
