clear query| facets| time Search criteria: .   Results from 1 to 10 from 1002 (0.0s).
Loading phrases to help you
refine your search...
Null array of cols - Spark - [mail # user]
...I am trying to understand the best way to handle the scenario where nullarray "[]" is passed. Can somebody suggest if there is a way to filter outsuch records. I've tried numerous things inc...
   Author: Mohit Anchlia , 2017-10-24, 23:52
Spark directory partition name - Spark - [mail # user]
...When spark writes the partition it writes in the format as:=/key value>Is there a way to have spark write only by keyvalue?...
   Author: Mohit Anchlia , 2017-10-16, 17:19
[expand - 1 more] - JDBC table source - Flink - [mail # user]
...Thanks. Idea was to query for 'x' records in last 'n' seconds using anindexed column. Looks like that is not possible?On Tue, Sep 26, 2017 at 3:24 PM, Fabian Hueske  wrote:> Hi Mohit...
   Author: Mohit Anchlia , 2017-09-26, 23:19
[KAFKA-3079] org.apache.kafka.common.KafkaException: java.lang.SecurityException: Configuration Error: - Kafka - [issue]
...After enabling security I am seeing the following error even though JAAS file has no mention of "Zookeeper". I used the following steps:http://docs.confluent.io/2.0.0/kafka/sasl.html[201...
http://issues.apache.org/jira/browse/KAFKA-3079    Author: Mohit Anchlia , 2017-08-31, 19:43
[expand - 1 more] - Deleting files in continuous processing - Flink - [mail # user]
...Just checking to see if there is a way to purge files after it's processed.On Tue, Aug 15, 2017 at 5:11 PM, Mohit Anchlia wrote:> Is there a way to delete a file once it has been processe...
   Author: Mohit Anchlia , 2017-08-21, 21:07
Avoiding duplicates in joined stream - Flink - [mail # user]
...What's the best way to avoid duplicates in joined stream. In below code Iget duplicates of "A" because I have multiple of "A" in fileInput3.SingleOutputStreamOperator fileInput3 = streamEnv....
   Author: Mohit Anchlia , 2017-08-15, 23:22
[expand - 4 more] - Odd flink behaviour - Flink - [mail # user]
...Thanks. I thought the purpose of below method was to supply thatinformation?@Override*public* *boolean* reachedEnd() *throws* IOException {*logger*.info("Reached " + reached);*return* reache...
   Author: Mohit Anchlia , 2017-08-02, 16:42
[FLINK-7330] Unable to read file on windows - InvalidFilePathException - Flink - [issue]
...It doesn't matter what I use for inputFormat.setFilePath() I keep getting this error://doesn't workformat.setFilePath("file:///c:/proj/test/a.txt.txt");format.setFilePath("file:/c:/proj/test...
http://issues.apache.org/jira/browse/FLINK-7330    Author: Mohit Anchlia , 2017-08-02, 10:27
[expand - 4 more] - Using FileInputFormat - org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit - Flink - [mail # user]
...This was user induced problem - me. I wasn't calling streamenv.execute() :(On Tue, Aug 1, 2017 at 1:29 PM, Mohit Anchlia wrote:> This doesn't work even with TextInputFormat. Not sure what...
   Author: Mohit Anchlia , 2017-08-01, 21:45
[FLINK-7329] Unable to use FileInputStream with StreamExecutionEnvironment.readFile with interval - Flink - [issue]
...FileInputFormat<String> fileInputFormat = new TextInputFormat(new Path(args[0])); fileInputFormat.setNestedFileEnumeration(true); streamEnv.readFile(fileInputFormat, args[0], File...
http://issues.apache.org/jira/browse/FLINK-7329    Author: Mohit Anchlia , 2017-08-01, 09:59