[jira] [Updated] (FLINK-20041) Support Watermark push down for kafka connector

[ https://issues.apache.org/jira/browse/FLINK-20041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-20041: -- Parent: FLINK-16987 Issue Type: Sub-task (was: New Feature) > Support Watermark push

[GitHub] [flink] flinkbot edited a comment on pull request #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

flinkbot edited a comment on pull request #13957: URL: https://github.com/apache/flink/pull/13957#issuecomment-722961884 ## CI report: * 0c4e62b055b5cd62d95be004423262ed9ce5eb86 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-20041) Support Watermark push down for kafka connector

Shengkai Fang created FLINK-20041: - Summary: Support Watermark push down for kafka connector Key: FLINK-20041 URL: https://issues.apache.org/jira/browse/FLINK-20041 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

flinkbot edited a comment on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-684611193 ## CI report: * c266341c63cc4cdc28a6585a82294710fd8ebbc5 UNKNOWN * c3b8c47d4aac9dbc1b425bdef346e084febd4a2d UNKNOWN * Unknown: [CANCELED](TBD)

[jira] [Closed] (FLINK-10240) Pluggable scheduling strategy for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-10240. --- Resolution: Later > Pluggable scheduling strategy for batch jobs > -

[jira] [Commented] (FLINK-10240) Pluggable scheduling strategy for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227751#comment-17227751 ] Zhu Zhu commented on FLINK-10240: - Let's close this ticket because the pluggable schedul

[jira] [Updated] (FLINK-19963) Give SinkWriter access to processing-time service

[ https://issues.apache.org/jira/browse/FLINK-19963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19963: - Description: Some sinks, like the new unified {{FileSink}} will need low-level processin

[jira] [Updated] (FLINK-19963) Give SinkWriter access to processing-time service

[ https://issues.apache.org/jira/browse/FLINK-19963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19963: - Summary: Give SinkWriter access to processing-time service (was: Let the `SinkWriter` s

[jira] [Updated] (FLINK-20031) Keep the UID of SinkWriter same as the SinkTransformation

[ https://issues.apache.org/jira/browse/FLINK-20031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20031: - Summary: Keep the UID of SinkWriter same as the SinkTransformation (was: Keep the uid o

[GitHub] [flink] flinkbot edited a comment on pull request #13958: [FLINK-19994][runtime] Do not force iteration job to generate one only pipelined region

flinkbot edited a comment on pull request #13958: URL: https://github.com/apache/flink/pull/13958#issuecomment-722993305 ## CI report: * e6c7892e55dd4baaff4968e4257a63a51023d841 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13931: [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions

flinkbot edited a comment on pull request #13931: URL: https://github.com/apache/flink/pull/13931#issuecomment-722165982 ## CI report: * 1bfce4d4cf3ad25b18bbcc654fcf89837fbefcbf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

flinkbot edited a comment on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-719924065 ## CI report: * 8afe5fbf796d216f655dd6e7ad7585f328196f54 UNKNOWN * a27c2c7198ec1cbaf7ad5d84c5d0562033b60e4e Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

flinkbot edited a comment on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-684611193 ## CI report: * c266341c63cc4cdc28a6585a82294710fd8ebbc5 UNKNOWN * Unknown: [CANCELED](TBD) * c3b8c47d4aac9dbc1b425bdef346e084febd4a2d UNKNOWN

[GitHub] [flink] caozhen1937 commented on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

caozhen1937 commented on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-723402849 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] zhuzhurk commented on a change in pull request #13958: [FLINK-19994][runtime] Do not force iteration job to generate one only pipelined region

zhuzhurk commented on a change in pull request #13958: URL: https://github.com/apache/flink/pull/13958#discussion_r519145694 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -91,6 +88,8 @@ public DefaultEx

[GitHub] [flink] flinkbot edited a comment on pull request #13958: [FLINK-19994][runtime] Do not force iteration job to generate one only pipelined region

flinkbot edited a comment on pull request #13958: URL: https://github.com/apache/flink/pull/13958#issuecomment-722993305 ## CI report: * e6c7892e55dd4baaff4968e4257a63a51023d841 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13974: [hotfix][doc] Fix a concurrent issue in testing.md

flinkbot edited a comment on pull request #13974: URL: https://github.com/apache/flink/pull/13974#issuecomment-723401121 ## CI report: * 0073a428d1b41297708cbd146482e1d8509174cd Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

flinkbot edited a comment on pull request #13957: URL: https://github.com/apache/flink/pull/13957#issuecomment-722961884 ## CI report: * eded6a80f900965a008691d061057dae9c0d7cfe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zhuzhurk commented on a change in pull request #13958: [FLINK-19994][runtime] Do not force iteration job to generate one only pipelined region

zhuzhurk commented on a change in pull request #13958: URL: https://github.com/apache/flink/pull/13958#discussion_r519143747 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -91,6 +88,8 @@ public DefaultEx

[GitHub] [flink] flinkbot commented on pull request #13974: [hotfix][doc] Fix a concurrent issue in testing.md

flinkbot commented on pull request #13974: URL: https://github.com/apache/flink/pull/13974#issuecomment-723401121 ## CI report: * 0073a428d1b41297708cbd146482e1d8509174cd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

flinkbot edited a comment on pull request #13957: URL: https://github.com/apache/flink/pull/13957#issuecomment-722961884 ## CI report: * eded6a80f900965a008691d061057dae9c0d7cfe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zhuzhurk commented on a change in pull request #13958: [FLINK-19994][runtime] Do not force iteration job to generate one only pipelined region

zhuzhurk commented on a change in pull request #13958: URL: https://github.com/apache/flink/pull/13958#discussion_r519129436 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -201,4 +195,32 @@ private stati

[GitHub] [flink] zhuzhurk commented on a change in pull request #13958: [FLINK-19994][runtime] Do not force iteration job to generate one only pipelined region

zhuzhurk commented on a change in pull request #13958: URL: https://github.com/apache/flink/pull/13958#discussion_r519133383 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -201,4 +195,32 @@ private stati

[GitHub] [flink] zhuzhurk commented on a change in pull request #13958: [FLINK-19994][runtime] Do not force iteration job to generate one only pipelined region

zhuzhurk commented on a change in pull request #13958: URL: https://github.com/apache/flink/pull/13958#discussion_r519129436 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -201,4 +195,32 @@ private stati

[GitHub] [flink] flinkbot commented on pull request #13974: [hotfix][doc] Fix a concurrent issue in testing.md

flinkbot commented on pull request #13974: URL: https://github.com/apache/flink/pull/13974#issuecomment-723399501 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] [Closed] (FLINK-19644) Support read specific partition of Hive table in temporal join

[ https://issues.apache.org/jira/browse/FLINK-19644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19644. Resolution: Fixed master (1.12): 09386f27b66c86e8148ae8d25d72e3c2ac552362 > Support read specific

[GitHub] [flink] xccui opened a new pull request #13974: [hotfix][doc] Fix a concurrent issue in testing.md

xccui opened a new pull request #13974: URL: https://github.com/apache/flink/pull/13974 ## What is the purpose of the change An example in `testing.md` uses `synchronized` keyword to protect a static variable, which will cause concurrent issues with multiple sink instances. #

[GitHub] [flink] JingsongLi merged pull request #13729: [FLINK-19644][hive] Support read latest partition of Hive table in temporal join

JingsongLi merged pull request #13729: URL: https://github.com/apache/flink/pull/13729 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

[GitHub] [flink] flinkbot edited a comment on pull request #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

flinkbot edited a comment on pull request #13957: URL: https://github.com/apache/flink/pull/13957#issuecomment-722961884 ## CI report: * eded6a80f900965a008691d061057dae9c0d7cfe 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 #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

JingsongLi commented on a change in pull request #13957: URL: https://github.com/apache/flink/pull/13957#discussion_r519122722 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/DeserializationSchemaAdapter.java ## @@ -0,0 +1,31

[GitHub] [flink] JingsongLi commented on a change in pull request #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

JingsongLi commented on a change in pull request #13957: URL: https://github.com/apache/flink/pull/13957#discussion_r519122574 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java ## @@ -251,6 +258,14 @@ p

[GitHub] [flink] flinkbot edited a comment on pull request #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

flinkbot edited a comment on pull request #13957: URL: https://github.com/apache/flink/pull/13957#issuecomment-722961884 ## CI report: * eded6a80f900965a008691d061057dae9c0d7cfe 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 #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

JingsongLi commented on a change in pull request #13957: URL: https://github.com/apache/flink/pull/13957#discussion_r519119368 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/DeserializationSchemaAdapter.java ## @@ -0,0 +1,31

[jira] [Commented] (FLINK-19653) HiveCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-19653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227733#comment-17227733 ] Dian Fu commented on FLINK-19653: - HiveTableSourceITCase failed with similar exception:

[GitHub] [flink] wuchong commented on pull request #13296: [FLINK-18774][format][debezium] Support debezium-avro format

wuchong commented on pull request #13296: URL: https://github.com/apache/flink/pull/13296#issuecomment-723396648 Hi @caozhen1937 , the compile CI is failed. This is an automated message from the Apache Git Service. To respon

[GitHub] [flink] flinkbot edited a comment on pull request #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

flinkbot edited a comment on pull request #13957: URL: https://github.com/apache/flink/pull/13957#issuecomment-722961884 ## CI report: * eded6a80f900965a008691d061057dae9c0d7cfe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[ https://issues.apache.org/jira/browse/FLINK-19868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19868: Release Note: The 'csv.line-delimiter' option has been removed from CSV format. Because the line delimiter

[GitHub] [flink] wuchong commented on a change in pull request #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

wuchong commented on a change in pull request #13957: URL: https://github.com/apache/flink/pull/13957#discussion_r519108294 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java ## @@ -251,6 +258,14 @@ priv

[GitHub] [flink] flinkbot edited a comment on pull request #13871: [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API

flinkbot edited a comment on pull request #13871: URL: https://github.com/apache/flink/pull/13871#issuecomment-720254759 ## CI report: * ab63312aba03160fffba96646c4f39257dc7f760 UNKNOWN * 179472a87778a738c1f9f866156dcf6e024e69c7 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

flinkbot edited a comment on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-719924065 ## CI report: * 3c1eac765ebab2b74ade4ccbcf576e496e4bdffc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13729: [FLINK-19644][hive] Support read latest partition of Hive table in temporal join

flinkbot edited a comment on pull request #13729: URL: https://github.com/apache/flink/pull/13729#issuecomment-713673157 ## CI report: * aefdb5f32451d2a47b8cd57b46bc559ccde5b797 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13871: [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API

flinkbot edited a comment on pull request #13871: URL: https://github.com/apache/flink/pull/13871#issuecomment-720254759 ## CI report: * ab63312aba03160fffba96646c4f39257dc7f760 UNKNOWN * 179472a87778a738c1f9f866156dcf6e024e69c7 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

flinkbot edited a comment on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-719924065 ## CI report: * 3c1eac765ebab2b74ade4ccbcf576e496e4bdffc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13729: [FLINK-19644][hive] Support read latest partition of Hive table in temporal join

flinkbot edited a comment on pull request #13729: URL: https://github.com/apache/flink/pull/13729#issuecomment-713673157 ## CI report: * aefdb5f32451d2a47b8cd57b46bc559ccde5b797 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20028) FileCompactionITCase is unstable

[ https://issues.apache.org/jira/browse/FLINK-20028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227723#comment-17227723 ] Jingsong Lee commented on FLINK-20028: -- Looks like hang in the source, let's keep l

[GitHub] [flink] JingsongLi commented on a change in pull request #13937: [FLINK-19886][hive] Integrate file compaction to Hive connector

JingsongLi commented on a change in pull request #13937: URL: https://github.com/apache/flink/pull/13937#discussion_r519097384 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveCompactReader.java ## @@ -0,0 +1,147 @@ +/

[jira] [Created] (FLINK-20040) Hive streaming sink does not support static partition inserting well

Jingsong Lee created FLINK-20040: Summary: Hive streaming sink does not support static partition inserting well Key: FLINK-20040 URL: https://issues.apache.org/jira/browse/FLINK-20040 Project: Flink

[GitHub] [flink] wangyang0918 commented on pull request #13871: [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based on Kubernetes API

wangyang0918 commented on pull request #13871: URL: https://github.com/apache/flink/pull/13871#issuecomment-723388940 Address the minor comments, rebase latest master and force pushed. This is an automated message from the Ap

[GitHub] [flink] wangyang0918 commented on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

wangyang0918 commented on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-723388865 Address the naming comments, rebase latest master and force pushed. This is an automated message from the A

[jira] [Comment Edited] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227720#comment-17227720 ] Jin Xing edited comment on FLINK-20038 at 11/7/20, 4:10 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

flinkbot edited a comment on pull request #13957: URL: https://github.com/apache/flink/pull/13957#issuecomment-722961884 ## CI report: * eded6a80f900965a008691d061057dae9c0d7cfe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

[ https://issues.apache.org/jira/browse/FLINK-20038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227720#comment-17227720 ] Jin Xing commented on FLINK-20038: -- Gentle ping [~zhuzh] and [~azagrebin] Flink master

[GitHub] [flink] flinkbot edited a comment on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

flinkbot edited a comment on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-719924065 ## CI report: * 3c1eac765ebab2b74ade4ccbcf576e496e4bdffc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-20034) Add maxwell-json format document

[ https://issues.apache.org/jira/browse/FLINK-20034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20034. --- Fix Version/s: (was: 1.12.0) Resolution: Duplicate > Add maxwell-json format document > -

[jira] [Commented] (FLINK-18897) Add documentation for the maxwell-json format

[ https://issues.apache.org/jira/browse/FLINK-18897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227719#comment-17227719 ] Jark Wu commented on FLINK-18897: - Hi [~shen_dijie], are you still working on this? > A

[jira] [Comment Edited] (FLINK-19488) Failed compilation of generated class

[ https://issues.apache.org/jira/browse/FLINK-19488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227718#comment-17227718 ] Jark Wu edited comment on FLINK-19488 at 11/7/20, 4:03 AM: --- [~

[jira] [Commented] (FLINK-19488) Failed compilation of generated class

[ https://issues.apache.org/jira/browse/FLINK-19488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227718#comment-17227718 ] Jark Wu commented on FLINK-19488: - [~satyamshekhar], There is a bug when in code generat

[jira] [Comment Edited] (FLINK-19488) Failed compilation of generated class

[ https://issues.apache.org/jira/browse/FLINK-19488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227718#comment-17227718 ] Jark Wu edited comment on FLINK-19488 at 11/7/20, 4:03 AM: --- [~

[jira] [Commented] (FLINK-20036) Join Has NoUniqueKey when using mini-batch

[ https://issues.apache.org/jira/browse/FLINK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227717#comment-17227717 ] Jark Wu commented on FLINK-20036: - Thanks for reporting this. > Join Has NoUniqueKey w

[jira] [Updated] (FLINK-20037) there is a comment problem in fromValues(AbstractDataType rowType, Object... values) method of TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-20037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20037: Component/s: (was: API / Core) Table SQL / API > there is a comment problem in fromVa

[jira] [Updated] (FLINK-20036) Join Has NoUniqueKey when using mini-batch

[ https://issues.apache.org/jira/browse/FLINK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20036: Fix Version/s: 1.12.0 > Join Has NoUniqueKey when using mini-batch > -

[jira] [Created] (FLINK-20038) Rectify the usage of ResultPartitionType#isPipelined() in partition tracker.

Jin Xing created FLINK-20038: Summary: Rectify the usage of ResultPartitionType#isPipelined() in partition tracker. Key: FLINK-20038 URL: https://issues.apache.org/jira/browse/FLINK-20038 Project: Flink

[jira] [Closed] (FLINK-14356) Introduce "raw" format to (de)serialize message to a single field

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14356. --- Resolution: Fixed Implemented in master (1.12.0) with: - d230058932d7563dff7de6bc8d8045dae4326f1f - 17c381

[jira] [Updated] (FLINK-20039) Streaming File Sink end-to-end test is unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-20039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20039: Fix Version/s: 1.12.0 > Streaming File Sink end-to-end test is unstable on Azure > ---

[jira] [Updated] (FLINK-14356) Introduce "raw" format to (de)serialize message to a single field

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14356: Summary: Introduce "raw" format to (de)serialize message to a single field (was: Introduce "single-field"

[GitHub] [flink] wuchong merged pull request #13909: [FLINK-14356][table][formats] Introduce "raw" format to (de)serialize message to a single field

wuchong merged pull request #13909: URL: https://github.com/apache/flink/pull/13909 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] wuchong commented on pull request #13909: [FLINK-14356][table][formats] Introduce "raw" format to (de)serialize message to a single field

wuchong commented on pull request #13909: URL: https://github.com/apache/flink/pull/13909#issuecomment-723387225 The failed e2e should not be related to this PR. I created https://issues.apache.org/jira/browse/FLINK-20039 to track the unstable e2e test. Will merge this.

[jira] [Created] (FLINK-20039) Streaming File Sink end-to-end test is unstable on Azure

Jark Wu created FLINK-20039: --- Summary: Streaming File Sink end-to-end test is unstable on Azure Key: FLINK-20039 URL: https://issues.apache.org/jira/browse/FLINK-20039 Project: Flink Issue Type: Bu

[GitHub] [flink] flinkbot edited a comment on pull request #13957: [FLINK-19823][table][fs-connector] Filesystem connector supports de/serialization schema

flinkbot edited a comment on pull request #13957: URL: https://github.com/apache/flink/pull/13957#issuecomment-722961884 ## CI report: * eded6a80f900965a008691d061057dae9c0d7cfe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13931: [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions

flinkbot edited a comment on pull request #13931: URL: https://github.com/apache/flink/pull/13931#issuecomment-722165982 ## CI report: * abbd41e66fa93bcb058a25bfbb21a1389192a2f5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

flinkbot edited a comment on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-719924065 ## CI report: * 3c1eac765ebab2b74ade4ccbcf576e496e4bdffc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] JingsongLi merged pull request #13937: [FLINK-19886][hive] Integrate file compaction to Hive connector

JingsongLi merged pull request #13937: URL: https://github.com/apache/flink/pull/13937 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

[jira] [Closed] (FLINK-19886) Integrate file compaction to Hive connector

[ https://issues.apache.org/jira/browse/FLINK-19886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19886. Resolution: Fixed master (1.12): f1f25e012b3fc7d338f169871addbd78b86f33bf > Integrate file compac

[GitHub] [flink] lirui-apache commented on a change in pull request #13729: [FLINK-19644][hive] Support read latest partition of Hive table in temporal join

lirui-apache commented on a change in pull request #13729: URL: https://github.com/apache/flink/pull/13729#discussion_r519093000 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveLookupTableSource.java ## @@ -0,0 +1,285 @@ +

[GitHub] [flink] flinkbot edited a comment on pull request #13931: [FLINK-19811][table-planner] Introduce RexSimplify to simplify SEARCH conditions

flinkbot edited a comment on pull request #13931: URL: https://github.com/apache/flink/pull/13931#issuecomment-722165982 ## CI report: * abbd41e66fa93bcb058a25bfbb21a1389192a2f5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

flinkbot edited a comment on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-719924065 ## CI report: * 3c1eac765ebab2b74ade4ccbcf576e496e4bdffc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13729: [FLINK-19644][hive] Support read latest partition of Hive table in temporal join

flinkbot edited a comment on pull request #13729: URL: https://github.com/apache/flink/pull/13729#issuecomment-713673157 ## CI report: * aefdb5f32451d2a47b8cd57b46bc559ccde5b797 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-19282) Support watermark push down with WatermarkStrategy

[ https://issues.apache.org/jira/browse/FLINK-19282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-19282: --- Fix Version/s: 1.12.0 > Support watermark push down with WatermarkStrategy > ---

[jira] [Closed] (FLINK-19282) Support watermark push down with WatermarkStrategy

[ https://issues.apache.org/jira/browse/FLINK-19282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-19282. -- Resolution: Implemented > Support watermark push down with WatermarkStrategy > ---

[jira] [Commented] (FLINK-19282) Support watermark push down with WatermarkStrategy

[ https://issues.apache.org/jira/browse/FLINK-19282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227699#comment-17227699 ] godfrey he commented on FLINK-19282: master: 2c1e24b53f54486827f767ab3ab5b22abc6fc27

[jira] [Assigned] (FLINK-19282) Support watermark push down with WatermarkStrategy

[ https://issues.apache.org/jira/browse/FLINK-19282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-19282: -- Assignee: Shengkai Fang > Support watermark push down with WatermarkStrategy > --

[GitHub] [flink] flinkbot edited a comment on pull request #13770: [FLINK-18858][connector-kinesis] Add Kinesis sources and sinks

flinkbot edited a comment on pull request #13770: URL: https://github.com/apache/flink/pull/13770#issuecomment-715323245 ## CI report: * c1af295630bc8064312d310846613a8a3b23bbca UNKNOWN * 42df702f984d75eb8ec74bc1a48613b20c0bb3c5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] lirui-apache commented on a change in pull request #13937: [FLINK-19886][hive] Integrate file compaction to Hive connector

lirui-apache commented on a change in pull request #13937: URL: https://github.com/apache/flink/pull/13937#discussion_r519086775 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveCompactReader.java ## @@ -0,0 +1,147 @@

[GitHub] [flink] godfreyhe merged pull request #13449: [FLINK-19282][table sql/planner]Supports watermark push down with Wat…

godfreyhe merged pull request #13449: URL: https://github.com/apache/flink/pull/13449 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 t

[GitHub] [flink] flinkbot edited a comment on pull request #13973: [FLINK-19850] Add e2e tests for the new File Sink in the streaming mode

flinkbot edited a comment on pull request #13973: URL: https://github.com/apache/flink/pull/13973#issuecomment-723320462 ## CI report: * c9aaec278c8352ee530c04016a0f8f7ab59252a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13729: [FLINK-19644][hive] Support read latest partition of Hive table in temporal join

flinkbot edited a comment on pull request #13729: URL: https://github.com/apache/flink/pull/13729#issuecomment-713673157 ## CI report: * aefdb5f32451d2a47b8cd57b46bc559ccde5b797 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] 1996fanrui commented on pull request #13885: [FLINK-19911] Read checkpoint stream with buffer to speedup restore

1996fanrui commented on pull request #13885: URL: https://github.com/apache/flink/pull/13885#issuecomment-723377721 > Sorry to be late to the game here, but could you share a bit more information on what the original setup was? > Specifically, what was your checkpoint storage system that

[GitHub] [flink] leonardBang commented on pull request #13729: [FLINK-19644][hive] Support read latest partition of Hive table in temporal join

leonardBang commented on pull request #13729: URL: https://github.com/apache/flink/pull/13729#issuecomment-723377617 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, ple

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

[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-19692: Fix Version/s: (was: statefun-2.3.0) > Can't restore feedback channel from sav

[GitHub] [flink-statefun] tzulitai commented on pull request #171: [FLINK-20009][docs] Add documentation link check to travis

tzulitai commented on pull request #171: URL: https://github.com/apache/flink-statefun/pull/171#issuecomment-723377364 +1, LGTM This is an automated message from the Apache Git Service. To respond to the message, please log o

[jira] [Closed] (FLINK-19748) KeyGroupRangeOffsets#KeyGroupOffsetsIterator should skip key groups that don't have a defined offset

[ https://issues.apache.org/jira/browse/FLINK-19748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-19748. --- Resolution: Fixed flink/master: 3367c238ad9de0dc50735df33ff09852a3427b1b flink/relea

[jira] [Closed] (FLINK-19741) InternalTimeServiceManager fails to restore due to corrupt reads if there are other users of raw keyed state streams

[ https://issues.apache.org/jira/browse/FLINK-19741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-19741. --- Resolution: Fixed flink/master: c151abc5bd6b4b642100cf75f8981f08535c5936 flink/relea

[GitHub] [flink] tzulitai closed pull request #13772: [FLINK-19748] Iterating key groups in raw keyed stream on restore fails if some key groups weren't written

tzulitai closed pull request #13772: URL: https://github.com/apache/flink/pull/13772 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] tzulitai closed pull request #13761: [FLINK-19741] Allow AbstractStreamOperator to skip restoring timers if subclasses are using raw keyed state

tzulitai closed pull request #13761: URL: https://github.com/apache/flink/pull/13761 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] [Closed] (FLINK-19992) Integrate new orc to Hive source

[ https://issues.apache.org/jira/browse/FLINK-19992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19992. Resolution: Fixed master (1.12): c33e1adbd401a2030d51863c940b8822f06005e5 > Integrate new orc to

[GitHub] [flink] JingsongLi merged pull request #13939: [FLINK-19992][hive] Integrate new orc to Hive source

JingsongLi merged pull request #13939: URL: https://github.com/apache/flink/pull/13939 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

[GitHub] [flink] JingsongLi commented on pull request #13939: [FLINK-19992][hive] Integrate new orc to Hive source

JingsongLi commented on pull request #13939: URL: https://github.com/apache/flink/pull/13939#issuecomment-723376249 E2E failed by `test_streaming_file_sink` looks like network reason which is unrelated to this PR. This is an

[jira] [Commented] (FLINK-20037) there is a comment problem in fromValues(AbstractDataType rowType, Object... values) method of TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-20037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227686#comment-17227686 ] hailong wang commented on FLINK-20037: -- Hi [~yandufeng], Thank you for reporting th

[GitHub] [flink] flinkbot edited a comment on pull request #13954: [FLINK-19903][Table SQL / API] Metadata fields for filesystem csv format

flinkbot edited a comment on pull request #13954: URL: https://github.com/apache/flink/pull/13954#issuecomment-722706660 ## CI report: * 905052e4286ce9d1ed0a7d5c7813a0f35b4fbbdc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20037) there is a comment problem in fromValues(AbstractDataType rowType, Object... values) method of TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-20037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yandufeng updated FLINK-20037: -- Description: there is a comment problem in fromValues(AbstractDataType rowType, Object... values) met

  1   2   3   4   5   6   7   >