[
https://issues.apache.org/jira/browse/FLINK-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358546#comment-15358546
]
Robert Metzger commented on FLINK-3294:
---
Hi Jens,
the Kafka 0.9 consumer doesn't co
Github user gallenvara commented on the issue:
https://github.com/apache/flink/pull/2078
Hi, @fhueske , sorry for the late update for this PR. Codes have been
modified.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358589#comment-15358589
]
ASF GitHub Bot commented on FLINK-2985:
---
Github user gallenvara commented on the iss
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2154#discussion_r69262604
--- Diff: docs/apis/streaming/windows.md ---
@@ -24,1023 +24,608 @@ specific language governing permissions and
limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358602#comment-15358602
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2154#discussion_r69263156
--- Diff: docs/apis/streaming/windows.md ---
@@ -24,1023 +24,608 @@ specific language governing permissions and
limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358608#comment-15358608
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2154#discussion_r69263379
--- Diff: docs/apis/streaming/windows.md ---
@@ -24,1023 +24,608 @@ specific language governing permissions and
limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358613#comment-15358613
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2154#discussion_r69263452
--- Diff: docs/apis/streaming/windows.md ---
@@ -24,1023 +24,608 @@ specific language governing permissions and
limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358614#comment-15358614
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2154#discussion_r69264040
--- Diff: docs/apis/streaming/windows.md ---
@@ -24,1023 +24,608 @@ specific language governing permissions and
limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358621#comment-15358621
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2154#discussion_r69264177
--- Diff: docs/apis/streaming/windows.md ---
@@ -24,1023 +24,608 @@ specific language governing permissions and
limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358623#comment-15358623
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2154#discussion_r69264437
--- Diff: docs/apis/streaming/windows.md ---
@@ -24,1023 +24,608 @@ specific language governing permissions and
limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358627#comment-15358627
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2154#discussion_r69264695
--- Diff: docs/apis/streaming/windows.md ---
@@ -24,1023 +24,608 @@ specific language governing permissions and
limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358630#comment-15358630
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358631#comment-15358631
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2154
Thanks for the thorough review, @uce. I incorporated the comments.
I left the section about triggers and lateness a bit vague on purpose since
we will probably change some stuff there after
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358646#comment-15358646
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2154
Thanks! +1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2128
@zentol Should I update this PR somehow?
---
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
e
[
https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358651#comment-15358651
]
ASF GitHub Bot commented on FLINK-4053:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2109
@zentol @kl0u Is there anything else I should change in this PR?
---
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-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358653#comment-15358653
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358655#comment-15358655
]
ASF GitHub Bot commented on FLINK-4053:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2128
Thank your for reminding me, i forgot about this PR a bit :(
The PR is fine imo, +1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on G
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/1813#discussion_r69266892
--- Diff:
flink-streaming-connectors/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358660#comment-15358660
]
ASF GitHub Bot commented on FLINK-3034:
---
Github user tzulitai commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2177#discussion_r69267193
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -269,26 +269,26 @@
* Percentage of heap space to remov
[
https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358664#comment-15358664
]
ASF GitHub Bot commented on FLINK-4127:
---
Github user rmetzger commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2158#discussion_r69270577
--- Diff: docs/apis/common/index.md ---
@@ -1350,3 +1350,397 @@ You may specify program arguments before the job is
executed. The plan visualiza
the execu
[
https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358684#comment-15358684
]
ASF GitHub Bot commented on FLINK-4127:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2177
I addressed all comments. It seems to me that the configuration parameters
for YARN are overly complicated now because they are separated in resource
manager and YARN now.
---
If your project is s
[
https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358685#comment-15358685
]
ASF GitHub Bot commented on FLINK-4116:
---
Github user zentol commented on a diff in t
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2109
@mushketyk Hello! Sorry for the later reply.
I can review this on Monday. This week I am on holidays.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358690#comment-15358690
]
ASF GitHub Bot commented on FLINK-3677:
---
Github user kl0u commented on the issue:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r69274234
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/KinesisConfigConstants.java
---
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358708#comment-15358708
]
ASF GitHub Bot commented on FLINK-3231:
---
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/2131#discussion_r69274851
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -60,10 +60,10 @@ to setup Kinesis streams. Make sure to create the
appropriate IAM policy and use
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358714#comment-15358714
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user rmetzger commented on a diff in
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2158#discussion_r69278183
--- Diff: docs/apis/common/index.md ---
@@ -1350,3 +1350,397 @@ You may specify program arguments before the job is
executed. The plan visualiza
the execu
[
https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358746#comment-15358746
]
ASF GitHub Bot commented on FLINK-4116:
---
Github user zentol commented on a diff in t
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2158
I've made the following changes:
- rewritte scope section
- removed ... from examples
- FIX ALL THE TYPOS
- better line breaking
- added dependency&example for DWHWrapper
- repla
[
https://issues.apache.org/jira/browse/FLINK-4116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358748#comment-15358748
]
ASF GitHub Bot commented on FLINK-4116:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2183
@tillrohrmann Addressed your comments.
---
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-4123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358805#comment-15358805
]
ASF GitHub Bot commented on FLINK-4123:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358812#comment-15358812
]
ASF GitHub Bot commented on FLINK-1550:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2146
Merging.
---
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 fea
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r69285572
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358818#comment-15358818
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user rmetzger commented on a diff in
Github user iemejia commented on the issue:
https://github.com/apache/flink/pull/2176
Hi, I tested it with the basic word count and with the beam pipeline
example that @ecesena put for his flink/beam demo.
I don't know if your case is maybe because you are running on docker fo
[
https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358823#comment-15358823
]
ASF GitHub Bot commented on FLINK-4118:
---
Github user iemejia commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2189
Please provide some context for this PR, the referenced JIRA is marked as
closed.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358833#comment-15358833
]
ASF GitHub Bot commented on FLINK-3667:
---
Github user zentol commented on the issue:
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2154
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358902#comment-15358902
]
ASF GitHub Bot commented on FLINK-4122:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2167
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if th
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358903#comment-15358903
]
ASF GitHub Bot commented on FLINK-4062:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-4062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-4062.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Added in
https://github.com/apache/flink/co
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2189
there are also some test failures in flink-clients:
```
testManualOptionsOverridesConfig(org.apache.flink.client.CliFrontendAddressConfigurationTest)
Time elapsed: 0.031 sec <<< FAILURE
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358911#comment-15358911
]
ASF GitHub Bot commented on FLINK-3667:
---
Github user zentol commented on the issue:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2172#discussion_r69295166
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/JarFileCreator.java
---
@@ -189,33 +189,33 @@ public synchronized void createJarFile() thr
[
https://issues.apache.org/jira/browse/FLINK-4096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358915#comment-15358915
]
ASF GitHub Bot commented on FLINK-4096:
---
Github user zentol commented on a diff in t
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2183
I think the change is good to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enable
[
https://issues.apache.org/jira/browse/FLINK-4123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358923#comment-15358923
]
ASF GitHub Bot commented on FLINK-4123:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358925#comment-15358925
]
ASF GitHub Bot commented on FLINK-3231:
---
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/2131#discussion_r69296319
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358927#comment-15358927
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2131
I tested the code, also with a shard-merging:
`aws kinesis merge-shards --shard-to-merge shardId-0001
--adjacent-shard-to-merge shardId-0002 --stream-name flink-test`
an
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2146
---
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-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-1550.
---
Resolution: Fixed
Fix Version/s: (was: pre-apache)
1.1.0
Impleme
[
https://issues.apache.org/jira/browse/FLINK-1550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358931#comment-15358931
]
ASF GitHub Bot commented on FLINK-1550:
---
Github user asfgit closed the pull request
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2167
merging
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358934#comment-15358934
]
ASF GitHub Bot commented on FLINK-4122:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4057.
---
Resolution: Fixed
Implemented in a3a9fd1147aa926987420057f8305ab498519a45,
8829f97344cd9a7a9c
Maximilian Michels created FLINK-4139:
-
Summary: Yarn: Adjust parallelism and task slots correctly
Key: FLINK-4139
URL: https://issues.apache.org/jira/browse/FLINK-4139
Project: Flink
Iss
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/2167
---
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-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4122.
---
Resolution: Fixed
Fixed in 96590ffaf650b80e277c3f35d3c63f33362f0cc6
> Cassandra jar contains
[
https://issues.apache.org/jira/browse/FLINK-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358943#comment-15358943
]
ASF GitHub Bot commented on FLINK-4122:
---
Github user zentol closed the pull request
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2176
Yes, this is exactly what I was trying on OS X. I'm quickly setting up a
ubuntu VM to see if it works there.
---
If your project is set up for it, you can reply to this email and have your
reply ap
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2189
---
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-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358949#comment-15358949
]
ASF GitHub Bot commented on FLINK-4118:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358951#comment-15358951
]
ASF GitHub Bot commented on FLINK-3667:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4139.
-
Resolution: Fixed
Fixed via 44b3bc45b382c1f2783e9c17dd76ea2e9bbb40ec
> Yarn: Adjust paral
[
https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358952#comment-15358952
]
ASF GitHub Bot commented on FLINK-3675:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2187
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2168
---
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-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358953#comment-15358953
]
ASF GitHub Bot commented on FLINK-3964:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358960#comment-15358960
]
Maximilian Michels commented on FLINK-3667:
---
Fixed via f9b52a3114a2114e6846091ac
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358962#comment-15358962
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r69298876
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -60,10 +60,10 @@ to setup Kinesis streams. Make sure to create the
appropriate IAM policy and use
[
https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-3675.
---
Resolution: Fixed
Fixed via 0483ba583c7790d13b8035c2916318a2b58c67d6
> YARN ship fold
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r69299145
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358968#comment-15358968
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2131#discussion_r69299251
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358969#comment-15358969
]
ASF GitHub Bot commented on FLINK-3231:
---
Github user tzulitai commented on a diff in
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2189
Sorry, didn't see your comments. The test failures should be resolved (I
ran `mvn verify`).
The changes delay the creation of the ActorSystem and thus any blocking
actions until we have executed
1 - 100 of 175 matches
Mail list logo
