[jira] [Updated] (FLINK-19723) The retry mechanism of jdbc connector has the risk of data duplication

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19723: Affects Version/s: (was: 1.11.1) > The retry mechanism of jdbc connector has the risk of data duplicat

[GitHub] [flink] gaoyunhaii commented on a change in pull request #13825: [FLINK-19836] Add SimpleVersionedSerializerTypeSerializerProxy

2020-10-28 Thread GitBox
gaoyunhaii commented on a change in pull request #13825: URL: https://github.com/apache/flink/pull/13825#discussion_r514034693 ## File path: flink-core/src/main/java/org/apache/flink/core/io/SimpleVersionedSerializerTypeSerializerProxy.java ## @@ -0,0 +1,153 @@ +/* + * License

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
shuiqiangchen commented on a change in pull request #13803: URL: https://github.com/apache/flink/pull/13803#discussion_r514034737 ## File path: flink-python/pyflink/datastream/functions.py ## @@ -540,3 +540,155 @@ def __init__(self, sink_func: Union[str, JavaObject]):

[jira] [Commented] (FLINK-19723) The retry mechanism of jdbc connector has the risk of data duplication

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222731#comment-17222731 ] Jark Wu commented on FLINK-19723: - Thanks [~tinny]. > The retry mechanism of jdbc conne

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [WIP][FLINK-17760][tests] Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

2020-10-28 Thread GitBox
zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r512792107 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphDeploymentTest.java ## @@ -566,174 +552,6 @@ public void

[jira] [Closed] (FLINK-19723) The retry mechanism of jdbc connector has the risk of data duplication

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19723. --- Resolution: Not A Problem > The retry mechanism of jdbc connector has the risk of data duplication > ---

[jira] [Assigned] (FLINK-19723) The retry mechanism of jdbc connector has the risk of data duplication

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19723: --- Assignee: (was: shizhengchao) > The retry mechanism of jdbc connector has the risk of data dupl

[GitHub] [flink] wuchong closed pull request #13717: [FLINK-19723][Connector/JDBC] Solve the problem of repeated data submission in the failure retry

2020-10-28 Thread GitBox
wuchong closed pull request #13717: URL: https://github.com/apache/flink/pull/13717 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Commented] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-28 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222729#comment-17222729 ] YUJIANBO commented on FLINK-19768: -- Thanks a lot! I'll try again ！ > The shell "./yar

[GitHub] [flink] wuchong commented on pull request #13717: [FLINK-19723][Connector/JDBC] Solve the problem of repeated data submission in the failure retry

2020-10-28 Thread GitBox
wuchong commented on pull request #13717: URL: https://github.com/apache/flink/pull/13717#issuecomment-718402409 Thanks @shizhengchao . This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot commented on pull request #13835: [FLINK-18122][e2e] Make K8s test more resilient by retrying and failing docker image build (2nd try)

2020-10-28 Thread GitBox
flinkbot commented on pull request #13835: URL: https://github.com/apache/flink/pull/13835#issuecomment-718401670 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] rmetzger opened a new pull request #13835: [FLINK-18122][e2e] Make K8s test more resilient by retrying and failing docker image build (2nd try)

2020-10-28 Thread GitBox
rmetzger opened a new pull request #13835: URL: https://github.com/apache/flink/pull/13835 ## What is the purpose of the change This is a follow up to https://github.com/apache/flink/pull/13779, which has been reverted due to a build failure. ---

[GitHub] [flink] shouweikun commented on pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-28 Thread GitBox
shouweikun commented on pull request #13789: URL: https://github.com/apache/flink/pull/13789#issuecomment-718400385 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Updated] (FLINK-19870) Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19870: --- Labels: pull-request-available (was: ) > Fix special case when the reuse of exchange causes

[GitHub] [flink] flinkbot edited a comment on pull request #13831: [FLINK-19870][table-planner-blink] Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13831: URL: https://github.com/apache/flink/pull/13831#issuecomment-718332223 ## CI report: * f7a377f9a04c5d630cb578ebc9040e936e6a60a4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13834: [FLINK-19872][Formats/Csv] Support to parse millisecond for TIME type in CSV format

2020-10-28 Thread GitBox
flinkbot commented on pull request #13834: URL: https://github.com/apache/flink/pull/13834#issuecomment-718397596 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-19872) Support to parse millisecond for TIME type in CSV format

2020-10-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19872: --- Labels: pull-request-available (was: ) > Support to parse millisecond for TIME type in CSV

[GitHub] [flink] flinkbot edited a comment on pull request #13830: [FLINK-14482][rocksdb] Bump FRocksDB verion to base on RocksDB-6.11.6

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13830: URL: https://github.com/apache/flink/pull/13830#issuecomment-718331944 ## CI report: * e4cd22945ab2b3e7cb44c302e9db12231f52fdbc Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
shuiqiangchen commented on a change in pull request #13803: URL: https://github.com/apache/flink/pull/13803#discussion_r514027062 ## File path: flink-python/pyflink/fn_execution/stateful_operation_common.py ## @@ -0,0 +1,72 @@ +##

[GitHub] [flink] pyscala opened a new pull request #13834: [FLINK-19872][Formats/Csv] Support to parse millisecond for TIME type in CSV format

2020-10-28 Thread GitBox
pyscala opened a new pull request #13834: URL: https://github.com/apache/flink/pull/13834 ## What is the purpose of the change Support to parse millisecond for TIME type in CSV format ## Brief change log Support to parse millisecond for TIME type in CSV f

[jira] [Commented] (FLINK-19723) The retry mechanism of jdbc connector has the risk of data duplication

2020-10-28 Thread shizhengchao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222726#comment-17222726 ] shizhengchao commented on FLINK-19723: -- Hi [~jark], after testing, this is not a bu

[GitHub] [flink] shizhengchao commented on pull request #13717: [FLINK-19723][Connector/JDBC] Solve the problem of repeated data submission in the failure retry

2020-10-28 Thread GitBox
shizhengchao commented on pull request #13717: URL: https://github.com/apache/flink/pull/13717#issuecomment-718395751 Hi [~jark], after testing, this is not a bug, could you close the issue?:D Generally, after executing executeBatch in jdbc, regardless of success or failure, the list

[jira] [Commented] (FLINK-18640) Fix PostgresDialect doesn't quote the identifiers

2020-10-28 Thread zl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222725#comment-17222725 ] zl commented on FLINK-18640: Maybe we can add a new property named `schema` for jdbc connect

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
shuiqiangchen commented on a change in pull request #13803: URL: https://github.com/apache/flink/pull/13803#discussion_r514023438 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamDataStreamStatefulPythonFunctionRunner.java ## @@ -

[jira] [Commented] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222723#comment-17222723 ] Xintong Song commented on FLINK-19768: -- [~YUJIANBO] As I mentioned before, you can

[jira] [Commented] (FLINK-19872) Support to parse millisecond for TIME type in CSV format

2020-10-28 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222722#comment-17222722 ] Fangliang Liu commented on FLINK-19872: --- [~jark] Thanks for your reply. > Support

[GitHub] [flink] wuchong commented on pull request #13806: [FLINK-19824][table-api] Refactor and merge SupportsComputedColumnPushDown and SupportsWatermarkPushDown interfaces

2020-10-28 Thread GitBox
wuchong commented on pull request #13806: URL: https://github.com/apache/flink/pull/13806#issuecomment-718393971 cc @godfreyhe @fsk119 This is an automated message from the Apache Git Service. To respond to the message, ple

[jira] [Updated] (FLINK-19872) Support to parse millisecond for TIME type in CSV format

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19872: Component/s: Table SQL / Ecosystem Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Sup

[jira] [Commented] (FLINK-19872) Support to parse millisecond for TIME type in CSV format

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222720#comment-17222720 ] Jark Wu commented on FLINK-19872: - [~liufangliang], I think it makes sense. Assigned it

