[jira] [Updated] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

2020-05-22 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13733: -- Fix Version/s: 1.11.0 > FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis > -

[jira] [Reopened] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

2020-05-22 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-13733: --- The issue seems to have reoccurred. [~rmetzger] please re-open closed issues if the problem see

[GitHub] [flink] flinkbot edited a comment on pull request #8622: [FLINK-12438][doc-zh]Translate Task Lifecycle document into Chinese

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #8622: URL: https://github.com/apache/flink/pull/8622#issuecomment-632686183 ## CI report: * 31efc8a0e9e9347c883706b481f2e060bae8bc32 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/167771628) Bot commands

[GitHub] [flink] flinkbot edited a comment on pull request #11978: [FLINK-16086][chinese-translation]Translate "Temporal Tables" page of "Streaming Concepts" into Chinese

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #11978: URL: https://github.com/apache/flink/pull/11978#issuecomment-623121072 ## CI report: * 689f08ae035886e85ab02097ec800afcaf8cf235 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12294: [FLINK-17882][table-common] Check for self references in structured types

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12294: URL: https://github.com/apache/flink/pull/12294#issuecomment-632633082 ## CI report: * 11cbf0ab775549319c4609fa5f1393277a28ec50 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] GJL commented on a change in pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

2020-05-22 Thread GitBox
GJL commented on a change in pull request #12256: URL: https://github.com/apache/flink/pull/12256#discussion_r429309837 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulk.java ## @@ -0,0 +1,57 @@ +/* + * Licensed to th

[GitHub] [flink] fpompermaier commented on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-22 Thread GitBox
fpompermaier commented on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-632754987 @wuchong or @leonardBang ? Do you have time to review this? This is an automated message from the Apache Gi

[jira] [Commented] (FLINK-13462) Add table api examples into flink-quickstart

2020-05-22 Thread nathan Xie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114175#comment-17114175 ] nathan Xie commented on FLINK-13462: Hi,Can i work on this?Try to add TableApi Examp

[GitHub] [flink] godfreyhe commented on a change in pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-22 Thread GitBox
godfreyhe commented on a change in pull request #12199: URL: https://github.com/apache/flink/pull/12199#discussion_r429320579 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/SelectTableSinkBase.java ## @@ -28,61 +28,106 @@

[jira] [Created] (FLINK-17888) JDBC Connector support LocalDateTime type

2020-05-22 Thread forideal (Jira)
forideal created FLINK-17888: Summary: JDBC Connector support LocalDateTime type Key: FLINK-17888 URL: https://issues.apache.org/jira/browse/FLINK-17888 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-17888) JDBC Connector support LocalDateTime type

2020-05-22 Thread forideal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] forideal updated FLINK-17888: - Affects Version/s: (was: 1.10.0) > JDBC Connector support LocalDateTime type > -

[jira] [Created] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

2020-05-22 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17889: -- Summary: flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory Key: FLINK-17889 URL: https://issues.apache.org/jira/browse

[jira] [Commented] (FLINK-17888) JDBC Connector support LocalDateTime type

2020-05-22 Thread forideal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114189#comment-17114189 ] forideal commented on FLINK-17888: -- [~lzljs3620320] Can you assign this task to me ? I'

[jira] [Commented] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets

