Error reported when using FlinkCDC full library synchronization function

Search before asking

[X] I had searched in the issues and found no similar issues.

What happened
版本   dinky1.0.0 flink1.17.2
使用整库同步功能代码
EXECUTE CDCSOURCE demo_print WITH (
'connector' = 'mysql-cdc',
'hostname' = 'bd1',
'port' = '3306',
'username' = 'root',
'password' = 'xxxxx',
'checkpoint' = '10000',
'scan.startup.mode' = 'initial',
'parallelism' = '1',
'table-name' = 'test1.student',
'sink.connector' = 'print'
);
What you expected to happen
2024-01-09 09:42:39,124 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_1) switched from CREATED to SCHEDULED.
2024-01-09 09:42:39,124 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_1) switched from CREATED to SCHEDULED.
2024-01-09 09:42:39,126 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Received resource requirements from job a5ab5a452ec08cd4ac3354897f00182e: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2024-01-09 09:42:39,127 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:39,127 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (attempt #1) with attempt id 81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_1 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:39,127 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_1) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:39,128 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (attempt #1) with attempt id 81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_1 and vertex id f6dc7f4d2283f4605b127b9364e21148_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:39,128 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_1) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:39,129 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying SinkMaterializer[4] -> Sink: student[4] (1/1) (attempt #1) with attempt id 81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_1 and vertex id ac517e93166644a0922111980a6172f5_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:39,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:39,150 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_1) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:39,162 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from INITIALIZING to FAILED on container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286).
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function.
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:405) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:837) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:804) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:793) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:793) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:199) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.(RegularOperatorChain.java:60) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:688) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:675) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:921) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) ~[flink-dist-1.17.2.jar:1.17.2]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_181]
Caused by: java.lang.ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.userFunction of type org.apache.flink.api.common.functions.Function in instance of org.apache.flink.streaming.api.operators.StreamFlatMap
at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2287) ~[?:1.8.0_181]
at java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1417) ~[?:1.8.0_181]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2293) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_181]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431) ~[?:1.8.0_181]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:534) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:522) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:476) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:389) ~[flink-dist-1.17.2.jar:1.17.2]
... 16 more
2024-01-09 09:42:39,165 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 3 tasks will be restarted to recover the failed task 81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_1.
2024-01-09 09:42:39,165 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job demo1 (a5ab5a452ec08cd4ac3354897f00182e) switched from state RUNNING to RESTARTING.
2024-01-09 09:42:39,165 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_1) switched from INITIALIZING to CANCELING.
2024-01-09 09:42:39,166 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_1) switched from DEPLOYING to CANCELING.
2024-01-09 09:42:39,166 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#1) of source Source: MySQL CDC Source.
2024-01-09 09:42:39,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_1) switched from CANCELING to CANCELED.
2024-01-09 09:42:39,364 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_1) switched from CANCELING to CANCELED.
2024-01-09 09:42:39,365 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Clearing resource requirements of job a5ab5a452ec08cd4ac3354897f00182e
2024-01-09 09:42:40,167 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job demo1 (a5ab5a452ec08cd4ac3354897f00182e) switched from state RESTARTING to RUNNING.
2024-01-09 09:42:40,168 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2024-01-09 09:42:40,168 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: MySQL CDC Source to checkpoint.
2024-01-09 09:42:40,168 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from CREATED to SCHEDULED.
2024-01-09 09:42:40,168 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_2) switched from CREATED to SCHEDULED.
2024-01-09 09:42:40,168 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_2) switched from CREATED to SCHEDULED.
2024-01-09 09:42:40,169 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Received resource requirements from job a5ab5a452ec08cd4ac3354897f00182e: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2024-01-09 09:42:40,169 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:40,170 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (attempt #2) with attempt id 81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_2 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:40,170 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_2) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:40,170 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (attempt #2) with attempt id 81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_2 and vertex id f6dc7f4d2283f4605b127b9364e21148_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:40,172 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_2) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:40,173 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying SinkMaterializer[4] -> Sink: student[4] (1/1) (attempt #2) with attempt id 81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_2 and vertex id ac517e93166644a0922111980a6172f5_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:40,194 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:40,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_2) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:40,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_2) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:40,217 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_2) switched from INITIALIZING to RUNNING.
2024-01-09 09:42:40,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from INITIALIZING to FAILED on container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286).
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function.
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:405) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:837) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:804) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:793) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:793) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:199) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.(RegularOperatorChain.java:60) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:688) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:675) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:921) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) ~[flink-dist-1.17.2.jar:1.17.2]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_181]
Caused by: java.lang.ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.userFunction of type org.apache.flink.api.common.functions.Function in instance of org.apache.flink.streaming.api.operators.StreamFlatMap
at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2287) ~[?:1.8.0_181]
at java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1417) ~[?:1.8.0_181]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2293) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_181]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431) ~[?:1.8.0_181]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:534) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:522) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:476) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:389) ~[flink-dist-1.17.2.jar:1.17.2]
... 16 more
2024-01-09 09:42:40,229 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 3 tasks will be restarted to recover the failed task 81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_2.
2024-01-09 09:42:40,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job demo1 (a5ab5a452ec08cd4ac3354897f00182e) switched from state RUNNING to RESTARTING.
2024-01-09 09:42:40,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_2) switched from INITIALIZING to CANCELING.
2024-01-09 09:42:40,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_2) switched from RUNNING to CANCELING.
2024-01-09 09:42:40,231 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#2) of source Source: MySQL CDC Source.
2024-01-09 09:42:40,247 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_2) switched from CANCELING to CANCELED.
2024-01-09 09:42:40,258 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_2) switched from CANCELING to CANCELED.
2024-01-09 09:42:40,258 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Clearing resource requirements of job a5ab5a452ec08cd4ac3354897f00182e
2024-01-09 09:42:41,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job demo1 (a5ab5a452ec08cd4ac3354897f00182e) switched from state RESTARTING to RUNNING.
2024-01-09 09:42:41,232 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2024-01-09 09:42:41,232 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: MySQL CDC Source to checkpoint.
2024-01-09 09:42:41,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from CREATED to SCHEDULED.
2024-01-09 09:42:41,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_3) switched from CREATED to SCHEDULED.
2024-01-09 09:42:41,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_3) switched from CREATED to SCHEDULED.
2024-01-09 09:42:41,234 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Received resource requirements from job a5ab5a452ec08cd4ac3354897f00182e: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2024-01-09 09:42:41,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:41,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (attempt #3) with attempt id 81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_3 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:41,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_3) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:41,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (attempt #3) with attempt id 81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_3 and vertex id f6dc7f4d2283f4605b127b9364e21148_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:41,235 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_3) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:41,235 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying SinkMaterializer[4] -> Sink: student[4] (1/1) (attempt #3) with attempt id 81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_3 and vertex id ac517e93166644a0922111980a6172f5_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:41,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:41,260 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_3) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:41,271 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from INITIALIZING to FAILED on container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286).
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function.
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:405) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:837) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:804) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:793) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:793) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:199) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.(RegularOperatorChain.java:60) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:688) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:675) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:921) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) ~[flink-dist-1.17.2.jar:1.17.2]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_181]
Caused by: java.lang.ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.userFunction of type org.apache.flink.api.common.functions.Function in instance of org.apache.flink.streaming.api.operators.StreamFlatMap
at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2287) ~[?:1.8.0_181]
at java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1417) ~[?:1.8.0_181]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2293) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_181]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431) ~[?:1.8.0_181]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:534) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:522) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:476) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:389) ~[flink-dist-1.17.2.jar:1.17.2]
... 16 more
2024-01-09 09:42:41,275 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#3) of source Source: MySQL CDC Source.
2024-01-09 09:42:41,275 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 3 tasks will be restarted to recover the failed task 81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_3.
2024-01-09 09:42:41,275 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job demo1 (a5ab5a452ec08cd4ac3354897f00182e) switched from state RUNNING to RESTARTING.
2024-01-09 09:42:41,275 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_3) switched from INITIALIZING to CANCELING.
2024-01-09 09:42:41,276 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_3) switched from DEPLOYING to CANCELING.
2024-01-09 09:42:41,332 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_3) switched from CANCELING to CANCELED.
2024-01-09 09:42:41,339 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_3) switched from CANCELING to CANCELED.
2024-01-09 09:42:41,340 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Clearing resource requirements of job a5ab5a452ec08cd4ac3354897f00182e
2024-01-09 09:42:42,277 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job demo1 (a5ab5a452ec08cd4ac3354897f00182e) switched from state RESTARTING to RUNNING.
2024-01-09 09:42:42,277 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2024-01-09 09:42:42,278 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: MySQL CDC Source to checkpoint.
2024-01-09 09:42:42,278 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from CREATED to SCHEDULED.
2024-01-09 09:42:42,278 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_4) switched from CREATED to SCHEDULED.
2024-01-09 09:42:42,278 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_4) switched from CREATED to SCHEDULED.
2024-01-09 09:42:42,279 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Received resource requirements from job a5ab5a452ec08cd4ac3354897f00182e: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2024-01-09 09:42:42,279 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:42,279 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (attempt #4) with attempt id 81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_4 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:42,279 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_4) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:42,279 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (attempt #4) with attempt id 81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_4 and vertex id f6dc7f4d2283f4605b127b9364e21148_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:42,281 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_4) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:42,281 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying SinkMaterializer[4] -> Sink: student[4] (1/1) (attempt #4) with attempt id 81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_4 and vertex id ac517e93166644a0922111980a6172f5_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:42,300 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:42,303 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_4) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:42,318 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_4) switched from INITIALIZING to RUNNING.
2024-01-09 09:42:42,319 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_4) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:42,341 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from INITIALIZING to FAILED on container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286).
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function.
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:405) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:837) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:804) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:793) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:793) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:199) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.(RegularOperatorChain.java:60) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:688) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:675) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:921) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) ~[flink-dist-1.17.2.jar:1.17.2]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_181]
Caused by: java.lang.ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.userFunction of type org.apache.flink.api.common.functions.Function in instance of org.apache.flink.streaming.api.operators.StreamFlatMap
at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2287) ~[?:1.8.0_181]
at java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1417) ~[?:1.8.0_181]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2293) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_181]
at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2287) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2211) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2069) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1573) ~[?:1.8.0_181]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:431) ~[?:1.8.0_181]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:534) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:522) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:476) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:389) ~[flink-dist-1.17.2.jar:1.17.2]
... 16 more
2024-01-09 09:42:42,343 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 3 tasks will be restarted to recover the failed task 81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_4.
2024-01-09 09:42:42,343 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job demo1 (a5ab5a452ec08cd4ac3354897f00182e) switched from state RUNNING to RESTARTING.
2024-01-09 09:42:42,343 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_4) switched from INITIALIZING to CANCELING.
2024-01-09 09:42:42,343 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_4) switched from RUNNING to CANCELING.
2024-01-09 09:42:42,353 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#4) of source Source: MySQL CDC Source.
2024-01-09 09:42:42,428 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_4) switched from CANCELING to CANCELED.
2024-01-09 09:42:42,429 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_4) switched from CANCELING to CANCELED.
2024-01-09 09:42:42,430 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Clearing resource requirements of job a5ab5a452ec08cd4ac3354897f00182e
2024-01-09 09:42:43,345 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job demo1 (a5ab5a452ec08cd4ac3354897f00182e) switched from state RESTARTING to RUNNING.
2024-01-09 09:42:43,345 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2024-01-09 09:42:43,345 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: MySQL CDC Source to checkpoint.
2024-01-09 09:42:43,346 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_5) switched from CREATED to SCHEDULED.
2024-01-09 09:42:43,346 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_5) switched from CREATED to SCHEDULED.
2024-01-09 09:42:43,346 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_5) switched from CREATED to SCHEDULED.
2024-01-09 09:42:43,347 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_5) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:43,347 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (attempt #5) with attempt id 81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_5 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:43,347 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_5) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:43,347 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (attempt #5) with attempt id 81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_5 and vertex id f6dc7f4d2283f4605b127b9364e21148_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:43,347 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Received resource requirements from job a5ab5a452ec08cd4ac3354897f00182e: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2024-01-09 09:42:43,348 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_5) switched from SCHEDULED to DEPLOYING.
2024-01-09 09:42:43,348 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying SinkMaterializer[4] -> Sink: student[4] (1/1) (attempt #5) with attempt id 81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_5 and vertex id ac517e93166644a0922111980a6172f5_0 to container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286) with allocation id 706e696f295daa876866ebce50576691
2024-01-09 09:42:43,368 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_5) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:43,372 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - SinkMaterializer[4] -> Sink: student[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_ac517e93166644a0922111980a6172f5_0_5) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:43,376 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - anonymous_datastream_source$2[3] -> ConstraintEnforcer[4] (1/1) (81f0b2217f899cd60a2953578f5e782a_f6dc7f4d2283f4605b127b9364e21148_0_5) switched from DEPLOYING to INITIALIZING.
2024-01-09 09:42:43,381 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: MySQL CDC Source -> Map -> Process -> Flat Map (1/1) (81f0b2217f899cd60a2953578f5e782a_cbc357ccb763df2852fee8c4fc7d55f2_0_5) switched from INITIALIZING to FAILED on container_e02_1702977012832_0303_01_000002 @ bd5 (dataPort=42286).
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function.
at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:405) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:837) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:804) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:793) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:793) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:722) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.OperatorChain.(OperatorChain.java:199) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.(RegularOperatorChain.java:60) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:688) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:675) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:952) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:921) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:745) ~[flink-dist-1.17.2.jar:1.17.2]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) ~[flink-dist-1.17.2.jar:1.17.2]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_181]
Caused by: java.lang.ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.userFunction of type
How to reproduce
版本采用dinky1.0.0，使用整库同步功能同步mysql数据，用yarn-session模式提交任务即可复现
Anything else
此问题每次都发生，并且在沟通群里，发现很多同事也遇到此问题。
Version
1.0.0
Are you willing to submit PR?

