GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/2324
Bump version to 1.2-SNAPSHOT
It is about time to do this.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/flink 12-bump
[
https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402825#comment-15402825
]
Ivan Mushketyk commented on FLINK-3414:
---
Hey Till.
Thank you for you reply.
I'll implement an
[
https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-3414:
-
Assignee: Ivan Mushketyk
> Add Scala API for CEP's pattern definition
>
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402814#comment-15402814
]
Ivan Mushketyk edited comment on FLINK-3873 at 8/1/16 9:03 PM:
---
I've
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402814#comment-15402814
]
Ivan Mushketyk commented on FLINK-3873:
---
I've implemented TableSink with Avro serialization here:
[
https://issues.apache.org/jira/browse/FLINK-4043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402806#comment-15402806
]
Ivan Mushketyk commented on FLINK-4043:
---
If you are going to work on it, here is an implementation
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2323
Set maximum limit for the toString result, as suggested by Stephan here:
https://issues.apache.org/jira/browse/FLINK-2090
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402762#comment-15402762
]
ASF GitHub Bot commented on FLINK-2090:
---
Github user mushketyk commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402759#comment-15402759
]
ASF GitHub Bot commented on FLINK-2090:
---
GitHub user mushketyk opened a pull request:
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/2323
[FLINK-2090] toString of CollectionInputFormat takes long time when tâ¦
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402673#comment-15402673
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73037620
--- Diff: docs/internals/flink_security.md ---
@@ -0,0 +1,87 @@
+---
+title: "Flink Security"
+# Top navigation
+top-nav-group: internals
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2275
@mxm - Thanks for your feedback and here is my response to some of your
comments.
- Do we need to run all the Yarn tests normally and secured? We already
have problems with our test
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402626#comment-15402626
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402606#comment-15402606
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the issue:
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2275
@nielsbasjes - In most deployments, the KRB5 configuration file will be
located in a well known (for e.g., /etc/krb5.conf) but in scenarios where
custom location needs to be provided, we could
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402585#comment-15402585
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73028461
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskManagerRunner.java ---
@@ -75,34 +84,47 @@ public static void runYarnTaskManager(String[]
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402572#comment-15402572
]
Stephan Ewen commented on FLINK-4094:
-
If we pool the off-heap byte buffers, we effectively make a
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402570#comment-15402570
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73027093
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/RunTypeSelectionRunner.java
---
@@ -0,0 +1,54 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-2363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402551#comment-15402551
]
ASF GitHub Bot commented on FLINK-2363:
---
Github user StephanEwen closed the pull request at:
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/913
---
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 vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73023852
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/RunTypeHolder.java
---
@@ -0,0 +1,36 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402540#comment-15402540
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402541#comment-15402541
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73023816
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
---
@@
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73023705
--- Diff:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/RunTypeHolder.java
---
@@ -0,0 +1,36 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402535#comment-15402535
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402530#comment-15402530
]
ASF GitHub Bot commented on FLINK-4251:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2281
---
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 vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73020806
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaShortRetentionTestBase.java
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402485#comment-15402485
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402457#comment-15402457
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73017860
--- Diff:
flink-streaming-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/RollingSinkSecuredITCase.java
---
[
https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402439#comment-15402439
]
ASF GitHub Bot commented on FLINK-4297:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402438#comment-15402438
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2320
It didn't fix it unfortunately.
---
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
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73015565
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java
---
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402428#comment-15402428
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73014755
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java
---
@@ -0,0 +1,218 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402414#comment-15402414
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402416#comment-15402416
]
ASF GitHub Bot commented on FLINK-4299:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2322
---
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-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4299.
--
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 4d988a9 (release-1.1), 7ea9c01 (master).
> Show
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73013795
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/JaasConfiguration.java
---
@@ -0,0 +1,158 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402412#comment-15402412
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4296.
--
Resolution: Fixed
Fixed in fa3a3fc (release-1.1), 10642f7 (master).
> Scheduler accepts more tasks
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73013657
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/JaasConfiguration.java
---
@@ -0,0 +1,158 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402408#comment-15402408
]
ASF GitHub Bot commented on FLINK-4296:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2321
---
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-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402402#comment-15402402
]
ASF GitHub Bot commented on FLINK-4297:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2320
Thanks for trying it out @uce! There was an unrelated quoting issue in
`yarn-session.sh`. I pushed another fix.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73012870
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/JaasConfiguration.java
---
@@ -0,0 +1,158 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402398#comment-15402398
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402395#comment-15402395
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73012593
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/security/JaasConfiguration.java
---
@@ -0,0 +1,158 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402387#comment-15402387
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on a diff in the pull
Github user vijikarthi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2275#discussion_r73012055
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java ---
@@ -1016,6 +1016,23 @@
/** The environment variable
[
https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402376#comment-15402376
]
ASF GitHub Bot commented on FLINK-4299:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2322
Yes, sir! :-) +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
Timo Walther created FLINK-4303:
---
Summary: Add CEP examples
Key: FLINK-4303
URL: https://issues.apache.org/jira/browse/FLINK-4303
Project: Flink
Issue Type: Improvement
Components:
[
https://issues.apache.org/jira/browse/FLINK-4297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402373#comment-15402373
]
ASF GitHub Bot commented on FLINK-4297:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2320
Tested this with Hadoop 2.4.1 and it works as expected with `bin/flink run
-m yarn-cluster`:
```
2016-08-01 16:32:06,214 INFO org.apache.flink.yarn.Utils - Copying from
2016-08-01 16:32:06,214
[
https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402370#comment-15402370
]
ASF GitHub Bot commented on FLINK-4296:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2321
+1 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, or if the
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402367#comment-15402367
]
Aljoscha Krettek commented on FLINK-4282:
-
Also, when you have day windows you need to offset
[
https://issues.apache.org/jira/browse/FLINK-4302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402363#comment-15402363
]
Chesnay Schepler commented on FLINK-4302:
-
that's a good idea.
We could also think about renaming
[
https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402348#comment-15402348
]
ASF GitHub Bot commented on FLINK-4299:
---
GitHub user mxm opened a pull request:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2322
@uce Is this has you had in mind?
---
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
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2322
[FLINK-4299] show loss of job manager in Client
This prints a message when the leading JobManager changes after first
connecting to a JobManager. Further, it prints a message when a connection
[
https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402349#comment-15402349
]
ASF GitHub Bot commented on FLINK-4299:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402338#comment-15402338
]
Ufuk Celebi commented on FLINK-4289:
Fixed in d13b825 (release-1.1).
> Source files have executable
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402339#comment-15402339
]
Aljoscha Krettek commented on FLINK-4282:
-
For most timezones this is valid but there are some
[
https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4293:
Summary: Malformatted Apache Headers (was: Malformatted Apache Haders)
> Malformatted
[
https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402334#comment-15402334
]
ASF GitHub Bot commented on FLINK-4296:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2321
Good catch. The change and test look good to me! This was broken for a long
time (since the initial refactoring of the network stack I think). It never
surfaced, because most use cases and tests run
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402332#comment-15402332
]
Till Rohrmann commented on FLINK-4283:
--
I tried to reproduce this issue locally but I was not
[
https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402308#comment-15402308
]
ASF GitHub Bot commented on FLINK-4296:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2321
[FLINK-4296] Fixes failure reporting of consumer task scheduling when
producer has already finished
This PR changes the failure behaviour such that the consumer task is failed
instead of the
[
https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402305#comment-15402305
]
Maximilian Michels commented on FLINK-4299:
---
Good idea! We should add some messages in the
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402291#comment-15402291
]
Stephan Ewen commented on FLINK-4280:
-
I like the latest suggestion for configuration, with a few
[
https://issues.apache.org/jira/browse/FLINK-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-4299:
-
Assignee: Maximilian Michels
> Show loss of job manager in Client
>
[
https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402303#comment-15402303
]
Till Rohrmann commented on FLINK-4296:
--
I found the issue. The problem is that a scheduling failure
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402301#comment-15402301
]
Stephan Ewen commented on FLINK-4282:
-
Seems the offset can serve two purposes:
1. Compensate for
[
https://issues.apache.org/jira/browse/FLINK-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402300#comment-15402300
]
Ufuk Celebi commented on FLINK-4154:
Reverted in 0274f9c (release-1.1) and 0f92a6b (master).
>
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402281#comment-15402281
]
Stephan Ewen commented on FLINK-2237:
-
It it is just about the fact the it is currently called
Ufuk Celebi created FLINK-4302:
--
Summary: Add JavaDocs to MetricConfig
Key: FLINK-4302
URL: https://issues.apache.org/jira/browse/FLINK-4302
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-4301:
Description: The Flink version is hard coded in the quickstart script (for
Scala and Java). Thus,
[
https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-4301:
Labels: starter (was: )
> Parameterize Flink version in Quickstart bash script
>
Timo Walther created FLINK-4301:
---
Summary: Parameterize Flink version in Quickstart bash script
Key: FLINK-4301
URL: https://issues.apache.org/jira/browse/FLINK-4301
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402243#comment-15402243
]
Stephan Ewen commented on FLINK-4290:
-
Updating the test assumption to skip the Cassandra tests on all
[
https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402231#comment-15402231
]
Maximilian Michels commented on FLINK-4094:
---
Thanks for elaborating on your thoughts
Timo Walther created FLINK-4300:
---
Summary: Improve error message for different Scala versions of JM
and Client
Key: FLINK-4300
URL: https://issues.apache.org/jira/browse/FLINK-4300
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402204#comment-15402204
]
Stephan Ewen commented on FLINK-4290:
-
Seems Cassandra does not work with Java 7, actually. We should
[
https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402201#comment-15402201
]
Stephan Ewen commented on FLINK-4290:
-
Sorry, correcting myself. The command line was Java 7, I
[
https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402179#comment-15402179
]
Stephan Ewen commented on FLINK-4290:
-
My environment is Ubuntu 14.4, Maven 3.0.5, Java 8
>
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2294
This would replace `Delegate` and is much simpler. I placed it in the Java
API package but it would not be visible to users through the `DataSet` API.
The ultimate goal is to implicitly
[
https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402172#comment-15402172
]
Stephan Ewen commented on FLINK-4290:
-
Running it with maven (command line), I get
[
https://issues.apache.org/jira/browse/FLINK-4265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402174#comment-15402174
]
ASF GitHub Bot commented on FLINK-4265:
---
Github user greghogan commented on the issue:
1 - 100 of 183 matches
Mail list logo