[jira] [Updated] (FLINK-8247) Support Hadoop-free variant of Flink on Mesos

2017-12-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8247: Fix Version/s: 1.4.1 1.5.0 > Support Hadoop-free variant of Flink on

[jira] [Updated] (FLINK-8202) Update queryable section on configuration page

2017-12-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8202: Fix Version/s: (was: 1.4.0) 1.4.1 > Update queryable section on

[jira] [Reopened] (FLINK-8211) Rename ResultPartitionWriter to OutputGate

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8211: - Reopen to remove fix version > Rename ResultPartitionWriter to OutputGate >

[jira] [Closed] (FLINK-8211) Rename ResultPartitionWriter to OutputGate

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8211. --- Resolution: Won't Fix Fix Version/s: (was: 1.5.0) > Rename ResultPartitionWriter

[jira] [Closed] (FLINK-8229) Cannot use broadcast in StreamingEnvironment

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8229. --- Resolution: Duplicate Please see this issue: https://issues.apache.org/jira/browse/FLINK-3659

[jira] [Assigned] (FLINK-3659) Add ConnectWithBroadcast Operation

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3659: --- Assignee: Kostas Kloudas (was: Aljoscha Krettek) > Add ConnectWithBroadcast

[jira] [Reopened] (FLINK-3659) Add ConnectWithBroadcast Operation

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-3659: - Assignee: Kostas Kloudas (was: Aljoscha Krettek) > Add ConnectWithBroadcast Operation

[jira] [Assigned] (FLINK-3659) Add ConnectWithBroadcast Operation

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3659: --- Assignee: Aljoscha Krettek (was: Kostas Kloudas) > Add ConnectWithBroadcast

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16286189#comment-16286189 ] Aljoscha Krettek commented on FLINK-7913: - [~tzulitai] I think you also already thought about

[jira] [Closed] (FLINK-5573) Kafka08ITCase.testStartFromZookeeperCommitOffsets fails on Travis

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5573. --- Resolution: Duplicate Haven't seen this one in a while and the Kafka 0.8 connector is very

[jira] [Reopened] (FLINK-7586) Report Watermark metrics in all operators

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7586: - Reopen to change fixVersion > Report Watermark metrics in all operators >

[jira] [Closed] (FLINK-7586) Report Watermark metrics in all operators

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7586. --- Resolution: Duplicate Fix Version/s: (was: 1.4.0) > Report Watermark metrics in

[jira] [Closed] (FLINK-7586) Report Watermark metrics in all operators

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7586. --- Resolution: Duplicate > Report Watermark metrics in all operators >

[jira] [Reopened] (FLINK-7586) Report Watermark metrics in all operators

2017-12-11 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7586: - Reopen to change fixVersion > Report Watermark metrics in all operators >

[jira] [Closed] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8186. --- Resolution: Fixed Fixed on release-1.4 in 612f07bbd2dc9aa1abf01ebf817c8341c1ad7a10 Fixed on

[jira] [Updated] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

2017-12-05 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8162: Fix Version/s: 1.5.0 > Kinesis Connector to report millisBehindLatest metric >

