[jira] [Assigned] (FLINK-13490) Fix return null in JDBCUtils::getFieldFromResultSet

[ https://issues.apache.org/jira/browse/FLINK-13490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13490: --- Assignee: Caizhi Weng > Fix return null in JDBCUtils::getFieldFromResultSet > -

[jira] [Commented] (FLINK-13491) AsyncWaitOperator doesn't handle endInput call properly

[ https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895937#comment-16895937 ] Guowei Ma commented on FLINK-13491: --- Currently, Operatorchain calls all operator's "en

[jira] [Commented] (FLINK-13492) BoundedOutOfOrderTimestamps cause Watermark's timestamp leak

[ https://issues.apache.org/jira/browse/FLINK-13492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895936#comment-16895936 ] Dawid Wysakowicz commented on FLINK-13492: -- Hi [~simonss] which commit did you

[jira] [Commented] (FLINK-13442) Remove unnecessary notifySubpartitionConsumed method from view reader

[ https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895932#comment-16895932 ] zhijiang commented on FLINK-13442: -- I change the priority of this issue as not blocker

[jira] [Closed] (FLINK-13492) BoundedOutOfOrderTimestamps cause Watermark's timestamp leak

[ https://issues.apache.org/jira/browse/FLINK-13492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Su closed FLINK-13492. Resolution: Fixed > BoundedOutOfOrderTimestamps cause Watermark's timestamp leak > ---

[GitHub] [flink] flinkbot edited a comment on issue #9264: [FLINK-13192][hive] Add tests for different Hive table formats

flinkbot edited a comment on issue #9264: [FLINK-13192][hive] Add tests for different Hive table formats URL: https://github.com/apache/flink/pull/9264#issuecomment-515988891 ## CI report: * 152412f354ed83326a23edbf5f47b138fdd8e9e2 : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] flinkbot edited a comment on issue #9244: [FLINK-13396] Deprecate the BucketingSink.

flinkbot edited a comment on issue #9244: [FLINK-13396] Deprecate the BucketingSink. URL: https://github.com/apache/flink/pull/9244#issuecomment-515493269 ## CI report: * 8e3b712c5c2e003747737d2fb77752a3e10a3279 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/120873450

[GitHub] [flink] kl0u commented on a change in pull request #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded.

kl0u commented on a change in pull request #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded. URL: https://github.com/apache/flink/pull/9240#discussion_r308610461 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph

[jira] [Commented] (FLINK-13421) Unexpected ConcurrentModificationException when RM notifies JM about allocation failure

[ https://issues.apache.org/jira/browse/FLINK-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895929#comment-16895929 ] Till Rohrmann commented on FLINK-13421: --- Hi [~zhuzh], what's the state of this iss

[jira] [Created] (FLINK-13493) BoundedBlockingSubpartition only notifies onConsumedSubpartition when all the readers are empty

zhijiang created FLINK-13493: Summary: BoundedBlockingSubpartition only notifies onConsumedSubpartition when all the readers are empty Key: FLINK-13493 URL: https://issues.apache.org/jira/browse/FLINK-13493

[jira] [Commented] (FLINK-13446) Row count sliding window outputs incorrectly in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895928#comment-16895928 ] Jark Wu commented on FLINK-13446: - Hi [~twalthr], currently, the behavior of row count s

[GitHub] [flink] kl0u commented on issue #9244: [FLINK-13396] Deprecate the BucketingSink.

kl0u commented on issue #9244: [FLINK-13396] Deprecate the BucketingSink. URL: https://github.com/apache/flink/pull/9244#issuecomment-516329506 Thanks for looking into it @mzuehlke . I integrated your comments. Let me know if I forgot anything. -

[GitHub] [flink] pnowojski commented on a change in pull request #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc…

pnowojski commented on a change in pull request #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc… URL: https://github.com/apache/flink/pull/9224#discussion_r308603077 ## File path: flink-connectors/flink-connector-kafka-base/src/tes

[GitHub] [flink] pnowojski commented on a change in pull request #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc…

pnowojski commented on a change in pull request #9224: [FLINK-13226] [connectors / kafka] Fix race condition between transaction commit and produc… URL: https://github.com/apache/flink/pull/9224#discussion_r308602206 ## File path: flink-connectors/flink-connector-kafka-0.11/src/tes

[GitHub] [flink] aljoscha commented on a change in pull request #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded.

aljoscha commented on a change in pull request #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded. URL: https://github.com/apache/flink/pull/9240#discussion_r308202942 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint

[GitHub] [flink] aljoscha commented on a change in pull request #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded.

aljoscha commented on a change in pull request #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded. URL: https://github.com/apache/flink/pull/9240#discussion_r308604883 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiong

[GitHub] [flink] aljoscha commented on a change in pull request #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded.

aljoscha commented on a change in pull request #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded. URL: https://github.com/apache/flink/pull/9240#discussion_r308604510 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint

[GitHub] [flink] aljoscha commented on a change in pull request #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded.

aljoscha commented on a change in pull request #9240: [FLINK-13440] Add test that fails job when in-flight sync savepoint is discarded. URL: https://github.com/apache/flink/pull/9240#discussion_r308605315 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiong

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

ifndef-SleePy commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect… URL: https://github.com/apache/flink/pull/9221#discussion_r308604404 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/fun

[jira] [Created] (FLINK-13492) BoundedOutOfOrderTimestamps cause Watermark's timestamp leak

Simon Su created FLINK-13492: Summary: BoundedOutOfOrderTimestamps cause Watermark's timestamp leak Key: FLINK-13492 URL: https://issues.apache.org/jira/browse/FLINK-13492 Project: Flink Issue T

[jira] [Commented] (FLINK-13491) AsyncWaitOperator doesn't handle endInput call properly

[ https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895922#comment-16895922 ] Biao Liu commented on FLINK-13491: -- Oops! Is there any more operators buffering data?

[jira] [Updated] (FLINK-13442) Remove unnecessary notifySubpartitionConsumed method from view reader

[ https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13442: - Fix Version/s: (was: 1.9.0) 1.10 > Remove unnecessary notifySubpartitionConsumed

[GitHub] [flink] flinkbot edited a comment on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

flinkbot edited a comment on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#issuecomment-513664474 ## CI report: * 74a251ff6fa8c2ff9b13ae5869aacf90146024aa : FAILURE [Build](https://travis-ci.co

[jira] [Commented] (FLINK-13474) NoSuchMethodError when registering DataStream

[ https://issues.apache.org/jira/browse/FLINK-13474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895921#comment-16895921 ] Aljoscha Krettek commented on FLINK-13474: -- Where can I find the latest docker

[jira] [Updated] (FLINK-13442) Remove unnecessary notifySubpartitionConsumed method from view reader

[ https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13442: - Issue Type: Improvement (was: Bug) > Remove unnecessary notifySubpartitionConsumed method from view rea

[jira] [Updated] (FLINK-13442) Remove unnecessary notifySubpartitionConsumed method from view reader

[ https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13442: - Priority: Minor (was: Blocker) > Remove unnecessary notifySubpartitionConsumed method from view reader

[jira] [Commented] (FLINK-13491) AsyncWaitOperator doesn't handle endInput call properly

[ https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895920#comment-16895920 ] Aljoscha Krettek commented on FLINK-13491: -- I feel it's the same problem as {{c

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895917#comment-16895917 ] Dian Fu commented on FLINK-13488: - [~sunjincheng121] +1 to drop the support for python 3

[GitHub] [flink] flinkbot edited a comment on issue #9261: [FLINK-13399][table] Create two separate table uber jars for old and blink planners

flinkbot edited a comment on issue #9261: [FLINK-13399][table] Create two separate table uber jars for old and blink planners URL: https://github.com/apache/flink/pull/9261#issuecomment-515974172 ## CI report: * c23ebe46842df43f20819767a24fa4008aa18423 : FAILURE [Build](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client

flinkbot edited a comment on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client URL: https://github.com/apache/flink/pull/9229#issuecomment-515087495 ## CI report: * 63d15eb2051a523b13ca094d6d100764366462e8 : SUCCESS [Build](https://travis-ci.com/fl

[jira] [Updated] (FLINK-13486) AsyncDataStreamITCase.testOrderedWaitUsingAnonymousFunction instable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13486: Priority: Blocker (was: Major) > AsyncDataStreamITCase.testOrderedWaitUsingAnonym

[jira] [Updated] (FLINK-13486) AsyncDataStreamITCase.testOrderedWaitUsingAnonymousFunction instable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13486: Fix Version/s: 1.9.0 > AsyncDataStreamITCase.testOrderedWaitUsingAnonymousFunction

[jira] [Comment Edited] (FLINK-13475) Reduce dependency on third-party maven repositories

[ https://issues.apache.org/jira/browse/FLINK-13475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895856#comment-16895856 ] Terry Wang edited comment on FLINK-13475 at 7/30/19 8:26 AM: -

[jira] [Updated] (FLINK-13267) Making it possible to have both flink planner and blink planner in classpath

[ https://issues.apache.org/jira/browse/FLINK-13267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13267: -- Priority: Major (was: Blocker) > Making it possible to have both flink planner and blink plan

[jira] [Assigned] (FLINK-13487) TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfterReleaseCall failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13487: - Assignee: zhijiang > TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfterReleas

[GitHub] [flink] flinkbot edited a comment on issue #9264: [FLINK-13192][hive] Add tests for different Hive table formats

flinkbot edited a comment on issue #9264: [FLINK-13192][hive] Add tests for different Hive table formats URL: https://github.com/apache/flink/pull/9264#issuecomment-515988891 ## CI report: * 152412f354ed83326a23edbf5f47b138fdd8e9e2 : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[jira] [Updated] (FLINK-13491) AsyncWaitOperator doesn't handle endInput call properly

[ https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-13491: --- Summary: AsyncWaitOperator doesn't handle endInput call properly (was: AsyncWaitOperator do

[jira] [Created] (FLINK-13491) AsyncWaitOperator doesn't handle endOfInput call properly

Piotr Nowojski created FLINK-13491: -- Summary: AsyncWaitOperator doesn't handle endOfInput call properly Key: FLINK-13491 URL: https://issues.apache.org/jira/browse/FLINK-13491 Project: Flink

[jira] [Commented] (FLINK-13446) Row count sliding window outputs incorrectly in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895905#comment-16895905 ] Till Rohrmann commented on FLINK-13446: --- [~twalthr] please discuss with [~jark] wh

[jira] [Commented] (FLINK-13442) Remove unnecessary notifySubpartitionConsumed method from view reader

[ https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895903#comment-16895903 ] Till Rohrmann commented on FLINK-13442: --- [~StephanEwen] & [~zjwang] please decide

[GitHub] [flink] flinkbot edited a comment on issue #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37

flinkbot edited a comment on issue #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37 URL: https://github.com/apache/flink/pull/9239#issuecomment-515435805 ## CI report: * bb0663ddbb6eeda06b756c4ffc7094e64dbdb5b9 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/buil

[jira] [Commented] (FLINK-13377) Streaming SQL e2e test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-13377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895897#comment-16895897 ] Dawid Wysakowicz commented on FLINK-13377: -- Yes this is the behavior that I obs

[GitHub] [flink] flinkbot commented on issue #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

flinkbot commented on issue #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type URL: https://github.com/apache/flink/pull/9272#issuecomment-516313300 ## CI report: * 0f1f8cbe36e97b7f3d8e2b21b693bd0b79623779 : PENDING [Build]

[GitHub] [flink] flinkbot commented on issue #9273: [FLINK-13449][core] Add ARM architecture to MemoryArchitecture

flinkbot commented on issue #9273: [FLINK-13449][core] Add ARM architecture to MemoryArchitecture URL: https://github.com/apache/flink/pull/9273#issuecomment-516313306 ## CI report: * 4537d90aff140a660450ffcabae918880cf075c4 : PENDING [Build](https://travis-ci.com/flink-ci/flink/bui

[jira] [Comment Edited] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895883#comment-16895883 ] sunjincheng edited comment on FLINK-13488 at 7/30/19 8:04 AM:

[jira] [Updated] (FLINK-13277) add documentation of Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13277: -- Priority: Critical (was: Blocker) > add documentation of Hive source/sink > -

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895883#comment-16895883 ] sunjincheng commented on FLINK-13488: - Due to python3.3 is pretty old（see more detai

[jira] [Commented] (FLINK-13475) Reduce dependency on third-party maven repositories

[ https://issues.apache.org/jira/browse/FLINK-13475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895882#comment-16895882 ] Martijn Visser commented on FLINK-13475: [~Terry1897] Just did a git reset --har

[GitHub] [flink] flinkbot commented on issue #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

flinkbot commented on issue #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type URL: https://github.com/apache/flink/pull/9272#issuecomment-516310046 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot

[GitHub] [flink] flinkbot commented on issue #9273: [FLINK-13449][core] Add ARM architecture to MemoryArchitecture

flinkbot commented on issue #9273: [FLINK-13449][core] Add ARM architecture to MemoryArchitecture URL: https://github.com/apache/flink/pull/9273#issuecomment-516310030 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Commented] (FLINK-13435) Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

[ https://issues.apache.org/jira/browse/FLINK-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895881#comment-16895881 ] Andrey Zagrebin commented on FLINK-13435: - [~zjwang] [~Zentol] Could you review?

[jira] [Updated] (FLINK-13449) Add ARM architecture to MemoryArchitecture

[ https://issues.apache.org/jira/browse/FLINK-13449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13449: --- Labels: pull-request-available (was: ) > Add ARM architecture to MemoryArchitecture > -

[GitHub] [flink] Yikun opened a new pull request #9273: [FLINK-13449][core] Add ARM architecture to MemoryArchitecture

Yikun opened a new pull request #9273: [FLINK-13449][core] Add ARM architecture to MemoryArchitecture URL: https://github.com/apache/flink/pull/9273 ## What is the purpose of the change This PR adds the `aarch64` for ARM64/AARCH64 to the known memory architectures. ## Bri

[jira] [Updated] (FLINK-13435) Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

[ https://issues.apache.org/jira/browse/FLINK-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13435: --- Labels: pull-request-available (was: ) > Remove ShuffleDescriptor.ReleaseType and make rele

[jira] [Commented] (FLINK-13377) Streaming SQL e2e test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-13377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895880#comment-16895880 ] Timo Walther commented on FLINK-13377: -- [~docete] this definitely needs some invest

[GitHub] [flink] azagrebin opened a new pull request #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

azagrebin opened a new pull request #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type URL: https://github.com/apache/flink/pull/9272 ## What is the purpose of the change In a long term we do not need auto-release semantics

[jira] [Comment Edited] (FLINK-13377) Streaming SQL e2e test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-13377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895880#comment-16895880 ] Timo Walther edited comment on FLINK-13377 at 7/30/19 7:55 AM: ---

[GitHub] [flink] mzuehlke commented on issue #9244: [FLINK-13396] Deprecate the BucketingSink.

mzuehlke commented on issue #9244: [FLINK-13396] Deprecate the BucketingSink. URL: https://github.com/apache/flink/pull/9244#issuecomment-516308763 Just some tiny comments: - should the `org.apache.flink.streaming.connectors.fs.bucketing.Bucketer` be deprecated, too ? - In the package

[GitHub] [flink] flinkbot edited a comment on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client

flinkbot edited a comment on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client URL: https://github.com/apache/flink/pull/9229#issuecomment-515087495 ## CI report: * 63d15eb2051a523b13ca094d6d100764366462e8 : SUCCESS [Build](https://travis-ci.com/fl

[jira] [Commented] (FLINK-13384) The back pressure monitoring does not work for StreamSources

[ https://issues.apache.org/jira/browse/FLINK-13384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895878#comment-16895878 ] Piotr Nowojski commented on FLINK-13384: >From your two proposals, as a hotfix I

[GitHub] [flink] JingsongLi commented on a change in pull request #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking

JingsongLi commented on a change in pull request #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking URL: https://github.com/apache/flink/pull/9236#discussion_r308576075 ## File path: flink-connectors/flink-jdbc/

[GitHub] [flink] JingsongLi commented on a change in pull request #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking

JingsongLi commented on a change in pull request #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking URL: https://github.com/apache/flink/pull/9236#discussion_r308578224 ## File path: flink-connectors/flink-jdbc/

[GitHub] [flink] JingsongLi commented on a change in pull request #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking

JingsongLi commented on a change in pull request #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking URL: https://github.com/apache/flink/pull/9236#discussion_r308575903 ## File path: flink-connectors/flink-jdbc/

[jira] [Commented] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895873#comment-16895873 ] Biao Liu commented on FLINK-9900: - Hi Gordon, I think it's already under "In progress". I

[GitHub] [flink] flinkbot commented on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

flinkbot commented on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-516306550 ## CI report: * abb4ae6bde1f3d1eac787c850c04614e7c5ff907 : PENDING [Build](https://travis-ci.com/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

flinkbot edited a comment on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#issuecomment-513664474 ## CI report: * 74a251ff6fa8c2ff9b13ae5869aacf90146024aa : FAILURE [Build](https://travis-ci.co

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895871#comment-16895871 ] sunjincheng commented on FLINK-13488: - Sure... > flink-python fails to build on Tra

[jira] [Assigned] (FLINK-13384) The back pressure monitoring does not work for StreamSources

[ https://issues.apache.org/jira/browse/FLINK-13384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-13384: Assignee: Gary Yao (was: Gary Yao) > The back pressure monitoring does not work for StreamSource

[jira] [Comment Edited] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895864#comment-16895864 ] sunjincheng edited comment on FLINK-13488 at 7/30/19 7:45 AM:

[jira] [Comment Edited] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895827#comment-16895827 ] Tzu-Li (Gordon) Tai edited comment on FLINK-9900 at 7/30/19 7:44 AM: --

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895869#comment-16895869 ] Tzu-Li (Gordon) Tai commented on FLINK-13488: - Please move the ticket to "In

[GitHub] [flink] flinkbot commented on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

flinkbot commented on issue #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-516305032 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[jira] [Updated] (FLINK-13384) The back pressure monitoring does not work for StreamSources

[ https://issues.apache.org/jira/browse/FLINK-13384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13384: --- Labels: pull-request-available (was: ) > The back pressure monitoring does not work for Str

[jira] [Assigned] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-13488: --- Assignee: sunjincheng > flink-python fails to build on Travis due to PackagesNotFoundError

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895864#comment-16895864 ] sunjincheng commented on FLINK-13488: - Thanks [~tzulitai] [~dawidwys] ,  the reason

[GitHub] [flink] GJL opened a new pull request #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask

GJL opened a new pull request #9271: [FLINK-13384][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271 ## What is the purpose of the change *This fixes back pressure sampling for sources.* cc: @pnowojski ## Brief chan

[GitHub] [flink] flinkbot edited a comment on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client

flinkbot edited a comment on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client URL: https://github.com/apache/flink/pull/9229#issuecomment-515087495 ## CI report: * 63d15eb2051a523b13ca094d6d100764366462e8 : SUCCESS [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9265: [FLINK-13477][core] Add `memory-overhead-ratio` conf for containers

flinkbot edited a comment on issue #9265: [FLINK-13477][core] Add `memory-overhead-ratio` conf for containers URL: https://github.com/apache/flink/pull/9265#issuecomment-516036391 ## CI report: * 559aa67320c1ec27553ebd3dec825fb9407ff3fb : FAILURE [Build](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot edited a comment on issue #8556: [FLINK-12171][Network] Do not limit the network buffer memory by heap size on the TM side

flinkbot edited a comment on issue #8556: [FLINK-12171][Network] Do not limit the network buffer memory by heap size on the TM side URL: https://github.com/apache/flink/pull/8556#issuecomment-510513877 ## CI report: * 4e2a56f6a3a9e57b001ee013d31053222e05ab7a : SUCCESS [Build](https:

[GitHub] [flink] zjuwangg closed pull request #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37

zjuwangg closed pull request #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37 URL: https://github.com/apache/flink/pull/9239 This is an automated message from the Apache Git Service. To respond to the message, p

[GitHub] [flink] zjuwangg opened a new pull request #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37

zjuwangg opened a new pull request #9239: [FLINK-13385]Align Hive data type mapping with FLIP-37 URL: https://github.com/apache/flink/pull/9239 ## What is the purpose of the change Align Hive data type mapping with FLIP-37. ## Brief change log - *Align Hive data type map

[GitHub] [flink] flinkbot edited a comment on issue #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking

flinkbot edited a comment on issue #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking URL: https://github.com/apache/flink/pull/9236#issuecomment-515390325 ## CI report: * 1135cc72f00606c7a230714838c938068887ce23 :

[GitHub] [flink] flinkbot edited a comment on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

flinkbot edited a comment on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#issuecomment-513664474 ## CI report: * 74a251ff6fa8c2ff9b13ae5869aacf90146024aa : FAILURE [Build](https://travis-ci.co

[GitHub] [flink] flinkbot commented on issue #9270: [hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module

flinkbot commented on issue #9270: [hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module URL: https://github.com/apache/flink/pull/9270#issuecomment-516302065 ## CI report: * 0d7e85e2e5c97817c599c52b590bb589ca2e55f6 : PENDING [B

[jira] [Commented] (FLINK-13475) Reduce dependency on third-party maven repositories

[ https://issues.apache.org/jira/browse/FLINK-13475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895856#comment-16895856 ] Terry Wang commented on FLINK-13475: [~MartijnVisser] It's a little strange that I c

[GitHub] [flink] sunjincheng121 commented on issue #9270: [hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module

sunjincheng121 commented on issue #9270: [hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module URL: https://github.com/apache/flink/pull/9270#issuecomment-516301797 @flinkbot approve all ---

[GitHub] [flink] sunjincheng121 merged pull request #9270: [hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module

sunjincheng121 merged pull request #9270: [hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module URL: https://github.com/apache/flink/pull/9270 This is an automated mess

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect… URL: https://github.com/apache/flink/pull/9221#discussion_r308567382 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functio

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect… URL: https://github.com/apache/flink/pull/9221#discussion_r308570824 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/api/ContinuousF

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect… URL: https://github.com/apache/flink/pull/9221#discussion_r308568245 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functio

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect… URL: https://github.com/apache/flink/pull/9221#discussion_r308568937 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/api/ContinuousF

[GitHub] [flink] pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

pnowojski commented on a change in pull request #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect… URL: https://github.com/apache/flink/pull/9221#discussion_r308570690 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/api/ContinuousF

[GitHub] [flink] flinkbot commented on issue #9270: [hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module

flinkbot commented on issue #9270: [hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module URL: https://github.com/apache/flink/pull/9270#issuecomment-516300557 Thanks a lot for your contribution to the Apache Flink project. I'm the @fli

[GitHub] [flink] HuangXingBo opened a new pull request #9270: [hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module

HuangXingBo opened a new pull request #9270: [hotfix][python] Change "flink-python-" to "flink-python" for the change of artifact of flink-python module URL: https://github.com/apache/flink/pull/9270 ## What is the purpose of the change *Because the artifact of flink-python has cha

[GitHub] [flink] flinkbot edited a comment on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client

flinkbot edited a comment on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client URL: https://github.com/apache/flink/pull/9229#issuecomment-515087495 ## CI report: * 63d15eb2051a523b13ca094d6d100764366462e8 : SUCCESS [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

flinkbot edited a comment on issue #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#issuecomment-513664474 ## CI report: * 74a251ff6fa8c2ff9b13ae5869aacf90146024aa : FAILURE [Build](https://travis-ci.co

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895852#comment-16895852 ] Dawid Wysakowicz commented on FLINK-13488: -- [~sunjincheng121] [~dian.fu] Could

[GitHub] [flink] knaufk commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

knaufk commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#discussion_r308568714 ## File path: docs/getting-started/docker-playgrounds/flink_cluster_playground.md ###

[GitHub] [flink] knaufk commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground

knaufk commented on a change in pull request #9192: [FLINK-12749] [docs] [examples] Initial Version of Flink Cluster Playground URL: https://github.com/apache/flink/pull/9192#discussion_r308564512 ## File path: docs/getting-started/docker-playgrounds/flink_cluster_playground.md ###

[GitHub] [flink] flinkbot edited a comment on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client

flinkbot edited a comment on issue #9229: [FLINK-13279][table-sql-client] Fully qualify sink name in sql-client URL: https://github.com/apache/flink/pull/9229#issuecomment-515087495 ## CI report: * 63d15eb2051a523b13ca094d6d100764366462e8 : SUCCESS [Build](https://travis-ci.com/fl

<    1   2   3   4   5   6   >