[jira] [Assigned] (FLINK-19872) Support to parse millisecond for TIME type in CSV format

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19872: --- Assignee: Fangliang Liu > Support to parse millisecond for TIME type in CSV format > --

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
shuiqiangchen commented on a change in pull request #13803: URL: https://github.com/apache/flink/pull/13803#discussion_r514019677 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/StatefulPythonFunctionOperator.java ## @@ -0,0 +1,237 @@ +

[jira] [Commented] (FLINK-19872) Support to parse millisecond for TIME type in CSV format

2020-10-28 Thread Fangliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222719#comment-17222719 ] Fangliang Liu commented on FLINK-19872: --- [~jark] Do you think it is necessary to b

[jira] [Updated] (FLINK-19871) add hash(primary key) sink partitioner for writing records to Kafka partitions

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19871: Summary: add hash(primary key) sink partitioner for writing records to Kafka partitions (was: add hash(pr

[GitHub] [flink] JingsongLi commented on a change in pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-28 Thread GitBox
JingsongLi commented on a change in pull request #13789: URL: https://github.com/apache/flink/pull/13789#discussion_r514019228 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala ## @@ -99

[jira] [Commented] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_L

2020-10-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222718#comment-17222718 ] Robert Metzger commented on FLINK-19865: This seems to be a problem in the Hadoo

[jira] [Assigned] (FLINK-19865) YARN tests failed with "java.lang.NumberFormatException: For input string: "${env:MAX_LOG_FILE_NUMBER}" java.lang.NumberFormatException: For input string: "${env:MAX_LO

2020-10-28 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-19865: -- Assignee: Robert Metzger > YARN tests failed with "java.lang.NumberFormatException: F

[jira] [Created] (FLINK-19872) Support to parse millisecond for TIME type in CSV format

2020-10-28 Thread Fangliang Liu (Jira)
Fangliang Liu created FLINK-19872: - Summary: Support to parse millisecond for TIME type in CSV format Key: FLINK-19872 URL: https://issues.apache.org/jira/browse/FLINK-19872 Project: Flink Is

[GitHub] [flink] shouweikun commented on a change in pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-28 Thread GitBox
shouweikun commented on a change in pull request #13789: URL: https://github.com/apache/flink/pull/13789#discussion_r514017050 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala ## @@ -99

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
shuiqiangchen commented on a change in pull request #13803: URL: https://github.com/apache/flink/pull/13803#discussion_r514014519 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/StatefulPythonFunctionOperator.java ## @@ -0,0 +1,237 @@ +

[jira] [Commented] (FLINK-18071) CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI

2020-10-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222717#comment-17222717 ] Xintong Song commented on FLINK-18071: -- [~sewen] Thanks for the updates. Sounds goo

[jira] [Created] (FLINK-19871) add hash(primary key） to kafka partition sink mapping

2020-10-28 Thread Jira
底限 created FLINK-19871: -- Summary: add hash(primary key） to kafka partition sink mapping Key: FLINK-19871 URL: https://issues.apache.org/jira/browse/FLINK-19871 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #13697: [FLINK-19357][FLINK-19357][fs-connector] Introduce createBucketWriter to BucketsBuilder & Introduce FileLifeCycleListener to Buckets

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13697: URL: https://github.com/apache/flink/pull/13697#issuecomment-712672697 ## CI report: * bd25177243a782fad2e7f9d9ff508e6ba3758303 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13307: [FLINK-19078][table-runtime] Import rowtime join temporal operator

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13307: URL: https://github.com/apache/flink/pull/13307#issuecomment-685763264 ## CI report: * 9f912a17d777463b856a19b64a03c16adadb8a73 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
shuiqiangchen commented on a change in pull request #13803: URL: https://github.com/apache/flink/pull/13803#discussion_r514007289 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/StatefulPythonFunctionOperator.java ## @@ -0,0 +1,237 @@ +

[GitHub] [flink] flinkbot edited a comment on pull request #13697: [FLINK-19357][FLINK-19357][fs-connector] Introduce createBucketWriter to BucketsBuilder & Introduce FileLifeCycleListener to Buckets

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13697: URL: https://github.com/apache/flink/pull/13697#issuecomment-712672697 ## CI report: * bd25177243a782fad2e7f9d9ff508e6ba3758303 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-19870) Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-19870: Description: Currently the reuse of exchange is not considered to be a deadlock because although

[jira] [Created] (FLINK-19870) Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-19870: --- Summary: Fix special case when the reuse of exchange causes the deadlock Key: FLINK-19870 URL: https://issues.apache.org/jira/browse/FLINK-19870 Project: Flink

[jira] [Created] (FLINK-19869) Support java.util.UUID as RAW type in PostgresCatalog and handle it in PostgresRowConverter

2020-10-28 Thread Jingwei Zhang (Jira)
Jingwei Zhang created FLINK-19869: - Summary: Support java.util.UUID as RAW type in PostgresCatalog and handle it in PostgresRowConverter Key: FLINK-19869 URL: https://issues.apache.org/jira/browse/FLINK-19869

[jira] [Updated] (FLINK-19867) Validation fails for UDF that accepts var-args

2020-10-28 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-19867: --- Fix Version/s: 1.12.0 > Validation fails for UDF that accepts var-args > ---

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [WIP][FLINK-17760][tests] Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * 9ea4cf7454f9b8e0c237ba8f540b224abdf9f7b0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13833: [FLINK-19867][table-common] Validation fails for UDF that accepts var…

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13833: URL: https://github.com/apache/flink/pull/13833#issuecomment-718355139 ## CI report: * 4bec3f4f3950b243ef9f87f24ef481c5e73ceb17 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13641: [WIP][FLINK-17760][tests] Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13641: URL: https://github.com/apache/flink/pull/13641#issuecomment-708569491 ## CI report: * 09d8deb89416f53dfe8b5c16fb9d723cbd98612c UNKNOWN * 9ea4cf7454f9b8e0c237ba8f540b224abdf9f7b0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13073: [FLINK-18820] SourceOperator should send MAX_WATERMARK to downstream operator when closed

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13073: URL: https://github.com/apache/flink/pull/13073#issuecomment-669650373 ## CI report: * 406f3764484bb5b004988002f620bd20c0c34fd6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wuchong merged pull request #13809: [Hotfix][json] Add serialVersionUID to JsonInputFormat class

2020-10-28 Thread GitBox
wuchong merged pull request #13809: URL: https://github.com/apache/flink/pull/13809 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot commented on pull request #13833: [FLINK-19867][table-common] Validation fails for UDF that accepts var…

2020-10-28 Thread GitBox
flinkbot commented on pull request #13833: URL: https://github.com/apache/flink/pull/13833#issuecomment-718355139 ## CI report: * 4bec3f4f3950b243ef9f87f24ef481c5e73ceb17 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] curcur edited a comment on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-28 Thread GitBox
curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-718354004 Hey @tillrohrmann , thanks for bringing this up. We've nowhere explicitly explained why to bring a new ResultPartitionType, so I think here is a good place to discuss the

[GitHub] [flink] flinkbot edited a comment on pull request #13784: [FLINK-19698][connectors/common] API improvements to the Sources.

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13784: URL: https://github.com/apache/flink/pull/13784#issuecomment-716153889 ## CI report: * f0dec4fa5d8e69761377a45df57106a4fbfe8152 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13685: [FLINK-19702][hive] Avoid using HiveConf::hiveSiteURL

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13685: URL: https://github.com/apache/flink/pull/13685#issuecomment-711940021 ## CI report: * b49b477343603ef7568ec9c1de8c59807d85d232 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13763: [FLINK-19779][avro] Remove the record_ field name prefix for Confluen…

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13763: URL: https://github.com/apache/flink/pull/13763#issuecomment-715195599 ## CI report: * 4c5a06b1ca2833fe7f63c25503660ed7acf9b77d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] curcur commented on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-28 Thread GitBox
curcur commented on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-718354004 Hey @tillrohrmann , thanks for bringing this up. We've nowhere explicitly explained why to bring a new ResultPartitionType, so I think here is a good place to discuss the reason.

[GitHub] [flink] curcur edited a comment on pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

2020-10-28 Thread GitBox
curcur edited a comment on pull request #13648: URL: https://github.com/apache/flink/pull/13648#issuecomment-718354004 Hey @tillrohrmann , thanks for bringing this up. We've nowhere explicitly explained why to bring a new ResultPartitionType, so I think here is a good place to discuss the

[GitHub] [flink] flinkbot edited a comment on pull request #13073: [FLINK-18820] SourceOperator should send MAX_WATERMARK to downstream operator when closed

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13073: URL: https://github.com/apache/flink/pull/13073#issuecomment-669650373 ## CI report: * 406f3764484bb5b004988002f620bd20c0c34fd6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] JingsongLi commented on a change in pull request #13789: [FLINK-19727][table-runtime] Implement ParallelismProvider for sink i…

2020-10-28 Thread GitBox
JingsongLi commented on a change in pull request #13789: URL: https://github.com/apache/flink/pull/13789#discussion_r513954139 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java ## @@ -20,13 +20,15 @@ i

[jira] [Closed] (FLINK-19587) Error result when casting binary type as varchar

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19587. --- Resolution: Fixed > Error result when casting binary type as varchar > -

[jira] [Comment Edited] (FLINK-19587) Error result when casting binary type as varchar

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221965#comment-17221965 ] Jark Wu edited comment on FLINK-19587 at 10/29/20, 4:22 AM:

[GitHub] [flink] wuchong merged pull request #13826: [BP-1.11][FLINK-19587][table-planner-blink] Fix error result when casting binary as varchar

2020-10-28 Thread GitBox
wuchong merged pull request #13826: URL: https://github.com/apache/flink/pull/13826 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #13832: [FLINK-19822][table-planner] Remove redundant shuffle for streaming

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13832: URL: https://github.com/apache/flink/pull/13832#issuecomment-718338774 ## CI report: * d32b02c2668093ff2745c4d124b11807f0b3f11c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19868: Fix Version/s: 1.12.0 > Csv Serialization schema contains line delimiter > ---

[jira] [Commented] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-10-28 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222700#comment-17222700 ] Jark Wu commented on FLINK-19868: - I think {{csv.line-delimiter}} is not a good option f

[GitHub] [flink] flinkbot edited a comment on pull request #13784: [FLINK-19698][connectors/common] API improvements to the Sources.

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13784: URL: https://github.com/apache/flink/pull/13784#issuecomment-716153889 ## CI report: * f0dec4fa5d8e69761377a45df57106a4fbfe8152 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13763: [FLINK-19779][avro] Remove the record_ field name prefix for Confluen…

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13763: URL: https://github.com/apache/flink/pull/13763#issuecomment-715195599 ## CI report: * 4c5a06b1ca2833fe7f63c25503660ed7acf9b77d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13685: [FLINK-19702][hive] Avoid using HiveConf::hiveSiteURL

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13685: URL: https://github.com/apache/flink/pull/13685#issuecomment-711940021 ## CI report: * b49b477343603ef7568ec9c1de8c59807d85d232 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-10-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222697#comment-17222697 ] Jingsong Lee commented on FLINK-19868: -- Now the filesystem wants to reuse serializa

[GitHub] [flink] flinkbot commented on pull request #13833: [FLINK-19867][table-common] Validation fails for UDF that accepts var…

2020-10-28 Thread GitBox
flinkbot commented on pull request #13833: URL: https://github.com/apache/flink/pull/13833#issuecomment-718346736 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-10-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-19868: - Description: CsvRowSerializationSchema.serialize(Row.of("f0", "f1")) => f0,f1\n Csv Serializati

[jira] [Updated] (FLINK-19867) Validation fails for UDF that accepts var-args

2020-10-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19867: --- Labels: pull-request-available (was: ) > Validation fails for UDF that accepts var-args > -

[jira] [Created] (FLINK-19868) Csv Serialization schema contains line delimiter

2020-10-28 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-19868: Summary: Csv Serialization schema contains line delimiter Key: FLINK-19868 URL: https://issues.apache.org/jira/browse/FLINK-19868 Project: Flink Issue Type:

[GitHub] [flink] lirui-apache opened a new pull request #13833: [FLINK-19867][table-common] Validation fails for UDF that accepts var…

2020-10-28 Thread GitBox
lirui-apache opened a new pull request #13833: URL: https://github.com/apache/flink/pull/13833 …-args ## What is the purpose of the change Fix the failure to extract eval method for functions with var-arg parameter. ## Brief change log - Check var-ar

[jira] [Created] (FLINK-19867) Validation fails for UDF that accepts var-args

2020-10-28 Thread Rui Li (Jira)
Rui Li created FLINK-19867: -- Summary: Validation fails for UDF that accepts var-args Key: FLINK-19867 URL: https://issues.apache.org/jira/browse/FLINK-19867 Project: Flink Issue Type: Bug

[GitHub] [flink] Sxnan commented on pull request #13073: [FLINK-18820] SourceOperator should send MAX_WATERMARK to downstream operator when closed

2020-10-28 Thread GitBox
Sxnan commented on pull request #13073: URL: https://github.com/apache/flink/pull/13073#issuecomment-718343253 I have made the change accordingly. @dawidwys Please have another look. This is an automated message from the Apac

[jira] [Created] (FLINK-19866) FunctionsStateBootstrapOperator.createStateAccessor fails due to uninitialized runtimeContext

2020-10-28 Thread wang (Jira)
wang created FLINK-19866: Summary: FunctionsStateBootstrapOperator.createStateAccessor fails due to uninitialized runtimeContext Key: FLINK-19866 URL: https://issues.apache.org/jira/browse/FLINK-19866 Project

[jira] [Commented] (FLINK-19768) The shell "./yarn-session.sh " not use log4j-session.properties , it use log4j.properties

2020-10-28 Thread YUJIANBO (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17222687#comment-17222687 ] YUJIANBO commented on FLINK-19768: -- Thanks a lot for your answer！ I changed the log4j.p

[GitHub] [flink] danny0405 commented on a change in pull request #13763: [FLINK-19779][avro] Remove the record_ field name prefix for Confluen…

2020-10-28 Thread GitBox
danny0405 commented on a change in pull request #13763: URL: https://github.com/apache/flink/pull/13763#discussion_r513927391 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java ## @@ -297,17 +299,22 @@ private

[GitHub] [flink] danny0405 commented on a change in pull request #13763: [FLINK-19779][avro] Remove the record_ field name prefix for Confluen…

2020-10-28 Thread GitBox
danny0405 commented on a change in pull request #13763: URL: https://github.com/apache/flink/pull/13763#discussion_r513370899 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java ## @@ -297,17 +299,22 @@ private

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
shuiqiangchen commented on a change in pull request #13803: URL: https://github.com/apache/flink/pull/13803#discussion_r513925523 ## File path: flink-end-to-end-tests/flink-python-test/python/datastream/data_stream_timer_job.py ## @@ -0,0 +1,89 @@ +

[jira] [Closed] (FLINK-19692) Can't restore feedback channel from savepoint

2020-10-28 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-19692. --- Assignee: Igal Shilman Resolution: Fixed Fixed via - statefun/master: ddeec31

[GitHub] [flink] flinkbot commented on pull request #13832: [FLINK-19822][table-planner] Remove redundant shuffle for streaming

2020-10-28 Thread GitBox
flinkbot commented on pull request #13832: URL: https://github.com/apache/flink/pull/13832#issuecomment-718338774 ## CI report: * d32b02c2668093ff2745c4d124b11807f0b3f11c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13831: [FLINK-19624][fix] Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13831: URL: https://github.com/apache/flink/pull/13831#issuecomment-718332223 ## CI report: * f7a377f9a04c5d630cb578ebc9040e936e6a60a4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13830: [FLINK-14482][rocksdb] Bump FRocksDB verion to base on RocksDB-6.11.6

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13830: URL: https://github.com/apache/flink/pull/13830#issuecomment-718331944 ## CI report: * e4cd22945ab2b3e7cb44c302e9db12231f52fdbc Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13803: URL: https://github.com/apache/flink/pull/13803#issuecomment-717145782 ## CI report: * 2ab68a5e26b158ab43b128e0d0dbbc62cb8dea17 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13797: [FLINK-19465][runtime / statebackends] Add CheckpointStorage interface and wire through runtime

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13797: URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695 ## CI report: * c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN * 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN * 942af8415dd1a9fbd715532bf6b578a7a4b7

[GitHub] [flink] gaoyunhaii commented on a change in pull request #13697: [FLINK-19357][FLINK-19357][fs-connector] Introduce createBucketWriter to BucketsBuilder & Introduce FileLifeCycleListener to B

2020-10-28 Thread GitBox
gaoyunhaii commented on a change in pull request #13697: URL: https://github.com/apache/flink/pull/13697#discussion_r513921052 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/FileLifeCycleListener.java ## @@ -0,0 +1,41

[GitHub] [flink] wangyang0918 commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

2020-10-28 Thread GitBox
wangyang0918 commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r513920680 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionDriver.java ## @@ -0,0 +1,314 @@ +/* + * Li

[GitHub] [flink] flinkbot edited a comment on pull request #13744: [FLINK-19766][table-runtime] Introduce File streaming compaction operators

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13744: URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975 ## CI report: * a01ecf0bade9f8e4a56052fb5b5d25c5034fe511 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13605: [FLINK-19599][table] Introduce Filesystem format factories to integrate new FileSource to table

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13605: URL: https://github.com/apache/flink/pull/13605#issuecomment-707521684 ## CI report: * a9df8a1384eb6306656b4fd952edd4be5d7a857d UNKNOWN * 96468e31f7614ef314c655f97a63fcabe83505a8 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] dianfu commented on a change in pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
dianfu commented on a change in pull request #13803: URL: https://github.com/apache/flink/pull/13803#discussion_r513882412 ## File path: flink-end-to-end-tests/flink-python-test/python/datastream/data_stream_timer_job.py ## @@ -0,0 +1,89 @@ +###

[GitHub] [flink] flinkbot commented on pull request #13831: [FLINK-19624][fix] Fix special case when the reuse of exchange causes the deadlock

2020-10-28 Thread GitBox
flinkbot commented on pull request #13831: URL: https://github.com/apache/flink/pull/13831#issuecomment-718332223 ## CI report: * f7a377f9a04c5d630cb578ebc9040e936e6a60a4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #13830: [FLINK-14482][rocksdb] Bump FRocksDB verion to base on RocksDB-6.11.6

2020-10-28 Thread GitBox
flinkbot commented on pull request #13830: URL: https://github.com/apache/flink/pull/13830#issuecomment-718331944 ## CI report: * e4cd22945ab2b3e7cb44c302e9db12231f52fdbc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13803: [FLINK-19821][python] Add ProcessFunction and timer access for Python DataStream API.

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13803: URL: https://github.com/apache/flink/pull/13803#issuecomment-717145782 ## CI report: * 2ab68a5e26b158ab43b128e0d0dbbc62cb8dea17 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13822: [FLINK-19856][network] Emit EndOfChannelRecoveryEvent

2020-10-28 Thread GitBox
flinkbot edited a comment on pull request #13822: URL: https://github.com/apache/flink/pull/13822#issuecomment-717894411 ## CI report: * 6e23ce525a7af28103e7abd8547b2ba6c9850567 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

  1   2   3   4   5   6   >