2020-05-22 Thread Jason Kania (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114190#comment-17114190 ] Jason Kania commented on FLINK-16468: - Sorry [~gjy], not to this point. The current

[jira] [Commented] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

2020-05-22 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114191#comment-17114191 ] Jeff Zhang commented on FLINK-17889: \cc [~lirui] [~lzljs3620320] > flink-connector

[jira] [Updated] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

2020-05-22 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-17889: --- Description: These 2 classes are in flink-connector-hive jar's SPI config file {code:java} org.apach

[GitHub] [flink] roeyshemtov commented on pull request #11972: [FLINK-17058] Adding ProcessingTimeoutTrigger of nested triggers.

2020-05-22 Thread GitBox
roeyshemtov commented on pull request #11972: URL: https://github.com/apache/flink/pull/11972#issuecomment-632767977 @aljoscha I personally don't like to use null (or at least wrap it with Objects.isNull), but i guess it is okay because the other Triggers use it too. You can merge this,

[jira] [Created] (FLINK-17890) support in DataType TIMESTAMP_WITH_LOCAL_TIME_ZONE in JDBC

2020-05-22 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-17890: -- Summary: support in DataType TIMESTAMP_WITH_LOCAL_TIME_ZONE in JDBC Key: FLINK-17890 URL: https://issues.apache.org/jira/browse/FLINK-17890 Project: Flink Issue

[jira] [Closed] (FLINK-17890) support in DataType TIMESTAMP_WITH_LOCAL_TIME_ZONE in JDBC

2020-05-22 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-17890. -- Resolution: Duplicate > support in DataType TIMESTAMP_WITH_LOCAL_TIME_ZONE in JDBC > -

[jira] [Updated] (FLINK-17848) Allow scala datastream api to create named sources

2020-05-22 Thread Zack LB (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zack LB updated FLINK-17848: Component/s: API / DataStream > Allow scala datastream api to create named sources > -

[jira] [Updated] (FLINK-17848) Allow scala datastream api to create named sources

2020-05-22 Thread Zack LB (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zack LB updated FLINK-17848: Description: Currently you can only provide a custom name to a source operator from the java API. There i

[jira] [Updated] (FLINK-17848) Allow scala datastream api to create named sources

2020-05-22 Thread Zack LB (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zack LB updated FLINK-17848: Description: Currently you can only provide a custom name to a source operator from the java API. There i

[jira] [Updated] (FLINK-17848) Allow scala datastream api to create named sources

2020-05-22 Thread Zack LB (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zack LB updated FLINK-17848: Description: Currently you can only provide a custom name to a source operator from the java API. There i

[GitHub] [flink] leonardBang commented on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-22 Thread GitBox
leonardBang commented on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-632779593 > @wuchong or @leonardBang ? Do you have time to review this? Thanks for the effort @fpompermaier , I'll look in this weekends. ^_^ --

[GitHub] [flink] tillrohrmann commented on pull request #12242: [FLINK-17801][tests] Increase timeout of TaskExecutorTest.testHeartbeatTimeoutWithResourceManager

2020-05-22 Thread GitBox
tillrohrmann commented on pull request #12242: URL: https://github.com/apache/flink/pull/12242#issuecomment-632781352 Thanks for the review @azagrebin. Merging this PR now. This is an automated message from the Apache Git Ser

[GitHub] [flink] sjwiesman commented on a change in pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

2020-05-22 Thread GitBox
sjwiesman commented on a change in pull request #12285: URL: https://github.com/apache/flink/pull/12285#discussion_r429340831 ## File path: flink-libraries/flink-state-processing-api-scala/pom.xml ## @@ -0,0 +1,119 @@ + + +http://maven.apache.org/POM/4.0.0"; +xm

[GitHub] [flink] tillrohrmann closed pull request #12242: [FLINK-17801][tests] Increase timeout of TaskExecutorTest.testHeartbeatTimeoutWithResourceManager

2020-05-22 Thread GitBox
tillrohrmann closed pull request #12242: URL: https://github.com/apache/flink/pull/12242 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 g

[GitHub] [flink] sjwiesman commented on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

2020-05-22 Thread GitBox
sjwiesman commented on pull request #12285: URL: https://github.com/apache/flink/pull/12285#issuecomment-632790591 Also, the build is failing due to missing license headers and checkstyle issues. If you run `mvn verify` from within `flink-state-processing-api-scala` locally you can check t

[GitHub] [flink] brandonbevans commented on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

2020-05-22 Thread GitBox
brandonbevans commented on pull request #12285: URL: https://github.com/apache/flink/pull/12285#issuecomment-632792699 @sjwiesman Thank you for the thorough review I really appreciate it. I'll make the advised changes / clean up and get back. --

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * 7f7d4c37fb57c5caaa862226305c6994fe622898 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Closed] (FLINK-17801) TaskExecutorTest.testHeartbeatTimeoutWithResourceManager timeout

2020-05-22 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-17801. - Fix Version/s: 1.10.2 Resolution: Fixed Fixed via master: a47d7050c77c373c1cb27f7c826bf0

[jira] [Created] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-05-22 Thread Shangwen Tang (Jira)
Shangwen Tang created FLINK-17891: - Summary: FlinkYarnSessionCli sets wrong execution.target type Key: FLINK-17891 URL: https://issues.apache.org/jira/browse/FLINK-17891 Project: Flink Issue

[jira] [Updated] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-05-22 Thread Shangwen Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shangwen Tang updated FLINK-17891: -- Description: I submitted a flink session job at the local YARN cluster, and I found that the

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * 7f7d4c37fb57c5caaa862226305c6994fe622898 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] alpinegizmo commented on a change in pull request #12257: [FLINK-17076][docs] Revamp Kafka Connector Documentation

2020-05-22 Thread GitBox
alpinegizmo commented on a change in pull request #12257: URL: https://github.com/apache/flink/pull/12257#discussion_r429283693 ## File path: docs/dev/connectors/kafka.md ## @@ -23,125 +23,59 @@ specific language governing permissions and limitations under the License. -->

[jira] [Commented] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-05-22 Thread Shangwen Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114246#comment-17114246 ] Shangwen Tang commented on FLINK-17891: --- My idea is that if we start the flink ses

[jira] [Comment Edited] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-05-22 Thread Shangwen Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114246#comment-17114246 ] Shangwen Tang edited comment on FLINK-17891 at 5/22/20, 5:14 PM: -

[jira] [Comment Edited] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-05-22 Thread Shangwen Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114246#comment-17114246 ] Shangwen Tang edited comment on FLINK-17891 at 5/22/20, 5:14 PM: -

[jira] [Commented] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-05-22 Thread Shangwen Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114251#comment-17114251 ] Shangwen Tang commented on FLINK-17891: --- This is a simple fix, assign this issue t

[GitHub] [flink] GJL closed pull request #12276: [FLINK-13553][tests][qs] Improve Logging to debug Test Instability

2020-05-22 Thread GitBox
GJL closed pull request #12276: URL: https://github.com/apache/flink/pull/12276 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 the

[jira] [Commented] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

2020-05-22 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114285#comment-17114285 ] Gary Yao commented on FLINK-13553: -- Added more debug/trace logs. 1.11: 7cbdd91413ee26d

[GitHub] [flink] flinkbot edited a comment on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12285: URL: https://github.com/apache/flink/pull/12285#issuecomment-632360179 ## CI report: * 754d93703e9ecf3043b9bf57121d1636a3a4c167 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

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

[GitHub] [flink] caozhen1937 opened a new pull request #12296: [FLINK-17814][chinese-translation]Translate native kubernetes document to Chinese

2020-05-22 Thread GitBox
caozhen1937 opened a new pull request #12296: URL: https://github.com/apache/flink/pull/12296 ## What is the purpose of the change Translate native kubernetes document to Chinese This is an automated message fr

[jira] [Updated] (FLINK-17814) Translate native kubernetes document to Chinese

2020-05-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17814: --- Labels: pull-request-available (was: ) > Translate native kubernetes document to Chinese >

[GitHub] [flink] caozhen1937 commented on pull request #12296: [FLINK-17814][chinese-translation]Translate native kubernetes document to Chinese

2020-05-22 Thread GitBox
caozhen1937 commented on pull request #12296: URL: https://github.com/apache/flink/pull/12296#issuecomment-632881152 @wangyang0918 hi, please review if you have time. This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot commented on pull request #12296: [FLINK-17814][chinese-translation]Translate native kubernetes document to Chinese

2020-05-22 Thread GitBox
flinkbot commented on pull request #12296: URL: https://github.com/apache/flink/pull/12296#issuecomment-632882488 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] flinkbot commented on pull request #12296: [FLINK-17814][chinese-translation]Translate native kubernetes document to Chinese

2020-05-22 Thread GitBox
flinkbot commented on pull request #12296: URL: https://github.com/apache/flink/pull/12296#issuecomment-632902501 ## CI report: * 22bae967d6b59eb8e4c5dcd6a37f5a27fc492ed1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * 5b62118449cdf8d0de8d5b98781fdff9c2d0c571 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12296: [FLINK-17814][chinese-translation]Translate native kubernetes document to Chinese

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

[GitHub] [flink] TengHu opened a new pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
TengHu opened a new pull request #12297: URL: https://github.com/apache/flink/pull/12297 > ## What is the purpose of the change > Flink triggers all panes belonging to one window at the same time. In other words, all panes are aligned and their triggers all fire simultaneously, causing

[GitHub] [flink] flinkbot commented on pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
flinkbot commented on pull request #12297: URL: https://github.com/apache/flink/pull/12297#issuecomment-632942068 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] TengHu commented on pull request #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
TengHu commented on pull request #8885: URL: https://github.com/apache/flink/pull/8885#issuecomment-632942543 > ## What is the purpose of the change > Flink triggers all panes belonging to one window at the same time. In other words, all panes are aligned and their triggers all fire simu

[GitHub] [flink] TengHu removed a comment on pull request #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
TengHu removed a comment on pull request #8885: URL: https://github.com/apache/flink/pull/8885#issuecomment-632942543 > ## What is the purpose of the change > Flink triggers all panes belonging to one window at the same time. In other words, all panes are aligned and their triggers all f

[GitHub] [flink] TengHu commented on pull request #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
TengHu commented on pull request #8885: URL: https://github.com/apache/flink/pull/8885#issuecomment-632942879 > This is a very good feature! Sorry for taking so (extremely) long to finally review this. I didn't initially see this PR. > > Could you please address my comments? >

[GitHub] [flink] TengHu commented on pull request #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
TengHu commented on pull request #8885: URL: https://github.com/apache/flink/pull/8885#issuecomment-632943368 > @TengHu have you been successfully using this change in production? We've run into a similar challenge with window alignment, would love to see this change merged and hear about

[GitHub] [flink] TengHu commented on a change in pull request #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
TengHu commented on a change in pull request #8885: URL: https://github.com/apache/flink/pull/8885#discussion_r429490081 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java ## @@ -107,7 +123,48

[GitHub] [flink] flinkbot commented on pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
flinkbot commented on pull request #12297: URL: https://github.com/apache/flink/pull/12297#issuecomment-632945310 ## CI report: * 52b0395a9fc4d3fa99def97fe79b42edef32bcf6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] TengHu commented on a change in pull request #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
TengHu commented on a change in pull request #8885: URL: https://github.com/apache/flink/pull/8885#discussion_r429491587 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java ## @@ -46,28 +46,44 @

[GitHub] [flink] TengHu closed pull request #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
TengHu closed pull request #8885: URL: https://github.com/apache/flink/pull/8885 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 the

[jira] [Created] (FLINK-17892) Dynamic option may not be a part of the table digest

2020-05-22 Thread hailong wang (Jira)
hailong wang created FLINK-17892: Summary: Dynamic option may not be a part of the table digest Key: FLINK-17892 URL: https://issues.apache.org/jira/browse/FLINK-17892 Project: Flink Issue Ty

[GitHub] [flink] TengHu commented on pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
TengHu commented on pull request #12297: URL: https://github.com/apache/flink/pull/12297#issuecomment-632947574 @aljoscha Here is the new PR. I will make the change for other window assigners after this one is approved. Thank you, Niel ---

[GitHub] [flink] TengHu commented on pull request #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
TengHu commented on pull request #8885: URL: https://github.com/apache/flink/pull/8885#issuecomment-632947709 Replaced with https://github.com/apache/flink/pull/12297 This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot edited a comment on pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12297: URL: https://github.com/apache/flink/pull/12297#issuecomment-632945310 ## CI report: * 52b0395a9fc4d3fa99def97fe79b42edef32bcf6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12297: URL: https://github.com/apache/flink/pull/12297#issuecomment-632945310 ## CI report: * 52b0395a9fc4d3fa99def97fe79b42edef32bcf6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114479#comment-17114479 ] Dian Fu commented on FLINK-17883: - [~jark] [~lzljs3620320] Thanks for your reply. It mak

[GitHub] [flink] JingsongLi commented on a change in pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

2020-05-22 Thread GitBox
JingsongLi commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r429503816 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,352 @@ +--- +title: "Hadoop FileSystem Connector" +nav-title: Hadoop FileSystem +na

[GitHub] [flink] JingsongLi commented on a change in pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

2020-05-22 Thread GitBox
JingsongLi commented on a change in pull request #12283: URL: https://github.com/apache/flink/pull/12283#discussion_r429503816 ## File path: docs/dev/table/connectors/filesystem.md ## @@ -0,0 +1,352 @@ +--- +title: "Hadoop FileSystem Connector" +nav-title: Hadoop FileSystem +na

[jira] [Comment Edited] (FLINK-17883) Unable to configure write mode for FileSystem() connector in PyFlink

2020-05-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114479#comment-17114479 ] Dian Fu edited comment on FLINK-17883 at 5/23/20, 1:53 AM: --- [~

[GitHub] [flink] JingsongLi commented on pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

2020-05-22 Thread GitBox
JingsongLi commented on pull request #12283: URL: https://github.com/apache/flink/pull/12283#issuecomment-632966730 @sjwiesman Thank you very much for your review. Very useful. I will modify them. This is an automated messag

[jira] [Commented] (FLINK-17892) Dynamic option may not be a part of the table digest

2020-05-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114482#comment-17114482 ] Jingsong Lee commented on FLINK-17892: -- Hi [~hailong wang], thanks for reporting. D

[jira] [Commented] (FLINK-17892) Dynamic option may not be a part of the table digest

2020-05-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114483#comment-17114483 ] Jingsong Lee commented on FLINK-17892: -- Change to 1.11 bug and critical. > Dynamic

[jira] [Updated] (FLINK-17892) Dynamic option may not be a part of the table digest

2020-05-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17892: - Fix Version/s: (was: 1.12.0) 1.11.0 > Dynamic option may not be a part of

[jira] [Updated] (FLINK-17892) Dynamic option may not be a part of the table digest

2020-05-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17892: - Priority: Critical (was: Major) > Dynamic option may not be a part of the table digest > --

[jira] [Updated] (FLINK-17892) Dynamic option may not be a part of the table digest

2020-05-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17892: - Issue Type: Bug (was: Improvement) > Dynamic option may not be a part of the table digest > ---

[GitHub] [flink] JingsongLi commented on pull request #12283: [FLINK-16975][documentation] Add docs for FileSystem connector

2020-05-22 Thread GitBox
JingsongLi commented on pull request #12283: URL: https://github.com/apache/flink/pull/12283#issuecomment-632971290 > @JingsongLi Thank you for working on this. I have one additional question that is not addressed in the docs. What happens when a record is supposed to be written into a par

[GitHub] [flink] zhougit86 closed pull request #12298: Feature/watermark

2020-05-22 Thread GitBox
zhougit86 closed pull request #12298: URL: https://github.com/apache/flink/pull/12298 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

[jira] [Commented] (FLINK-14527) Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module

2020-05-22 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114493#comment-17114493 ] Lijie Wang commented on FLINK-14527: Hi [~jark] , I'm considering the same thing. I

[GitHub] [flink] zhougit86 opened a new pull request #12298: Feature/watermark

2020-05-22 Thread GitBox
zhougit86 opened a new pull request #12298: URL: https://github.com/apache/flink/pull/12298 ## Verifying this change This change is a trivial rework ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a d

[jira] [Commented] (FLINK-14527) Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module

2020-05-22 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114494#comment-17114494 ] Lijie Wang commented on FLINK-14527: About UT, we can check whether the results retu

[GitHub] [flink] zhougit86 opened a new pull request #12299: [FLINK-17878][filesystem] StreamingFileWriter currentWatermark attrib…

2020-05-22 Thread GitBox
zhougit86 opened a new pull request #12299: URL: https://github.com/apache/flink/pull/12299 ## Verifying this change This change is a trivial rework ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a d

[jira] [Commented] (FLINK-17878) Transient watermark attribute should be initial at runtime in streaming file operators

2020-05-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114499#comment-17114499 ] xiaogang zhou commented on FLINK-17878: --- [~lzljs3620320] Hi Jingsong, thx for the

[GitHub] [flink] flinkbot commented on pull request #12299: [FLINK-17878][filesystem] StreamingFileWriter currentWatermark attrib…

2020-05-22 Thread GitBox
flinkbot commented on pull request #12299: URL: https://github.com/apache/flink/pull/12299#issuecomment-632975818 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] flinkbot edited a comment on pull request #12293: [FLINK-17878][filesystem] StreamingFileWriter currentWatermark attrib…

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

[jira] [Created] (FLINK-17893) SQL-CLI no exception stack

2020-05-22 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17893: Summary: SQL-CLI no exception stack Key: FLINK-17893 URL: https://issues.apache.org/jira/browse/FLINK-17893 Project: Flink Issue Type: Bug Componen

[jira] [Updated] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

2020-05-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17889: - Priority: Blocker (was: Major) > flink-connector-hive jar contains wrong class in its SPI confi

[jira] [Updated] (FLINK-17889) flink-connector-hive jar contains wrong class in its SPI config file org.apache.flink.table.factories.TableFactory

2020-05-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17889: - Fix Version/s: 1.11.0 > flink-connector-hive jar contains wrong class in its SPI config file >

[jira] [Created] (FLINK-17894) RowGenerator in datagen connector should be serializable

2020-05-22 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17894: Summary: RowGenerator in datagen connector should be serializable Key: FLINK-17894 URL: https://issues.apache.org/jira/browse/FLINK-17894 Project: Flink Issu

[GitHub] [flink] flinkbot edited a comment on pull request #12293: [FLINK-17878][filesystem] StreamingFileWriter currentWatermark attrib…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12297: URL: https://github.com/apache/flink/pull/12297#issuecomment-632945310 ## CI report: * 52b0395a9fc4d3fa99def97fe79b42edef32bcf6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12299: [FLINK-17878][filesystem] StreamingFileWriter currentWatermark attrib…

2020-05-22 Thread GitBox
flinkbot commented on pull request #12299: URL: https://github.com/apache/flink/pull/12299#issuecomment-632977800 ## CI report: * 6c0db10514575ddaeb66689ff7b3e2ee2975bdfe UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

2020-05-22 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114503#comment-17114503 ] Yun Tang commented on FLINK-16572: -- Another instance: https://dev.azure.com/apache-fli

[jira] [Created] (FLINK-17895) Default value of rows-per-second in datagen should be limited

2020-05-22 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17895: Summary: Default value of rows-per-second in datagen should be limited Key: FLINK-17895 URL: https://issues.apache.org/jira/browse/FLINK-17895 Project: Flink

[GitHub] [flink] Myasuka commented on pull request #12282: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-22 Thread GitBox
Myasuka commented on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632978514 My azure CI pipeline has run successfully twice: [my-build-1](https://myasuka.visualstudio.com/flink/_build/results?buildId=77) and [my-build-2](https://myasuka.visualstudio.co

[GitHub] [flink] flinkbot edited a comment on pull request #12299: [FLINK-17878][filesystem] StreamingFileWriter currentWatermark attrib…

2020-05-22 Thread GitBox
flinkbot edited a comment on pull request #12299: URL: https://github.com/apache/flink/pull/12299#issuecomment-632977800 ## CI report: * 6c0db10514575ddaeb66689ff7b3e2ee2975bdfe Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-17896) HiveCatalog can work with new table factory because of is_generic

2020-05-22 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17896: Summary: HiveCatalog can work with new table factory because of is_generic Key: FLINK-17896 URL: https://issues.apache.org/jira/browse/FLINK-17896 Project: Flink

[jira] [Commented] (FLINK-17893) SQL-CLI no exception stack

2020-05-22 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114515#comment-17114515 ] godfrey he commented on FLINK-17893: sql client should support {{-verbose}} option

[GitHub] [flink] klion26 commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

2020-05-22 Thread GitBox
klion26 commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r429510266 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -26,66 +26,65 @@ under the License. * This will be replaced by the TOC {:toc} -##

[GitHub] [flink] flinkbot edited a comment on pull request #12297: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

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

[jira] [Commented] (FLINK-17892) Dynamic option may not be a part of the table digest

2020-05-22 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114547#comment-17114547 ] hailong wang commented on FLINK-17892: -- Hi [~lzljs3620320], No, kafka source will n

<    1   2   3   4   >