[jira] [Commented] (FLINK-10216) Add REGEXP_MATCH in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16593557#comment-16593557 ] Juho Autio commented on FLINK-10216: [~yanghua] thanks, I had missed it. I wonder if

[jira] [Updated] (FLINK-10216) Add REGEXP_MATCH in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juho Autio updated FLINK-10216: --- Description: Here's a naive implementation: {code:java} public class RegexpMatchFunction extends Sca

[jira] [Created] (FLINK-10216) Add REGEXP_MATCH in TableAPI and SQL

Juho Autio created FLINK-10216: -- Summary: Add REGEXP_MATCH in TableAPI and SQL Key: FLINK-10216 URL: https://issues.apache.org/jira/browse/FLINK-10216 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-9335) Expose client logs via Flink UI

[ https://issues.apache.org/jira/browse/FLINK-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16471734#comment-16471734 ] Juho Autio commented on FLINK-9335: --- I'm submitting jobs on command line with flink run,

[jira] [Updated] (FLINK-9335) Expose client logs via Flink UI

[ https://issues.apache.org/jira/browse/FLINK-9335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juho Autio updated FLINK-9335: -- Description: The logs logged by my Flink job jar _before_ *env.execute* can't be found in jobmanager lo

[jira] [Created] (FLINK-9335) Expose client logs via Flink UI

Juho Autio created FLINK-9335: - Summary: Expose client logs via Flink UI Key: FLINK-9335 URL: https://issues.apache.org/jira/browse/FLINK-9335 Project: Flink Issue Type: Improvement R

[jira] [Updated] (FLINK-9334) Docs to have a code snippet of Kafka partition discovery

[ https://issues.apache.org/jira/browse/FLINK-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juho Autio updated FLINK-9334: -- Description: Tzu-Li (Gordon) said: {quote}Yes, it might be helpful to have a code snippet to demonstrate

[jira] [Created] (FLINK-9334) Docs to have a code snippet of Kafka partition discovery

Juho Autio created FLINK-9334: - Summary: Docs to have a code snippet of Kafka partition discovery Key: FLINK-9334 URL: https://issues.apache.org/jira/browse/FLINK-9334 Project: Flink Issue Type:

[jira] [Updated] (FLINK-9184) Remove warning from kafka consumer docs

[ https://issues.apache.org/jira/browse/FLINK-9184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juho Autio updated FLINK-9184: -- Description: Once the main problem of FLINK-5479 has been fixed, remove the warning about idle partition

[jira] [Updated] (FLINK-9184) Remove warning from kafka consumer docs

[ https://issues.apache.org/jira/browse/FLINK-9184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juho Autio updated FLINK-9184: -- Description: Once the main problem (FLINK-5479) has been fixed, remove the warning about idle partitions

[jira] [Created] (FLINK-9184) Remove warning from kafka consumer docs

Juho Autio created FLINK-9184: - Summary: Remove warning from kafka consumer docs Key: FLINK-9184 URL: https://issues.apache.org/jira/browse/FLINK-9184 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9183) Kafka consumer docs to warn about idle partitions

Juho Autio created FLINK-9183: - Summary: Kafka consumer docs to warn about idle partitions Key: FLINK-9183 URL: https://issues.apache.org/jira/browse/FLINK-9183 Project: Flink Issue Type: Sub-tas

[jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

[ https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435048#comment-16435048 ] Juho Autio commented on FLINK-5479: --- [~tzulitai]: {quote}Raised this to blocker for 1.5.

[jira] [Commented] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15657244#comment-15657244 ] Juho Autio commented on FLINK-3123: --- Nice one, looking forward to this! {quote} If a su

[jira] [Commented] (FLINK-3964) Job submission times out with recursive.file.enumeration

[ https://issues.apache.org/jira/browse/FLINK-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15346263#comment-15346263 ] Juho Autio commented on FLINK-3964: --- Sorry I didn't realize that {{-m yarn-cluster}} was

[jira] [Commented] (FLINK-3964) Job submission times out with recursive.file.enumeration

[ https://issues.apache.org/jira/browse/FLINK-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15341594#comment-15341594 ] Juho Autio commented on FLINK-3964: --- [~mxm], I'm pretty sure I tried {{bin/flink run -yD

[jira] [Commented] (FLINK-2672) Add partitioned output format to HDFS RollingSink

[ https://issues.apache.org/jira/browse/FLINK-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15299557#comment-15299557 ] Juho Autio commented on FLINK-2672: --- I wonder what the full pattern syntax would be? To

[jira] [Commented] (FLINK-3961) Possibility to write output to multiple locations based on partitions

[ https://issues.apache.org/jira/browse/FLINK-3961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15299554#comment-15299554 ] Juho Autio commented on FLINK-3961: --- This question is primarily about Flink Batch API.

[jira] [Created] (FLINK-3964) Job submission times out with recursive.file.enumeration

Juho Autio created FLINK-3964: - Summary: Job submission times out with recursive.file.enumeration Key: FLINK-3964 URL: https://issues.apache.org/jira/browse/FLINK-3964 Project: Flink Issue Type: