[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26524: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability) Priority: Major (was: Critical) This issue was labeled "stale-critical" 7 days ago and has not received any updates so it is being deprioritized. If this ticket is actually Critical, please raise the priority and ask a committer to assign you the issue or revive the public discussion. > Elasticsearch (v5.3.3) sink end-to-end test > --- > > Key: FLINK-26524 > URL: https://issues.apache.org/jira/browse/FLINK-26524 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch >Affects Versions: 1.14.3 >Reporter: Matthias Pohl >Priority: Major > Labels: auto-deprioritized-critical, test-stability > > e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this > build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] > on {{release-1.14}} probably because of the following stacktrace showing up > in the logs: > {code} > Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN > org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to > trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive > failed attempts so far) > Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: > Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > [?:1.8.0_322] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > [?:1.8.0_322] > Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] > Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task > name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: > Unnamed (1/1)#0 Failure reason: Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1389) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1382) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.triggerCheckpointBarrier(Task.java:1348) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskexecutor.TaskExecutor.triggerCheckpoint(TaskExecutor.java:956) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) ~[?:1.8.0_322] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26524: --- Labels: stale-critical test-stability (was: test-stability) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Critical but is unassigned and neither itself nor its Sub-Tasks have been updated for 14 days. I have gone ahead and marked it "stale-critical". If this ticket is critical, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > Elasticsearch (v5.3.3) sink end-to-end test > --- > > Key: FLINK-26524 > URL: https://issues.apache.org/jira/browse/FLINK-26524 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch >Affects Versions: 1.14.3 >Reporter: Matthias Pohl >Priority: Critical > Labels: stale-critical, test-stability > > e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this > build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] > on {{release-1.14}} probably because of the following stacktrace showing up > in the logs: > {code} > Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN > org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to > trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive > failed attempts so far) > Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: > Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > [?:1.8.0_322] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > [?:1.8.0_322] > Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] > Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task > name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: > Unnamed (1/1)#0 Failure reason: Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1389) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1382) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.triggerCheckpointBarrier(Task.java:1348) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskexecutor.TaskExecutor.triggerCheckpoint(TaskExecutor.java:956) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) ~[?:1.8.0_322] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26524: --- Fix Version/s: (was: 1.14.5) > Elasticsearch (v5.3.3) sink end-to-end test > --- > > Key: FLINK-26524 > URL: https://issues.apache.org/jira/browse/FLINK-26524 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch >Affects Versions: 1.14.3 >Reporter: Matthias Pohl >Priority: Critical > Labels: test-stability > > e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this > build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] > on {{release-1.14}} probably because of the following stacktrace showing up > in the logs: > {code} > Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN > org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to > trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive > failed attempts so far) > Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: > Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > [?:1.8.0_322] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > [?:1.8.0_322] > Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] > Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task > name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: > Unnamed (1/1)#0 Failure reason: Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1389) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1382) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.triggerCheckpointBarrier(Task.java:1348) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskexecutor.TaskExecutor.triggerCheckpoint(TaskExecutor.java:956) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) ~[?:1.8.0_322] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26524: - Fix Version/s: 1.14.5 (was: 1.14.4) > Elasticsearch (v5.3.3) sink end-to-end test > --- > > Key: FLINK-26524 > URL: https://issues.apache.org/jira/browse/FLINK-26524 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch >Affects Versions: 1.14.3 >Reporter: Matthias Pohl >Priority: Critical > Labels: test-stability > Fix For: 1.14.5 > > > e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this > build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] > on {{release-1.14}} probably because of the following stacktrace showing up > in the logs: > {code} > Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN > org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to > trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive > failed attempts so far) > Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: > Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > [?:1.8.0_322] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > [?:1.8.0_322] > Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] > Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task > name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: > Unnamed (1/1)#0 Failure reason: Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1389) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1382) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.triggerCheckpointBarrier(Task.java:1348) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskexecutor.TaskExecutor.triggerCheckpoint(TaskExecutor.java:956) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) ~[?:1.8.0_322] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26524: --- Description: e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] on {{release-1.14}} probably because of the following stacktrace showing up in the logs: {code} Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive failed attempts so far) Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint was declined (task is closing) Mar 07 15:40:41 at org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_322] Mar 07 15:40:41 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_322] Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: Unnamed (1/1)#0 Failure reason: Checkpoint was declined (task is closing) Mar 07 15:40:41 at org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1389) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1382) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at org.apache.flink.runtime.taskmanager.Task.triggerCheckpointBarrier(Task.java:1348) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at org.apache.flink.runtime.taskexecutor.TaskExecutor.triggerCheckpoint(TaskExecutor.java:956) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_322] {code} was: e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] on {{master}} probably because of the following stacktrace showing up in the logs: {code} Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive failed attempts so far) Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint was declined (task is closing) Mar 07 15:40:41 at org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] Mar 07 15:40:41 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_322] Mar 07 15:40:41 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_322] Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: Unnamed
[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-26524: --- Affects Version/s: 1.14.3 (was: 1.15.0) > Elasticsearch (v5.3.3) sink end-to-end test > --- > > Key: FLINK-26524 > URL: https://issues.apache.org/jira/browse/FLINK-26524 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch >Affects Versions: 1.14.3 >Reporter: Matthias Pohl >Priority: Critical > Labels: test-stability > Fix For: 1.15.0 > > > e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this > build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] > on {{master}} probably because of the following stacktrace showing up in the > logs: > {code} > Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN > org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to > trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive > failed attempts so far) > Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: > Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > [?:1.8.0_322] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > [?:1.8.0_322] > Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] > Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task > name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: > Unnamed (1/1)#0 Failure reason: Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1389) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1382) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.triggerCheckpointBarrier(Task.java:1348) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskexecutor.TaskExecutor.triggerCheckpoint(TaskExecutor.java:956) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) ~[?:1.8.0_322] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-26524: --- Fix Version/s: 1.14.4 (was: 1.15.0) > Elasticsearch (v5.3.3) sink end-to-end test > --- > > Key: FLINK-26524 > URL: https://issues.apache.org/jira/browse/FLINK-26524 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch >Affects Versions: 1.14.3 >Reporter: Matthias Pohl >Priority: Critical > Labels: test-stability > Fix For: 1.14.4 > > > e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this > build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] > on {{master}} probably because of the following stacktrace showing up in the > logs: > {code} > Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN > org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to > trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive > failed attempts so far) > Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: > Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > [?:1.8.0_322] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > [?:1.8.0_322] > Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] > Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task > name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: > Unnamed (1/1)#0 Failure reason: Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1389) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1382) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.triggerCheckpointBarrier(Task.java:1348) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskexecutor.TaskExecutor.triggerCheckpoint(TaskExecutor.java:956) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) ~[?:1.8.0_322] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26524: -- Priority: Critical (was: Major) > Elasticsearch (v5.3.3) sink end-to-end test > --- > > Key: FLINK-26524 > URL: https://issues.apache.org/jira/browse/FLINK-26524 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Critical > Labels: test-stability > > e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this > build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] > on {{master}} probably because of the following stacktrace showing up in the > logs: > {code} > Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN > org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to > trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive > failed attempts so far) > Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: > Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > [?:1.8.0_322] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > [?:1.8.0_322] > Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] > Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task > name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: > Unnamed (1/1)#0 Failure reason: Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1389) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1382) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.triggerCheckpointBarrier(Task.java:1348) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskexecutor.TaskExecutor.triggerCheckpoint(TaskExecutor.java:956) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) ~[?:1.8.0_322] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26524: -- Labels: test-stability (was: ) > Elasticsearch (v5.3.3) sink end-to-end test > --- > > Key: FLINK-26524 > URL: https://issues.apache.org/jira/browse/FLINK-26524 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Major > Labels: test-stability > > e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this > build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] > on {{master}} probably because of the following stacktrace showing up in the > logs: > {code} > Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN > org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to > trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive > failed attempts so far) > Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: > Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > [?:1.8.0_322] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > [?:1.8.0_322] > Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] > Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task > name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: > Unnamed (1/1)#0 Failure reason: Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1389) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1382) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.triggerCheckpointBarrier(Task.java:1348) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskexecutor.TaskExecutor.triggerCheckpoint(TaskExecutor.java:956) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) ~[?:1.8.0_322] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26524: -- Fix Version/s: 1.15.0 > Elasticsearch (v5.3.3) sink end-to-end test > --- > > Key: FLINK-26524 > URL: https://issues.apache.org/jira/browse/FLINK-26524 > Project: Flink > Issue Type: Bug > Components: Connectors / ElasticSearch >Affects Versions: 1.15.0 >Reporter: Matthias Pohl >Priority: Critical > Labels: test-stability > Fix For: 1.15.0 > > > e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this > build|https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32627=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=070ff179-953e-5bda-71fa-d6599415701c=16598] > on {{master}} probably because of the following stacktrace showing up in the > logs: > {code} > Mar 07 15:40:41 2022-03-07 15:40:40,336 WARN > org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to > trigger checkpoint 1 for job 3a2fd4c6fb03d5b20929a6f2b7131d82. (0 consecutive > failed attempts so far) > Mar 07 15:40:41 org.apache.flink.runtime.checkpoint.CheckpointException: > Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.messages.checkpoint.SerializedCheckpointException.unwrap(SerializedCheckpointException.java:51) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveDeclineMessage(CheckpointCoordinator.java:988) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$declineCheckpoint$2(ExecutionGraphHandler.java:103) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$3(ExecutionGraphHandler.java:119) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > [?:1.8.0_322] > Mar 07 15:40:41 at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > [?:1.8.0_322] > Mar 07 15:40:41 at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322] > Mar 07 15:40:41 Caused by: org.apache.flink.util.SerializedThrowable: Task > name with subtask : Source: Sequence Source (Deprecated) -> Flat Map -> Sink: > Unnamed (1/1)#0 Failure reason: Checkpoint was declined (task is closing) > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1389) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.declineCheckpoint(Task.java:1382) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskmanager.Task.triggerCheckpointBarrier(Task.java:1348) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at > org.apache.flink.runtime.taskexecutor.TaskExecutor.triggerCheckpoint(TaskExecutor.java:956) > ~[flink-dist_2.11-1.14-SNAPSHOT.jar:1.14-SNAPSHOT] > Mar 07 15:40:41 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native > Method) ~[?:1.8.0_322] > {code} -- This message was sent by Atlassian Jira (v8.20.1#820001)