[X] Yes I am willing to submit a PR!

Code of Conduct

[X] I agree to follow this project's Code of Conduct

It's a compile bug, we will fix it.

这个问题解决了吗？  我也遇到了这个问题 从mysqlcdc 到mysql 整库同步时

这个问题解决了吗？ 我用dinky的整库同步功能从mysqlcdc 到doris时会报这个异常。

整库同步到paimon,也会报这个错误，忘尽快解决一下，或者回复一下解决方案 @aiwenmo

这个问题来源已找到，缺包导致的此异常，该异常无发从JobManager看完整，请在taskmanager看全日志报错信息，新的rc4版本在flink集群上添加dinky-app.jar即可解决。
以下才是真正的异常错误信息：

@zackyoungh
我升级到了rc4 的版本 执行还有相应的错误 下面是我的错误信息和lib 截图
flink  1.16.3
dinky  1.0.0 rc4
这是flink 的报错信息
2024-01-31 13:51:43
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function.
	at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:399)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:763)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:736)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:676)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:726)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:676)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:726)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:676)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:195)
	at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.<init>(RegularOperatorChain.java:60)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:685)
	at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:672)
	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:904)
	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
	at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassCastException: cannot assign instance of java.lang.invoke.SerializedLambda to field org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.userFunction of type org.apache.flink.api.common.functions.Function in instance of org.apache.flink.streaming.api.operators.StreamFlatMap
	at java.io.ObjectStreamClass$FieldReflector.setObjFieldValues(ObjectStreamClass.java:2133)
	at java.io.ObjectStreamClass.setObjFieldValues(ObjectStreamClass.java:1305)
	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2251)
	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2169)
	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2027)
	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
	at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2245)
	at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2169)
	at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2027)
	at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1535)
	at java.io.ObjectInputStream.readObject(ObjectInputStream.java:422)
	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:617)
	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:602)
	at org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:589)
	at org.apache.flink.util.InstantiationUtil.readObjectFromConfig(InstantiationUtil.java:543)
	at org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperatorFactory(StreamConfig.java:383)
	... 16 more

