[jira] [Created] (FLINK-32025) Make job cancellation button on UI configurable

Ted Yu created FLINK-32025: -- Summary: Make job cancellation button on UI configurable Key: FLINK-32025 URL: https://issues.apache.org/jira/browse/FLINK-32025 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10468) Potential missing break for PARTITION_CUSTOM in OutputEmitter ctor

Ted Yu created FLINK-10468: -- Summary: Potential missing break for PARTITION_CUSTOM in OutputEmitter ctor Key: FLINK-10468 URL: https://issues.apache.org/jira/browse/FLINK-10468 Project: Flink

[jira] [Created] (FLINK-10467) Upgrade commons-compress to 1.18

Ted Yu created FLINK-10467: -- Summary: Upgrade commons-compress to 1.18 Key: FLINK-10467 URL: https://issues.apache.org/jira/browse/FLINK-10467 Project: Flink Issue Type: Task Reporter

[jira] [Created] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

Ted Yu created FLINK-10446: -- Summary: Use the "guava beta checker" plugin to keep off of @Beta API Key: FLINK-10446 URL: https://issues.apache.org/jira/browse/FLINK-10446 Project: Flink

[jira] [Created] (FLINK-10391) MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils

Ted Yu created FLINK-10391: -- Summary: MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils Key: FLINK-10391 URL: https://issues.apache.org/jira/browse/FLINK-10391 Project

[jira] [Created] (FLINK-10389) TaskManagerServicesConfiguration ctor contains self assignment

Ted Yu created FLINK-10389: -- Summary: TaskManagerServicesConfiguration ctor contains self assignment Key: FLINK-10389 URL: https://issues.apache.org/jira/browse/FLINK-10389 Project: Flink Issue

[jira] [Created] (FLINK-10388) RestClientTest sometimes fails with AssertionError

Ted Yu created FLINK-10388: -- Summary: RestClientTest sometimes fails with AssertionError Key: FLINK-10388 URL: https://issues.apache.org/jira/browse/FLINK-10388 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-10228) Add metrics for netty direct memory consumption

Ted Yu created FLINK-10228: -- Summary: Add metrics for netty direct memory consumption Key: FLINK-10228 URL: https://issues.apache.org/jira/browse/FLINK-10228 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10125) Unclosed ByteArrayDataOutputView in RocksDBMapState

Ted Yu created FLINK-10125: -- Summary: Unclosed ByteArrayDataOutputView in RocksDBMapState Key: FLINK-10125 URL: https://issues.apache.org/jira/browse/FLINK-10125 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9924) Upgrade zookeeper to 3.4.13

Ted Yu created FLINK-9924: - Summary: Upgrade zookeeper to 3.4.13 Key: FLINK-9924 URL: https://issues.apache.org/jira/browse/FLINK-9924 Project: Flink Issue Type: Task Reporter: Ted Yu

[jira] [Created] (FLINK-9880) Incorrect argument order calling BucketerContext#update

Ted Yu created FLINK-9880: - Summary: Incorrect argument order calling BucketerContext#update Key: FLINK-9880 URL: https://issues.apache.org/jira/browse/FLINK-9880 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9849) Upgrade hbase version to 2.0.1 for hbase connector

Ted Yu created FLINK-9849: - Summary: Upgrade hbase version to 2.0.1 for hbase connector Key: FLINK-9849 URL: https://issues.apache.org/jira/browse/FLINK-9849 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9825) Upgrade checkstyle version to 8.6

Ted Yu created FLINK-9825: - Summary: Upgrade checkstyle version to 8.6 Key: FLINK-9825 URL: https://issues.apache.org/jira/browse/FLINK-9825 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9824) Support IPv6 literal

Ted Yu created FLINK-9824: - Summary: Support IPv6 literal Key: FLINK-9824 URL: https://issues.apache.org/jira/browse/FLINK-9824 Project: Flink Issue Type: Bug Reporter: Ted Yu

