Re: [jira] [Created] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

Same Issue I am facing :- http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Issues-in-migrating-code-from-1-3-2-to-1-4-0-td20461.html Can anyone explain the exception Thanks On Thu, Dec 14, 2017 at 1:45 AM, Ryan Brideau (JIRA) wrote: > Ryan Brideau created FLINK-8256: > --

Re: Issues in migrating code from 1.3.2 to 1.4.0

yeah I am using Table API of flink. Basically I am creating my UserDefined Function like below: class DateTimeUDF extends ScalarFunction { def eval(timeStamp: String, destFormat: String): String = { val format = new SimpleDateFormat("-MM-dd HH:mm:ss") val date: Date = for

[jira] [Created] (FLINK-8258) Enable query configuration for batch queries

Xingcan Cui created FLINK-8258: -- Summary: Enable query configuration for batch queries Key: FLINK-8258 URL: https://issues.apache.org/jira/browse/FLINK-8258 Project: Flink Issue Type: Improvemen

Re: Issues in migrating code from 1.3.2 to 1.4.0

Hi, Could you please provide a bit of context. From your second email I gather that you're using the Table API, is that right? Best, Aljoscha > On 14. Dec 2017, at 07:08, Shivam Sharma <28shivamsha...@gmail.com> wrote: > > Basically I am registering one scalarfunction in my code. Is there any

Re: Issues in migrating code from 1.3.2 to 1.4.0

Basically I am registering one scalarfunction in my code. Is there any change in writing or registering a User Defined function in flink 1.4.0? On Wed, Dec 13, 2017 at 11:55 PM, Shivam Sharma <28shivamsha...@gmail.com> wrote: > Hi > > I am getting following issues in working code in new version 1

[jira] [Created] (FLINK-8257) Unify the value checks for setParallelism()

Xingcan Cui created FLINK-8257: -- Summary: Unify the value checks for setParallelism() Key: FLINK-8257 URL: https://issues.apache.org/jira/browse/FLINK-8257 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8256) Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException

Ryan Brideau created FLINK-8256: --- Summary: Cannot use Scala functions to filter in 1.4 - java.lang.ClassCastException Key: FLINK-8256 URL: https://issues.apache.org/jira/browse/FLINK-8256 Project: Flink

Issues in migrating code from 1.3.2 to 1.4.0

Hi I am getting following issues in working code in new version 1.4.0. org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function. at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:235) at org.apache.flink.streaming.runtim

Re: Storing large lists into state per key

Hi, Using a MapState is a workaround that should work but it would be nice if ListState would work for state that is too big to fit into memory. Best, Aljoscha > On 13. Dec 2017, at 17:40, Jan Lukavský wrote: > > Hi Aljoscha, > > thanks for reply. Do you see any issues in implementing the li

Re: Storing large lists into state per key

Hi Aljoscha, thanks for reply. Do you see any issues in implementing the list state the way Fabian suggested (i.e. using the MapState)? I feel there are some open questions, mostly because the InternalListState (which I suppose the RocksDBListState should implement) extends InternalKvState, w

[jira] [Created] (FLINK-8255) Key expressions on named rows types do not work

Timo Walther created FLINK-8255: --- Summary: Key expressions on named rows types do not work Key: FLINK-8255 URL: https://issues.apache.org/jira/browse/FLINK-8255 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8254) REST API documentation wonky due to shading

Chesnay Schepler created FLINK-8254: --- Summary: REST API documentation wonky due to shading Key: FLINK-8254 URL: https://issues.apache.org/jira/browse/FLINK-8254 Project: Flink Issue Type: I

[jira] [Created] (FLINK-8253) flink-docs-stable still points to 1.3

Ufuk Celebi created FLINK-8253: -- Summary: flink-docs-stable still points to 1.3 Key: FLINK-8253 URL: https://issues.apache.org/jira/browse/FLINK-8253 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-8251) Add some network micro-benchmarks in Flink

Nico Kruber created FLINK-8251: -- Summary: Add some network micro-benchmarks in Flink Key: FLINK-8251 URL: https://issues.apache.org/jira/browse/FLINK-8251 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-8252) Convert network benchmarks to streaming benchmarks

Nico Kruber created FLINK-8252: -- Summary: Convert network benchmarks to streaming benchmarks Key: FLINK-8252 URL: https://issues.apache.org/jira/browse/FLINK-8252 Project: Flink Issue Type: Sub-

Re: Storing large lists into state per key

Hi, If I remember correctly, there was actually an effort to change the RocksDB list state the way you described. I'm cc'ing Stephan, who was involved in that and this is the Jira issue: https://issues.apache.org/jira/browse/FLINK-5756 Best, A

[jira] [Created] (FLINK-8250) Remove RecordSerializer#instantiateMetrics

Chesnay Schepler created FLINK-8250: --- Summary: Remove RecordSerializer#instantiateMetrics Key: FLINK-8250 URL: https://issues.apache.org/jira/browse/FLINK-8250 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-8249) Kinesis Producer dont cpnfigure region

Joao Boto created FLINK-8249: Summary: Kinesis Producer dont cpnfigure region Key: FLINK-8249 URL: https://issues.apache.org/jira/browse/FLINK-8249 Project: Flink Issue Type: Bug Compon

[jira] [Created] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4

jia liu created FLINK-8248: -- Summary: RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4 Key: FLINK-8248 URL: https://issues.apache.org/jira/browse/FLINK-8248 Project: Flink Is