[jira] [Created] (FLINK-27330) Why Read File Stream Function Deprecated?
Karthik created FLINK-27330: --- Summary: Why Read File Stream Function Deprecated? Key: FLINK-27330 URL: https://issues.apache.org/jira/browse/FLINK-27330 Project: Flink Issue Type: Technical Debt Components: API / DataStream Affects Versions: 1.11.6 Reporter: Karthik env.readFileStream() is used in previous version of flink. But I think after 1.11.6 it is deprecated. may I know why? -- This message was sent by Atlassian Jira (v8.20.7#820007)
[jira] [Updated] (FLINK-27192) Parquet File Read From Local
[ https://issues.apache.org/jira/browse/FLINK-27192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Karthik updated FLINK-27192: Issue Type: Technical Debt (was: Bug) > Parquet File Read From Local > > > Key: FLINK-27192 > URL: https://issues.apache.org/jira/browse/FLINK-27192 > Project: Flink > Issue Type: Technical Debt > Components: Table SQL / API, Table SQL / Client >Affects Versions: 1.13.6 > Environment: Flink-1.13.6 > Scala-2.11 > >Reporter: Karthik >Priority: Major > Fix For: 1.13.6 > > > Hi, I want to read a parquet file from my local > But it is asking for Hadoop Config > Note: I'm using this jar flink-sql-parquet_2.11-1.13.6.jar -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-27192) Parquet File Read From Local
[ https://issues.apache.org/jira/browse/FLINK-27192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Karthik updated FLINK-27192: Component/s: Table SQL / API Table SQL / Client Fix Version/s: 1.13.6 Affects Version/s: 1.13.6 Description: Hi, I want to read a parquet file from my local But it is asking for Hadoop Config Note: I'm using this jar flink-sql-parquet_2.11-1.13.6.jar Environment: Flink-1.13.6 Scala-2.11 Summary: Parquet File Read From Local (was: Hi,) > Parquet File Read From Local > > > Key: FLINK-27192 > URL: https://issues.apache.org/jira/browse/FLINK-27192 > Project: Flink > Issue Type: Bug > Components: Table SQL / API, Table SQL / Client >Affects Versions: 1.13.6 > Environment: Flink-1.13.6 > Scala-2.11 > >Reporter: Karthik >Priority: Major > Fix For: 1.13.6 > > > Hi, I want to read a parquet file from my local > But it is asking for Hadoop Config > Note: I'm using this jar flink-sql-parquet_2.11-1.13.6.jar -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-27192) Hi,
Karthik created FLINK-27192: --- Summary: Hi, Key: FLINK-27192 URL: https://issues.apache.org/jira/browse/FLINK-27192 Project: Flink Issue Type: Bug Reporter: Karthik -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-27151) Group By Aggregation With Sorted Data
[ https://issues.apache.org/jira/browse/FLINK-27151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520304#comment-17520304 ] Karthik commented on FLINK-27151: - yes, when I send data to agg_udf it is not processed in the order. for example the first-row process last, second-row process first like that. > Group By Aggregation With Sorted Data > - > > Key: FLINK-27151 > URL: https://issues.apache.org/jira/browse/FLINK-27151 > Project: Flink > Issue Type: Bug > Components: Table SQL / API, Table SQL / Client >Affects Versions: 1.13.6 >Reporter: Karthik >Priority: Major > > Hi, > I want To aggregate a table by grouping some of the columns. > But after grouping the columns when I send the data to UDF aggregate function > it is not going in sorted order. > Is there any way to do that? > Thank You. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-27151) Group By Aggregation With Sorted Data
Karthik created FLINK-27151: --- Summary: Group By Aggregation With Sorted Data Key: FLINK-27151 URL: https://issues.apache.org/jira/browse/FLINK-27151 Project: Flink Issue Type: Bug Components: Table SQL / API, Table SQL / Client Affects Versions: 1.13.6 Reporter: Karthik Hi, I want To aggregate a table by grouping some of the columns. But after grouping the columns when I send the data to UDF aggregate function it is not going in sorted order. Is there any way to do that? Thank You. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Closed] (FLINK-26878) get previous window values in udf
[ https://issues.apache.org/jira/browse/FLINK-26878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Karthik closed FLINK-26878. --- Fix Version/s: 1.13.6 Resolution: Fixed > get previous window values in udf > - > > Key: FLINK-26878 > URL: https://issues.apache.org/jira/browse/FLINK-26878 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.13.6 > Environment: OS: Linux, ubuntu 20 > Flink Version: 1.13.6 >Reporter: Karthik >Priority: Major > Labels: UDF, table-api, window_function > Fix For: 1.13.6 > > > hi everyone, > I am facing a problem when I want previous window values. > I want them for some aggregation purpose. > Is there any way to get them? -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-26878) get previous window values in udf
[ https://issues.apache.org/jira/browse/FLINK-26878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17515727#comment-17515727 ] Karthik commented on FLINK-26878: - yeah that worked i tried that one > get previous window values in udf > - > > Key: FLINK-26878 > URL: https://issues.apache.org/jira/browse/FLINK-26878 > Project: Flink > Issue Type: Bug > Components: Table SQL / API >Affects Versions: 1.13.6 > Environment: OS: Linux, ubuntu 20 > Flink Version: 1.13.6 >Reporter: Karthik >Priority: Major > Labels: UDF, table-api, window_function > > hi everyone, > I am facing a problem when I want previous window values. > I want them for some aggregation purpose. > Is there any way to get them? -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Created] (FLINK-26878) get previous window values in udf
Karthik created FLINK-26878: --- Summary: get previous window values in udf Key: FLINK-26878 URL: https://issues.apache.org/jira/browse/FLINK-26878 Project: Flink Issue Type: Bug Components: Table SQL / API Affects Versions: 1.13.6 Environment: OS: Linux, ubuntu 20 Flink Version: 1.13.6 Reporter: Karthik hi everyone, I am facing a problem when I want previous window values. I want them for some aggregation purpose. Is there any way to get them? -- This message was sent by Atlassian Jira (v8.20.1#820001)