Re: [VOTE] Release 1.5.1, release candidate #2

+1 Checked signatures of artifacts Ran test suite On Fri, Jul 6, 2018 at 11:42 AM Yaz Sh wrote: > +1 > > Tests have been done on OS X > > - Ran in cluster mode ./bin/start-cluster.sh > - Checked that *.out files are empty > - Stopped cluster ./bin/stop-cluster.sh > - Checked for No Exceptions

Re: Flink Kafka TimeoutException

Have you tried increasing the request.timeout.ms parameter (Kafka) ? Which Flink / Kafka release are you using ? Cheers On Thu, Jul 5, 2018 at 5:39 AM Amol S - iProgrammer wrote: > Hello, > > I am using flink with kafka and getting below exception. > > org.apache.kafka.common.errors.TimeoutExc

[jira] [Created] (FLINK-9736) Potential null reference in KeyGroupPartitionedPriorityQueue#poll()

Ted Yu created FLINK-9736: - Summary: Potential null reference in KeyGroupPartitionedPriorityQueue#poll() Key: FLINK-9736 URL: https://issues.apache.org/jira/browse/FLINK-9736 Project: Flink Issue

[jira] [Created] (FLINK-9735) Potential resource leak in RocksDBStateBackend#getDbOptions

Ted Yu created FLINK-9735: - Summary: Potential resource leak in RocksDBStateBackend#getDbOptions Key: FLINK-9735 URL: https://issues.apache.org/jira/browse/FLINK-9735 Project: Flink Issue Type: Bug

Re: Job jumbo jar can't be extracted on Windows

Looking at javadoc of separatorChar : * The system-dependent default name-separator character. This field is * initialized to contain the first character of the value of the system * property file.separator. On UNIX systems the value of this * field is '/'; on Microsoft Wi

[jira] [Created] (FLINK-9697) Provide connector for Kafka 2.0.0

Ted Yu created FLINK-9697: - Summary: Provide connector for Kafka 2.0.0 Key: FLINK-9697 URL: https://issues.apache.org/jira/browse/FLINK-9697 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9675) Avoid FileInputStream/FileOutputStream

Ted Yu created FLINK-9675: - Summary: Avoid FileInputStream/FileOutputStream Key: FLINK-9675 URL: https://issues.apache.org/jira/browse/FLINK-9675 Project: Flink Issue Type: Improvement

Re: [Flink-9407] Question about proposed ORC Sink !

For #1, the word exist should be exit, right ?Thanks Original message From: zhangminglei <18717838...@163.com> Date: 6/23/18 10:12 AM (GMT+08:00) To: sagar loke Cc: dev , user Subject: Re: [Flink-9407] Question about proposed ORC Sink ! Hi, Sagar. 1. It solves the issue par

Re: [ANNOUNCE] New committer Piotr Nowojski

Congratulations, Piotr! On Fri, Jun 22, 2018 at 12:26 PM, Till Rohrmann wrote: > Hi everybody, > > On behalf of the PMC I am delighted to announce Piotr Nowojski as a new > Flink > committer! > > Piotr has been an active member of our community for more than a year. > Among other things, he cont

Re: [ANNOUNCE] New committer: Sihua Zhou

Congratulations Sihua! On Fri, Jun 22, 2018 at 6:42 AM, zhangminglei <18717838...@163.com> wrote: > Congrats! Sihua > > Cheers > Minglei. > > > 在 2018年6月22日，下午9:17，Till Rohrmann 写道： > > > > Hi everybody, > > > > On behalf of the PMC I am delighted to announce Sihua Zhou as a new Flink > > commit

Re: Please review FLINK-9610 Add Kafka partitioner that uses the key to partition by

Interesting enhancement. I left a minor comment on the PR. Cheers On Tue, Jun 19, 2018 at 12:26 AM, Niels Basjes wrote: > Hi, > > Yesterday we ran into problems regarding the distribution of records across > Kafka where Flink was used as the producer. So we fixed this and realized > that the c

