Apache Flink Mailing List archive.

This forum is an archive for the mailing list dev@flink.apache.org (more options) Messages posted here will be sent to this mailing list.
This is a public archive of the Flink mailing mailing list.

More about the different Flink mailing lists: http://flink.apache.org/community.html#community
123456 ... 293
Topics (10234)
Replies Last Post Views
[jira] [Created] (FLINK-8713) FileInputFormatTest.testGetStatisticsMultipleOneFileWithCachedVersion unstable on Travis by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8711) Flink with YARN use wrong SlotsPerTaskManager by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8710) AbstractYarnClusterDescriptor doesn't use pre-defined configs in Hadoop's YarnConfiguration by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8709) Flaky test: SlotPoolRpcTest.testCancelSlotAllocationWithoutResourceManager by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8708) Unintended integer division in StandaloneThreadedGenerator by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8707) Excessive amount of files opened by flink task manager by JIRA jira@apache.org
0
by JIRA jira@apache.org
Flink 1.3.2 -- mvn clean package -Pbuild-jar command takes to much time by Melekh, Gregory
2
by Melekh, Gregory
[jira] [Created] (FLINK-8706) Supported Data Types - Six or Seven by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8705) Integrate Remote(Stream)Environment with Flip-6 cluster by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8704) Migrate tests from TestingCluster to MiniClusterResource by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8703) Migrate tests from LocalFlinkMiniCluster to MiniClusterResource by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8702) Migrate tests from FlinkMiniCluster to MiniClusterResource by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8701) Migrate SavepointMigrationTestBase to MiniClusterResource by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8700) Port tests from FlinkMiniCluster to MiniClusterResource by JIRA jira@apache.org
0
by JIRA jira@apache.org
[VOTE] Release flink-shaded 3.0, release candidate #1 by Chesnay Schepler-3
3
by Chesnay Schepler-3
[jira] [Created] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8698) Use Flip-6 MiniCluster in Local(Stream)Environment by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8697) Rename DummyFlinkKafkaConsumer in Kinesis tests by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8696) Remove JobManager local mode from the Unix Shell Scripts by JIRA jira@apache.org
0
by JIRA jira@apache.org
[ANNOUNCE] Apache Flink 1.4.1 released by Tzu-Li (Gordon) Tai
5
by Stephan Ewen
Reading a single input file in parallel? by Niels Basjes
2
by Fabian Hueske-2
[jira] [Created] (FLINK-8695) Move RocksDB State Backend from 'flink-contrib' to 'flink-state-backends' by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8694) Make notifyDataAvailable call reliable by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8693) initPythonInterpreter is called twice with same arguments in InterpreterUtils#initAndExecPythonScript by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8692) Mistake in MyMapFunction code snippet by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8691) Update table API to support distinct operator on data stream by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct operator by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8689) Add runtime support of distinct filter using MapView for GenerateAggregation by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8688) Enable distinct aggregation for data stream on Table/SQL API by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8686) Improve basic embedded SQL client by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8685) Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStreamCalcRule$3069" grows beyond 64 KB by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8684) Rework MesosTaskManagerParameters#MESOS_RM_TASKS_SLOTS by JIRA jira@apache.org
0
by JIRA jira@apache.org
[jira] [Created] (FLINK-8683) Add test for configuration docs completeness by JIRA jira@apache.org
0
by JIRA jira@apache.org
123456 ... 293