这是flink 的lib

Dinky v1.0.0 Release中仍有此错误.
需要将${dinky-home}/jar下dinky-app-1.18-1.0.0-jar-with-dependencies.jar 复制到${flinkhome}/lib下才行

已接受到你的信息或文件


Wait loops are asking for off-by-one errors

1.upto(WAIT_ATTEMPTS) do |try|
        fail('Giving up') if try >= WAIT_ATTEMPTS

The loop should be infinite. Otherwise if someone forgets the '=' we'll still escape the loop even in the error state.

fixed


[Rendering] No horizontal scroll teams desktop application

Target Platforms
Other
SDK Version
1.5
Application Name
Microsoft Teams
Problem Description
With recent teams update, there is no more horizontal scroll appearing in adaptive cards.
I am using table component and users cannot horizontally scroll to see further data.
In old version of teams, scroll is there. (But 1st of July old teams will be completely deprecated)
Screenshots

Card JSON
I can't provide.

Sample Code Language
No response
Sample Code
No response

Adaptive Cards is now a semi private repo

Pull requests and issue creations will no longer be accepted and will be closed. Please send all issues with Adaptive Cards to Microsoft Teams docs repo (msteams-docs)
Issues will be reviewed and prioritized from there
Source code will still be available to the public.
Packages will still be posted to the public.


Backspace not working with several input method

React-simple-keyboard version
I'm using react-simple-keyboard ->  1.14.1 and I've following this link to handle multiple inputs. Everything works fine unless backspace button doesn't return any response from onChange function
For now, I must click on an input again then backspace will be working.
any help or suggestion?
Screenshots

Hello @NSLog0,
I've tweaked a bit the demo and added it to a sandbox.
Here's the link:
https://codesandbox.io/s/github/hodgef/react-simple-keyboard-demos/tree/uc-multiple-inputs/
If that sandbox doesn't fix your issue, please let me know and I'll reopen the ticket. I will need to reproduce the issue so if you share a new sandbox with the issue it will help a lot.
Regards,
Francisco Hodge

Hello @hodgef ,
Thank you for support. I can't fix the problem and I create a sandbox https://codesandbox.io/s/7kz33ylkj1 , Could you please check it
The project structure, I split all the file and use import to compose it like my local project

Hey @NSLog0, your example seems to be missing a few things from the sandbox I shared.
Basically, you need to set the inputName option in simple-keyboard and call setInput on input change.
Also, it seems you are destroying the keyboard instance every time you set this.state.keyboardOn. This also destroys the internal keyboard input. I think you should rather hide the keyboard through CSS.
Here's a modified sandbox, hope it helps.
https://codesandbox.io/s/kkn757p1nv
As usual, let me know if you have issues and I'll reopen the thread
Francisco Hodge


Restarting a vm with microk8s erases data

I have a question about the lifecycle of microk8s data. I use microk8s with kubeflow enabled, and I tried to upload a bunch of files in Minio and also add some kubeflow experiments.
I am able to consistently replicate that a vm reboot erases minio / kubeflow experiments data. Is this by design, or I messed something up at configuration level?
I would kindly request some assistance into how I could make minio / kubeflow data persistent, since my only input was microk8s enable kubeflow to get all of these.

Attaching persistent volumes screenshot.
It seems like the dynamically created persistent volumes contain delete reclaim policy. I would like to know the best practice for keeping data intact, and also if there's any chance to configure persistent volumes size while enabling kubeflow, since I guess they use some defaults.

As you detected it, the default microk8s storageclass microk8s-hostpath  has a reclaim policy set to Delete. I think that you can either patch the storageclass or edit file  /snap/microk8s/current/actions/storage.yaml before enabling kubeflow.

is there any example of how to do that? @polyedre  thanks for your response!

Maybe the easiest way to do so in your case could be to modify the applied yaml file before enabling the plugin. For example with a sed ?
An alternative could be to add an argument to the plugin (as it is done with built-in registry: microk8s enable registry:size=40Gi).
Something like:
microk8s enable storage:reclaim_policy=persistent

Thanks, we changed reclaim policy and everything was fine afterwards.


add Haxe support

Haxe plugin https://marketplace.visualstudio.com/items?itemName=nadako.vshaxe
More info about haxe language http://haxe.org/
Haxe docset https://github.com/Kapeli/Dash-User-Contributions/tree/master/docsets/Haxe

Coverage remained the same at 100.0% when pulling c48c40847833523ba844e139f7f3b3492fea324f on profelis:master into 708775894bc81d4c42cd389b8fdd2394efd0d9dc on deerawan:master.

Coverage remained the same at 100.0% when pulling 8500602b82aa7064412037afa5194061444dcda7 on profelis:master into 708775894bc81d4c42cd389b8fdd2394efd0d9dc on deerawan:master.

@profelis Thank you for your contribution 👍


Use AST module to provide hints for exercises

When we evaluate a cell, we could check for some of the most common mistakes that aren't syntax-related.
Example we saw during the course:

Assigning a new constant value to the  the function input variables
Printing as a last statement in the function body
Missing return statement
Returning a "print" statement
Returning None

I think this discussion can be merged with/continued in #68


TABConf Lightning Socratic Seminar

Welcome
Hello Bitcoiners! This is where we'll organize the topics of discussion for our upcoming Socratic Seminar.
Please use this issue to suggest topics that you'd like to see discussed at the seminar. To suggest a topic, simply add a new comment to this issue with the topic title as the comment's title.
As we work through organizing the topics, feel free to edit and update your comments as needed. This will help us keep everything organized and easy to follow.
To help get us started, here are some main topics of discussion that we could consider:

Bitcoin Core
Lightning Network
Scaling
Privacy
Media
Miscellaneous

Remember, this is Bitcoin only, do not post about your favorite clown-coin.
Thank you for your contributions and we look forward to a great seminar!

