[jira] [Assigned] (BEAM-2995) can't read/write hdfs in Flink CLUSTER(Standalone)

[ https://issues.apache.org/jira/browse/BEAM-2995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned BEAM-2995: -- Assignee: Dawid Wysakowicz (was: Aljoscha Krettek) > can't read/write hdfs in Flink

[jira] [Commented] (BEAM-2995) can't read/write hdfs in Flink CLUSTER(Standalone)

[ https://issues.apache.org/jira/browse/BEAM-2995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352114#comment-16352114 ] Dawid Wysakowicz commented on BEAM-2995: [~huangjianhuang] I could not reproduce your exact

[jira] [Commented] (BEAM-1107) Display user names for steps in the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400471#comment-16400471 ] Dawid Wysakowicz commented on BEAM-1107: Fixed in [BEAM-3043] > Display user names for steps in

[jira] [Resolved] (BEAM-1107) Display user names for steps in the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved BEAM-1107. Resolution: Duplicate Fix Version/s: Not applicable > Display user names for steps in

[jira] [Resolved] (BEAM-3281) PTransform name not being propagated to the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-3281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved BEAM-3281. Resolution: Duplicate Fix Version/s: 2.5.0 > PTransform name not being propagated to

[jira] [Commented] (BEAM-3281) PTransform name not being propagated to the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-3281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400476#comment-16400476 ] Dawid Wysakowicz commented on BEAM-3281: Fixed in [BEAM-3043] > PTransform name not being

[jira] [Updated] (BEAM-1107) Display user names for steps in the Flink Web UI

[ https://issues.apache.org/jira/browse/BEAM-1107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated BEAM-1107: --- Fix Version/s: (was: Not applicable) 2.5.0 > Display user names for

[jira] [Updated] (BEAM-3703) java.io.IOException: KafkaWriter : failed to send 1 records (since last report)

[ https://issues.apache.org/jira/browse/BEAM-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated BEAM-3703: --- Description: I am trying to read from file and write to Kafka in google cloud kafka and

[jira] [Assigned] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned BEAM-3414: -- Assignee: Dawid Wysakowicz (was: Aljoscha Krettek) > AfterProcessingTime trigger issue

[jira] [Commented] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16406119#comment-16406119 ] Dawid Wysakowicz commented on BEAM-3414: I think it might be the same problem as noticed in

[jira] [Commented] (BEAM-3225) Non deterministic behaviour of AfterProcessingTime trigger with multiple group by transformations

[ https://issues.apache.org/jira/browse/BEAM-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401800#comment-16401800 ] Dawid Wysakowicz commented on BEAM-3225: Hi, I've tried to reproduce the _"allowed lateness

[jira] [Commented] (BEAM-3494) Snapshot state of aggregated data of apache beam project is not maintained in flink's checkpointing

[ https://issues.apache.org/jira/browse/BEAM-3494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16401919#comment-16401919 ] Dawid Wysakowicz commented on BEAM-3494: [~suganyap] Could you elaborate a bit more how you enable

[jira] [Assigned] (BEAM-2873) Detect number of shards for file sink in Flink Streaming Runner

[ https://issues.apache.org/jira/browse/BEAM-2873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned BEAM-2873: -- Assignee: Dawid Wysakowicz > Detect number of shards for file sink in Flink Streaming

[jira] [Assigned] (BEAM-3359) Unable to change "flinkMaster" from "[auto]" in TestFlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned BEAM-3359: -- Assignee: Dawid Wysakowicz > Unable to change "flinkMaster" from "[auto]" in