(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 363364365366367368369 ... 784

Topics (27406)

Replies

Last Post

Views

[jira] [Created] (FLINK-12484) Drop unnecessary locking for code-paths that now use the mailbox by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12483) Support (legacy) SourceFunctions with mailbox by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12482) Make checkpoint trigger/notifyComplete run via the mailbox queue by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12481) Make processing time timer trigger run via the mailbox by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12480) Introduce mailbox to StreamTask main-loop by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12479) Make InputProcessors and StreamIterationHead non-blocking by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12478) Decompose monolithic run-loops in StreamTask implementations into step-wise calls by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12477) Change threading-model in StreamTask to a mailbox-based approach by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[VOTE] FLIP-36 Interactive Programming for the Table API by Stephan Ewen

by Stephan Ewen

[DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API by Becket Qin

by Stephan Ewen

[jira] [Created] (FLINK-12476) [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12475) CommonTestUtils#printLog4jDebugConfig() should include timestamp by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12474) UnionInputGate should be notified when closing SingleInputGate by canceler thread by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12473) Add ML pipeline and ML lib Core API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12472) Support setting attemptFailuresValidityInterval of jobs on Yarn by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12471) Fix broken links in documentation to make CRON travis job work by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12470) FLIP39: Flink ML pipeline and ML libs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12469) Clean up catalog API on default/current DB by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12468) Unregister application from the YARN Resource Manager with a valid appTrackingUrl by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12467) DataStreamAllroundTestProgram should define pause between checkpoints by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12466) Containerized e2e tests fail on Java 9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12465) MetricsAvailabilityITCase fails on Java 9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12464) Kinesis e2e test fails on Java 9 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12463) Deduplicate empty .out log file checks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12462) Classloading fails in 1.8.0 when Scalatest is loaded first by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12461) 1.8 not working with Scala 2.12.8 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12460) Change taskmanager.tmp.dirs to io.tmp.dirs in configuration docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Apply for contributor permission by Rui Li

by Fabian Hueske-2

[jira] [Created] (FLINK-12459) YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should affect the order of classpath between user jars and flink jar by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12458) Throw PartitionNotFoundException if consumer can not establish a connection to remote TM by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12457) Remove char support in blink by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12456) Wrong CharType convertion in type_utils.py by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12455) Move the package of pyflink to flink-dist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12454) Add custom check options for lint-python.sh by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-12453) StreamExecGlobalGroupAggregate construct wrong args for AggsHandlerCodeGenerator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 363364365366367368369 ... 784