[jira] [Commented] (FLINK-17088) Search TaskManager log content based on keywords function

[ https://issues.apache.org/jira/browse/FLINK-17088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118246#comment-17118246 ] ambition commented on FLINK-17088: -- [~azagrebin]  First, Ctrl + F adds additional keybo

[jira] [Closed] (FLINK-11487) Support for writing data to Apache Flume

[ https://issues.apache.org/jira/browse/FLINK-11487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition closed FLINK-11487. Resolution: Fixed Release Note: [FLINK-4446] Remove Flume connector (now in Bahir) > Support for wri

[jira] [Created] (FLINK-11487) Support for writing data to Apache Flume

ambition created FLINK-11487: Summary: Support for writing data to Apache Flume Key: FLINK-11487 URL: https://issues.apache.org/jira/browse/FLINK-11487 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-11206) sql statement parser enhancement

[ https://issues.apache.org/jira/browse/FLINK-11206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725707#comment-16725707 ] ambition commented on FLINK-11206: -- sorry, I just see this doc  https://docs.google.co

[jira] [Closed] (FLINK-11206) sql statement parser enhancement

[ https://issues.apache.org/jira/browse/FLINK-11206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition closed FLINK-11206. Resolution: Fixed > sql statement parser enhancement > > >

[jira] [Created] (FLINK-11206) sql statement parser enhancement

ambition created FLINK-11206: Summary: sql statement parser enhancement Key: FLINK-11206 URL: https://issues.apache.org/jira/browse/FLINK-11206 Project: Flink Issue Type: Improvement Co

[jira] [Closed] (FLINK-11039) LogicalExchange and HashPartitioner realization

[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition closed FLINK-11039. Resolution: Fixed > LogicalExchange and HashPartitioner realization >

[jira] [Updated] (FLINK-11039) LogicalExchange and HashPartitioner realization

[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-11039: - Description: RelTimeIndicatorConverter.visit(exchange: LogicalExchange) function realization. FlinkLogi

[jira] [Commented] (FLINK-11039) LogicalExchange and HashPartitioner realization

[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706717#comment-16706717 ] ambition commented on FLINK-11039: -- It was originally implemented as RelTimeIndicatorCo

[jira] [Commented] (FLINK-11039) LogicalExchange and HashPartitioner realization

[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16705710#comment-16705710 ] ambition commented on FLINK-11039: -- pull request links [PR7202|https://github.com/apach

[jira] [Created] (FLINK-11039) LogicalExchange and HashPartitioner realization

ambition created FLINK-11039: Summary: LogicalExchange and HashPartitioner realization Key: FLINK-11039 URL: https://issues.apache.org/jira/browse/FLINK-11039 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-10299) RowSerializer.copy data value cast exception and use checkpoint function Lead to Could not restart this job

[ https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10299: - Attachment: image-2018-11-19-10-40-14-577.png > RowSerializer.copy data value cast exception and use che

[jira] [Closed] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition closed FLINK-10818. Resolution: Fixed > RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not > enough

[jira] [Reopened] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition reopened FLINK-10818: -- > RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not > enough free slots availa

[jira] [Comment Edited] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684814#comment-16684814 ] ambition edited comment on FLINK-10818 at 11/13/18 7:37 AM:

[jira] [Comment Edited] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684814#comment-16684814 ] ambition edited comment on FLINK-10818 at 11/13/18 7:36 AM:

[jira] [Commented] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16684814#comment-16684814 ] ambition commented on FLINK-10818: -- [^jobmanager.log][^taskmanager.log] > RestartStrat

***UNCHECKED*** [jira] [Updated] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10818: - Attachment: jobmanager.log > RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: No

[jira] [Updated] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10818: - Attachment: taskmanager.log > RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: N

[jira] [Created] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

ambition created FLINK-10818: Summary: RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job. Key: FLINK-10818 URL: https://issues.apache.org/jira/brow

[jira] [Commented] (FLINK-10674) DistinctAccumulator.remove lead to NPE

[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679246#comment-16679246 ] ambition commented on FLINK-10674: -- Our Online Flink on Yarn environment operation  job

[jira] [Created] (FLINK-10674) DistinctAccumulator.remove lead to NPE

ambition created FLINK-10674: Summary: DistinctAccumulator.remove lead to NPE Key: FLINK-10674 URL: https://issues.apache.org/jira/browse/FLINK-10674 Project: Flink Issue Type: Bug Comp

[jira] [Comment Edited] (FLINK-10299) RowSerializer.copy data value cast exception and use checkpoint function Lead to Could not restart this job

[ https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608810#comment-16608810 ] ambition edited comment on FLINK-10299 at 9/10/18 12:51 PM:

[jira] [Comment Edited] (FLINK-10299) RowSerializer.copy data value cast exception and use checkpoint function Lead to Could not restart this job

[ https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608810#comment-16608810 ] ambition edited comment on FLINK-10299 at 9/10/18 7:15 AM: --- So

[jira] [Updated] (FLINK-10299) RowSerializer.copy data value cast exception and use checkpoint function Lead to Could not restart this job

[ https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10299: - Summary: RowSerializer.copy data value cast exception and use checkpoint function Lead to Could not rest

[jira] [Commented] (FLINK-10299) RowSerializer.copy data value cast exception Lead to Could not restart this job

[ https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608810#comment-16608810 ] ambition commented on FLINK-10299: -- Sorry,The past two days are not workdays. I briefly

[jira] [Updated] (FLINK-10299) RowSerializer.copy data value cast exception Lead to Could not restart this job

[ https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10299: - Summary: RowSerializer.copy data value cast exception Lead to Could not restart this job (was: RowSeria

[jira] [Updated] (FLINK-10299) RowSerializer.copy data value cast exception

[ https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10299: - Description: Flink sql deal with User behavior data collection, such as： {code:java} {     "event_id": "

[jira] [Created] (FLINK-10299) RowSerializer.copy data value cast exception

ambition created FLINK-10299: Summary: RowSerializer.copy data value cast exception Key: FLINK-10299 URL: https://issues.apache.org/jira/browse/FLINK-10299 Project: Flink Issue Type: Bug