Splicing merged into CLN
https://github.com/ElementsProject/lightning/pull/6253
10101.finance is building DLCs on lightning
https://10101.finance/blog/dlc-to-lightning-part-1/
https://10101.finance/blog/dlc-to-lightning-part-2/
https://10101.finance/blog/dlc-to-lightning-part-3/
Blockstream Greenlight launches, a low-resource non-custodial cloud node service
https://blog.blockstream.com/greenlight-by-blockstream-scalable-non-custodial-lightning-infrastructure-now-open-to-developers/
is there a better, or more recent article or blog post?

How the Voltage LSP Enhances Privacy for Mutiny Wallet Users
https://blog.mutinywallet.com/enhanced-lightning-privacy-for-mutiny-users/

@arik-so: https://lists.linuxfoundation.org/pipermail/lightning-dev/2023-September/004088.html

https://ellemouton.com/posts/normal-operation-pre-taproot/

https://voltage.cloud/blog/lightning-network-use-cases/taproot-assets-on-bitcoin-and-lightning-network/

blatantly stolen directly from bitcoin optech...open source woo!
LND v0.17.0-beta.rc2 is a release candidate for the next major version of this popular LN node implementation. A major new experimental feature planned for this release, which could likely benefit from testing, is support for “simple taproot channels”.
LDK #2468 allows users to provide a payment_id which is encrypted in an invoice request’s metadata field. LDK checks the metadata in received invoices and will only pay if it recognizes the id and hasn’t already paid another invoice for it. This PR is part of LDK’s work toward implementing BOLT12.

@arik-so https://msrc.microsoft.com/blog/2023/09/results-of-major-technical-investigations-for-storm-0558-key-acquisition/
@arik-so https://gist.github.com/arik-so/2d228c3046c65ce2f73ee9c9ac819ce0


add simple example

Add a first, super-simple example of a u,v parametric equation and show how it goes from Grapher to Numpy.

subtask:#3

Subtasks:

[ ] #3
[ ] #4
[ ] #5
[ ] #6
[ ] #7
[ ] #8


Examples/anything for R

Hi,
Apologies if I've missed an obvious link somewhere describing how this works.
The recent developments mention making the widgets available to other kernels, but I've not found any examples. I'm specifically interested in R. If it isn't ready to go yet, what needs to be done/written/fixed etc.
Thanks

ipywidgets depend on the ipython kernel, so they don't work with IRkernel. However, I found a couple links that might help:

Using Plotly widgets with IRkernel: https://plot.ly/r/using-r-in-jupyter-notebooks/
Using declarative-widgets with IRkernel: https://github.com/jupyter-incubator/declarativewidgets

I guess I was chasing the status of R support mentioned in 5th paragraph of this post:
http://blog.jupyter.org/2016/04/22/ipywidgets5/
FYI - we're trying to produce some commonish notebooks for python and R for the simpleITK project.

The decoupling of jupyter-js-widgets allows kernel authors (and others) to make use of this client-side code to create things like ipywidgets for other kernels, although I don't think anything for R is available yet. It looks like declarativewidgets uses a very small part. I would suggest taking a look at declarativewidgets as they work with IPython and IRkernel.

Thanks - will do


Close project files after reading them in Core

Many unit tests were failing on .NET Core because of a subtle difference
in behavior between the XmlTextReader we use on full framework and the
XmlReader we use in its absence--when disposed, XmlTextReader closed the
file, while XmlReader does so only when told to do so explicitly.
Since project files were still open, unit test cleanup that attempted to
delete the test project files was failing with a file-in-use
IOException.  That's bad, but more generally we shouldn't hold a lock on
the files for longer than we need to, so we should match the
full-framework behavior.
This reduces test failures in Engine from 241 to 179.

Looks good. I would add a comment to indicate what that flag actually does.


Search for health professionals

Describe the solution you'd like

Registry can be queried by name
Search results should list all members by name and associated clinics by default
It should be possible to add other search terms as needed, e.g. specialization, location

Additional context
Add any other context or screenshots about the feature request here.

+1 for this feature :D
It would be great to see a search interface with some styling here. Perhaps you could make this a priority? The search doesn't necessarily have to be advanced, it's more important to have it look good: Form over function. :laughing:


Fix cargo build directory to libindy

Build from where cargo build can find Cargo.toml

 Thank you for your submission, we really appreciate it. Like many open source projects, we ask that you sign our Contributor License Agreement before we can accept your contribution.You have signed the CLA already but the status is still pending? Let us recheck it.


swift: fix hardeningCFlags

Description of changes
Accidentally stumbled upon a stray reference to hardeningCFlags in swift's wrapper.sh. Those had been renamed / split into hardeningCFlagsBefore and hardeningCFlagsAfter in #246244. I can't find any other references to hardeningCFlags in nixpkgs, so I assume it's the same variable and swift never got the memo.
While this change seems to make sense to me, it makes building swift fail with a segmentation fault. No idea or intention to continue here myself, I'm not using swift. @dduan @stephank @trepetti @Trundle can anyone have a look at this?
Things done

Built on platform(s)

[ ] x86_64-linux
[ ] aarch64-linux
[ ] x86_64-darwin
[ ] aarch64-darwin

For non-Linux: Is sandboxing enabled in nix.conf? (See Nix manual)

[ ] sandbox = relaxed
[ ] sandbox = true

[ ] Tested, as applicable:

NixOS test(s) (look inside nixos/tests)
and/or package tests
or, for functions and "core" functionality, tests in lib/tests or pkgs/test
made sure NixOS tests are linked to the relevant packages

[ ] Tested compilation of all packages that depend on this change using nix-shell -p nixpkgs-review --run "nixpkgs-review rev HEAD". Note: all changes have to be committed, also see nixpkgs-review usage
[ ] Tested basic functionality of all binary files (usually in ./result/bin/)
24.11 Release Notes (or backporting 23.11 and 24.05 Release notes)

[ ] (Package updates) Added a release notes entry if the change is major or breaking
[ ] (Module updates) Added a release notes entry if the change is significant
[ ] (Module addition) Added a release notes entry if adding a new NixOS module

[ ] Fits CONTRIBUTING.md.

Add a :+1: reaction to pull requests you find important.

I don't think the variables used inside cc-wrapper were ever intended as an external interface and it surprises me that something was doing this. Also have no idea about swift, but you may get better information about what's going on by using the NIX_DEBUG env var.

Thanks. The Swift wrapper is somewhat awkwardly forked from cc-wrapper, so I think there are a lot of issues like this. Probably we will either have to teach cc-wrapper about Swift or otherwise detach it more fully.


Speed-up HTTP 1.1 header and line parsing

Motivation:
Http content parsing is making use of bi-morphic inheritance and loop fusion to improve performance: both
are not working as expected.
Modifications:
Splitting (CR)LF parsing into SWAR + copy loops ie loop fission
and saving LineParser to inherit HeaderParser
Result:
Parsing speedup

These are my early results, but feel free to point me any other HTTP header parsing intensive benchmark,
4.1:
Benchmark                                                                              (step)   Mode  Cnt      Score      Error  Units
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters            2  thrpt   10   7417.600 ±  585.303  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters:·asm       2  thrpt             NaN               ---
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters            4  thrpt   10  11726.992 ±  385.804  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters:·asm       4  thrpt             NaN               ---
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters            8  thrpt   10  15545.752 ±  454.380  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters:·asm       8  thrpt             NaN               ---
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters           16  thrpt   10  18464.836 ±  699.593  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters:·asm      16  thrpt             NaN               ---
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters           32  thrpt   10  19669.667 ± 3289.623  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters:·asm      32  thrpt             NaN               ---

