[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-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. > >

[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

[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

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

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 > >

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

[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: >

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=AWPxETxA3e-qcckj1Sl1=false=BLOCKER=BUG For ./flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/PredefinedOptions.java ,

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

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

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

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

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

hould not block the release 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 <yuzhih...@gmail.com&

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

[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

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

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

Re: Closing (automatically?) inactive pull requests

ml) that I don't > see > >>> a > >>> chance for getting merged. > >>> > >>> Best, Fabian > >>> > >>> > >>> - > >>> > >>> 2018-05-15 9:13 GMT+02:00 Chesnay Schepler <ches...@apache.org>: &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: >

[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

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

[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

[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

>> >> Hi Amit, >> >> >> >> 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 candi

[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?

t; > So should I do the bit of extra code to show using a CompletableFuture > with a Future? > > — Ken > > > On Apr 14, 2018, at 9:13 AM, Ted Yu <yuzhih...@gmail.com> wrote: > > > > bq. resultFuture.thenAccept( (String result) -> { > > > &

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.

[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

Re: Using Slack for online discussions

ly be different from email threads. > > > > Thanks, > > Thomas > > > > > > On Tue, Apr 3, 2018 at 7:37 AM, Ted Yu <yuzhih...@gmail.com> wrote: > > > >> It is the lack of searchable public record (of Slack) that we should be > >> co

Re: Using Slack for online discussions

gt; can be solved by an explicit invite for everyone [1]. > > [1] https://s.apache.org/slack-invite > > Cheers, > Till > > > On Tue, Apr 3, 2018 at 3:09 PM, Ted Yu <yuzhih...@gmail.com> wrote: > > > Thanks for the background information. > > I withdraw

Re: Using Slack for online discussions

so available to contributors. On 30.03.2018 10:17, Ted Yu wrote: > +1 > Original message From: Jean-Baptiste Onofré > <j...@nanthrax.net> Date: 3/30/18  12:43 AM  (GMT-08:00) To: > dev@flink.apache.org Subject: Re: Using Slack for online discussions > +1 >

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

[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.

[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

[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

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

[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

[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

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-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

w long will the long weekend be? 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 <yuzhih...@gmail.com> wrote: > > Aljoscha: > Thanks for spinning RC. > > bq. The vote will

[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: 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

[jira] [Created] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

Ted Yu created FLINK-7897: - Summary: Consider using nio.Files for file deletion in TransientBlobCleanupTask Key: FLINK-7897 URL: https://issues.apache.org/jira/browse/FLINK-7897 Project: Flink

[jira] [Created] (FLINK-7796) RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation should close snapshotCloseableRegistry

Ted Yu created FLINK-7796: - Summary: RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation should close snapshotCloseableRegistry Key: FLINK-7796 URL: https://issues.apache.org/jira/browse/FLINK-7796 Project

[jira] [Created] (FLINK-7795) Utilize error-prone to discover common coding mistakes

Ted Yu created FLINK-7795: - Summary: Utilize error-prone to discover common coding mistakes Key: FLINK-7795 URL: https://issues.apache.org/jira/browse/FLINK-7795 Project: Flink Issue Type

  1   2   3   >