[jira] [Created] (FLINK-9580) Potentially unclosed ByteBufInputStream in RestClient#readRawResponse

Ted Yu created FLINK-9580: - Summary: Potentially unclosed ByteBufInputStream in RestClient#readRawResponse Key: FLINK-9580 URL: https://issues.apache.org/jira/browse/FLINK-9580 Project: Flink Issue

Re: how to build the connectors and examples from the source

Which connector from the following list are you trying to build ? https://flink.apache.org/ecosystem.html#connectors The available connectors from 1.5.0 are quite recent. Is there any functionality missing in the 1.5.0 release ? Thanks On Tue, Jun 12, 2018 at 5:17 PM, Chris Kellogg wrote: > H

Re: Static code analysis for Flink project

I took a look at some of the blocker defects. e.g. https://sonarcloud.io/project/issues?id=org.apache.flink%3Aflink-parent&open=AWPxETxA3e-qcckj1Sl1&resolved=false&severities=BLOCKER&types=BUG For ./flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/s

Re: [WEBSITE] Proposal to rework the Flink website

+1 On Tue, Jun 5, 2018 at 9:46 AM, Stephan Ewen wrote: > Big +1 to this! > > I would like to contribute to this effort and help strengthen the way Flink > presents itself. > > > On Tue, Jun 5, 2018 at 11:56 AM, Fabian Hueske wrote: > > > Hi everybody, > > > > I've opened a PR [1] that reworks p

Re: [PROPOSAL] Improving Flink’s timer management for large state

+1 Original message From: Bowen Li Date: 5/27/18 12:31 AM (GMT-08:00) To: dev@flink.apache.org Subject: Re: [PROPOSAL] Improving Flink’s timer management for large state +1 LGTM. RocksDB timer service is one of the most highly anticipated features from Flink users, and it's f

Re: [VOTE] Release 1.5.0, release candidate #5

+1 Checked signatures Ran test suite Due to FLINK-9340 and FLINK-9091, I had to run tests in multiple rounds. Cheers On Wed, May 23, 2018 at 7:39 AM, Fabian Hueske wrote: > +1 (binding) > > - checked hashes and signatures > - checked source archive and didn't find unexpected binary files > -