this PR:
Benchmark                                                                              (step)   Mode  Cnt      Score      Error  Units
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters            2  thrpt   10   8596.119 ±  340.640  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters:·asm       2  thrpt             NaN               ---
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters            4  thrpt   10  12566.280 ±  383.398  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters:·asm       4  thrpt             NaN               ---
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters            8  thrpt   10  17125.243 ±  158.794  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters:·asm       8  thrpt             NaN               ---
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters           16  thrpt   10  19737.088 ± 1065.066  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters:·asm      16  thrpt             NaN               ---
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters           32  thrpt   10  21936.390 ±  438.841  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters:·asm      32  thrpt             NaN               ---

I need to check the ASM of the new methods (including SWAR) yet (that's why is still a DRAFT)

Re-running builds. Autobahn got stuck and killed after 5 hours. (Which may or may not be a bad sign… haven't seen Autobahn get stuck like that on other PRs that I recall.)

Got again stuck... @franz1981 seems like there is something wrong ?

Got again stuck... @franz1981 seems like there is something wrong ?

Investigating right now: I've tried hard to make the new code to work exactly the same as the previous one, but found weird things related size change and I'm not familiar with the purpose of the code itself :/
Will try to get to the top of it, but not having any failed existing test means that there's something we're not covering (escplicitely)

@normanmaurer
last build failed with jdk 11 and got cancelled here
2022-04-21T00:30:38.9418372Z 00:30:38.940 [main] INFO  i.n.c.e.EpollSocketShutdownOutputBySelfTest - Running: testShutdownOutput 1 of 2 with UnpooledByteBufAllocator
2022-04-21T00:30:38.9428094Z 00:30:38.942 [testsuite-epoll-worker-11-1] DEBUG i.n.channel.DefaultChannelPipeline - Discarded inbound message AdvancedLeakAwareByteBuf(PooledUnsafeDirectByteBuf(ridx: 0, widx: 1, cap: 64)) that reached at the tail of the pipeline. Please check your pipeline configuration.
2022-04-21T00:30:38.9429628Z 00:30:38.942 [testsuite-epoll-worker-11-1] DEBUG i.n.channel.DefaultChannelPipeline - Discarded message pipeline : [ChannelInboundHandlerAdapter#0, DefaultChannelPipeline$TailContext#0]. Channel : [id: 0x64cf054c, L:/<IP_ADDRESS>:35470 ! R:<IP_ADDRESS>/<IP_ADDRESS>:36221].
2022-04-21T00:30:40.9054161Z 00:30:40.904 [epollEventLoopGroup-34-1] DEBUG io.netty.buffer.PoolThreadCache - Freed 1 thread-local buffer(s) from thread: epollEventLoopGroup-34-1
2022-04-21T00:30:40.9057481Z 00:30:40.904 [epollEventLoopGroup-36-2] DEBUG io.netty.buffer.PoolThreadCache - Freed 1 thread-local buffer(s) from thread: epollEventLoopGroup-36-2
2022-04-21T00:30:40.9058821Z 00:30:40.904 [epollEventLoopGroup-36-1] DEBUG io.netty.buffer.PoolThreadCache - Freed 1 thread-local buffer(s) from thread: epollEventLoopGroup-36-1
2022-04-21T00:30:40.9060084Z 00:30:40.905 [epollEventLoopGroup-34-2] DEBUG io.netty.buffer.PoolThreadCache - Freed 1 thread-local buffer(s) from thread: epollEventLoopGroup-34-2
2022-04-21T00:30:40.9083363Z 00:30:40.907 [epollEventLoopGroup-38-1] DEBUG io.netty.buffer.PoolThreadCache - Freed 1 thread-local buffer(s) from thread: epollEventLoopGroup-38-1
2022-04-21T00:30:40.9159906Z 00:30:40.915 [epollEventLoopGroup-40-1] DEBUG io.netty.buffer.PoolThreadCache - Freed 1 thread-local buffer(s) from thread: epollEventLoopGroup-40-1
2022-04-21T05:22:29.3824396Z ##[error]The operation was canceled.

Let's see if I can reproduce the failure by doing the same

@normanmaurer running it from my branch (without leak detection) -> https://github.com/franz1981/netty/runs/6108265337?check_suite_focus=true
has worked fine with jdk 11, but I've found some weird thing the original code and maybe you can help me to understand if I should do the same for this PR; for HeaderParser
        @Override
        public boolean process(byte value) throws Exception {
            char nextByte = (char) (value & 0xFF);
            if (nextByte == HttpConstants.LF) {
                int len = seq.length();
                // Drop CR if we had a CRLF pair
                if (len >= 1 && seq.charAtUnsafe(len - 1) == HttpConstants.CR) {
                    -- size;
                    seq.setLength(len - 1);
                }
                return false;
            }

            increaseCount();

            seq.append(nextByte);
            return true;
        }

        protected final void increaseCount() {
            if (++ size > maxLength) {
                // TODO: Respond with Bad Request and discard the traffic
                //    or close the connection.
                //       No need to notify the upstream handlers - just log.
                //       If decoding a response, just throw an exception.
                throw newException(maxLength);
            }
        }

Due to the check for LF before incrementing count and the check for (++ size > maxLength), if the readable bytes in a buffer are 4 and max length is 3, but the last byte (buffer offset 3) is LF the parsing won't fail with TooLongHttpHeaderException :O
Meaning that we've parsed 4 bytes, exceeding the configured limit of 3: it looks like a subtle (maybe innocuous) bug, but am I suppose to do the same? :O

Summoning @trustin as well for https://github.com/netty/netty/pull/12321#issuecomment-1105026072

Hey, thanks for summoning, @franz1981. It indeed looks like a bug to me and we should count CR.

@franz1981 agree with @trustin here... Can you do an extra PR to fix this on the existing code for visibility ?

@franz1981 agree with @trustin here... Can you do an extra PR to fix this on the existing code for visibility ?

Yep, so, let me summarize in case I got it wrong: maxLength is shouldn't be evaluated against the number of read bytes, but against the resulting body
eg
 maxLength = 4096
 <body of 4096 bytes> \r\n = total 4098 bytes

and
 maxLength = 4096
 <body of 4096 bytes> \n = total 4097 bytes

should both worth without throwing any exception

This is still performing as good as https://github.com/netty/netty/pull/12321#issuecomment-1104153568 but I would like to run other benchmark(s) on it (end to end, possibly) @idelpivnitskiy anything in mind I can try?

Let's see @chrisvest if it's still failing on jdk 11 build :(

Checking
HttpRequestDecoderTest.testContentLengthAndTransferEncodingHeadersWithCR:516->testContentLengthAndTransferEncodingHeadersWithInvalidSeparator:529->testInvalidHeaders0:572->testInvalidHeaders0:577
failure

Adding same treatment for line parsing as well, results:
Benchmark                                                                                (step)   Mode  Cnt      Score     Error  Units
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters              2  thrpt   20   8811.375 ± 262.989  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters              4  thrpt   20  13051.612 ±  61.193  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters              8  thrpt   20  17298.027 ±  78.159  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters             16  thrpt   20  20127.898 ± 655.783  ops/s
HttpRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters             32  thrpt   20  22062.810 ± 516.576  ops/s

Slightly improved, Now running other frameworks (based on Netty, Vert-x @vietj ) to see if I got better/similar improvements

@normanmaurer I've decided to both fix and improve performance directly on this one; given that the logic is now slightly more complex; it would have been more complex to fix it twice TBH
Now looking at the assembly and LineParser to check if there's anything I've left that could improve further performance

The vtable here requires some investigation

I notice the original logic wasn't accounting for control characters inside body itself and I've left this behaviour the same.

Ok, it seems is not yet there uff (after introducing the line parsing(!))

Still working on this: running a different end 2 end test doesn't show the same (expected) improvement meaning that:

line/header parsing is not important as profiling data report shown (that's weird)
SWAR index of is not giving the expected improvement, because of predictable input pattern

I've been dragged by other perf issue so couldn't continue on it now - @idelpivnitskiy any change you taken a look at this already?

Many thanks @idelpivnitskiy indeed that was one of the other direction I was considering but I still see you can try as well a small change (consider that I just quick looked at the servicetalk impl) - https://github.com/apple/servicetalk/blob/11dd16a4c97a2d70f8ef0052c5b4b82aecea1321/servicetalk-http-netty/src/main/java/io/servicetalk/http/netty/HttpObjectDecoder.java#L907
Is using a byte processor while it can use the shiny new SWAR based indexOf I've implemented on ByteBuf.
In benchs you won't get huge improvement because of predictable LF positions, but on real world, yep.
Let me know if that works for you!

@franz1981 let me know once this is ready for review

@normanmaurer I've pushed other changes, inspired by ServiceTalk; given that slicing buffers is pretty costy due to the atomic instructions, I've preferred to use https://github.com/AdoptOpenJDK/openjdk-jdk11/blob/master/src/java.base/share/classes/java/lang/String.java#L380 at our advantage and leverage on the many intrinsics available to String.
The parser ascii buffer can be then be:

NIO  heap ByteBuffer(s) and just manually perform toString as new String(buffer.array(), ....)
Netty heap (unpooled) ByteBufs

And I've decided for the latter, but as soon as I'll run other perf tests I'll decided if switch to 1.
The changes could be already reviewed really, from a functional pov.
Thanks to loop fission (that's splitting the search part + copy as 2 separate operations) and changing into a byte[] backed buffer I can now benefit from batching for both (SWAR index of + copy ascii part is now a memcpy between direct -> heap memory)

@trustin @normanmaurer
I would like to replace the existing getChunkSize with
    private static int getChunkSize(byte[] hex, int length) {
        // hex shouldn't contain both ISO chars nor spaces
        int result = 0;
        for (int i = 0; i < length; i++) {
            final int digit = StringUtil.decodeHexNibble(hex[i]);
            if (digit == -1) {
                throw new NumberFormatException();
            }
            result *= 16;
            result += digit;
        }
        return result;
    }
    ```
that's using a lookup table for the hex digits, given that now we have a byte[] hex line (that shouldn't contains both whitespace nor ISO control chars according to the line parsing method.
wdyt?
It's not performing 2 things:
- it doesn't understand the `-` sign (while `Integer::parse` does), but that one shouldn't be legal and chunks sizes cannot be negatives
- it doesn't check vs negative results due to integer overflow

I can fix the latter if needed, I don't know

The last changes on this PR already deliver a nice speed up: plaintext of Techempower is now
4.1:
Requests/sec: 4689443.78
vs
this PR:
Requests/sec: 4816419.40

Trying the changes in our CI to see what's the perf increase, if any

@normanmaurer I've discovered the checkcast issue while trying to improve this; will get back to this once completed that one

@normanmaurer @chrisvest
Parking this till https://bugs.openjdk.org/browse/JDK-8295496 isn't solved -
this will make me decide if use a byte[] to accumulate lines/headers or use the previous one ie (appendable char thing)

Sorry @normanmaurer if it has taken me so long; today I'm fixing few things, including adding a benchmark and publishing results.
I'm not very proud nor happy of some changes but overall it deliver already a very good improvement. Will ping soon for a review

ok @normanmaurer @franz1981 and @idelpivnitskiy I've ready for another round of review
but let me show you first the results :)
I've modified the benchmarks in order to be less noisy (I've verified it by using async profiler and see what's going on under the hood):
on 4.1 now:
Benchmark                                                                                (direct)  (headerFragmentBytes)  (pooled)  (validateHeaders)   Mode  Cnt       Score      Error  Units
HttpFragmentedRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters             true                    128      true               true  thrpt   20  161623.000 ± 1673.380  ops/s
HttpFragmentedRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters             true                    128      true              false  thrpt   20  180905.629 ± 2170.629  ops/s

Benchmark                                                                                (direct)  (pipeline)  (pooled)  (validateHeaders)   Mode  Cnt      Score     Error  Units
HttpPipelinedRequestDecoderBenchmark.testDecodeWholePipelinedRequestMixedDelimiters             true          16      true               true  thrpt   20  17337.447 ± 243.611  ops/s
HttpPipelinedRequestDecoderBenchmark.testDecodeWholePipelinedRequestMixedDelimiters             true          16      true              false  thrpt   20  21638.195 ± 156.030  ops/s

while this PR at 2c1ac0300392c1fd56e5d600e0601e3505fa021f:
Benchmark                                                                                (direct)  (headerFragmentBytes)  (pooled)  (validateHeaders)   Mode  Cnt       Score       Error  Units
HttpFragmentedRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters             true                    128      true               true  thrpt   20  217749.025 ±  7146.787  ops/s
HttpFragmentedRequestDecoderBenchmark.testDecodeWholeRequestInMultipleStepsMixedDelimiters             true                    128      true              false  thrpt   20  245216.399 ± 19453.047  ops/s

Benchmark                                                                                (direct)  (pipeline)  (pooled)  (validateHeaders)   Mode  Cnt      Score      Error  Units
HttpPipelinedRequestDecoderBenchmark.testDecodeWholePipelinedRequestMixedDelimiters             true          16      true               true  thrpt   20  22973.653 ±  242.725  ops/s
HttpPipelinedRequestDecoderBenchmark.testDecodeWholePipelinedRequestMixedDelimiters             true          16      true              false  thrpt   20  27687.301 ± 2143.095  ops/s

The raw figure in a simple use case like this, shows benefits around 30% performance increase, but the reality is more interesting: the nice thing of using https://github.com/netty/netty/issues/10731 is that in a real world scenario (ie not both system nor micro benchs) the gap increase till becoming 50/70% depending on the use case.
The pipelining case is very artificial, on Http 1.1, but still representative of few workload.
Some end to end tests using https://github.com/eclipse-vertx/vert.x with https://www.techempower.com/'s PLAINTEXT shows this improvement (run by courtesy by @vietj):

where baseline is 4.1.86.Final,  netty parser is just 3abf18d26ae76763840c9a4e50b32a365cf9c6a3 and nettyparserpooling includes 43f48f7715766fc1112536a8d2da10b569f91f78.
I still have to run the full CI for vertx http too, but on Netty I was getting a green light.
I'm opened to many suggestions and the critical parts of this PR are indeed, related pooling :

why you implemented header names pooling using bittricks lookup? Why not using trie or chained ifs?

Reason is: this is faster, less branchy and memory compact and I can produce a micro to demonstrate it, if needed.  The beauty of this "compressed" approach is that with Unsafe or VarHandle's byte array view, it could save (thinking about Netty 5) reading byte per byte and shifting, making the comparison even faster (although is already that fast that doesn't show up in any profiling measurement I've made)

why pooling is using byte[] and not ByteBufs?

Our ByteBufs cannot skip accesibility checks in prod, and they can suffer from inlining problems; I'm not sure yet they worth it in such hot path

this is going to modify the public API!

Yes, kind of; and I'm ready to make it everything more private, if needed.
Related the parsing improvements, instead:

https://bugs.openjdk.org/browse/JDK-8295496 is still a problem?

Yes, but pooling mitigate it a bit and,as the JDK issue explain, it depends by the length of the produced string(s): very small ones would see an unexpected perf hit, but longer ones will copy half of the data, reducing the gap.
Usually the most critical part of the decoding process is the line/header parsing because is the very first one accessing data that could not be hot anymore (the source buffer, with pipelining, because we traverse the whole pipeline to propagate the just parsed http resquest, and keep on draining out of the I/O buffer, making it become "cold") , while the header/value splitting is manipulating a scratch buffer that's supposed to be made recently hot because just used by the line/header parsing.
2. why modifying every validation/scanning to use byte[] and not ByteBuf
as Ditto before: bad inlining decision and compiled method reuse can cause unexpected slowdown, especially with bound/accessibility checks in place.
Hope to have covered the most of the problems and questionable choices

Today still travelling, but will try hard to complete tests on Vertx (and its http test suite) on Monday, adding few tests to preserve the header name pooling too.
@chrisvest @normanmaurer Netty CI tests are happy in the current state?

@chrisvest I will send other changes (just a microbenchmark for the pooling part) in a follow-up PR likely; looking at the assembly I see that that the validation using the offset seems to work the same, hence I haven't decided if change it or not: feel free to merge it and/or wait till the others will complete their review round (@idelpivnitskiy and/or @normanmaurer and/or @vietj )

@franz1981 is "vert.x" happy as well ?

waiting @vietj to run vertx CI too, thanks @normanmaurer

@franz1981 @vietj ping me once done

@normanmaurer we're ready to go, vertx CI is happy
I'll send a followup PR with an additional test, bench and improvement on the header names pooling part, but this PR is already pretty big as it is IMO

@franz1981 thanks a lot for all the work you put into this!

@franz1981 can you please open a PR for main as well ?

Yep @normanmaurer will do it today ☺
Thanks a lot for the patience bud


Quick start should focus on usage, not examples

Quick start should be converted to a quick guide on how to install, import and use the web components in a production setting instead of running the ready-made examples

For example, "Once you have a Payment Pointer address to your wallet, update its value into paymentPointer property in examples/audioAndVideo/config.js — or examples/text/config.js if your media is text." doesn't apply in a regular use case.


K3s install timing out waiting for Node Token generation

The install runs smoothly until reaching Task [k3s-config: Wait until node token is generated] on my server node. Everything stops there, and returns the message:
fatal: [<IP_ADDRESS>]: FAILED! => {"changed": false, "elapsed": 300, "msg": "Timeout when waiting for file /var/lib/rancher/k3s/server/node-token"}
"sudo k3s kubectl get node -0 wide" on the server node returns:
The connection to the server localhost:8080 was refused - did you specify the right host or port?
systemctl status shows that the k3s-server is loaded and active on the server node.
The inventory file is set up correctly.

same issue

+1

+1


GitHub Auth. fail if PW contains special chars

Reproduce by changing GitHub pw to something containing the "!" character and try to clone a repository via abapGit.

Thanks I'll look into the issue, the code uses standard SAP for generating the password stuff, so it might work on a different SAP release, if not I'll implement the basic auth from scratch

no additional error reports, closing
plus this uses standard functionality to encode the password


provide NVIDIA_VISIBLE_DEVICES environment variable to nvidia-container-runtime

Currently, we use --device=/dev/nvidia0 to tell docker isolate gpu for jobs. But this parameter seems is ignored by nvidia-container-runtime. If we want to achieve same effect of gpu isolation, we should pass NVIDIA_VISIBLE_DEVICES to docker run like -e NVIDIA_VISIBLE_DEVICES=0,1.

supplyment:
currently, pai default marked it with all at job docker base image, later change need consider make this configurable or overwrite this config.
https://github.com/Microsoft/pai/blob/e8e21cda23894224a0c78e44caaedb487bce1042/examples/Dockerfiles/cuda9.0-cudnn7/Dockerfile.build.base#L67

this variable can be override by -e parameter.

@xudifsd
If you use nvidia-container-runtime as Docker runtime to start Docker, the container will be started in privileged mode and all gpu devices will be mount into Docker container.
Although NVIDIA_VISIBLE_DEVICES can be used to select gpu ids, but it CANNOT be used to isolate gpu devices. User can overwrite the NVIDIA_VISIBLE_DEVICES env variable easily to use all gpu devices on the host. In fact, deep learning frameworks may set that env variable to all by default.
BTW, why do you need to use nvidia-container-runtime? Won't nvidia-docker2 be better?

@abuccts Why NVIDIA_VISIBLE_DEVICES  can not be used to isolate gpu? This environment variable will be used in yarnScript before docker run. User can overwrite the variable, of course, but by the time they can, the nvidia runtime has set gpu isolation already. Am I right?
nvidia-docker2's only value is to provide a --runtime=nvidia before call actual docker run, the gpu isolation's work is done via nvidia-container-runtime. This is why I only install nvidia-container-runtime not nvidia-docker2. Am I missing something?

--env passed to docker run is equal to export inside a Docker container. After docker run -e VAR1=value1, export VAR1=value2 will change its value inside the container.

@abuccts So, if user's task image defined export NVIDIA_VISIBLE_DEVICES=all, no matter what value of -e NVIDIA_VISIBLE_DEVICES, the nvidia-container-runtime will give all gpus to the task? Have you verified this?

@abuccts I have verified, the -e will override ENV in dockerfile, not other way around.
In a docker configured with default-runtime=nvidia and docker image with ENV NVIDIA_VISIBLE_DEVICES=all, docker run -e NVIDIA_VISIBLE_DEVICES=0,1 will still isolate the gpu as expected.

Because GPU minor number may not necessarily same with device minor number, we can not pass the same minor number to both --device argument and as NVIDIA_VISIBLE_DEVICES environment. For example, in node with different GPU/device minor number:
$ sudo docker run -it --device=/dev/nvidiactl --device=/dev/nvidia-uvm --device=/dev/nvidia0 --volume /var/drivers/nvidia/current:/usr/local/nvidia:ro -e LD_LIBRARY_PATH=/usr/local/nvidia/lib/:/usr/local/nvidia/lib64 --runtime=nvidia -e NVIDIA_VISIBLE_DEVICES=0 ubuntu:16.04 /usr/local/nvidia/bin/nvidia-smi -L
GPU 0: Tesla K80 (UUID: GPU-6f233ab5-200d-f809-b2d6-8d9909735d41)
GPU 1: Tesla K80 (UUID: GPU-36a06e86-501a-6f52-3938-13a884435fe0)

although we pass --device=/dev/nvidia0 and -e NVIDIA_VISIBLE_DEVICES=0, but they mean different devices to nvidia-container-runtime, so it will mount 2 device into container, this is not what we want. To avoid this, we need to set NVIDIA_VISIBLE_DEVICES to empty, and only relay on --device arguments in case nvidia-container-runtime enabled.
It is important to set NVIDIA_VISIBLE_DEVICES as empty, because if not, image which set NVIDIA_VISIBLE_DEVICES=all will still be able to use all GPUs if the runtime is nvidia-container-runtime:
$ for i in `seq 0 3` ; do echo $i; sudo docker run -it --device=/dev/nvidiactl --device=/dev/nvidia-uvm --device=/dev/nvidia$i --device=/dev/fuse --volume /var/drivers/nvidia/current:/usr/local/nvidia:ro -e LD_LIBRARY_PATH=/usr/local/nvidia/lib/:/usr/local/nvidia/lib64 --runtime=nvidia openpai/pai.example.tensorflow /usr/local/nvidia/bin/nvidia-smi -L; done
0
GPU 0: Tesla K80 (UUID: GPU-6f233ab5-200d-f809-b2d6-8d9909735d41)
GPU 1: Tesla K80 (UUID: GPU-0ec71ff9-8bb2-c756-ecad-623cee39da97)
GPU 2: Tesla K80 (UUID: GPU-43ffb100-5348-2276-8ae1-ddc6574f1520)
GPU 3: Tesla K80 (UUID: GPU-36a06e86-501a-6f52-3938-13a884435fe0)
1
GPU 0: Tesla K80 (UUID: GPU-6f233ab5-200d-f809-b2d6-8d9909735d41)
GPU 1: Tesla K80 (UUID: GPU-0ec71ff9-8bb2-c756-ecad-623cee39da97)
GPU 2: Tesla K80 (UUID: GPU-43ffb100-5348-2276-8ae1-ddc6574f1520)
GPU 3: Tesla K80 (UUID: GPU-36a06e86-501a-6f52-3938-13a884435fe0)
2
GPU 0: Tesla K80 (UUID: GPU-6f233ab5-200d-f809-b2d6-8d9909735d41)
GPU 1: Tesla K80 (UUID: GPU-0ec71ff9-8bb2-c756-ecad-623cee39da97)
GPU 2: Tesla K80 (UUID: GPU-43ffb100-5348-2276-8ae1-ddc6574f1520)
GPU 3: Tesla K80 (UUID: GPU-36a06e86-501a-6f52-3938-13a884435fe0)
3
GPU 0: Tesla K80 (UUID: GPU-6f233ab5-200d-f809-b2d6-8d9909735d41)
GPU 1: Tesla K80 (UUID: GPU-0ec71ff9-8bb2-c756-ecad-623cee39da97)
GPU 2: Tesla K80 (UUID: GPU-43ffb100-5348-2276-8ae1-ddc6574f1520)
GPU 3: Tesla K80 (UUID: GPU-36a06e86-501a-6f52-3938-13a884435fe0)

But if we set to empty, we can override environments set by image:
$ for i in `seq 0 3` ; do echo $i; sudo docker run -it --device=/dev/nvidiactl --device=/dev/nvidia-uvm --device=/dev/nvidia$i --device=/dev/fuse --volume /var/drivers/nvidia/current:/usr/local/nvidia:ro -e LD_LIBRARY_PATH=/usr/local/nvidia/lib/:/usr/local/nvidia/lib64 --runtime=nvidia -e NVIDIA_VISIBLE_DEVICES= openpai/pai.example.tensorflow /usr/local/nvidia/bin/nvidia-smi -L; done
0
GPU 0: Tesla K80 (UUID: GPU-36a06e86-501a-6f52-3938-13a884435fe0)
1
GPU 0: Tesla K80 (UUID: GPU-6f233ab5-200d-f809-b2d6-8d9909735d41)
2
GPU 0: Tesla K80 (UUID: GPU-0ec71ff9-8bb2-c756-ecad-623cee39da97)
3
GPU 0: Tesla K80 (UUID: GPU-43ffb100-5348-2276-8ae1-ddc6574f1520)


following "withdraw protected position" - website shows blank page

Describe the bug
after withdrawing protected position, the site i see is blank.

To Reproduce
Steps to reproduce the behavior:

go to protfolio
withdraw a protected position
sign the trnasaction on metamask
expected: see the portfolio page
actual: see blank page

@pingustar to investigate now that ropsten should be 100% operational.


Is there someone who got this working on wordpress.com hosted instances

Seems like the caching is too aggressive on wordpress.com and it doesn't respect the accept headers. I have been trying to get this to work properly and so far have failed miserably.

url : https://blog.anantshri.info
user: anantshri
plugin installed : webmentions, indieweb plugin, activitypub, webfinger, nodeinfo
<EMAIL_ADDRESS>is suppose to be the fediverse id. seems like webfinger is working https://webfinger.net/lookup/?resource=anantshri%40blog.anantshri.info
Any help or pointer appreciated.
Problems

Site health says not a valid json response on author profile (I think what i showed above could be reason for that)
Even if i am able to see my id on other servers if i click follow i dont see followers nor i see a approval request.
My fediverse tool of choice is gotosocial and it errors out with a message

error enriching account from remote: enrichAccount: error dereferencing account https://blog.anantshri.info/author/anantshri/: ResolveAccountable: error unmarshalling bytes into json: unexpected end of JSON input

which could be due to caching, but i am clueless on how to handle it. hence raising a request here to get a pointer as to what could be wrong.

Seems like the caching is too aggressive on wordpress.com and it doesn't respect the accept headers.

That's indeed something that should be fixed in the caching solution used on WordPress.com. The problem is currently tracked here:
https://github.com/Automattic/batcache/issues/104

this working as expected so far.

That's gotosocial, calckey, mastodon, bookwrym and kbin in that order. all appearing clearly as followers.
Thanks folks. Can confirm its working.


Matching requires unique files for lower nodes

Describe the bug
Consider the following shcema:
work.notes.2020.12.15.meeting w/Bob
work.training.2020.12.15.leadership
work.team.kevin.2020.12.15.quarterly review
In order to have the tree recognize every node and sub-node I had to have unique DATE.YML files for each sub-node. I would LIKE to have ONE date.yml file and use it as a child for ANY sub-node.
The workaround is described in the attached image.

Each date_n.yml is the same and looks like this:

The resulting tree is full of matches:

we now support the pattern property which allows you to match multiple notes with a globbing pattern


Second inference makes a higher-pitched and slightly shorter sound without changing any parameters

Hi,
When inferencing once, I can get the correct audio result. However, in the second inference or later, I get a quite higher-pitched and slightly shorter sound without changing any parameters. I can also get a correct audio result if I infer again after reloading the window.
My parameter settings are below:

Transpose: 0
Pitch extraction algorithm: crepe
Filter radius: 3
Search feature ratio: 0.5
Resample the output audio in post-processing to the final sample rate: 48000
Adjust the volume envelope scaling: 1
Protect voiceless consonants and breath sounds to prevent artifacts such as tearing in electronic music: 0.33

Please note that when I leave parameters of "Resample the output audio in post-processing to the final sample rate," "Adjust the volume envelope scaling," and "Protect voiceless consonants and breath sounds to prevent artifacts such as tearing in electronic music" as default before the first inference, multiple inferences do not change a pitch and length of audio result at all.
Many thanks for considering my issue.

Fixed now.
https://github.com/RVC-Project/Retrieval-based-Voice-Conversion-WebUI/commit/deb756bf1b0bc5924865e646dc7925c68c9f5bc5