clear query| facets| time Search criteria: .   Results from 1 to 9 from 9 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-11201] Document SBT dependency requirements when using MiniClusterResource - Flink - [issue]
...Starting with Flink 1.7, there's lack of `runtime.testutils.MiniClusterResource` class in `flink-test-utils` distribution.Steps to reproduce (Scala code)build.sbtname := "flink-17-test-issue...
http://issues.apache.org/jira/browse/FLINK-11201    Author: eugen yushin , 2019-02-14, 16:23
[FLINK-10422] Follow AWS specs in Kinesis Consumer - Flink - [issue]
...Related conversation in mailing list:https://lists.apache.org/thread.html/96de3bac9761564767cf283b58d664f5ae1b076e0c4431620552af5b@%3Cdev.flink.apache.org%3ESummary:Flink Kinesis consumer ch...
http://issues.apache.org/jira/browse/FLINK-10422    Author: eugen yushin , 2019-02-09, 19:46
[FLINK-10496] CommandLineParser arguments interleaving - Flink - [issue]
...Business case:Run Flink job cluster within Docker/k8s. Job takes an argument called `--config` which can't be recognized in runtime.Caused by: java.lang.RuntimeException: No data for require...
http://issues.apache.org/jira/browse/FLINK-10496    Author: eugen yushin , 2019-02-05, 16:44
[IMPALA-7877] Support Hive GenericUDF - Impala - [issue]
...Running Hive UDF extending GenericUDF interface results in class cast exception. Relevant code block:LOG.debug("Loading UDF '" + udfPath + "' from " + jarPath);loader = getClassLoader(jarPat...
http://issues.apache.org/jira/browse/IMPALA-7877    Author: eugen yushin , 2019-02-01, 14:23
[IMPALA-7885] Create function to convert to ts from unix millis - Impala - [issue]
...There're several functions like `from_unixtime`/`unix_micros_to_utc_timestamp`/`to_timestamp` in Impala which accepts seconds and micros, but none of them works with millis.At the same time,...
http://issues.apache.org/jira/browse/IMPALA-7885    Author: eugen yushin , 2018-11-26, 09:28
[FLINK-10050] Support 'allowedLateness' in CoGroupedStreams - Flink - [issue]
...WindowedStream has a support of 'allowedLateness' feature, while CoGroupedStreams are not. At the mean time, WindowedStream is an inner part of CoGroupedStreams and all main functionality (l...
http://issues.apache.org/jira/browse/FLINK-10050    Author: eugen yushin , 2018-11-21, 17:01
[SPARK-25506] Spark CSV multiline with CRLF - Spark - [issue]
...Spark produces empty rows (or ']' when printing via call to `collect`) dealing with '\r' character at the end of each line in CSV file. Note, no fields are escaped in original input file.val...
http://issues.apache.org/jira/browse/SPARK-25506    Author: eugen yushin , 2018-09-23, 05:41
[SPARK-21442] Spark CSV writer trims trailing spaces - Spark - [issue]
...Looks like Spark truncates trailing spaces saving data with csv codec. Check the following example for more details (note extra space at the end of "Johny " field):scala> case class Sampl...
http://issues.apache.org/jira/browse/SPARK-21442    Author: eugen yushin , 2017-07-17, 14:49
[DRILL-4666] Pushdown doesn't apply for HBase with substr(key) from UT - Drill - [issue]
...Following example section, running query from testFilterPushDownCompositeBigIntRowKey1() results in following execution plan:EXPLAIN PLAN FORSELECT     CONVERT_FROM(BYTE_SUBST...
http://issues.apache.org/jira/browse/DRILL-4666    Author: eugen yushin , 2016-05-11, 13:04