Re: [VOTE] Enable GitBox integration (#2)

+1 Original message From: Chesnay Schepler Date: 5/22/18 1:12 AM (GMT-08:00) To: dev@flink.apache.org Subject: [VOTE] Enable GitBox integration (#2) Hello, since no concerns have been raised in the discussion about enabling GitBox [1] I'm opening this vote to make things of

Re: [VOTE] Release 1.5.0, release candidate #4

elease it. > > Since it's hard to reproduce, we cannot be sure that Timo's fix actually > solves the problem. > We can merge the fix to the master and see if the problem goes away. > > Best, Fabian > > 2018-05-18 18:31 GMT+02:00 Ted Yu : > > > When I ran tests, I

Re: [VOTE] Release 1.5.0, release candidate #4

When I ran tests, I hit FLINK-9091 . It seems Timo already has a fix. It would be nice to include the fix since flink-json module is new in 1.5 release. On Fri, May 18, 2018 at 9:26 AM, Till Rohrmann wrote: > Hi everyone, > > since the effective voting period for the RC4 was quite short and it

[jira] [Created] (FLINK-9393) LocatableInputSplit#hashCode should take hostnames into account

Ted Yu created FLINK-9393: - Summary: LocatableInputSplit#hashCode should take hostnames into account Key: FLINK-9393 URL: https://issues.apache.org/jira/browse/FLINK-9393 Project: Flink Issue Type

Re: [DISCUSS] GitBox

+1 Original message From: Shuyi Chen Date: 5/16/18 1:12 PM (GMT-08:00) To: dev@flink.apache.org Subject: Re: [DISCUSS] GitBox +1 :) A lot of projects are already using it. On Wed, May 16, 2018 at 3:40 AM, Chesnay Schepler wrote: > Hell

Re: [DISCUSS] Drop "canEqual" from TypeInformation, TypeSerializer, etc.

+1 from me as well. I checked a few serializer classes. The `equals` method on serializers contains the logic of `canEqual` method whose existence seems redundant. On Wed, May 16, 2018 at 1:49 AM, Tzu-Li (Gordon) Tai wrote: > +1. > > Looking at the implementations of the `canEqual` method in se

Re: [DISCUSS] Adding new interfaces in [Stream]ExecutionEnvironment

bq. In a design document, Timo mentioned that we can ship multiple JAR files Mind telling us where the design doc can be retrieved ? Thanks On Wed, May 16, 2018 at 1:29 AM, Fabian Hueske wrote: > Hi, > > I'm not sure if we need to modify the existing method. > What we need is a bit different f

Re: Closing (automatically?) inactive pull requests

t;> a > >>> chance for getting merged. > >>> > >>> Best, Fabian > >>> > >>> > >>> - > >>> > >>> 2018-05-15 9:13 GMT+02:00 Chesnay Schepler : > >>> > >>> -1 > >>&g

Re: Closing (automatically?) inactive pull requests

bq. this pull request requires a review, please simply write any comment. Shouldn't the wording of such comment be known before hand ? Otherwise pull request waiting for committers' review may be mis-classified. Cheers On Mon, May 14, 2018 at 7:59 PM, blues zheng wrote: > +1 for the proposal.

[jira] [Created] (FLINK-9363) Bump up the Jackson version

Ted Yu created FLINK-9363: - Summary: Bump up the Jackson version Key: FLINK-9363 URL: https://issues.apache.org/jira/browse/FLINK-9363 Project: Flink Issue Type: Improvement Reporter

Re: [VOTE] Release 1.5.0, release candidate #2

Can you try out mvn 3.5.2 ? I don't get the error when running the command line you gave. BTW 2.7.3.2.6.2.0-205 was quite old release. Cheers On Mon, May 14, 2018 at 7:15 AM, shashank734 wrote: > While building from source failing with following error : > > Failed to execute goal > org.apache

Re: Snapshots and RC-candidate maven artifacts

Flavio: Can you use the snapshot for 1.5 RC ? https://repository.apache.org/content/repositories/orgapacheflink-1154/ It was uploaded on Apr 2nd. FYI On Mon, May 14, 2018 at 7:54 AM, Fabian Hueske wrote: > Hi, > > I'd assume that we stopped updating 1.5-SNAPSHOT jars when we forked off > the r

[jira] [Created] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use

Ted Yu created FLINK-9340: - Summary: ScheduleOrUpdateConsumersTest may fail with Address already in use Key: FLINK-9340 URL: https://issues.apache.org/jira/browse/FLINK-9340 Project: Flink Issue

Re: [VOTE] Release 1.5.0, release candidate #2

I ran the test suite twice and both failed with: Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 9.784 sec <<< FAILURE! - in org.apache.flink.runtime.jobmanager.scheduler.ScheduleOrUpdateConsumersTest org.apache.flink.runtime.jobmanager.scheduler.ScheduleOrUpdateConsumersTest Time

Re: [ANNOUNCE] Two new committers: Xingcan Cui and Nico Kruber

Congratulations, Xingcan and Nico ! On Tue, May 8, 2018 at 11:52 AM, Fabian Hueske wrote: > Hi everyone, > > I'm happy to announce that two members of the Flink community accepted the > offer of the PMC to become committers. > > * Xingcan Cui has been contributing to Flink for about a year, focu

[jira] [Created] (FLINK-9265) Upgrade Prometheus version

Ted Yu created FLINK-9265: - Summary: Upgrade Prometheus version Key: FLINK-9265 URL: https://issues.apache.org/jira/browse/FLINK-9265 Project: Flink Issue Type: Improvement Reporter: Ted

[jira] [Created] (FLINK-9236) Use Apache Parent POM 19

Ted Yu created FLINK-9236: - Summary: Use Apache Parent POM 19 Key: FLINK-9236 URL: https://issues.apache.org/jira/browse/FLINK-9236 Project: Flink Issue Type: Improvement Reporter: Ted

[jira] [Created] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

Ted Yu created FLINK-9231: - Summary: Enable SO_REUSEADDR on listen sockets Key: FLINK-9231 URL: https://issues.apache.org/jira/browse/FLINK-9231 Project: Flink Issue Type: Improvement

Re: TaskManager deadlock on NetworkBufferPool

t;> >> >> The network stack has been redesigned for the upcoming Flink 1.5 >> release. >> >> The issue might have been fixed by that. >> >> >> >> There's already a first release candidate for Flink 1.5.0 available >> [1]. >

[jira] [Created] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd

Ted Yu created FLINK-9223: - Summary: bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd Key: FLINK-9223 URL: https://issues.apache.org/jira/browse/FLINK-9223

[jira] [Created] (FLINK-9214) YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal

Ted Yu created FLINK-9214: - Summary: YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal Key: FLINK-9214 URL: https://issues.apache.org/jira/browse/FLINK-9214

[jira] [Created] (FLINK-9185) Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives

Ted Yu created FLINK-9185: - Summary: Potential null dereference in PrioritizedOperatorSubtaskState#resolvePrioritizedAlternatives Key: FLINK-9185 URL: https://issues.apache.org/jira/browse/FLINK-9185 Project

Re: Documentation glitch w/AsyncFunction?

tra code to show using a CompletableFuture > with a Future? > > — Ken > > > On Apr 14, 2018, at 9:13 AM, Ted Yu wrote: > > > > bq. resultFuture.thenAccept( (String result) -> { > > > > I think the type of variable for the above call sho

Re: Documentation glitch w/AsyncFunction?

bq. resultFuture.thenAccept( (String result) -> { I think the type of variable for the above call should be CompletableFuture. Meaning, the variable currently named resultFuture should be renamed so that the intention is clearer. bq. resultFuture.complete(Collections.singlet

[jira] [Created] (FLINK-9150) Prepare for Java 10

Ted Yu created FLINK-9150: - Summary: Prepare for Java 10 Key: FLINK-9150 URL: https://issues.apache.org/jira/browse/FLINK-9150 Project: Flink Issue Type: Task Reporter: Ted Yu When

Re: TaskManager deadlock on NetworkBufferPool

I searched for 0x0005e28fe218 in the two files you attached to FLINK-2685 but didn't find any hit. Was this the same instance as the attachment to FLINK-2685 ? Thanks On Wed, Apr 4, 2018 at 10:21 AM, Amit Jain wrote: > +u...@flink.apache.org > > On Wed, Apr 4, 2018 at 11:33 AM, Amit Jain

Re: Using Slack for online discussions

record, it may be possible to archive what's posted > > on the slack channel by subscribing the mailing list. > > > > I think a communication platform like Slack or IRC complements email, the > > type of messages there would typically be different from email threads. > &g

Re: Using Slack for online discussions

plicit invite for everyone [1]. > > [1] https://s.apache.org/slack-invite > > Cheers, > Till > > > On Tue, Apr 3, 2018 at 3:09 PM, Ted Yu wrote: > > > Thanks for the background information. > > I withdraw previous +1 > > Original message ---

Re: Using Slack for online discussions

ontributors. On 30.03.2018 10:17, Ted Yu wrote: > +1 > Original message From: Jean-Baptiste Onofré > Date: 3/30/18  12:43 AM  (GMT-08:00) To: > dev@flink.apache.org Subject: Re: Using Slack for online discussions > +1 > > Regards > JB > > On 03/29/2018

Re: Using Slack for online discussions

+1 Original message From: Jean-Baptiste Onofré Date: 3/30/18 12:43 AM (GMT-08:00) To: dev@flink.apache.org Subject: Re: Using Slack for online discussions +1 Regards JB On 03/29/2018 07:22 PM, Thomas Weise wrote: > How does the community think about using ASF Slack for onli

[jira] [Created] (FLINK-9091) Failure while enforcing releasability in building flink-json module

Ted Yu created FLINK-9091: - Summary: Failure while enforcing releasability in building flink-json module Key: FLINK-9091 URL: https://issues.apache.org/jira/browse/FLINK-9091 Project: Flink Issue

[jira] [Created] (FLINK-9090) Replace UUID.randomUUID with deterministic PRNG

Ted Yu created FLINK-9090: - Summary: Replace UUID.randomUUID with deterministic PRNG Key: FLINK-9090 URL: https://issues.apache.org/jira/browse/FLINK-9090 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9089) Upgrade Orc dependency to 1.4.3

Ted Yu created FLINK-9089: - Summary: Upgrade Orc dependency to 1.4.3 Key: FLINK-9089 URL: https://issues.apache.org/jira/browse/FLINK-9089 Project: Flink Issue Type: Improvement Reporter

[jira] [Created] (FLINK-9088) Upgrade Nifi connector dependency to 1.6.0

Ted Yu created FLINK-9088: - Summary: Upgrade Nifi connector dependency to 1.6.0 Key: FLINK-9088 URL: https://issues.apache.org/jira/browse/FLINK-9088 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

Ted Yu created FLINK-9087: - Summary: Return value of broadcastEvent should be closed in StreamTask#performCheckpoint Key: FLINK-9087 URL: https://issues.apache.org/jira/browse/FLINK-9087 Project: Flink

Re: Flip 6 mesos support

Renjie:The log didn't go through. Consider logging a JIRA and attach the log there.  Thanks Original message From: Renjie Liu Date: 3/23/18 1:38 AM (GMT-08:00) To: dev@flink.apache.org Subject: Re: Flip 6 mesos support Hi, Till:Attached is my log. I'm also looking into this,

[jira] [Created] (FLINK-9048) LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails

Ted Yu created FLINK-9048: - Summary: LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails Key: FLINK-9048 URL: https://issues.apache.org/jira/browse/FLINK-9048

Re: Too many open files

Not sure if you have looked at FLINK-8707 FYI On Tue, Mar 20, 2018 at 2:13 PM, Govindarajan Srinivasaraghavan < govindragh...@gmail.com> wrote: > Hi, > > We have a streaming job that runs on flink in docker and checkpointing > happens every 10 seconds. After several starts and cancellations we a

[jira] [Created] (FLINK-9019) Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs

Ted Yu created FLINK-9019: - Summary: Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs Key: FLINK-9019 URL: https://issues.apache.org/jira/browse/FLINK-9019 Project: Flink

[jira] [Created] (FLINK-9018) Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot

Ted Yu created FLINK-9018: - Summary: Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot Key: FLINK-9018 URL: https://issues.apache.org/jira/browse/FLINK-9018

Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0

+1 on marking bugs as fixed for 1.5.0 only. Original message From: Piotr Nowojski Date: 3/15/18 12:48 AM (GMT-08:00) To: dev@flink.apache.org Subject: Re: [DISCUSS] Not marking Jira issues as resolved in 1.5.0 as resolved in 1.6.0 Same as Chesnay +1 for marking bugs as fixe

Re: [VOTE] Release 1.3.3, release candidate #2

+1 Ran the following command - passed: mvn clean package -Pjdk8 On Wed, Mar 14, 2018 at 3:26 AM, Tzu-Li (Gordon) Tai wrote: > Hi everyone, > > Please review and vote on release candidate #2 for Flink 1.3.3, as > follows: > [ ] +1, Approve the release > [ ] -1, Do not approve the release (pleas

[jira] [Created] (FLINK-8933) Avoid calling Class#newInstance

Ted Yu created FLINK-8933: - Summary: Avoid calling Class#newInstance Key: FLINK-8933 URL: https://issues.apache.org/jira/browse/FLINK-8933 Project: Flink Issue Type: Task Reporter: Ted

Re: [VOTE] Release 1.3.3, release candidate #1

+1 Ran the following command which passed: mvn clean package -Pjdk8 On Mon, Mar 12, 2018 at 9:09 AM, Tzu-Li (Gordon) Tai wrote: > Hi everyone, > > Please review and vote on release candidate #1 for Flink 1.3.3, as > follows: > [ ] +1, Approve the release > [ ] -1, Do not approve the release (p

[jira] [Created] (FLINK-8931) TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled

Ted Yu created FLINK-8931: - Summary: TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled Key: FLINK-8931 URL: https://issues.apache.org/jira/browse/FLINK-8931 Project: Flink Issue

Re: [VOTE] Release 1.3.3, release candidate #1

When I used the following command: mvn package -Pscala-2.11,jdk8 I got: [ERROR] Failed to execute goal on project flink-scala_2.10: Could not resolve dependencies for project org.apache.flink:flink-scala_2.10:jar:1.3.3: Could not find artifact org.scalamacros:quasiquotes_2.11:jar:2.0.1 in centra

Re: [DISCUSS] Releasing Flink 1.3.3 with only critical fixes

+1 to Aljoscha's proposal.

[jira] [Created] (FLINK-8771) Upgrade scalastyle to 1.0.0

Ted Yu created FLINK-8771: - Summary: Upgrade scalastyle to 1.0.0 Key: FLINK-8771 URL: https://issues.apache.org/jira/browse/FLINK-8771 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-8708) Unintended integer division in StandaloneThreadedGenerator

Ted Yu created FLINK-8708: - Summary: Unintended integer division in StandaloneThreadedGenerator Key: FLINK-8708 URL: https://issues.apache.org/jira/browse/FLINK-8708 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8693) initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript

Ted Yu created FLINK-8693: - Summary: initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript Key: FLINK-8693 URL: https://issues.apache.org/jira/browse/FLINK-8693

[jira] [Created] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

Ted Yu created FLINK-8687: - Summary: MaterializedCollectStreamResult#retrievePage should take resultLock Key: FLINK-8687 URL: https://issues.apache.org/jira/browse/FLINK-8687 Project: Flink Issue

[jira] [Created] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap()

Ted Yu created FLINK-8661: - Summary: Replace Collections.EMPTY_MAP with Collections.emptyMap() Key: FLINK-8661 URL: https://issues.apache.org/jira/browse/FLINK-8661 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8554) Upgrade AWS SDK

Ted Yu created FLINK-8554: - Summary: Upgrade AWS SDK Key: FLINK-8554 URL: https://issues.apache.org/jira/browse/FLINK-8554 Project: Flink Issue Type: Improvement Reporter: Ted Yu AWS

[jira] [Created] (FLINK-8464) TestRaftReconfigurationWithSimulatedRpc fails with assertion error

Ted Yu created FLINK-8464: - Summary: TestRaftReconfigurationWithSimulatedRpc fails with assertion error Key: FLINK-8464 URL: https://issues.apache.org/jira/browse/FLINK-8464 Project: Flink Issue

[jira] [Created] (FLINK-8415) Unprotected access to recordsToSend in LongRecordWriterThread#shutdown()

Ted Yu created FLINK-8415: - Summary: Unprotected access to recordsToSend in LongRecordWriterThread#shutdown() Key: FLINK-8415 URL: https://issues.apache.org/jira/browse/FLINK-8415 Project: Flink

[jira] [Created] (FLINK-8394) Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown

Ted Yu created FLINK-8394: - Summary: Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown Key: FLINK-8394 URL: https://issues.apache.org/jira/browse/FLINK-8394 Project: Flink

[jira] [Created] (FLINK-8335) Upgrade hbase connector dependency to 1.4.0

Ted Yu created FLINK-8335: - Summary: Upgrade hbase connector dependency to 1.4.0 Key: FLINK-8335 URL: https://issues.apache.org/jira/browse/FLINK-8335 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8198) Useless check against -1 in LimitedConnectionsFileSystem#fromConfig

Ted Yu created FLINK-8198: - Summary: Useless check against -1 in LimitedConnectionsFileSystem#fromConfig Key: FLINK-8198 URL: https://issues.apache.org/jira/browse/FLINK-8198 Project: Flink Issue

Re: [VOTE] Release 1.4.0, release candidate #1

? I thought about closing the vote on Wednesday, i.e. not count the weekend. Would that work? Best, Aljoscha > On 24. Nov 2017, at 12:18, Ted Yu wrote: > > Aljoscha: > Thanks for spinning RC. > > bq. The vote will be open for at least 72 hours > > As you are aware,

[jira] [Created] (FLINK-8146) Potential resource leak in PythonPlanBinder#unzipPythonLibrary

Ted Yu created FLINK-8146: - Summary: Potential resource leak in PythonPlanBinder#unzipPythonLibrary Key: FLINK-8146 URL: https://issues.apache.org/jira/browse/FLINK-8146 Project: Flink Issue Type

Re: [VOTE] Release 1.4.0, release candidate #1

Aljoscha: Thanks for spinning RC. bq. The vote will be open for at least 72 hours As you are aware, it is long weekend in US. Is it possible to extend by 24 hours so that developers in US can participate in validation ? Cheers On Fri, Nov 24, 2017 at 2:57 AM, Aljoscha Krettek wrote: > Hi eve

Re: Adding a blog post about the 1.4/1.5 timeline and features

+1 Looking forward to the new releases.

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

Ted Yu created FLINK-8100: - Summary: Consider introducing log4j-extras Key: FLINK-8100 URL: https://issues.apache.org/jira/browse/FLINK-8100 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8075) Redundant clone() in Configuration ctor

Ted Yu created FLINK-8075: - Summary: Redundant clone() in Configuration ctor Key: FLINK-8075 URL: https://issues.apache.org/jira/browse/FLINK-8075 Project: Flink Issue Type: Bug Reporter

[jira] [Created] (FLINK-8048) RAT check complaint

Ted Yu created FLINK-8048: - Summary: RAT check complaint Key: FLINK-8048 URL: https://issues.apache.org/jira/browse/FLINK-8048 Project: Flink Issue Type: Bug Reporter: Ted Yu Running

[jira] [Created] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort

Ted Yu created FLINK-8037: - Summary: Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort Key: FLINK-8037 URL: https://issues.apache.org/jira/browse/FLINK-8037 Project: Flink

[jira] [Created] (FLINK-8036) Consider using gradle to build Flink

Ted Yu created FLINK-8036: - Summary: Consider using gradle to build Flink Key: FLINK-8036 URL: https://issues.apache.org/jira/browse/FLINK-8036 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7966) Create flink-connector-kafka-1.0 submodule

Ted Yu created FLINK-7966: - Summary: Create flink-connector-kafka-1.0 submodule Key: FLINK-7966 URL: https://issues.apache.org/jira/browse/FLINK-7966 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7936) Lack of synchronization w.r.t. taskManagers in MetricStore#add()

Ted Yu created FLINK-7936: - Summary: Lack of synchronization w.r.t. taskManagers in MetricStore#add() Key: FLINK-7936 URL: https://issues.apache.org/jira/browse/FLINK-7936 Project: Flink Issue Type

  1   2   3   4   >