[jira] [Updated] (FLINK-8173) Fix input unboxing and support Avro Utf8 in Table API

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8173: Summary: Fix input unboxing and support Avro Utf8 in Table API (was:

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276924#comment-16276924 ] Aljoscha Krettek commented on FLINK-8186: - I have a fix for this, PR coming up in a minute. >

[jira] [Assigned] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-8186: --- Assignee: Aljoscha Krettek > AvroInputFormat regression: fails to deserialize

[jira] [Closed] (FLINK-8177) Flink cannot be built for Hadoop 2.9.0

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8177. --- Resolution: Fixed Assignee: Aljoscha Krettek Fix Version/s: 1.4.0 Fixed on

[jira] [Commented] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276685#comment-16276685 ] Aljoscha Krettek commented on FLINK-8186: - Just a quick update, I'm looking into this. Setting

[jira] [Updated] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8186: Priority: Blocker (was: Minor) > AvroInputFormat regression: fails to deserialize

[jira] [Updated] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on standalone cluster with hadoop27 compat

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8186: Fix Version/s: 1.4.0 > AvroInputFormat regression: fails to deserialize GenericRecords on

[jira] [Updated] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7595: Priority: Blocker (was: Major) > Removing stateless task from task chain breaks savepoint

[jira] [Updated] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore

2017-12-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7595: Fix Version/s: 1.4.0 > Removing stateless task from task chain breaks savepoint restore >

[jira] [Commented] (FLINK-8174) Mesos RM unable to accept offers for unreserved resources

2017-11-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273365#comment-16273365 ] Aljoscha Krettek commented on FLINK-8174: - thanks! > Mesos RM unable to accept offers for

[jira] [Commented] (FLINK-8174) Mesos RM unable to accept offers for unreserved resources

2017-11-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273185#comment-16273185 ] Aljoscha Krettek commented on FLINK-8174: - Are there any updates on this? > Mesos RM unable to

[jira] [Comment Edited] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-11-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182713#comment-16182713 ] Aljoscha Krettek edited comment on FLINK-5506 at 11/30/17 3:29 PM: --- Same

[jira] [Updated] (FLINK-5506) Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException

2017-11-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5506: Description: Reporting this here as per Vasia's advice. I am having the following problem

[jira] [Comment Edited] (FLINK-8177) Flink cannot be built for Hadoop 2.9.0

2017-11-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272679#comment-16272679 ] Aljoscha Krettek edited comment on FLINK-8177 at 11/30/17 1:44 PM: --- I

[jira] [Commented] (FLINK-8177) Flink cannot be built for Hadoop 2.9.0

2017-11-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272679#comment-16272679 ] Aljoscha Krettek commented on FLINK-8177: - I simply changed the test to not extend {{Container}}

[jira] [Commented] (FLINK-7881) flink can't deployed on yarn with ha

2017-11-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272673#comment-16272673 ] Aljoscha Krettek commented on FLINK-7881: - [~djh4230] Does [~till.rohrmann]'s suggestion at the

[jira] [Commented] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore

2017-11-30 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16272638#comment-16272638 ] Aljoscha Krettek commented on FLINK-7595: - Fixed on release-1.4 in

[jira] [Reopened] (FLINK-8081) Annotate MetricRegistry#getReporters() with @VisibleForTesting

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8081: - reopen to change fixVersion > Annotate MetricRegistry#getReporters() with @VisibleForTesting

[jira] [Reopened] (FLINK-6294) BucketingSink throws NPE while cancelling job

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-6294: - reopen to change fixVersion > BucketingSink throws NPE while cancelling job >

[jira] [Closed] (FLINK-8125) Support limiting the number of open FileSystem connections

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8125. --- Resolution: Fixed Fix Version/s: (was: 1.4.1) (was: 1.5.0)

[jira] [Closed] (FLINK-8081) Annotate MetricRegistry#getReporters() with @VisibleForTesting

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8081. --- Resolution: Fixed Fix Version/s: (was: 1.4.1) 1.4.0 > Annotate

[jira] [Closed] (FLINK-6294) BucketingSink throws NPE while cancelling job

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6294. --- Resolution: Fixed Fix Version/s: (was: 1.4.1) 1.4.0 >

[jira] [Reopened] (FLINK-8125) Support limiting the number of open FileSystem connections

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-8125: - reopen to change fixVersion > Support limiting the number of open FileSystem connections >

[jira] [Closed] (FLINK-8165) ParameterTools not serializable properly

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8165. --- Resolution: Fixed Fixed on master in 731896ae709753d5cc225d94585cb0d738e86ca9 Fixed on

[jira] [Closed] (FLINK-8166) Release scripts should also create Hadoop-free binaries by default

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8166. --- Resolution: Fixed Fix Version/s: (was: 1.5.0) 1.4.0 Fixed on

[jira] [Assigned] (FLINK-8166) Release scripts should also create Hadoop-free binaries by default

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-8166: --- Assignee: Aljoscha Krettek > Release scripts should also create Hadoop-free binaries

[jira] [Closed] (FLINK-7300) End-to-end tests are instable on Travis

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7300. --- Resolution: Fixed Fixed on master in 8ca150f4232a940108a5ff7de04de368eb2eb3f0 Fixed on

[jira] [Commented] (FLINK-8167) Failing WikipediaEditsSourceTest on Travis

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16270575#comment-16270575 ] Aljoscha Krettek commented on FLINK-8167: - Related to FLINK-7762 > Failing

[jira] [Commented] (FLINK-7300) End-to-end tests are instable on Travis

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16270566#comment-16270566 ] Aljoscha Krettek commented on FLINK-7300: - I'll add the {{RejectedExecutionException}} to the list

[jira] [Updated] (FLINK-8165) ParameterTools not serializable properly

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8165: Fix Version/s: 1.4.0 > ParameterTools not serializable properly >

[jira] [Updated] (FLINK-8165) ParameterTools not serializable properly

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8165: Priority: Blocker (was: Critical) > ParameterTools not serializable properly >

[jira] [Updated] (FLINK-8165) ParameterTools not serializable properly

2017-11-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8165: Description: Trying to get with default value after deserialization fails as the EmptyMap

[jira] [Closed] (FLINK-8022) Kafka at-least-once tests fail occasionally

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8022. --- Resolution: Fixed Assignee: Piotr Nowojski (was: Tzu-Li (Gordon) Tai) Fixed on master

[jira] [Updated] (FLINK-8152) Add Kafka 1.0.0 connector

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8152: Summary: Add Kafka 1.0.0 connector (was: Any plans to Upgrade to Kafka 1.0.0 ) > Add

[jira] [Commented] (FLINK-8155) Class org.apache.hadoop.yarn.client.RequestHedgingRMFailoverProxyProvider not found

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16266591#comment-16266591 ] Aljoscha Krettek commented on FLINK-8155: - This might seem a stupid question but did you use the

[jira] [Updated] (FLINK-7574) Remove unused dependencies from flink-clients

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7574: Summary: Remove unused dependencies from flink-clients (was: flink-clients) > Remove

[jira] [Updated] (FLINK-3828) Remove unused dependencies from flink-runtime

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3828: Summary: Remove unused dependencies from flink-runtime (was: flink-runtime) > Remove

[jira] [Updated] (FLINK-3831) Remove unused dependencies from flink-streaming-java

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3831: Summary: Remove unused dependencies from flink-streaming-java (was: flink-streaming-java)

[jira] [Updated] (FLINK-3832) Remove unused dependencies from flink-streaming-scala

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3832: Summary: Remove unused dependencies from flink-streaming-scala (was:

[jira] [Updated] (FLINK-3830) Remove unused dependencies from flink-scala

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3830: Summary: Remove unused dependencies from flink-scala (was: flink-scala) > Remove unused

[jira] [Updated] (FLINK-7577) Remove unused dependencies from flink-core

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7577: Summary: Remove unused dependencies from flink-core (was: flink-core) > Remove unused

[jira] [Updated] (FLINK-3833) Remove unused dependencies from flink-test-utils

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3833: Summary: Remove unused dependencies from flink-test-utils (was: flink-test-utils) >

[jira] [Updated] (FLINK-3829) Remove unused dependencies from flink-java

2017-11-27 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3829: Summary: Remove unused dependencies from flink-java (was: flink-java) > Remove unused

[jira] [Commented] (FLINK-7883) Stop fetching source before a cancel with savepoint

2017-11-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16265345#comment-16265345 ] Aljoscha Krettek commented on FLINK-7883: - The problem is that this is harder than it looks. In a

[jira] [Commented] (FLINK-8100) Consider introducing log4j-extras

2017-11-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16265322#comment-16265322 ] Aljoscha Krettek commented on FLINK-8100: - We don't use log4j directly but slf4j. Would this still

[jira] [Commented] (FLINK-8103) Flink 1.4 not writing to standard out log file

2017-11-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16265321#comment-16265321 ] Aljoscha Krettek commented on FLINK-8103: - I just ran an example like this on the (just-released)

[jira] [Commented] (FLINK-8124) EventTimeTrigger (and other triggers) could have less specific generic types

2017-11-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16265309#comment-16265309 ] Aljoscha Krettek commented on FLINK-8124: - I think that should be feasible, yes. >

[jira] [Closed] (FLINK-6294) BucketingSink throws NPE while cancelling job

2017-11-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6294. --- Resolution: Fixed Fixed on release-1.3 in 5aea4917662d80899d3adff0378b97ae58aa2afc Fixed on

[jira] [Updated] (FLINK-6294) BucketingSink throws NPE while cancelling job

2017-11-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6294: Fix Version/s: 1.4.1 1.3.3 > BucketingSink throws NPE while cancelling

[jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"

2017-11-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16265290#comment-16265290 ] Aljoscha Krettek commented on FLINK-8093: - Do you mean thread safe or *not* thread safe? I think

[jira] [Updated] (FLINK-8022) Kafka at-least-once tests fail occasionally

2017-11-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8022: Priority: Critical (was: Blocker) > Kafka at-least-once tests fail occasionally >

[jira] [Updated] (FLINK-8022) Kafka at-least-once tests fail occasionally

2017-11-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8022: Fix Version/s: (was: 1.4.0) 1.5.0 > Kafka at-least-once tests fail

[jira] [Closed] (FLINK-8132) FlinkKafkaProducer011 can commit incorrect transaction during recovery

2017-11-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8132. --- Resolution: Fixed Fixed on release-1.4 in 27564c33955d8e53f0275a5b43d4b2415ba86547 Fixed on

[jira] [Commented] (FLINK-7913) Add support for Kafka default partitioner

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262932#comment-16262932 ] Aljoscha Krettek commented on FLINK-7913: - What is the default Kafka partitioner doing different

[jira] [Closed] (FLINK-7841) Add docs for Flink's S3 support

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7841. --- Resolution: Fixed > Add docs for Flink's S3 support > --- > >

[jira] [Commented] (FLINK-4716) Add trigger full recovery button to web UI

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262747#comment-16262747 ] Aljoscha Krettek commented on FLINK-4716: - What's the state of this? And also: what's the purpose

[jira] [Closed] (FLINK-8131) Update to Kafka 0.11.0.2

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8131. --- Resolution: Fixed Updated on release-1.4 in 7ed2cef83723fadb63f5cccf35ade1c9c78725e2 Updated

[jira] [Updated] (FLINK-8022) Kafka at-least-once tests fail occasionally

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8022: Fix Version/s: 1.4.0 > Kafka at-least-once tests fail occasionally >

[jira] [Updated] (FLINK-8022) Kafka at-least-once tests fail occasionally

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8022: Priority: Blocker (was: Critical) > Kafka at-least-once tests fail occasionally >

[jira] [Updated] (FLINK-8131) Update to Kafka 0.11.0.2

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8131: Priority: Blocker (was: Major) > Update to Kafka 0.11.0.2 > > >

[jira] [Assigned] (FLINK-8131) Update to Kafka 0.11.0.2

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-8131: --- Assignee: Aljoscha Krettek > Update to Kafka 0.11.0.2 > > >

[jira] [Updated] (FLINK-8131) Update to Kafka 0.11.0.2

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8131: Fix Version/s: 1.4.0 > Update to Kafka 0.11.0.2 > > >

[jira] [Created] (FLINK-8131) Update to Kafka 0.11.0.2

2017-11-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-8131: --- Summary: Update to Kafka 0.11.0.2 Key: FLINK-8131 URL: https://issues.apache.org/jira/browse/FLINK-8131 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8130) Javadocs link for snapshot release is not correct

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8130: Description: See last comments on FLINK-7702. (was: The "Javadocs" link in the left side

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16262268#comment-16262268 ] Aljoscha Krettek commented on FLINK-7702: - I created FLINK-8130. This issue was properly fixed for

[jira] [Closed] (FLINK-7702) Javadocs are not being built

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7702. --- Resolution: Fixed > Javadocs are not being built > > >

[jira] [Created] (FLINK-8130) Javadocs link for snapshot release is not correct

2017-11-22 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-8130: --- Summary: Javadocs link for snapshot release is not correct Key: FLINK-8130 URL: https://issues.apache.org/jira/browse/FLINK-8130 Project: Flink Issue

[jira] [Updated] (FLINK-7702) Javadocs are not being built

2017-11-22 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7702: Fix Version/s: (was: 1.5.0) 1.4.0 > Javadocs are not being built >

[jira] [Closed] (FLINK-8115) Kafka E2E tests fail on travis

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8115. --- Resolution: Fixed Fixed on release-1.4 in 3d4146c10bf3d2f7df6d9992670017247d1952dd Fixed on

[jira] [Closed] (FLINK-8099) Reduce default restart delay to 1 second

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8099. --- Resolution: Fixed Changed on release-1.4 in d0ea9d95109a7e8ca7eb81d42f72c7f132192321 Changed

[jira] [Closed] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8086. --- Fixed on master in d57ebd063bad571d0ea276da5beee18aeb568b50 Fixed on release-1.4 in

[jira] [Updated] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery through ProducerFencedException

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8086: Affects Version/s: (was: 1.5.0) > FlinkKafkaProducer011 can permanently fail in

[jira] [Closed] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4228. --- > YARN artifact upload does not work with S3AFileSystem >

[jira] [Updated] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

2017-11-20 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4228: Fix Version/s: (was: 1.5.0) > YARN artifact upload does not work with S3AFileSystem >

[jira] [Commented] (FLINK-8083) FileSystem class not binary compatible with 1.3

2017-11-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16257180#comment-16257180 ] Aljoscha Krettek commented on FLINK-8083: - [~Zentol] I think you can now merge that change to the

[jira] [Closed] (FLINK-7266) Don't attempt to delete parent directory on S3

2017-11-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7266. --- Resolution: Fixed Fixed on release-1.4 in 666b1b2e62463ae4985d237535d56c9e0ab9dba9 > Don't

[jira] [Closed] (FLINK-8083) FileSystem class not binary compatible with 1.3

2017-11-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8083. --- Resolution: Fixed This should be fixed now that FLINK-7265 is on master and release-1.4. >

[jira] [Closed] (FLINK-7265) FileSystems should describe their kind and consistency level

2017-11-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7265. --- Resolution: Fixed Fixed on release-1.4 in a0dbe182fa677a87f601cbedc4115e63fff9fe4f >

[jira] [Updated] (FLINK-8099) Reduce default restart delay to 1 second

2017-11-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8099: Issue Type: Improvement (was: Bug) > Reduce default restart delay to 1 second >

[jira] [Created] (FLINK-8099) Reduce default restart delay to 1 second

2017-11-17 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-8099: --- Summary: Reduce default restart delay to 1 second Key: FLINK-8099 URL: https://issues.apache.org/jira/browse/FLINK-8099 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7266) Don't attempt to delete parent directory on S3

2017-11-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16257146#comment-16257146 ] Aljoscha Krettek commented on FLINK-7266: - Fixed on master (to be 1.5) in

[jira] [Commented] (FLINK-7265) FileSystems should describe their kind and consistency level

2017-11-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16257145#comment-16257145 ] Aljoscha Krettek commented on FLINK-7265: - Added on master (to be 1.5) in

[jira] [Updated] (FLINK-7266) Don't attempt to delete parent directory on S3

2017-11-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7266: Fix Version/s: (was: 1.5.0) > Don't attempt to delete parent directory on S3 >

[jira] [Updated] (FLINK-7265) FileSystems should describe their kind and consistency level

2017-11-17 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7265: Fix Version/s: (was: 1.5.0) 1.4.0 > FileSystems should describe

  1   2   3   4   5   6   7   8   9   10   >