dev@flink.apache.org, 2020-04

You are viewing a plain text version of this content. The canonical link for it is here.

- [DISCUSS] Change default planner to blink planner in 1.11 - posted by Kurt Young <yk...@gmail.com> on 2020/04/01 01:15:17 UTC, 10 replies.
- Re: [VOTE] FLIP-113: Supports Dynamic Table Options for Flink SQL - posted by Jingsong Li <ji...@gmail.com> on 2020/04/01 02:37:43 UTC, 7 replies.
- Re: [VOTE] Apache Flink Stateful Functions Release 2.0.0, release candidate #4 - posted by Yu Li <ca...@gmail.com> on 2020/04/01 02:47:02 UTC, 9 replies.
- [DISCUSS] FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame - posted by Dian Fu <di...@gmail.com> on 2020/04/01 02:49:42 UTC, 6 replies.
- Re: [DISCUSS] FLIP-118: Improve Flink’s ID system - posted by Zhu Zhu <re...@gmail.com> on 2020/04/01 03:52:28 UTC, 7 replies.
- [jira] [Created] (FLINK-16903) Add sink.parallelism for file system factory - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/01 04:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16904) Migrate FileSystem descriptor to new table factory - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/01 05:56:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-84 Feedback Summary - posted by godfrey he <go...@gmail.com> on 2020/04/01 07:31:32 UTC, 16 replies.
- [jira] [Created] (FLINK-16905) Add fromValues in Python API - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/01 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16906) TPC-DS end-to-end test (Blink planner) failed after 80 minutes - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/01 08:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method: - posted by "辛羿彤 (Jira)" <ji...@apache.org> on 2020/04/01 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16909) fix doc : The default value for params for HBase Connector - posted by "gkgkgk (Jira)" <ji...@apache.org> on 2020/04/01 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms. - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/01 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16910) The job running on agent Hosted Agent ran longer than the maximum time of 240 minutes - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/01 08:18:00 UTC, 0 replies.
- [DISCUSS] FLIP-123: DDL and DML compatibility for Hive connector - posted by Rui Li <li...@apache.org> on 2020/04/01 08:24:34 UTC, 6 replies.
- Re: [DISCUSS] FLIP-122: New Connector Property Keys for New Factory - posted by zoudan <zo...@163.com> on 2020/04/01 08:29:57 UTC, 1 replies.
- [jira] [Created] (FLINK-16911) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/01 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16912) Introduce table row write support for parquet writer - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/01 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16913) ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/01 08:51:00 UTC, 0 replies.
- [ANNOUNCE] New Committers and PMC member - posted by Stephan Ewen <se...@apache.org> on 2020/04/01 08:51:59 UTC, 37 replies.
- Re: [DISCUSS] FLIP-108: Add GPU support in Flink - posted by Stephan Ewen <se...@apache.org> on 2020/04/01 08:55:38 UTC, 1 replies.
- [VOTE] Apache Flink Stateful Functions Release 2.0.0, release candidate #5 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/04/01 09:09:43 UTC, 8 replies.
- [jira] [Created] (FLINK-16914) Support ArrayType in vectorized Python UDF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/04/01 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16915) Cannot find compatible factory for specified execution.target (=local) - posted by "Jaryzhen (Jira)" <ji...@apache.org> on 2020/04/01 09:19:00 UTC, 0 replies.
- [VOTE] FLIP-108: Add GPU support in Flink - posted by Yangze Guo <ka...@gmail.com> on 2020/04/01 09:22:39 UTC, 26 replies.
- Question about the ReadableConfigToConfigurationAdapter - posted by Canbin Zheng <fe...@gmail.com> on 2020/04/01 09:25:43 UTC, 3 replies.
- Re: [VOTE] FLIP-114: Support Python UDF in SQL Client - posted by Xingbo Huang <hx...@gmail.com> on 2020/04/01 09:35:19 UTC, 4 replies.
- [jira] [Created] (FLINK-16916) The logic of NullableSerializer#copy is wrong - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2020/04/01 09:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16917) "TPC-H end-to-end test (Blink planner)" gets stuck - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/01 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16918) flink influxdb metrics depency okio.BufferedSource.getBuffer() NoSuchMethodException - posted by "chun111111 (Jira)" <ji...@apache.org> on 2020/04/01 10:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16919) Parameter 'jobName' not used in BatchTableEnvUtil - posted by "Zhanchun Zhang (Jira)" <ji...@apache.org> on 2020/04/01 10:18:00 UTC, 0 replies.
- flink开发交流 - posted by 李朋 <11...@qq.com> on 2020/04/01 11:11:43 UTC, 0 replies.
- [jira] [Created] (FLINK-16920) Flink UI cancel uses an undocumented rest api and uses GET rather than a mutating HTTP method - posted by "John Lonergan (Jira)" <ji...@apache.org> on 2020/04/01 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16921) "kubernetes session test" is unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/01 12:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16922) Decimal.toUnscaledBytes should be consistent with BigDecimla.unscaledValue.toByteArray - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/01 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16923) DistinctAggregateITCaseBase.testSingleDistinctAggOnMultiColumnsWithGroupingSets gets stuck - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/01 12:52:00 UTC, 0 replies.
- Re: [DISCUSS]FLIP-113: Support SQL and planner hints - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/04/01 13:12:10 UTC, 17 replies.
- [jira] [Created] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2020/04/01 13:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16925) remove Custom Search Engine files from statefun docs - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/01 14:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16926) Values present at flink-conf.yaml are not respected via the StreamPlanEnvironment - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/04/01 14:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16927) Stateful Function jobs fail to restore after losing task slots using the new Flink scheduler - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/04/01 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16928) Switch back to new scheduler in Stateful Functions - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/04/01 16:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16929) Session Window produces sessions randomly - posted by "Ori Popowski (Jira)" <ji...@apache.org> on 2020/04/01 16:45:00 UTC, 0 replies.
- Configuring autolinks to Flink JIRA ticket in github repos - posted by Yun Tang <my...@LIVE.COM> on 2020/04/01 16:51:45 UTC, 10 replies.
- Re: [VOTE] FLIP-102: Add More Metrics to TaskManager - posted by Zhijiang <wa...@aliyun.com.INVALID> on 2020/04/01 17:03:04 UTC, 2 replies.
- [jira] [Created] (FLINK-16930) Drop StatefulFunctionsClusterEntryPoint - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/04/01 20:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart - posted by "Lu Niu (Jira)" <ji...@apache.org> on 2020/04/02 00:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16932) Remove unnecessary entries in the distribution jar NOTICE - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/04/02 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16933) No suitable driver found for jdbc:xxx - posted by "morgan (Jira)" <ji...@apache.org> on 2020/04/02 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16934) Change default planner to blink - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/04/02 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16935) Open or delete ignored test cases in blink planner - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/04/02 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16936) TablEnv creation and planner execution must be in the same thread - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2020/04/02 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16937) ParquetTableSource should generate correct isFilterPushedDown - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/02 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16938) SqlTimestamp has lag when convert long to Timestamp - posted by "YufeiLiu (Jira)" <ji...@apache.org> on 2020/04/02 07:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16939) TaskManagerMessageParameters#taskManagerIdParameter is not declared final - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/02 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16940) Avoid creating currentRegion HashSet with manually set initialCapacity - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/02 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16941) Bump netty 4.X to 4.1.44+ - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/02 08:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16942) ES 5 sink should allows users to select netty transport client - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/02 09:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-16943) Support adding jars in PyFlink - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/04/02 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16944) Compile error in. DumpCompiledPlanTest and PreviewPlanDumpTest - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/02 09:21:00 UTC, 0 replies.
- Re: [VOTE] FLIP-95: New TableSource and TableSink interfaces - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/04/02 10:28:31 UTC, 6 replies.
- [jira] [Created] (FLINK-16945) Execute CheckpointFailureManager.FailJobCallback directly in main thread executor - posted by "Biao Liu (Jira)" <ji...@apache.org> on 2020/04/02 12:11:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-111: Docker image unification - posted by Patrick Lucas <pa...@ververica.com> on 2020/04/02 14:34:06 UTC, 12 replies.
- [jira] [Created] (FLINK-16946) Update user documentation for job manager memory model - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/02 14:58:00 UTC, 0 replies.
- Re: [VOTE] FLIP-119: Pipelined Region Scheduling - posted by Till Rohrmann <tr...@apache.org> on 2020/04/02 15:02:56 UTC, 6 replies.
- [VOTE] FLIP-122: New Connector Property Keys for New Factory - posted by Jark Wu <im...@gmail.com> on 2020/04/02 15:22:48 UTC, 8 replies.
- [jira] [Created] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this poo - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/02 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16948) Change docs to better highlight embedded vs remote module configurations - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/04/02 16:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16949) Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/04/02 18:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16950) Kafka console consumer displays uncommitted records. - posted by "Igal Shilman (Jira)" <ji...@apache.org> on 2020/04/02 19:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16951) Integrate parquet to file system connector - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/03 02:37:00 UTC, 0 replies.
- [VOTE] Apache Flink Stateful Functions Release 2.0.0, release candidate #6 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/04/03 03:48:20 UTC, 11 replies.
- [jira] [Created] (FLINK-16952) Parquet file system format support filter pushdown - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/03 05:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16953) TableEnvHiveConnectorTest is unstable on travis. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/04/03 05:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16954) 1.9 branch was not compile - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16955) Bump Zookeeper to 3.4.14 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 07:02:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL - posted by Zhenghua Gao <do...@gmail.com> on 2020/04/03 07:04:09 UTC, 12 replies.
- [jira] [Created] (FLINK-16956) Git fetch failed with exit code 128 - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/03 07:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16957) Bump Hive to 1.2.2 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16958) Bump Hive 2.0.X to 2.0.1 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16959) 'Walkthrough Table Java nightly end-to-end test' [FAIL] Test script contains errors - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/03 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16960) Add PipelinedRegion Interface to Topology - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/03 07:50:00 UTC, 0 replies.
- [PSA] Please report all occurrences of test failures - posted by Aljoscha Krettek <al...@apache.org> on 2020/04/03 07:57:46 UTC, 1 replies.
- [jira] [Created] (FLINK-16961) Bump Netty 4 to 4.1.44 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 08:43:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-95: New TableSource and TableSink interfaces - posted by Timo Walther <tw...@apache.org> on 2020/04/03 08:59:51 UTC, 0 replies.
- [jira] [Created] (FLINK-16962) Convert DatadogReporter to plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16964) Convert Dropwizard reporter to plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16963) Convert all MetricReporters to plugins - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16965) Convert Graphite reporter to plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16967) Convert Slf4j reporter to plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16966) Convert InfluxDB reporter to plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 09:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16968) Conver StatsD reporter to plugin - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16969) Unable to use case class in flink scala shell - posted by "Jeff Zhang (Jira)" <ji...@apache.org> on 2020/04/03 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16970) Bundle JMXReporter separately form dist jar - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/03 09:52:00 UTC, 0 replies.
- Re: [VOTE] FLIP-110: Support LIKE clause in CREATE TABLE - posted by Aljoscha Krettek <al...@apache.org> on 2020/04/03 09:53:14 UTC, 0 replies.
- [RESULT][VOTE] FLIP-114: Support Python UDF in SQL Client - posted by Wei Zhong <we...@gmail.com> on 2020/04/03 11:25:27 UTC, 0 replies.
- [jira] [Created] (FLINK-16971) Support Python UDF in SQL Client (FLIP-114) - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/04/03 11:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16972) Fix non-blocking output availability logic. - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/04/03 11:55:00 UTC, 0 replies.
- Re: [DISCUSS] Releasing Flink 1.10.1 - posted by Yu Li <ca...@gmail.com> on 2020/04/03 12:42:59 UTC, 11 replies.
- Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment & Table - posted by godfrey he <go...@gmail.com> on 2020/04/03 13:07:26 UTC, 8 replies.
- [jira] [Created] (FLINK-16973) Various builds failing with "Corrupted STDOUT by directly writing" - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/03 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16974) Azure build failed with OutOfMemoryError: unable to create new native thread - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/03 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16975) Add docs for FileSystem connector and hive connector - posted by "Leonard Xu (Jira)" <ji...@apache.org> on 2020/04/03 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16976) Update chinese documentation for ListCheckpointed deprecation - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/04/03 16:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16977) Add Architecture docs for Stateful Functions - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/04/03 16:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16978) Update flink-statefun README.md for Stateful Functions 2.0. - posted by "Marta Paes Moreira (Jira)" <ji...@apache.org> on 2020/04/03 17:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16979) flink-sql-connector-hive-1.2.2_2.11 doesn't compile on JDK11 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/04 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16980) PyFlink UDF execution module is not compatible with protobuf 3.6.1 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/04 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16981) flink-runtime tests are crashing the JVM on Java11 - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/04 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16982) scala-maven-plugin JVM runs out of memory in flink-runtime - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/04 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16983) Support RowType in vectorized Python UDF - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/04/04 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16984) Consolidate test Log4j properties files - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/04 16:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16985) Specify job names for Stateful Functions examples - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/04/05 00:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16986) Enhance the OperatorEvent handling guarantee during checkpointing. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/04/05 02:00:10 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/14 - posted by Konstantin Knauf <ko...@ververica.com> on 2020/04/05 21:16:59 UTC, 0 replies.
- [jira] [Created] (FLINK-16987) Add new table source and sink interfaces - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16988) Add core table source/sink interfaces - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16989) Support ScanTableSource in planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16990) Support LookupTableSource in planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 07:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16991) Support DynamicTableSink in planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 07:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16992) Add ability interfaces for table source/sink - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 07:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16993) Support SupportsComputedColumnPushDown in planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16994) Support SupportsWatermarkPushDown in planner - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16995) Add new data structure interfaces in table-common - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16996) Refactor planner and connectors to use new data structures - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16997) Add new factory interfaces and utilities - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16998) Add a changeflag to Row type - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-16999) Data structure should cover all conversions declared in logical types - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 08:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17000) Type information in sources should cover all data structures - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/06 08:30:00 UTC, 0 replies.
- [DISCUSS] FLIP-124: Add open/close and Collector to (De)SerializationSchema - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/04/06 09:08:37 UTC, 14 replies.
- [RESULT][VOTE] FLIP-110: Support LIKE clause in CREATE TABLE - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/04/06 09:13:12 UTC, 0 replies.
- [jira] [Created] (FLINK-17001) Support LIKE clause in CREATE TABLE - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/06 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17002) Support creating tables using other tables definition - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/06 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17003) Support parsing LIKE clause in CREATE TABLE statement - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/06 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17004) Document the CREATE TABLE ... LIKE syntax in english - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/06 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17005) Translate the CREATE TABLE ... LIKE syntax documentation to chinese - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/06 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17006) AggregateITCase.testDistinctGroupBy fails with FileNotFoundException (in Rocksdb) - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/06 09:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17007) Add section "How to handle application parameters" in DataStream documentation - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2020/04/06 09:53:01 UTC, 0 replies.
- [DISCUSS] Consolidated log4j2-properties file - posted by Chesnay Schepler <ch...@apache.org> on 2020/04/06 10:24:25 UTC, 6 replies.
- [jira] [Created] (FLINK-17008) Handle null value for HADOOP_CONF_DIR/HADOOP_HOME env in AbstractKubernetesParameters#getLocalHadoopConfigurationDirectory - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/06 12:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17009) Fold API-agnostic documentation into DataStream documentation - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/04/06 14:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17010) Streaming File Sink s3 end-to-end test fails with "Output hash mismatch" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/06 15:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17011) Introduce builder to create AbstractStreamOperatorTestHarness for testing - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/04/06 17:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17012) Expose cost of task initialization - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/04/07 02:17:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-105: Support to Interpret and Emit Changelog in Flink SQL - posted by Jark Wu <im...@gmail.com> on 2020/04/07 03:49:20 UTC, 3 replies.
- Re: [DISCUSS] FLIP-121: Support Cython Optimizing Python User Defined Function - posted by Robert Metzger <rm...@apache.org> on 2020/04/07 04:38:25 UTC, 4 replies.
- [jira] [Created] (FLINK-17013) Support Python UDTF in old planner under batch mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/07 05:10:00 UTC, 0 replies.
- [RESULT] [VOTE] Apache Flink Stateful Functions Release 2.0.0, release candidate #6 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/04/07 05:29:21 UTC, 0 replies.
- [jira] [Created] (FLINK-17014) Implement PipelinedRegionSchedulingStrategy - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/07 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17015) Fix NPE from NullAwareMapIterator - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/07 06:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17016) Use PipelinedRegionSchedulingStrategy in DefaultScheduler (for Blink Planner) - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/07 06:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17017) Implement Bulk Slot Allocation in SchedulerImpl - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/07 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17018) Use Bulk Slot Allocation in DefaultExecutionSlotAllocator - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/07 06:31:00 UTC, 0 replies.
- [ANNOUNCE] New Flink committer: Seth Wiesman - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/04/07 06:32:47 UTC, 19 replies.
- [jira] [Created] (FLINK-17019) Implement FIFO Physical Slot Assignment in SlotPoolImpl - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/07 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17020) Introduce GlobalDataExchangeMode for JobGraph Generation - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/07 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17021) Blink Planner set GlobalDataExchangeMode - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/07 06:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17022) Flink SQL ROW_NUMBER() Exception: TableException: This calc has no useful projection and no filter. It should be removed by CalcRemoveRule. - posted by "xingoo (Jira)" <ji...@apache.org> on 2020/04/07 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17023) The format checking of extractExecutionParams in config.sh is incorrect - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/04/07 06:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17024) Make RpcEndpoint#getRpcService#getExecutor return a custom thread pool - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/04/07 07:03:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-122: New Connector Property Keys for New Factory - posted by Jark Wu <im...@gmail.com> on 2020/04/07 07:06:23 UTC, 0 replies.
- [jira] [Created] (FLINK-17025) Introduce new set of connectors using new property keys and new factory interface - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/07 07:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17026) Introduce a new Kafka connector with new property keys - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/07 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17027) Introduce a new Elasticsearch connector with new property keys - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/07 07:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17028) Introduce a new HBase connector with new property keys - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/07 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17029) Introduce a new JDBC connector with new property keys - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/07 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17030) Add primary key syntax to DDL - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/07 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17031) HiveTableSourceTest fails with: "Timeout waiting for HMS to start" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/07 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17032) Naming convention unification for all the Kubernetes Resources - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/07 08:43:00 UTC, 0 replies.
- [VOTE] FLIP-111: Docker image unification - posted by Andrey Zagrebin <az...@apache.org> on 2020/04/07 09:28:44 UTC, 7 replies.
- [jira] [Created] (FLINK-17033) Upgrade OpenJDK docker image for Kubernetes - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/07 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17034) Execute the container CMD under TINI for better hygiene - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/07 09:45:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 2.0.0 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/04/07 12:58:22 UTC, 6 replies.
- [jira] [Created] (FLINK-17035) Replace FailoverTopology with SchedulingTopology - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/07 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17036) Datadog forwarder does not allow for EU endpoint - posted by "Raymond Farrelly (Jira)" <ji...@apache.org> on 2020/04/07 15:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17037) add e2e tests for reading array data types from postgres with JDBCTableSource and PostgresCatalog - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/04/07 21:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17038) Decouple resolving Type and creating TypeInformation process - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/04/08 01:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17039) Introduce TypeInformationExtractor interface - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/04/08 01:50:00 UTC, 0 replies.
- [VOTE] FLIP-121: Support Cython Optimizing Python User Defined Function - posted by Xingbo Huang <hx...@gmail.com> on 2020/04/08 01:53:03 UTC, 4 replies.
- [jira] [Created] (FLINK-17040) SavepointWriterITCase broken - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/04/08 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17041) Migrate current TypeInformation creation to the TypeInformationExtractor framework - posted by "Guowei Ma (Jira)" <ji...@apache.org> on 2020/04/08 02:01:00 UTC, 0 replies.
- [VOTE] FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame - posted by Dian Fu <di...@gmail.com> on 2020/04/08 02:02:55 UTC, 6 replies.
- [jira] [Created] (FLINK-17042) Jackson version conflict for Flink 1.9 - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/04/08 02:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17043) Putting more information into accounting when failing a job in FailureManager - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2020/04/08 03:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17044) FLIP-108: Add GPU support in Flink - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/04/08 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17045) If multiple views are based on tables not defined in the yaml config file, dropping one of the views will throw exception - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/04/08 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17046) SavepointWriterITCase failed on travis - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/08 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17047) Simplify SchedulingStrategy#onPartitionConsumable(...) parameters - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/08 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17048) Add memory related JVM args to Mesos JM startup scripts - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/08 10:28:00 UTC, 0 replies.
- [PSA] Please check your github email configuration when merging on Github - posted by Aljoscha Krettek <al...@apache.org> on 2020/04/08 11:48:49 UTC, 0 replies.
- [jira] [Created] (FLINK-17049) Support implicit conversions in nested rows - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/08 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17050) Remove methods getVertex() and getResultPartition() from SchedulingTopology - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/08 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17051) Persist spilled records of SpillingAdaptiveSpanningRecordDeserializer - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/08 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17052) Introduce PlanGenerator - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/04/08 13:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17053) RecordWriterTest.testClearBuffersAfterInterruptDuringBlockingBufferRequest fails - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/08 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17054) TaskMailboxProcessorTest.testIdleTime() unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/08 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/08 14:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17056) JMH main() methods call unrelated benchmarks - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/04/08 16:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17057) Add OpenSSL micro-benchmarks - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/04/08 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17058) Adding TimeoutTrigger support nested triggers - posted by "Roey Shem Tov (Jira)" <ji...@apache.org> on 2020/04/08 20:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17059) flink-shaded-hadoop-2-uber:2.8.3-10.0 has invalid pom in Gradle - posted by "John Lonergan (Jira)" <ji...@apache.org> on 2020/04/08 20:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17060) "{flink}" isn't being replaced by the Apache Flink trademark in Stateful Functions docs - posted by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/04/09 00:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17061) Unset process/flink memory size from configuration once dynamic worker resource is activated. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/04/09 02:37:00 UTC, 0 replies.
- [DISCUSS] Creating a new repo to host Flink benchmarks - posted by Yun Tang <my...@LIVE.COM> on 2020/04/09 06:56:38 UTC, 12 replies.
- [jira] [Created] (FLINK-17062) Fix the conversion from Java row type to Python row type - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/04/09 07:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17063) Make null typ be a possible result of a type inference - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/09 07:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17064) Improve ExpressionConverter - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/09 07:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17065) Adds notes of Python versions supported by PyFlink in doc - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/09 08:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17066) Limits the PyArrow version to 0.13 - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/09 08:27:00 UTC, 0 replies.
- [DISCUSS] Generating java code? - posted by Niels Basjes <Ni...@basjes.nl> on 2020/04/09 08:47:14 UTC, 9 replies.
- contributor apply - posted by zhangzhanhua <zh...@163.com> on 2020/04/09 09:03:30 UTC, 1 replies.
- [jira] [Created] (FLINK-17067) CatalogManager#createTable and createTemporaryTable should provide consistent semantics - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2020/04/09 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17068) ERROR at teardown of TableConfigTests.test_get_set_decimal_context - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/09 09:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17069) DefaultClusterClientServiceLoader should provide more information in case of missing dependencies - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/09 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17070) Kubernetes session CLI ignores stop/help command in detached mode - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/09 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17071) Kubernetes session CLI logging output is either misleading or concerning - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/09 12:40:00 UTC, 0 replies.
- [VOTE] FLIP-71: E2E View support in Flink SQL - posted by Zhenghua Gao <do...@gmail.com> on 2020/04/09 12:46:17 UTC, 8 replies.
- [jira] [Created] (FLINK-17072) Let Dispatcher and ResourceManager pick random endpoint id - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/04/09 14:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17073) Slow checkpoint cleanup causing OOMs - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/04/09 14:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/04/09 15:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17075) Add task status reconciliation between TM and JM - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/04/09 16:52:00 UTC, 0 replies.
- [PROPOSAL] Contribute training materials to Apache Flink - posted by David Anderson <da...@ververica.com> on 2020/04/09 18:09:45 UTC, 8 replies.
- [jira] [Created] (FLINK-17076) Revamp Kafka Connector Documentation - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/04/09 22:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container - posted by "Eui Heo (Jira)" <ji...@apache.org> on 2020/04/10 00:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17078) Logging output is misleading when executing bin/flink -e kubernetes-session without specifying cluster-id - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/10 02:53:00 UTC, 0 replies.
- [DISCUSS] Releasing Flink 1.9.3 - posted by Dian Fu <di...@gmail.com> on 2020/04/10 03:08:41 UTC, 9 replies.
- [jira] [Created] (FLINK-17079) CsvTableSinkFactoryBase add numFiles and writeMode config when createTableSink - posted by "sulei (Jira)" <ji...@apache.org> on 2020/04/10 06:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17080) Utils.CollectHelper is possible to throw NPE if the sink is up but not initialized when the job fails - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/04/10 07:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17081) Batch test classes in Blink planner does not extend TestLogger - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/04/10 07:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17082) Remove mocking from SQL client tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/10 08:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17083) Restrict users of accumulators not to return null in Accumulator#getLocalValue - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/04/10 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17084) Implement type inference for ROW/ARRAY/MAP constructors - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/10 09:15:00 UTC, 0 replies.
- Javadocs Broken? - posted by tison <wa...@gmail.com> on 2020/04/10 09:27:28 UTC, 2 replies.
- [jira] [Created] (FLINK-17085) Remove FlinkKubeClient#handleException since it does not do anything - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/04/10 09:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17086) Flink sql client not able to read parquet hive table because `HiveMapredSplitReader` not supports name mapping reading for parquet format. - posted by "Lei Wang (Jira)" <ji...@apache.org> on 2020/04/10 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17087) Use constant port for rest.port when it's set as 0 on Kubernetes - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/10 13:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17088) Search TaskManager log content based on keywords function - posted by "pingle wang (Jira)" <ji...@apache.org> on 2020/04/10 17:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading - posted by "Lu Niu (Jira)" <ji...@apache.org> on 2020/04/10 19:22:00 UTC, 0 replies.
- [VOTE] FLIP-105: Support to Interpret and Emit Changelog in Flink SQL - posted by Jark Wu <im...@gmail.com> on 2020/04/11 03:31:04 UTC, 5 replies.
- [jira] [Created] (FLINK-17090) Harden preckeck for the KubernetesConfigOptions.JOB_MANAGER_CPU - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/11 05:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17091) AvroRowSerializationSchema doesn't support new Timestamp conversion classes - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2020/04/11 05:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/04/11 17:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17093) Python UDF doesn't work when the input column is of composite type - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/04/12 06:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17094) OverWindowITCase#testRowTimeBoundedPartitionedRowsOver failed by FileNotFoundException - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/04/12 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17095) KafkaProducerExactlyOnceITCase fails with "address already in use" - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/04/12 15:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17096) Minibatch Group Agg support state ttl - posted by "dalongliu (Jira)" <ji...@apache.org> on 2020/04/13 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17097) Flink HBase Connector String field size at least equal 8 - posted by "xingoo (Jira)" <ji...@apache.org> on 2020/04/13 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17098) CatalogManager#dropTemporaryTable and dropTemporaryView should use ObjectIdentifier as its argument - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2020/04/13 03:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17099) Refactoring State TTL solution in Group Agg、TopN operator, etc replace Timer with StateTtlConfig - posted by "dalongliu (Jira)" <ji...@apache.org> on 2020/04/13 03:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17100) Document Native Kubernetes Improvements - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/13 03:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17101) Supports dynamic table options for Flink SQL - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/04/13 03:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17102) Add -Dkubernetes.container.image= for the start-flink-session section - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/13 03:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17103) Supports dynamic table options for Blink planner - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/04/13 03:43:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-113: Support dynamic table options for Flink SQL - posted by Danny Chan <yu...@gmail.com> on 2020/04/13 03:48:06 UTC, 0 replies.
- [jira] [Created] (FLINK-17104) Support registering custom JobStatusListeners from config - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/13 04:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17105) FLIP-71: E2E viewsupport - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2020/04/13 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17106) Support create/drop view in Flink SQL - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2020/04/13 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17107) CheckpointCoordinatorConfiguration#isExactlyOnce() is inconsistent with StreamConfig#getCheckpointMode() - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/04/13 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17108) Exception: Cannot determine simple type name "com" - posted by "xiemeilong (Jira)" <ji...@apache.org> on 2020/04/13 06:45:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame - posted by Dian Fu <di...@gmail.com> on 2020/04/13 06:53:55 UTC, 0 replies.
- [jira] [Created] (FLINK-17109) FlinkPipelineTranslationUtil#getJobGraph doesn't consider Jars and Classpaths in configuration. - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/04/13 07:19:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-121: Support Cython Optimizing Python User Defined Function - posted by Xingbo Huang <hx...@gmail.com> on 2020/04/13 07:26:36 UTC, 0 replies.
- [jira] [Created] (FLINK-17110) Make StreamExecutionEnvironment#configure also affects configuration - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/04/13 07:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17111) Support SHOW VIEWS in Flink SQL - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2020/04/13 07:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17112) Support DESCRIBE VIEW view_name in Flink SQL - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2020/04/13 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17113) Refactor view support in SQL Client - posted by "Zhenghua Gao (Jira)" <ji...@apache.org> on 2020/04/13 07:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17114) When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/04/13 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17115) Support Cython Optimizing Python User Defined Function(FLIP-121) - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/13 08:11:00 UTC, 0 replies.
- apply contributor - posted by 郭牧桦 <18...@163.com> on 2020/04/13 09:33:11 UTC, 1 replies.
- [jira] [Created] (FLINK-17116) support UsernamePasswordCredentials for elasticsearch sink via SQL DDL - posted by "Kai Chen (Jira)" <ji...@apache.org> on 2020/04/13 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17117) There are an useless cast operation for sql on blink when generate code - posted by "hehuiyuan (Jira)" <ji...@apache.org> on 2020/04/13 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17118) Support Primitive DataTypes in Cython - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/13 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17119) Support Composite DataTypes in Cython - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/13 11:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17120) Support Cython Optimizing Python Operations - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/13 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17121) Adds Pipeline of Building Wheel Packages in Azure CI - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/13 12:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17122) Support InputSelectable and BoundedMultiInput operators with checkpointing - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/13 12:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17123) flink-sql-connector-elasticsearch版本与 es 版本不对应 - posted by "longxibendi (Jira)" <ji...@apache.org> on 2020/04/13 12:37:00 UTC, 0 replies.
- [VOTE] FLIP-123: DDL and DML compatibility for Hive connector - posted by Rui Li <li...@apache.org> on 2020/04/13 13:26:45 UTC, 5 replies.
- [jira] [Created] (FLINK-17124) The PyFlink Job runs into infinite loop if the UDF file imports job code. - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/13 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17125) Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/14 02:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17126) Correct the execution behavior of BatchTableEnvironment - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/04/14 04:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17127) Make pod creating retry interval configurable - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/04/14 05:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17128) Add isBounded to TableSinkFactory#Context - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/14 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17129) 【Flink Kafka Connector】The DDL config(connector.properties.zookeeper.connect) could be optioanal - posted by "zhisheng (Jira)" <ji...@apache.org> on 2020/04/14 06:40:00 UTC, 0 replies.
- flink-orc or flink-orc-nohive - posted by Sivaprasanna <si...@gmail.com> on 2020/04/14 07:36:38 UTC, 4 replies.
- [jira] [Created] (FLINK-17130) Web UI: Enable listing JM Logs and displaying Logs by Filename - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2020/04/14 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17131) Javadocs broken for master - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/14 09:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17132) Use the latest version of simpleclient_pushgateway to solve the "Failed to push metrics to PushGateway" problem - posted by "MING LIU (Jira)" <ji...@apache.org> on 2020/04/14 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17133) Support CsvParser Features for CSV format via SQL DDL - posted by "Kai Chen (Jira)" <ji...@apache.org> on 2020/04/14 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17134) Wrong logging information in Kafka010PartitionDiscoverer#L80 - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/04/14 10:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed on master - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/04/14 11:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17136) Rename toplevel DataSet/DataStream section titles - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/04/14 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17137) Support mini batch for WindowOperator in blink planner - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/04/14 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17138) LocalExecutorITCase.testParameterizedTypes failed on travis - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/14 13:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17139) The sub-plan reuse optimizer can't reuse sub-plan that from different sql node tree - posted by "jinfeng (Jira)" <ji...@apache.org> on 2020/04/14 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17140) AsyncLookupJoinITCase.testAsyncJoinTemporalTableOnMultiFieldsWithUdf failed on Azure - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/04/14 14:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17141) Name of SQL Operator is too long - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/04/14 15:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17142) Bump ORC version - posted by "Sivaprasanna Sethuraman (Jira)" <ji...@apache.org> on 2020/04/14 15:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17143) Blog feed.xml should only contain excerpts, not full contents - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/04/14 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17144) Input type generalization does not work correctly for ARRAY and MAP in sql - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/14 16:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17145) AggregateRemoveITCase.testAggregateRemove failed in travis - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/15 02:17:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-105: Support to Interpret and Emit Changelog in Flink SQL - posted by Jark Wu <im...@gmail.com> on 2020/04/15 03:17:30 UTC, 0 replies.
- [jira] [Created] (FLINK-17146) Support conversion between PyFlink Table and Pandas DataFrame - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/04/15 03:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17147) Remove dynamic table options from table source table digest - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/04/15 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17148) Support converting pandas dataframe to flink table - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/04/15 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17149) Introduce Debezium format to support reading debezium changelogs - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/15 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17150) Introduce Canal format to support reading canal changelogs - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/15 03:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17151) Align Calcite's and Flink's SYMBOL types - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/15 06:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17152) FunctionDefinitionUtil generate wrong resultType and acc type of AggregateFunctionDefinition - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2020/04/15 07:22:00 UTC, 0 replies.
- [DISCUSS] Releasing "fat" and "slim" Flink distributions - posted by Aljoscha Krettek <al...@apache.org> on 2020/04/15 07:30:45 UTC, 27 replies.
- Flink On Yarn , ResourceManager is HA , if active ResourceManager changed，what is flink task status ? - posted by LakeShen <sh...@gmail.com> on 2020/04/15 07:39:26 UTC, 1 replies.
- [jira] [Created] (FLINK-17153) flink sql convert constant to char type cause loop - posted by "xiaodao (Jira)" <ji...@apache.org> on 2020/04/15 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17154) Make ResourceManager#internalDeregisterApplication and implementation asynchronous - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/04/15 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17155) flink in memory catalog can not support hive udf - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/04/15 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17156) Add checkpoint cancellation to Unaligner - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/04/15 09:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17157) TaskMailboxProcessorTest.testIdleTime failed on travis - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/15 09:28:00 UTC, 0 replies.
- [PROPOSAL] Google Season of Docs 2020. - posted by Marta Paes Moreira <ma...@ververica.com> on 2020/04/15 10:11:21 UTC, 9 replies.
- [jira] [Created] (FLINK-17158) Watermark strategy property cannot be expressed in YAML - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/15 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/15 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17160) FLIP-111: Docker image unification - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/15 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17161) Document the official docker hub image and examples of how to run - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/15 12:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17162) Document examples of how to extend the official docker hub image - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/15 12:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17164) Extend entry point script and docs with job cluster mode and user job artefacts - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/15 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17163) Remove flink-contrib/docker-flink - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/15 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17165) Remove flink-container/docker - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/15 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17166) Modify the log4j-console.properties to also output logs into the files for WebUI - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/15 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17167) Extend entry point script and docs with history server mode - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/15 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17168) TPC-DS end-to-end test failed on travis due to failed to download data generator - posted by "Yu Li (Jira)" <ji...@apache.org> on 2020/04/15 13:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17169) Refactor BaseRow to use RowKind instead of byte header - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/15 14:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer - posted by "Vasii Cosmin Radu (Jira)" <ji...@apache.org> on 2020/04/15 15:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17171) Blink planner fails to compile Table program with POJO source - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/04/15 17:09:00 UTC, 0 replies.
- [DISCUSS] Integration of training materials into Apache Flink - posted by David Anderson <da...@ververica.com> on 2020/04/15 18:53:53 UTC, 11 replies.
- [jira] [Created] (FLINK-17172) Re-enable debug level logging in Jepsen Tests - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/15 19:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per query in SQL - posted by "Danny Chen (Jira)" <ji...@apache.org> on 2020/04/16 02:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17174) Conversion to relational algebra failed to preserve datatypes when using Table API but succeed when using SQL query - posted by "Yiwen Tu (Jira)" <ji...@apache.org> on 2020/04/16 05:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17175) StringUtils.arrayToString() should consider Object[] lastly - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/04/16 05:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17176) Slow down Pod recreation in KubernetesResourceManager#PodCallbackHandler - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/16 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17177) Handle Pod ERROR event correctly in KubernetesResourceManager#onError - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/16 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17178) Provide "ALL" cache strategy in LookupFunction - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2020/04/16 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17179) Set row time attribute not working in connector descriptor - posted by "Yiwen Tu (Jira)" <ji...@apache.org> on 2020/04/16 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17180) Implement PipelinedRegion interface for SchedulingTopology - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/16 06:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17181) Simplify generic Types in Topology Interface - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/16 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17182) RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/16 07:10:00 UTC, 0 replies.
- [VOTE] FLIP-124: Add open/close and Collector to (De)SerializationSchema - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/04/16 07:54:50 UTC, 4 replies.
- [VOTE] FLIP-118: Improve Flink’s ID system - posted by Yangze Guo <ka...@gmail.com> on 2020/04/16 08:51:09 UTC, 4 replies.
- [jira] [Created] (FLINK-17183) the 'create table [if not exists]' syntax is not supported - posted by "muzimusi (Jira)" <ji...@apache.org> on 2020/04/16 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17184) sink_ddl source_ddl query_sql webui没有指标数据 - posted by "zck (Jira)" <ji...@apache.org> on 2020/04/16 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17185) blink执行计划，自定义函数解析 array，参数为空元素 - posted by "zck (Jira)" <ji...@apache.org> on 2020/04/16 11:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17186) set eventtime from source with timestampsFromField funcation at flink 1.10 error - posted by "jiefeng zheng (Jira)" <ji...@apache.org> on 2020/04/16 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17187) Streamline setting of config options - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/16 11:32:00 UTC, 0 replies.
- [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL - posted by Konstantin Knauf <kn...@apache.org> on 2020/04/16 12:16:17 UTC, 9 replies.
- [jira] [Created] (FLINK-17188) Failed to download conda when running python tests - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/16 12:24:01 UTC, 0 replies.
- [jira] [Created] (FLINK-17189) Table with processing time attribute can not be read from Hive catalog - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/16 12:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17190) SQL client does not support views that reference a table from DDL - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/16 12:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17191) CREATE TABLE does not support interval types - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/16 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17192) java.lang.RuntimeException: Error obtaining the sorted input: Thread 'SortMerger Reading Thread' terminated due to an exception: The record exceeds the maximum size of a sort buffer (current maximum: 72351744 bytes) - posted by "Nikola (Jira)" <ji...@apache.org> on 2020/04/16 15:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17193) k8s-python-example build-example.sh improvements - posted by "Rafi Aroch (Jira)" <ji...@apache.org> on 2020/04/16 19:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17194) TPC-DS end-to-end test fails due to missing execution attempt - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/16 21:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17195) Worker threads for source function have wrong ClassLoader - posted by "Teng Fei Liao (Jira)" <ji...@apache.org> on 2020/04/17 02:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17196) Rework the implementation of Fabric8FlinkKubeClient#getRestEndpoint - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/17 03:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17197) ContinuousFileReaderOperator might shade the real exception when processing records - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/04/17 03:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17198) DDL and DML compatibility for Hive connector - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/17 03:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17199) Use NeverReturnExpired strategy for states in blink streaming join. - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/04/17 05:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17200) Add connectors to ClickHouse - posted by "jinhai (Jira)" <ji...@apache.org> on 2020/04/17 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17201) Implement Streaming ClickHouseSink - posted by "jinhai (Jira)" <ji...@apache.org> on 2020/04/17 05:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17202) Add SQL for ClickHouse connector - posted by "jinhai (Jira)" <ji...@apache.org> on 2020/04/17 05:43:00 UTC, 1 replies.
- [jira] [Created] (FLINK-17203) Add metrics for ClickHouse sink - posted by "jinhai (Jira)" <ji...@apache.org> on 2020/04/17 05:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17204) The RMQSource and RMQSink of the RabbitMQ connector have inconsistent default value of durable when declaring the queue. - posted by "ChaojianZhang (Jira)" <ji...@apache.org> on 2020/04/17 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17205) test_ci Python fails with unable to execute 'gcc': No such file or directory - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/17 06:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17206) Refactor FunctionCatalog to support delayed UDF initialization. - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/04/17 06:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17207) Lots of test_ci Python tests failing with OSError: [Errno 9] Bad file descriptor - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/17 06:32:00 UTC, 0 replies.
- [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen - posted by Becket Qin <be...@gmail.com> on 2020/04/17 06:36:24 UTC, 36 replies.
- [jira] [Created] (FLINK-17208) Reduce redundant data available notification of PipelinedSubpartition - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/04/17 06:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17209) Allow users to specify dialect in sql-client yaml - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/17 07:48:00 UTC, 0 replies.
- Re: [jira] [Commented] (FLINK-17200) Add connectors to ClickHouse - posted by jinhai wang <ji...@gmail.com> on 2020/04/17 07:53:26 UTC, 1 replies.
- Re: [DISCUSS] Switch to Azure Pipelines as the primary CI tool / switch off Travis - posted by Gary Yao <ga...@apache.org> on 2020/04/17 08:05:01 UTC, 2 replies.
- [jira] [Created] (FLINK-17210) Implement database DDLs for Hive dialect - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/17 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17211) Some tests in flink-sql-parser module were disabled - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/17 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17212) Disable the cython tests - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/17 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17213) Surefire configuration should override locale - posted by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2020/04/17 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17214) Docker entry po - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/17 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17215) Clean the build document for Pyflink - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/04/17 09:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17216) Allow user to provide credential provider to Elasticsearch rest client. - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/04/17 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17217) Download links for central.maven.org in doc don't work - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/04/17 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17218) Add recovery to integration tests of unaligned checkpoints - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/04/17 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17219) start-cluster.bat doesn't run task manager due to misconfiguration that is released default configuration - posted by "Bulent Coskun (Jira)" <ji...@apache.org> on 2020/04/17 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17220) It reports "No space left on device" on azure pipeline - posted by "Dian Fu (Jira)" <ji...@apache.org> on 2020/04/17 12:54:00 UTC, 0 replies.
- Are there any link between the flink project.version and flink.shaded.version - posted by Sivaprasanna <si...@gmail.com> on 2020/04/17 12:59:45 UTC, 2 replies.
- [jira] [Created] (FLINK-17221) Flink on YARN fails with NoClassDefFoundError: com/sun/jersey/core/util/FeaturesAndProperties - posted by "Sivaprasanna Sethuraman (Jira)" <ji...@apache.org> on 2020/04/17 13:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17222) Improve FieldsDataType - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/17 14:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17223) System.IO.IOException: No space left on device in misc profile on free Azure builders - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/17 14:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17224) Precision of TIME type does not work correctly - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/17 14:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17225) Support native k8s for scala shell - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/04/17 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17226) Remove Prometheus relocations - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/17 15:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17227) Remove Datadog relocations - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/17 15:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17228) Streaming sql with nested GROUP BY got wrong results - posted by "Xingxing Di (Jira)" <ji...@apache.org> on 2020/04/17 16:59:00 UTC, 0 replies.
- [VOTE] Release 1.9.3, release candidate #1 - posted by Dian Fu <di...@gmail.com> on 2020/04/18 02:37:46 UTC, 11 replies.
- [jira] [Created] (FLINK-17229) Add a flink-sql-client-sdk module - posted by "molsion (Jira)" <ji...@apache.org> on 2020/04/18 03:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/18 09:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/18 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17232) Rethink the implicit behavior to use the Service externalIP as the address of the Endpoint - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/18 11:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17233) Remove copied methods from Calcite introduced by fixing TIMESTAMPDIFF - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/04/18 13:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17234) Show more error messages in taskmanager's log - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/04/19 04:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17235) Dynamic table options will not work when there doesn't exist a space between + and OPTIONS - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/04/19 13:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17236) Add new Tutorials section to Documentation - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17237) Add Intro to DataStream API page to Tutorials section - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17238) Add ETL page to Tutorials section - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 16:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17239) Add streaming analytics page to Tutorials section - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 16:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17240) Add page on Event-driven Applications to Tutorials section - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 17:00:02 UTC, 0 replies.
- [jira] [Created] (FLINK-17241) Add page on Fault Tolerance to Tutorials - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17242) Update docs Home page to mention Tutorials - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17243) Update Getting Started / Overview to mention Tutorials - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 17:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17244) Update Getting Started / Overview to mention Tutorials - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17245) Merge concepts/stream-processing into tutorials overview - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 17:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17246) Rework Concepts / Stateful Stream Processing to depend on Tutorials - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 17:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17247) Rework Concepts / Timely Stream Processing to depend on Tutorials - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/19 17:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17248) Make the thread nums of io executor of ClusterEntrypoint and MiniCluster configurable - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/04/19 18:09:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/16 - posted by Konstantin Knauf <kn...@apache.org> on 2020/04/19 21:17:54 UTC, 0 replies.
- [jira] [Created] (FLINK-17249) Bump universal Kafka connector to Kafka 2.2.2 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2020/04/19 22:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17250) interface akka.event.LoggingFilter is not assignable from class akka.event.slf4j.Slf4jLoggingFilter - posted by "Tammy zhang (Jira)" <ji...@apache.org> on 2020/04/20 01:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17251) TableEnvironment#executeSql supports INSERT statement - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/04/20 02:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17252) TableEnvironment#executeSql supports SELECT statement and Table introduces execute method - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/04/20 02:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17253) Support writing to viewfs for hadoop versions < 2.7 when using BulkFormatBuilder in StreamingFileSink - posted by "chaganti spurthi (Jira)" <ji...@apache.org> on 2020/04/20 04:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/04/20 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17255) Add HBase connector descriptor support in PyFlink - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/04/20 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17256) Suppport keyword arguments in the PyFlink Descriptor API - posted by "sunjincheng (Jira)" <ji...@apache.org> on 2020/04/20 06:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17257) AbstractYarnClusterTest does not compile with Hadoop 2.10 - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/04/20 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17258) Enable unaligned checkpoints in tests by default - posted by "Arvid Heise (Jira)" <ji...@apache.org> on 2020/04/20 07:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17259) Have scala 2.12 support - posted by "João Boto (Jira)" <ji...@apache.org> on 2020/04/20 07:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17260) StreamingKafkaITCase failure on Azure - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/04/20 08:00:23 UTC, 0 replies.
- [jira] [Created] (FLINK-17261) Statefun docs broken - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/20 08:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17262) Statefun snapshot deployments broken - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/20 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17263) Remove RepeatFamilyOperandTypeChecker in blink planner and replace it with calcite's CompositeOperandTypeChecker - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2020/04/20 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17264) taskmanager.sh could not work on Mac - posted by "Yang Wang (Jira)" <ji...@apache.org> on 2020/04/20 10:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17265) uniform time and timeUnit use - posted by "Jake.zhang (Jira)" <ji...@apache.org> on 2020/04/20 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17266) WorkerResourceSpec is not serializable - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/20 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17267) supports EXPLAIN statement in TableEnvironment#executeSql and Table#explain api - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/04/20 12:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17268) SourceReaderTestBase.testAddSplitToExistingFetcher deadlocks on Travis - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/04/20 12:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17269) Translate new Tutorials Overview - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/20 12:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17270) param has space in config.sh - posted by "Yu Wang (Jira)" <ji...@apache.org> on 2020/04/20 12:25:00 UTC, 0 replies.
- [GitHub] [flink-web] MarkSfik commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10" - posted by GitBox <gi...@apache.org> on 2020/04/20 12:27:38 UTC, 9 replies.
- [jira] [Created] (FLINK-17271) Translate new DataStream API tutorial - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/20 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17272) param has space in config.sh - posted by "Yu Wang (Jira)" <ji...@apache.org> on 2020/04/20 12:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17273) Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/20 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17274) Maven: Premature end of Content-Length delimited message body - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/20 14:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17275) Add core training exercises - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/04/20 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17276) Add checkstyle to training exercises - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/04/20 15:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17277) Apply IntelliJ recommendations to training exercises - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/04/20 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17278) Add Travis to the training exercises - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/04/20 15:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17279) Use gradle build scans - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/04/20 15:09:00 UTC, 0 replies.
- [DISCUSS] FLIP-126: Unify (and separate) Watermark Assigners - posted by Aljoscha Krettek <al...@apache.org> on 2020/04/20 16:10:36 UTC, 4 replies.
- [jira] [Created] (FLINK-17280) Migrate existing flink-benchmarks under apache project - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/04/20 16:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17281) Add existing flink-benchmarks code - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/04/20 16:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17282) Add CI build for new flink-benchmarks repo - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/04/20 16:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17283) Improve and explain the solution to Long Rides training exercise - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/20 17:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17284) Support serial field type in PostgresCatalog - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2020/04/20 20:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17285) Add Chinese translation to Python Table API Documentations - posted by "Zixuan Rao (Jira)" <ji...@apache.org> on 2020/04/20 21:47:00 UTC, 0 replies.
- Apply to contribute to Flink - posted by Lee Sysuke <sy...@gmail.com> on 2020/04/21 04:31:03 UTC, 3 replies.
- [jira] [Created] (FLINK-17286) Integrate json to file system connector - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/21 04:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17287) Disable merge commit button - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/21 07:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17288) Speedup loading from savepoints into RocksDB by bulk load - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2020/04/21 07:33:00 UTC, 0 replies.
- [GitHub] [flink-shaded] zentol opened a new pull request #84: [FLINK-17287][github] Disable merge commit button - posted by GitBox <gi...@apache.org> on 2020/04/21 08:16:42 UTC, 0 replies.
- [GitHub] [flink-web] azagrebin commented on a change in pull request #328: Add blog post: "Memory Management improvements with Apache Flink 1.10" - posted by GitBox <gi...@apache.org> on 2020/04/21 08:32:47 UTC, 5 replies.
- [jira] [Created] (FLINK-17289) Translate tutorials/etl.md to chinese - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/21 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17290) Translate Streaming Analytics tutorial to chinese - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/21 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17291) Translate tutorial on event-driven applications to chinese - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/21 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17292) Translate Fault Tolerance tutorial to Chinese - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/21 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17293) Port training exercises data sets to a generator - posted by "Nico Kruber (Jira)" <ji...@apache.org> on 2020/04/21 09:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17294) Using "DataSource" instead of "DriverManager" to get connection in JDBC connector - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2020/04/21 09:12:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-118: Improve Flink's ID System - posted by Yangze Guo <ka...@gmail.com> on 2020/04/21 09:16:57 UTC, 0 replies.
- [jira] [Created] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/04/21 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17296) Support "create table if not exists" in JDBC table sink. - posted by "Lijie Wang (Jira)" <ji...@apache.org> on 2020/04/21 09:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17298) Log the lineage information between ExecutionAttemptID and SlotRequestID - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/04/21 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17297) Log the lineage information between ExecutionAttemptID and SlotRequestID - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/04/21 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17299) Add remote channel throughput benchmark - posted by "Yingjie Cao (Jira)" <ji...@apache.org> on 2020/04/21 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17300) Log the lineage information between ExecutionAttemptID and AllocationID - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/04/21 09:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17301) TaskManagerRunnerStartupTest.testStartupWhenNetworkStackFailsToInitialize fails on OSX - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/21 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17302) Add multiget() interface for state of rocksdb statebackend - posted by "Peidian Li (Jira)" <ji...@apache.org> on 2020/04/21 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17303) Return TableResult for Python TableEnvironment - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/04/21 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17304) Kafka two streams cannot use Flink SQL to query inner join - posted by "xingyuan cheng (Jira)" <ji...@apache.org> on 2020/04/21 11:54:00 UTC, 0 replies.
- [RESULT][VOTE] FLIP-124: Add open/close and Collector to (De)SerializationSchema - posted by Dawid Wysakowicz <dw...@apache.org> on 2020/04/21 14:17:50 UTC, 0 replies.
- [jira] [Created] (FLINK-17305) Add open/close and collector to (De)serializationSchema - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/21 14:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17306) Add open/close methods to DeserializationSchema - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/21 14:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17307) Add collector to DeserializationSchema - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/21 14:29:00 UTC, 0 replies.
- [DISCUSS] Adding support for Hadoop 3 and removing flink-shaded-hadoop - posted by Robert Metzger <rm...@apache.org> on 2020/04/21 14:37:33 UTC, 13 replies.
- [jira] [Created] (FLINK-17308) ExecutionGraphCache cachedExecutionGraphs not cleanup cause OOM Bug - posted by "yujunyong (Jira)" <ji...@apache.org> on 2020/04/21 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17309) TPC-DS fail to run data generator - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/21 16:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17310) Test blink planner failed to generate JobGraph when the checkpoint mode enable - posted by "LionelZ (Jira)" <ji...@apache.org> on 2020/04/21 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17311) Add executable permissions to the script in the wheel package - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/22 02:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17312) Support sql client savepoint - posted by "lun zhang (Jira)" <ji...@apache.org> on 2020/04/22 02:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row - posted by "Terry Wang (Jira)" <ji...@apache.org> on 2020/04/22 03:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17314) 【Flink Kafka Connector】The Config（connector.topic）support list topic - posted by "zhisheng (Jira)" <ji...@apache.org> on 2020/04/22 03:31:00 UTC, 0 replies.
- [DISCUSS] Should max/min be part of the hierarchy of config option? - posted by Yangze Guo <ka...@gmail.com> on 2020/04/22 03:47:04 UTC, 7 replies.
- [jira] [Created] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/04/22 04:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17316) Have HourlyTips solutions use TumblingEventTimeWindows.of - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/22 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17317) Schema.rowtime() method not working correctly, throws 'Window aggregate can only be defined over a time attribute column' exception - posted by "bianhaihua (Jira)" <ji...@apache.org> on 2020/04/22 06:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17318) The comment is not right in `org.apache.flink.table.planner.delegation.PlannerBase` - posted by "Hequn Cheng (Jira)" <ji...@apache.org> on 2020/04/22 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17319) Fix broken link to walkthrough guide - posted by "Patrick Wiener (Jira)" <ji...@apache.org> on 2020/04/22 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17320) Java8 lambda expression cannot be serialized. - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/04/22 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17321) Support for casting collection types. - posted by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/04/22 07:58:00 UTC, 0 replies.
- [DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API - posted by Xuannan Su <su...@gmail.com> on 2020/04/22 08:00:00 UTC, 7 replies.
- [jira] [Created] (FLINK-17322) Enable latency tracker would corrupt the broadcast state - posted by "Yun Tang (Jira)" <ji...@apache.org> on 2020/04/22 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17323) ChannelStateReader rejects requests about unkown channels (Unaligned checkpoints) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/04/22 09:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17324) Move the image we use to generate the flink-docker image into flink-docker - posted by "Ismaël Mejía (Jira)" <ji...@apache.org> on 2020/04/22 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17325) Integrate orc to file system connector - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/22 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17326) flink sql gateway should support persist meta information such as SessionContext in order to recover - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/04/22 12:20:00 UTC, 0 replies.
- [DISCUSS] Intermediary releases of the flink-docker images - posted by Ismaël Mejía <ie...@gmail.com> on 2020/04/22 12:55:47 UTC, 10 replies.
- [jira] [Created] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown - posted by "Jun Qin (Jira)" <ji...@apache.org> on 2020/04/22 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17328) Expose network metric for job vertex in rest api - posted by "lining (Jira)" <ji...@apache.org> on 2020/04/23 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17329) Quickstarts Scala nightly e2e test failed on travis - posted by "Yu Li (Jira)" <ji...@apache.org> on 2020/04/23 03:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/23 03:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/04/23 04:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17332) Fix restart policy not equals to Never for native task manager pods - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/23 04:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17333) add doc for "create ddl" - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/04/23 05:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17334) Flink does not support UDFs with primitive return types - posted by "xin.ruan (Jira)" <ji...@apache.org> on 2020/04/23 05:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17335) JDBCUpsertTableSink Upsert mysql exception No value specified for parameter 1 - posted by "yutao (Jira)" <ji...@apache.org> on 2020/04/23 05:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17336) MVN exited with EXIT CODE: 143. in "libraries" test job - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/23 07:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/23 07:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17338) LocalExecutorITCase.testBatchQueryCancel test timeout - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/23 07:21:00 UTC, 0 replies.
- Re: Flink dev blog - posted by Robert Metzger <rm...@apache.org> on 2020/04/23 07:48:52 UTC, 0 replies.
- [DISCUSS] Exact feature freeze date - posted by Stephan Ewen <se...@apache.org> on 2020/04/23 08:10:17 UTC, 15 replies.
- Re: Reading a single input file in parallel? - posted by Niels Basjes <Ni...@basjes.nl> on 2020/04/23 08:13:26 UTC, 2 replies.
- [jira] [Created] (FLINK-17339) Change default planner to blink and update test cases in both planners - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/04/23 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17340) Update docs which related to default planner changes - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/04/23 08:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17341) freeSlot in TaskExecutor.closeJobManagerConnection cause ConcurrentModificationException - posted by "huweihua (Jira)" <ji...@apache.org> on 2020/04/23 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17342) Schedule savepoint if max-inflight-checkpoints limit is reached isntead of forcing (in UC mode) - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/04/23 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17343) Add doc for retraction behavior for all operators - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/04/23 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17344) RecordWriterTest.testIdleTime possibly deadlocks on Travis - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/23 09:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17345) Support registering and getting Python UDF in HiveCatalog - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/04/23 09:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17346) Deduplicate process setup in docker tests - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/23 09:32:00 UTC, 0 replies.
- [DISCUSS] Add a custom label on MetricReporter like PrometheusPushGatewayReporter's groupingKey - posted by jinhai wang <ji...@gmail.com> on 2020/04/23 09:32:59 UTC, 0 replies.
- [jira] [Created] (FLINK-17347) upgrade to latest angular version - posted by "Yadong Xie (Jira)" <ji...@apache.org> on 2020/04/23 10:28:00 UTC, 0 replies.
- [GitHub] [flink-web] dianfu commented on issue #329: Add Apache Flink release 1.9.3 - posted by GitBox <gi...@apache.org> on 2020/04/23 10:49:25 UTC, 0 replies.
- [DISCUSS] Move docker development into versioned branches - posted by Chesnay Schepler <ch...@apache.org> on 2020/04/23 11:22:57 UTC, 3 replies.
- Contribution - posted by Manish G <ma...@gmail.com> on 2020/04/23 11:35:05 UTC, 1 replies.
- [jira] [Created] (FLINK-17348) Expose metric group to ascendingTimestampExtractor - posted by "Theo Diefenthal (Jira)" <ji...@apache.org> on 2020/04/23 11:54:00 UTC, 0 replies.
- [DISCUSS] Removing deprecated state methods in 1.11 - posted by Stephan Ewen <se...@apache.org> on 2020/04/23 12:07:36 UTC, 4 replies.
- [jira] [Created] (FLINK-17349) Reduce runtime of LocalExecutorITCase - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/04/23 12:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17350) StreamTask should always fail immediately on failures in synchronous part of a checkpoint - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/23 12:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17351) CheckpointCoordinator and CheckpointFailureManager ignores checkpoint timeouts - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/23 12:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17352) All doc links w/ site.baseurl & link tag are broken - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/23 13:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17353) Broken links in Flink docs master - posted by "Seth Wiesman (Jira)" <ji...@apache.org> on 2020/04/23 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17354) Introduce range sort for batch sort operator in blink - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/04/23 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17355) Exactly once kafka checkpointing sensitive to single node failures - posted by "Teng Fei Liao (Jira)" <ji...@apache.org> on 2020/04/23 19:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17356) Properly set constraints (PK and UNIQUE) - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2020/04/23 21:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17357) add "DROP catalog" DDL to blink planner - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2020/04/23 21:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17358) JDBCTableSource support FiltertableTableSource - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2020/04/23 21:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17359) Entropy key is not resolved if flink-s3-fs-hadoop is added as a plugin - posted by "Prem Santosh (Jira)" <ji...@apache.org> on 2020/04/23 21:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17360) Support custom partitioners in JDBCReadOptions - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2020/04/23 21:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17361) Support creating of a JDBC table using a custom query - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2020/04/23 21:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17362) Improve table examples to reflect latest status - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/04/24 01:50:00 UTC, 0 replies.
- [RESULT][VOTE] Release 1.9.3, release candidate #1 - posted by Dian Fu <di...@gmail.com> on 2020/04/24 02:00:51 UTC, 0 replies.
- [jira] [Created] (FLINK-17363) Asynchronous association dimension table timeout - posted by "robert (Jira)" <ji...@apache.org> on 2020/04/24 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17364) Support StreamingFileSink in PrestoS3FileSystem - posted by "Lu Niu (Jira)" <ji...@apache.org> on 2020/04/24 04:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17365) Update Dockerfiles to 1.9.3 - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/24 07:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17366) Implement listViews - posted by "Flavio Pompermaier (Jira)" <ji...@apache.org> on 2020/04/24 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17367) Support generating dockerfiles against custom URL - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/24 07:53:00 UTC, 0 replies.
- JIRA Contributor - posted by shx <17...@163.com> on 2020/04/24 07:59:25 UTC, 2 replies.
- [jira] [Created] (FLINK-17368) exception message in PrometheusPushGatewayReporter - posted by "zl (Jira)" <ji...@apache.org> on 2020/04/24 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17369) Migrate RestartPipelinedRegionFailoverStrategyBuildingTest to PipelinedRegionComputeUtilTest - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/24 09:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17370) Ensure deterministic type inference extraction - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/24 09:03:00 UTC, 0 replies.
- [DISCUSS] flink-connector-rabbitmq api changes - posted by "senegalo@gmail.com" <se...@gmail.com> on 2020/04/24 09:17:50 UTC, 7 replies.
- New contributor - posted by Etienne Chauchot <ec...@apache.org> on 2020/04/24 09:20:24 UTC, 4 replies.
- [jira] [Created] (FLINK-17371) Failed to cast decimal from string or double - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/04/24 09:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17372) SlotManager should expose total required resources - posted by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/04/24 10:02:00 UTC, 0 replies.
- [DISCUSS] Add custom labels on AbstractPrometheusReporter like PrometheusPushGatewayReporter's groupingKey - posted by jinhai wang <ji...@gmail.com> on 2020/04/24 10:23:44 UTC, 0 replies.
- [jira] [Created] (FLINK-17373) Support the NULL type for function calls - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/24 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17374) Remove travis-related files - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/24 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17375) Clean up CI system related scripts - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/24 13:55:00 UTC, 0 replies.
- Tags for beginners - posted by Manish G <ma...@gmail.com> on 2020/04/24 14:11:50 UTC, 1 replies.
- [ANNOUNCE] Development progress of Apache Flink 1.11 - posted by Piotr Nowojski <pn...@apache.org> on 2020/04/24 14:41:46 UTC, 1 replies.
- [jira] [Created] (FLINK-17376) Remove deprecated state access methods - posted by "Stephan Ewen (Jira)" <ji...@apache.org> on 2020/04/24 16:47:00 UTC, 0 replies.
- [GitHub] [flink-web] carp84 opened a new pull request #330: Add Apache Flink release 1.10.1 - posted by GitBox <gi...@apache.org> on 2020/04/24 18:00:05 UTC, 0 replies.
- [VOTE] Release 1.10.1, release candidate #1 - posted by Yu Li <ca...@gmail.com> on 2020/04/24 18:09:42 UTC, 10 replies.
- Contributor - posted by 流动的联系 <10...@qq.com> on 2020/04/25 03:31:02 UTC, 1 replies.
- [GitHub] [flink-web] dianfu commented on pull request #329: Add Apache Flink release 1.9.3 - posted by GitBox <gi...@apache.org> on 2020/04/25 05:58:42 UTC, 0 replies.
- How to reproduce the issue locally - posted by Manish G <ma...@gmail.com> on 2020/04/25 09:18:00 UTC, 1 replies.
- [ANNOUNCE] Apache Flink 1.9.3 released - posted by Dian Fu <di...@apache.org> on 2020/04/25 11:56:34 UTC, 9 replies.
- [jira] [Created] (FLINK-17377) support variable substitution - posted by "Guangbin Zhu (Jira)" <ji...@apache.org> on 2020/04/25 11:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17378) KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/25 12:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17379) testScaleDownBeforeFirstCheckpoint Error reading field 'api_versions': Error reading field 'max_version': - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/25 12:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17380) runAllDeletesTest: "Memory records is not writable" - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/25 12:43:00 UTC, 0 replies.
- Unable to self-assign issue - posted by Manish G <ma...@gmail.com> on 2020/04/25 12:45:03 UTC, 1 replies.
- [jira] [Created] (FLINK-17381) travis_controller prints wrong mvn version - posted by "Benchao Li (Jira)" <ji...@apache.org> on 2020/04/25 15:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17382) Flink should support dynamic log level setting - posted by "Xingxing Di (Jira)" <ji...@apache.org> on 2020/04/25 19:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17383) flink legacy planner should not use CollectionEnvironment any more - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/04/26 02:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17384) support read hbase conf dir from flink.conf just like hadoop_conf - posted by "jackylau (Jira)" <ji...@apache.org> on 2020/04/26 02:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17385) Fix precision problem when converting JDBC numberic into Flink decimal type - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/26 03:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided. - posted by "Wenlong Lyu (Jira)" <ji...@apache.org> on 2020/04/26 04:20:00 UTC, 0 replies.
- Integration of DataSketches into Flink - posted by leerho <le...@gmail.com> on 2020/04/26 06:06:54 UTC, 6 replies.
- [jira] [Created] (FLINK-17387) Implement LookupableTableSource for Hive connector - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/26 07:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17388) flink sql The custom function in ROW type is executed multiple times - posted by "cloudzhao (Jira)" <ji...@apache.org> on 2020/04/26 08:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17389) LocalExecutorITCase.testBatchQueryCancel asserts error - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/04/26 09:06:00 UTC, 0 replies.
- [ANNOUNCE] Weekly Community Update 2020/17 - posted by Konstantin Knauf <kn...@apache.org> on 2020/04/26 11:24:16 UTC, 0 replies.
- [jira] [Created] (FLINK-17390) Container resource cannot be mapped on Hadoop 2.10+ - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/04/26 11:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17391) sink.rolling-policy.time.interval default value should be bigger - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/26 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17392) enable configuring minicluster in Flink SQL in IDE - posted by "Bowen Li (Jira)" <ji...@apache.org> on 2020/04/26 20:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17393) Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly. - posted by "Jiangjie Qin (Jira)" <ji...@apache.org> on 2020/04/27 01:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17394) Add RemoteEnvironment and RemoteStreamEnvironment in Python - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/27 02:09:00 UTC, 0 replies.
- Re: [DISCUSS] Add custom labels on AbstractPrometheusReporter like PrometheusPushGatewayReporter's groupingKey - posted by Yang Wang <da...@gmail.com> on 2020/04/27 02:28:29 UTC, 0 replies.
- [jira] [Created] (FLINK-17395) Add the sign and sha logic for PyFlink wheel packages - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/27 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17396) Support SHOW MODULES in Flink SQL - posted by "Caizhi Weng (Jira)" <ji...@apache.org> on 2020/04/27 03:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17397) Filesystem support lookup table source - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/27 03:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17398) Support flexible path reading - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/27 03:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17399) CsvTableSink should also extend from OverwritableTableSink - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/04/27 05:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17400) LocalStandaloneKafkaResource.setupKafkaDist fails due to download timeout - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/27 06:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17401) Add Labels to Mesos TM taskinfo - posted by "chaganti spurthi (Jira)" <ji...@apache.org> on 2020/04/27 06:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17402) Add User to Task Manager - posted by "chaganti spurthi (Jira)" <ji...@apache.org> on 2020/04/27 06:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17403) Fix invalid classpath in BashJavaUtilsITCase - posted by "Paul Lin (Jira)" <ji...@apache.org> on 2020/04/27 06:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/27 07:27:00 UTC, 0 replies.
- Multiple rebalances are incorrectly ignored in some cases. - posted by David Morávek <dm...@apache.org> on 2020/04/27 07:34:54 UTC, 2 replies.
- [RESULT][VOTE] FLIP-108: Add GPU support in Flink - posted by Yangze Guo <ka...@gmail.com> on 2020/04/27 07:56:38 UTC, 0 replies.
- [jira] [Created] (FLINK-17405) add test cases for cancel job in SQL client - posted by "godfrey he (Jira)" <ji...@apache.org> on 2020/04/27 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17406) add documentation about dynamic table options - posted by "Kurt Young (Jira)" <ji...@apache.org> on 2020/04/27 08:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17407) Introduce external resource framework. - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/04/27 09:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17408) Introduce GPUDriver - posted by "Yangze Guo (Jira)" <ji...@apache.org> on 2020/04/27 09:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17409) SqlCreateView's SqlParserPos return wrong value - posted by "zhanghang-dev (Jira)" <ji...@apache.org> on 2020/04/27 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17410) BlockingPartitionBenchmark compilation failed due to changed StreamGraph interface - posted by "Zhu Zhu (Jira)" <ji...@apache.org> on 2020/04/27 09:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17411) Add async mode in JDBCLookupFunction - posted by "Simon Tao (Jira)" <ji...@apache.org> on 2020/04/27 10:12:00 UTC, 0 replies.
- A query on codebase exploration - posted by Manish G <ma...@gmail.com> on 2020/04/27 10:22:07 UTC, 2 replies.
- [jira] [Created] (FLINK-17412) Make the FLINK_YARN_FILES value configurable - posted by "zhangzhiyuan (Jira)" <ji...@apache.org> on 2020/04/27 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17413) Remove redundant states from ThreadSafeUnaligner - posted by "Zhijiang (Jira)" <ji...@apache.org> on 2020/04/27 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17414) Change the steps of building PyFlink in doc - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/27 10:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17415) Fold API-agnostic documentation into DataStream documentation (chinese) - posted by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/04/27 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252 - posted by "wangxiyuan (Jira)" <ji...@apache.org> on 2020/04/27 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17417) The flink-avro-sql-jar is not really sql-jar - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/04/27 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17418) Windows system is not supported currently - posted by "Simon Tao (Jira)" <ji...@apache.org> on 2020/04/27 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17419) kafka sink json data convert issuse,type compare error - posted by "xiaodao (Jira)" <ji...@apache.org> on 2020/04/27 13:39:00 UTC, 0 replies.
- Re: Flink 1.9.2 why always checkpoint expired - posted by Congxian Qiu <qc...@gmail.com> on 2020/04/27 14:12:23 UTC, 2 replies.
- [jira] [Created] (FLINK-17420) Cannot alias Tuple and Row fields when converting DataStream to Table - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/04/27 15:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17421) Backpressure new checkpoints if previous were not managed to be cleaned up yet - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/27 16:53:00 UTC, 0 replies.
- Question about FLIP-66 - posted by Jungtaek Lim <ka...@gmail.com> on 2020/04/27 23:45:26 UTC, 5 replies.
- Re: [VOTE] FLIP-103: Better TM/JM Log Display - posted by Yadong Xie <vt...@gmail.com> on 2020/04/28 02:03:34 UTC, 2 replies.
- [jira] [Created] (FLINK-17422) Create user document for the external resource framework and the GPU plugin.. - posted by "Xintong Song (Jira)" <ji...@apache.org> on 2020/04/28 02:39:00 UTC, 0 replies.
- Issue - posted by pavan adihtya <p....@gmail.com> on 2020/04/28 05:40:53 UTC, 1 replies.
- [jira] [Created] (FLINK-17423) Support Python UDTF in blink planner under batch mode - posted by "Huang Xingbo (Jira)" <ji...@apache.org> on 2020/04/28 07:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17424) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) failed due to download error - posted by "Yu Li (Jira)" <ji...@apache.org> on 2020/04/28 07:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17425) Supports SupportsFilterPushDown in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/28 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17427) Support SupportsPartitionPushDown in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/28 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17426) Support SupportsLimitPushDown in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/28 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17428) Support SupportsProjectionPushDown in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/28 08:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17430) Support SupportsPartitioning in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/28 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17429) Support SupportsOverwrite in planner - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/28 08:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17431) Implement table DDLs for Hive dialect part 1 - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/28 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17432) Rename Tutorials to Training - posted by "David Anderson (Jira)" <ji...@apache.org> on 2020/04/28 09:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17433) Real time hive integration - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/28 10:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17434) Hive partitioned source support streaming read - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/28 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17435) Hive non-partitioned source support streaming read - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/28 10:26:00 UTC, 0 replies.
- 'Too many files with unapproved license' issue - posted by Manish G <ma...@gmail.com> on 2020/04/28 10:29:48 UTC, 2 replies.
- [jira] [Created] (FLINK-17436) When submitting Python job via "flink run" a IllegalAccessError will be raised due to the package's private access control - posted by "Wei Zhong (Jira)" <ji...@apache.org> on 2020/04/28 11:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17437) Use StringData instead of BinaryStringData in code generation - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/28 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17438) Flink StreamingFileSink chinese garbled - posted by "颖 (Jira)" <ji...@apache.org> on 2020/04/28 11:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17439) Setup versioned branches in flink-docker - posted by "Chesnay Schepler (Jira)" <ji...@apache.org> on 2020/04/28 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17440) Potential Buffer leak in output unspilling for unaligned checkpoints - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/28 14:40:00 UTC, 0 replies.
- [DISCUSS] Have foreground processes also create log files - posted by Chesnay Schepler <ch...@apache.org> on 2020/04/28 16:30:09 UTC, 1 replies.
- [jira] [Created] (FLINK-17441) FlinkKinesisConsumerTest.testPeriodicWatermark: watermark count expected:<2> but was:<1> - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/28 18:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17442) Cannot convert String or boxed-primitive arrays to DataStream using TypeInformation - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/04/28 18:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17443) Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable - posted by "Piyush Narang (Jira)" <ji...@apache.org> on 2020/04/28 19:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17444) Flink StreamingFileSink Azure HadoopRecoverableWriter is missing. - posted by "Marie May (Jira)" <ji...@apache.org> on 2020/04/28 20:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17445) Allow OperatorTransformation to bootstrapWith a Scala DataSet - posted by "Brandon Bevans (Jira)" <ji...@apache.org> on 2020/04/28 22:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17446) Blink supports cube and window together in group by - posted by "Liu (Jira)" <ji...@apache.org> on 2020/04/29 01:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17447) Flink CEPOperator StateException - posted by "chun111111 (Jira)" <ji...@apache.org> on 2020/04/29 02:21:00 UTC, 0 replies.
- [GitHub] [flink-web] klion26 commented on a change in pull request #235: [FLINK-13344][docs-zh] Translate "How to Contribute" page into Chinese - posted by GitBox <gi...@apache.org> on 2020/04/29 02:27:59 UTC, 0 replies.
- [jira] [Created] (FLINK-17448) Implement table DDLs for Hive dialect part2 - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/29 02:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17449) Implement ADD/DROP partitions - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/29 02:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17451) Implement view DDLs for Hive dialect - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/29 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17450) Implement function DDLs for Hive dialect - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/29 02:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17452) Support creating Hive tables with constraints - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/29 02:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue - posted by "Jiayi Liao (Jira)" <ji...@apache.org> on 2020/04/29 02:44:00 UTC, 0 replies.
- The use of state ttl incremental cleanup strategy in sql deduplication resulting in significant performance degradation - posted by 刘大龙 <ld...@zju.edu.cn> on 2020/04/29 03:53:20 UTC, 2 replies.
- [GitHub] [flink-web] klion26 commented on pull request #242: [FLINK-13684][docs-zh] Translate "Code Style - Formatting Guide" page into Chinese - posted by GitBox <gi...@apache.org> on 2020/04/29 04:26:03 UTC, 0 replies.
- [GitHub] [flink-web] klion26 edited a comment on pull request #242: [FLINK-13684][docs-zh] Translate "Code Style - Formatting Guide" page into Chinese - posted by GitBox <gi...@apache.org> on 2020/04/29 04:26:26 UTC, 0 replies.
- [jira] [Created] (FLINK-17454) test_configuration.py ConfigurationTests::test_add_all failed on travis - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/29 05:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17455) Move FileSystemFormatFactory to table common - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/29 06:28:00 UTC, 0 replies.
- [DISCUSS][FLIP-108] Problems regarding the class loader and dependency - posted by Yangze Guo <ka...@gmail.com> on 2020/04/29 06:40:01 UTC, 8 replies.
- [jira] [Created] (FLINK-17456) Update hive connector tests to execute DDL & DML via TableEnvironment - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/29 07:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17457) Manage Hive metadata via Flink DDL - posted by "Rui Li (Jira)" <ji...@apache.org> on 2020/04/29 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17458) TaskExecutorSubmissionTest#testFailingScheduleOrUpdateConsumers - posted by "Congxian Qiu(klion26) (Jira)" <ji...@apache.org> on 2020/04/29 08:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17459) JDBCAppendTableSink not support flush by flushIntervalMills - posted by "ranqiqiang (Jira)" <ji...@apache.org> on 2020/04/29 09:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17460) Create sql-jars for parquet and orc - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/29 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17461) Support JSON serialization and deseriazation schema for RowData type - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/29 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17462) Support CSV serialization and deseriazation schema for RowData type - posted by "Jark Wu (Jira)" <ji...@apache.org> on 2020/04/29 10:29:00 UTC, 0 replies.
- Test errors - posted by Manish G <ma...@gmail.com> on 2020/04/29 13:00:21 UTC, 1 replies.
- [jira] [Created] (FLINK-17463) BlobCacheCleanupTest.testPermanentBlobCleanup:133->verifyJobCleanup:432 » FileAlreadyExists - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/29 13:28:00 UTC, 0 replies.
- [DISCUSS] Hierarchies in ConfigOption - posted by Timo Walther <tw...@apache.org> on 2020/04/29 14:05:11 UTC, 11 replies.
- [jira] [Created] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service - posted by "John Lonergan (Jira)" <ji...@apache.org> on 2020/04/29 15:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17465) Update Chinese user documentation for job manager memory model - posted by "Andrey Zagrebin (Jira)" <ji...@apache.org> on 2020/04/29 15:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17466) toRetractStream doesn't work correctly with Pojo conversion class - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/04/29 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17467) Implement aligned savepoint in UC mode - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/04/29 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/29 15:50:00 UTC, 0 replies.
- doing demultiplexing using Apache flink - posted by dhurandar S <dh...@gmail.com> on 2020/04/29 17:46:48 UTC, 2 replies.
- [jira] [Created] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment - posted by "John Lonergan (Jira)" <ji...@apache.org> on 2020/04/29 18:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file - posted by "Hunter Herman (Jira)" <ji...@apache.org> on 2020/04/29 20:18:00 UTC, 0 replies.
- [GitHub] [flink-shaded] piyushnarang opened a new pull request #85: [FLINK-16955] Bump Zookeeper 3.4.X to 3.4.14 - posted by GitBox <gi...@apache.org> on 2020/04/29 20:30:31 UTC, 0 replies.
- [GitHub] [flink-shaded] piyushnarang commented on pull request #85: [FLINK-16955] Bump Zookeeper 3.4.X to 3.4.14 - posted by GitBox <gi...@apache.org> on 2020/04/29 22:47:39 UTC, 2 replies.
- [GitHub] [flink-web] klion26 commented on a change in pull request #245: [FLINK-13678] Translate "Code Style - Preamble" page into Chinese - posted by GitBox <gi...@apache.org> on 2020/04/30 04:29:23 UTC, 1 replies.
- [GitHub] [flink-web] klion26 commented on pull request #245: [FLINK-13678] Translate "Code Style - Preamble" page into Chinese - posted by GitBox <gi...@apache.org> on 2020/04/30 04:31:09 UTC, 0 replies.
- [GitHub] [flink-web] XBaith commented on a change in pull request #245: [FLINK-13678] Translate "Code Style - Preamble" page into Chinese - posted by GitBox <gi...@apache.org> on 2020/04/30 04:40:57 UTC, 0 replies.
- [jira] [Created] (FLINK-17471) Move LICENSE and NOTICE files to root directory of python distribution - posted by "Yu Li (Jira)" <ji...@apache.org> on 2020/04/30 04:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17472) StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode - posted by "RocMarshal (Jira)" <ji...@apache.org> on 2020/04/30 06:46:00 UTC, 0 replies.
- [VOTE] FLIP-36 - Support Interactive Programming in Flink Table API - posted by Xuannan Su <su...@gmail.com> on 2020/04/30 07:00:00 UTC, 2 replies.
- [GitHub] [flink-web] klion26 commented on pull request #247: [FLINK-13683] Translate "Code Style - Component Guide" page into Chinese - posted by GitBox <gi...@apache.org> on 2020/04/30 07:55:39 UTC, 1 replies.
- [jira] [Created] (FLINK-17473) Remove unused classes ArchivedExecutionVertexBuilder and ArchivedExecutionJobVertexBuilder - posted by "Gary Yao (Jira)" <ji...@apache.org> on 2020/04/30 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17474) Test and correct case insensitive for parquet and orc in hive - posted by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/04/30 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17475) Flink Multiple buffers ,IllgeaStateException - posted by "chun111111 (Jira)" <ji...@apache.org> on 2020/04/30 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17476) Add tests to check recovery from snapshot created with different UC mode - posted by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/04/30 08:56:00 UTC, 0 replies.
- [GitHub] [flink-shaded] zentol commented on a change in pull request #85: [FLINK-16955] Bump Zookeeper 3.4.X to 3.4.14 - posted by GitBox <gi...@apache.org> on 2020/04/30 09:04:58 UTC, 0 replies.
- chinese-translation for FLINK-16091 - posted by flinker <fl...@126.com> on 2020/04/30 09:35:48 UTC, 2 replies.
- [jira] [Created] (FLINK-17477) resumeConsumption call should happen as quickly as possible to minimise latency - posted by "Piotr Nowojski (Jira)" <ji...@apache.org> on 2020/04/30 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17478) Avro format logical type conversions do not work due to type mismatch - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/04/30 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17479) Occasional checkpoint failure due to null pointer exception in Flink version 1.10 - posted by "nobleyd (Jira)" <ji...@apache.org> on 2020/04/30 10:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17480) Support PyFlink on native Kubernetes setup - posted by "Canbin Zheng (Jira)" <ji...@apache.org> on 2020/04/30 11:37:00 UTC, 0 replies.
- [GitHub] [flink-web] morsapaes opened a new pull request #332: [blog] Flink's application to Google Season of Docs. - posted by GitBox <gi...@apache.org> on 2020/04/30 12:04:28 UTC, 0 replies.
- [DISCUSS]Refactor flink-jdbc connector structure - posted by Leonard Xu <xb...@gmail.com> on 2020/04/30 12:09:56 UTC, 4 replies.
- [jira] [Created] (FLINK-17481) Cannot set LocalDateTime column as rowtime when converting DataStream to Table - posted by "Gyula Fora (Jira)" <ji...@apache.org> on 2020/04/30 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17482) KafkaITCase.testMultipleSourcesOnePartition unstable - posted by "Robert Metzger (Jira)" <ji...@apache.org> on 2020/04/30 13:04:00 UTC, 0 replies.
- Re: [DISCUSS] Introduce TableFactory for StatefulSequenceSource - posted by Konstantin Knauf <kn...@apache.org> on 2020/04/30 13:19:06 UTC, 2 replies.
- [jira] [Created] (FLINK-17483) Missing NOTICE file in flink-sql-connector-elasticsearch7 to reflect bundled dependencies - posted by "Yu Li (Jira)" <ji...@apache.org> on 2020/04/30 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-17484) Enable type coercion - posted by "Timo Walther (Jira)" <ji...@apache.org> on 2020/04/30 13:59:00 UTC, 0 replies.
- [GitHub] [flink-shaded] piyushnarang commented on a change in pull request #85: [FLINK-16955] Bump Zookeeper 3.4.X to 3.4.14 - posted by GitBox <gi...@apache.org> on 2020/04/30 14:05:37 UTC, 0 replies.
- "[VOTE] FLIP-108: edit the Public API" - posted by Yangze Guo <ka...@gmail.com> on 2020/04/30 14:33:57 UTC, 0 replies.
- [jira] [Created] (FLINK-17485) Add a thread dump REST API - posted by "Xingxing Di (Jira)" <ji...@apache.org> on 2020/04/30 15:33:00 UTC, 0 replies.
- Re: [DISCUSS] Introduce a new module 'flink-hadoop-utils' - posted by Sivaprasanna <si...@gmail.com> on 2020/04/30 16:54:38 UTC, 0 replies.
- [jira] [Created] (FLINK-17486) ClassCastException when copying AVRO SpecificRecord containing a decimal field - posted by "Lorenzo Nicora (Jira)" <ji...@apache.org> on 2020/04/30 19:52:00 UTC, 0 replies.