GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3003
[Flink-5188] Create analog of RowCsvInputFormat in java and adjust all the
imports of Row and RowTypeInfo
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the
GitHub user rboorgapally opened a pull request:
https://github.com/apache/flink/pull/3002
Fix typo in variable name
- Fixed a typo in the variable name
- `mvn clean verify` has been executed successfully locally
You can merge this pull request into a Git repository by run
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15747053#comment-15747053
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a dif
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r92315209
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java
---
@@ -0,0 +1,58 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15747043#comment-15747043
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a dif
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r92314677
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java
---
@@ -0,0 +1,58 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746999#comment-15746999
]
ASF GitHub Bot commented on FLINK-4821:
---
GitHub user tony810430 opened a pull reques
GitHub user tony810430 opened a pull request:
https://github.com/apache/flink/pull/3001
[FLINK-4821] [kinesis] Implement rescalable non-partitioned state for
Kinesis Connector
Implement ListCheckpointed interface on Kinesis Consumer
As a reminder, I returned empty list inst
[
https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746832#comment-15746832
]
ASF GitHub Bot commented on FLINK-5108:
---
Github user Renkai commented on the issue:
Github user Renkai commented on the issue:
https://github.com/apache/flink/pull/2928
That is ok to close this issue.
Max äº2016å¹´12æ14æ¥å¨ä¸ 02:31åéï¼
> There is one problem we overlooked. In detached mode we ensure cluster
> shutdown through a message
Github user chenqin commented on the issue:
https://github.com/apache/flink/pull/2982
@aljoscha Thanks for your time. We can chat more after 1.2 release!
I think it makes sense to extends Collector, even though we may not remove
collect(T obj) due to API compability issue in 1
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746680#comment-15746680
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user chenqin commented on the issue:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2985
Hi @greghogan ,
Thank you for your feedback. I've updated the PR accordingly. The only
thing that I did differently is that I've replaced projections and two
`count()` executions with join
[
https://issues.apache.org/jira/browse/FLINK-5104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746410#comment-15746410
]
ASF GitHub Bot commented on FLINK-5104:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746405#comment-15746405
]
ASF GitHub Bot commented on FLINK-5104:
---
Github user mushketyk commented on a diff i
Github user mushketyk commented on a diff in the pull request:
https://github.com/apache/flink/pull/2985#discussion_r92276412
--- Diff:
flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/validation/InvalidBipartiteVertexIdsValidator.java
---
@@ -0,0 +1,85 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746359#comment-15746359
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2664
New implementation using maven-shade-plugin in #3000.
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746356#comment-15746356
]
ASF GitHub Bot commented on FLINK-4861:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3000
[FLINK-4861] [build] Package optional project artifacts
Package the Flink connectors, metrics, and libraries into subdirectories of
a new opt directory in the release/snapshot tarballs.
I
[
https://issues.apache.org/jira/browse/FLINK-5311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746285#comment-15746285
]
ASF GitHub Bot commented on FLINK-5311:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2984
Hi @vasia. Thank you for your comments. I've added the link to the doc and
added the image (I tried to make it in the same style as other Gelly image).
---
If your project is set up for it, you ca
[
https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746163#comment-15746163
]
Ivan Mushketyk edited comment on FLINK-5245 at 12/13/16 8:23 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746163#comment-15746163
]
Ivan Mushketyk commented on FLINK-5245:
---
I got it now, sorry for the misunderstandin
[
https://issues.apache.org/jira/browse/FLINK-5332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746126#comment-15746126
]
ASF GitHub Bot commented on FLINK-5332:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2999
I think this should go into 1.2 - it is quite a bug for local testing.
---
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 proj
[
https://issues.apache.org/jira/browse/FLINK-5332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746125#comment-15746125
]
ASF GitHub Bot commented on FLINK-5332:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2999
[FLINK-5332] [core] Synchronize FileSystem::initOutPathLocalFS() to prevent
lost files/directories when called concurrently
This is mainly relevant to tests and Local Mini Cluster executions.
[
https://issues.apache.org/jira/browse/FLINK-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746119#comment-15746119
]
Boris Osipov commented on FLINK-4798:
-
Yes, it is. I've reproduced it several times wi
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2969
+1 looks good. Will put this into my merge pipeline
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-5289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746105#comment-15746105
]
ASF GitHub Bot commented on FLINK-5289:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4798:
Comment: was deleted
(was: I think that FLINK-5332 is probably the root cause of this issue.)
> CEP
[
https://issues.apache.org/jira/browse/FLINK-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746088#comment-15746088
]
Stephan Ewen commented on FLINK-4798:
-
I think that FLINK-5332 is probably the root ca
[
https://issues.apache.org/jira/browse/FLINK-4798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746086#comment-15746086
]
Stephan Ewen commented on FLINK-4798:
-
I think that FLINK-5332 is probably the root ca
[
https://issues.apache.org/jira/browse/FLINK-5288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5288.
-
Resolution: Duplicate
> Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test
[
https://issues.apache.org/jira/browse/FLINK-5288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5288.
---
> Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test
>
[
https://issues.apache.org/jira/browse/FLINK-5287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5287.
---
> Test randomly fails with wrong result: testWithAtomic2[Execution mode =
> CLUSTER](org.apache.flink.api
[
https://issues.apache.org/jira/browse/FLINK-5287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5287.
-
Resolution: Duplicate
> Test randomly fails with wrong result: testWithAtomic2[Execution mode =
>
Stephan Ewen created FLINK-5332:
---
Summary: Non-thread safe FileSystem::initOutPathLocalFS() can
cause lost files/directories in local execution
Key: FLINK-5332
URL: https://issues.apache.org/jira/browse/FLINK-5332
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5322:
Affects Version/s: 1.1.3
> Clean up yarn configuration documentation
> -
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5322:
Description:
The value I specified in flink-conf.yaml
{code}
yarn.taskmanager.env:
MY_ENV
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5322:
Fix Version/s: (was: 1.1.3)
1.1.4
1.2.0
> Clean up
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5322:
Affects Version/s: 1.2.0
> Clean up yarn configuration documentation
> -
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5322:
Description:
The value I specified in flink-conf.yaml
{code}
yarn.taskmanager.env:
MY_ENV
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746029#comment-15746029
]
Chesnay Schepler edited comment on FLINK-5322 at 12/13/16 7:35 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5322:
Summary: Clean up yarn configuration documentation (was:
yarn.taskmanager.env value does no
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746029#comment-15746029
]
Chesnay Schepler edited comment on FLINK-5322 at 12/13/16 7:32 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-5322:
---
Assignee: Chesnay Schepler
> yarn.taskmanager.env value does not appear in System.get
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5322:
Component/s: Documentation
> yarn.taskmanager.env value does not appear in System.getenv
> -
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5322:
Issue Type: Improvement (was: Bug)
> yarn.taskmanager.env value does not appear in System.g
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746029#comment-15746029
]
Chesnay Schepler commented on FLINK-5322:
-
yes, we can adjust he configuration.
>
[
https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15746008#comment-15746008
]
Shannon Carey commented on FLINK-5322:
--
Yes, that worked! Thanks! It becomes availabl
[
https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745856#comment-15745856
]
ASF GitHub Bot commented on FLINK-5108:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2928
There is one problem we overlooked. In detached mode we ensure cluster
shutdown through a message sent by the client during job submission to tell the
JobManager that this is going to be the last job it
[
https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-5108:
--
Priority: Major (was: Blocker)
> Remove ClientShutdownHook during job execution
> -
[
https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745679#comment-15745679
]
ASF GitHub Bot commented on FLINK-5051:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2962#discussion_r92220463
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedBackendSerializationProxy.java
---
@@ -0,0 +1,219 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-5290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745665#comment-15745665
]
ASF GitHub Bot commented on FLINK-5290:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2966#discussion_r92219738
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java
---
@@ -0,0 +1,319 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-5189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745658#comment-15745658
]
Fabian Hueske commented on FLINK-5189:
--
Given that we move all Table API classes anyw
[
https://issues.apache.org/jira/browse/FLINK-5325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745654#comment-15745654
]
ASF GitHub Bot commented on FLINK-5325:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2992
I made the interface generic and changed the hierarchy as suggested by
@zentol.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
[
https://issues.apache.org/jira/browse/FLINK-5331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-5331:
-
Attachment: Screen Shot 2016-12-13 at 16.36.38.png
Activity monitor showing some of the python pro
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2958
Thanks for the PR @ex00!
I would like to suggest to move a few more files:
- move `flink-table` examples: `org/apache/flink/examples` ->
`org/apache/flink/table/examples` (for Java and Scala)
[
https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745638#comment-15745638
]
ASF GitHub Bot commented on FLINK-4704:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745485#comment-15745485
]
ASF GitHub Bot commented on FLINK-5325:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2992#discussion_r92199074
--- Diff:
flink-core/src/main/java/org/apache/flink/core/fs/CloseableRegistryImpl.java ---
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Soft
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745481#comment-15745481
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user fhueske commented on the issue:
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2971
---
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 i
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2810
Thanks for asking @tonycox! FLINK-5188 is more urgent. We want to do the
feature freeze by end of the week. Would be great if you could open a PR at
Thursday the latest. If this is too soon, please l
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2971
Has been merged into the release-1.1 branch.
---
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 fe
[
https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745478#comment-15745478
]
ASF GitHub Bot commented on FLINK-5300:
---
Github user tillrohrmann closed the pull re
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2970
---
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-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745477#comment-15745477
]
ASF GitHub Bot commented on FLINK-5300:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745475#comment-15745475
]
ASF GitHub Bot commented on FLINK-5300:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5300.
Resolution: Fixed
Fixed in 1.2.0 via 8a7288ea9af6b6822ea1f4022bb08a10b7b82318
Fixed in 1.1.4 via f3d
Till Rohrmann created FLINK-5331:
Summary: PythonPlanBinderTest idling extremely long
Key: FLINK-5331
URL: https://issues.apache.org/jira/browse/FLINK-5331
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745440#comment-15745440
]
ASF GitHub Bot commented on FLINK-5008:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/2764
I wasn't able to test the Scala SBT path though, so this may need some
additional love by someone with a working SBT environment
---
If your project is set up for it, you can reply to this email and h
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/2764
Developing Flink programs still works with Eclipse (tested with Eclipse
4.6.1 and Scala IDE 4.4.1 for Scala 2.11). Alongside testing the quickstarts, I
also updated them as promised and made a switch f
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745429#comment-15745429
]
ASF GitHub Bot commented on FLINK-5008:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745414#comment-15745414
]
ASF GitHub Bot commented on FLINK-5325:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2992
Changes look good to me. But I think that @zentol is right that
`AbstractCloseableRegistry` should probably implement the `CloseableRegistry`
interface from an OOP point of view.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745409#comment-15745409
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2664
@greghogan I think that when an immediate dependency is "provided", then
its transitive dependencies are not pulled. If a user adds a "provided"
`flink-streaming-connector-kafka-0.9_2.10`, then n
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2664
@StephanEwen @rmetzger, as I revisit this, I'm still questioning the
viability of shading an uber jar. For example, a user depending on a Kafka
connector. Normally the dependency would be packaged
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745338#comment-15745338
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan commented on the issu
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2998
[FLINK-5330] [tests] Harden KafkaConsumer08Test to fail reliably with
unknown host exception
Using static mocking to reliably fail the InetAddress.getByName call with
an UnknowHostException.
[
https://issues.apache.org/jira/browse/FLINK-5330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745330#comment-15745330
]
ASF GitHub Bot commented on FLINK-5330:
---
GitHub user tillrohrmann opened a pull requ
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
Hi @fhueske , what should I finish first, this PR or FLINK-5188 ?
---
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
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745324#comment-15745324
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user tonycox commented on the issue:
Till Rohrmann created FLINK-5330:
Summary: Harden KafkaConsumer08Test
Key: FLINK-5330
URL: https://issues.apache.org/jira/browse/FLINK-5330
Project: Flink
Issue Type: Bug
Components
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2982
@chenqin I had a quick look at the implementation and it looks quite good.
I'll look at it in more detail once the 1.2 release is out and then I'll also
have more thorough comments.
These a
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745298#comment-15745298
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745293#comment-15745293
]
ASF GitHub Bot commented on FLINK-5240:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2997
[FLINK-5240][tests] ensure state backends are properly closed
This adds additional test cases to verify the state backends are closed
properly upon the end of a task. The state backends should always
[
https://issues.apache.org/jira/browse/FLINK-5223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5223.
Resolution: Done
Fix Version/s: 1.2.0
Done with 5c86efbb449c631aea0b1b490cec706ad7596b44
> A
[
https://issues.apache.org/jira/browse/FLINK-5304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5304.
Resolution: Done
Fix Version/s: 1.2.0
Done with da4af1259ae750953ca2e7a3ecec342d9eb77bac
> C
[
https://issues.apache.org/jira/browse/FLINK-5223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745175#comment-15745175
]
ASF GitHub Bot commented on FLINK-5223:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15745173#comment-15745173
]
ASF GitHub Bot commented on FLINK-5220:
---
Github user asfgit closed the pull request
1 - 100 of 218 matches
Mail list logo
