[jira] [Commented] (FLINK-27053) IncrementalRemoteKeyedStateHandle.discardState swallows errors

2022-04-11 Thread zhouenning (Jira)


[ 
https://issues.apache.org/jira/browse/FLINK-27053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520512#comment-17520512
 ] 

zhouenning commented on FLINK-27053:


Hi [~mapohl] 
Ok, I'll take a look at this when you're done, thanks

> IncrementalRemoteKeyedStateHandle.discardState swallows errors
> --
>
> Key: FLINK-27053
> URL: https://issues.apache.org/jira/browse/FLINK-27053
> Project: Flink
>  Issue Type: Sub-task
>  Components: Runtime / Coordination
>Reporter: Matthias Pohl
>Priority: Major
>
> IncrementalRemoteKeyedStateHandle.discardState swallows errors instead of 
> propagating them which would make the discard failure go un-noticed.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)


[jira] [Commented] (FLINK-27053) IncrementalRemoteKeyedStateHandle.discardState swallows errors

2022-04-09 Thread zhouenning (Jira)


[ 
https://issues.apache.org/jira/browse/FLINK-27053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519981#comment-17519981
 ] 

zhouenning commented on FLINK-27053:


hi Matthias Pohl

   I see the source code which to use try/catch error. Would it be better if I 
changed the log warn to error level?

> IncrementalRemoteKeyedStateHandle.discardState swallows errors
> --
>
> Key: FLINK-27053
> URL: https://issues.apache.org/jira/browse/FLINK-27053
> Project: Flink
>  Issue Type: Sub-task
>  Components: Runtime / Coordination
>Reporter: Matthias Pohl
>Priority: Major
>
> IncrementalRemoteKeyedStateHandle.discardState swallows errors instead of 
> propagating them which would make the discard failure go un-noticed.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)


[jira] [Commented] (FLINK-26910) flink-benchmarks build fails on Apple M1 silicon

2022-04-05 Thread zhouenning (Jira)


[ 
https://issues.apache.org/jira/browse/FLINK-26910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517323#comment-17517323
 ] 

zhouenning commented on FLINK-26910:


can u try this way?

1) com.google.protobuf:protoc:exe:osx-aarch_64:3.11.4

  Try downloading the file manually from the project website.

  Then, install it using the command: 
      mvn install:install-file -DgroupId=com.google.protobuf 
-DartifactId=protoc -Dversion=3.11.4 -Dclassifier=osx-aarch_64 -Dpackaging=exe 
-Dfile=/path/to/file

  Alternatively, if you host your own repository you can deploy the file there: 
      mvn deploy:deploy-file -DgroupId=com.google.protobuf -DartifactId=protoc 
-Dversion=3.11.4 -Dclassifier=osx-aarch_64 -Dpackaging=exe -Dfile=/path/to/file 
-Durl=[url] -DrepositoryId=[id]

> flink-benchmarks build fails on Apple M1 silicon
> 
>
> Key: FLINK-26910
> URL: https://issues.apache.org/jira/browse/FLINK-26910
> Project: Flink
>  Issue Type: Sub-task
>  Components: Benchmarks
>Reporter: Sebastian Mattheis
>Priority: Minor
>
> {code:java}
> mvn clean package
> ...
> Downloading from central: 
> https://repo.maven.apache.org/maven2/com/google/protobuf/protoc/3.11.4/protoc-3.11.4-osx-aarch_64.exe
> [INFO] 
> 
> [INFO] BUILD FAILURE
> [INFO] 
> 
> [INFO] Total time:  22.012 s
> [INFO] Finished at: 2022-03-29T11:03:25+02:00
> [INFO] 
> 
> [ERROR] Failed to execute goal 
> org.xolstice.maven.plugins:protobuf-maven-plugin:0.6.1:compile (default) on 
> project benchmark: Unable to resolve artifact: Missing:
> [ERROR] --
> [ERROR] 1) com.google.protobuf:protoc:exe:osx-aarch_64:3.11.4
> [ERROR] 
> [ERROR]   Try downloading the file manually from the project website.
> [ERROR] 
> [ERROR]   Then, install it using the command: 
> [ERROR]       mvn install:install-file -DgroupId=com.google.protobuf 
> -DartifactId=protoc -Dversion=3.11.4 -Dclassifier=osx-aarch_64 
> -Dpackaging=exe -Dfile=/path/to/file
> [ERROR] 
> [ERROR]   Alternatively, if you host your own repository you can deploy the 
> file there: 
> [ERROR]       mvn deploy:deploy-file -DgroupId=com.google.protobuf 
> -DartifactId=protoc -Dversion=3.11.4 -Dclassifier=osx-aarch_64 
> -Dpackaging=exe -Dfile=/path/to/file -Durl=[url] -DrepositoryId=[id]
> [ERROR] 
> [ERROR]   Path to dependency: 
> [ERROR]       1) org.apache.flink:benchmark:jar:0.1
> [ERROR]       2) com.google.protobuf:protoc:exe:osx-aarch_64:3.11.4
> [ERROR] 
> [ERROR] --
> [ERROR] 1 required artifact is missing.
> [ERROR] 
> [ERROR] for artifact: 
> [ERROR]   org.apache.flink:benchmark:jar:0.1
> [ERROR] 
> [ERROR] from the specified remote repositories:
> [ERROR]   apache.snapshots 
> (https://repository.apache.org/content/repositories/snapshots/, 
> releases=false, snapshots=true),
> [ERROR]   central (https://repo.maven.apache.org/maven2, releases=true, 
> snapshots=false)
> [ERROR] 
> [ERROR] -> [Help 1]
> [ERROR] 
> [ERROR] To see the full stack trace of the errors, re-run Maven with the -e 
> switch.
> [ERROR] Re-run Maven using the -X switch to enable full debug logging.
> [ERROR] 
> [ERROR] For more information about the errors and possible solutions, please 
> read the following articles:
> [ERROR] [Help 1] 
> http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException{code}



--
This message was sent by Atlassian Jira
(v8.20.1#820001)


[jira] [Created] (FLINK-20842) Data row is smaller than a column index, internal schema representation is probably out of sync with real database schema

2021-01-04 Thread zhouenning (Jira)
zhouenning created FLINK-20842:
--

 Summary: Data row is smaller than a column index, internal schema 
representation is probably out of sync with real database schema
 Key: FLINK-20842
 URL: https://issues.apache.org/jira/browse/FLINK-20842
 Project: Flink
  Issue Type: Bug
  Components: Table SQL / Planner
Affects Versions: 1.11.1
 Environment: FLINK VERSION 1.11.1
SCALA 2.11.1

KAFKA 2.11

MYSQL 5.6
com.alibaba.ververica:flink-connector-mysql-cdc:1.1.0
Reporter: zhouenning
 Fix For: 1.11.1
 Attachments: error.log

I try to use FLINK CDC Sink Kafka ,The error  has been prompted 'Data row is 
smaller than a column index, internal schema representation is probably out of 
sync with real database schema', it should be the table structure change caused 
the program to stop.
I try to use the latest 
com.alibaba.ververica:flink-connector-mysql-cdc:1.1.0,Error is still happend

When I change other database instance  who's new is ok
How can I skip this error and let the program continue



--
This message was sent by Atlassian Jira
(v8.3.4#803005)