[GitHub] [flink] GJL commented on a change in pull request #11600: [FLINK-14311] Relax restart checker to harden StreaminFileSink e2e test

2020-04-01 Thread GitBox
GJL commented on a change in pull request #11600: [FLINK-14311] Relax restart checker to harden StreaminFileSink e2e test URL: https://github.com/apache/flink/pull/11600#discussion_r401630599 ## File path: flink-end-to-end-tests/test-scripts/common.sh ## @@ -731,7 +731,8

[jira] [Commented] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

2020-04-01 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072801#comment-17072801 ] Terry Wang commented on FLINK-16924: cc [~danny0405] > TableEnvironment#sqlUpdate throw NPE when

[jira] [Updated] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

2020-04-01 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16924: --- Description: Now in the latest code of flink master branch, we encountered unexpected npe

[GitHub] [flink] rmetzger commented on issue #11601: [FLINK-16906][e2e][hotfix] Disable TPC-DS end-to-end test (Blink)

2020-04-01 Thread GitBox
rmetzger commented on issue #11601: [FLINK-16906][e2e][hotfix] Disable TPC-DS end-to-end test (Blink) URL: https://github.com/apache/flink/pull/11601#issuecomment-607270217 Maybe I should rather assign this PR to https://issues.apache.org/jira/browse/FLINK-16917.

[jira] [Commented] (FLINK-16708) When a JDBC connection has been closed, the retry policy of the JDBCUpsertOutputFormat cannot take effect

2020-04-01 Thread Shangwen Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072812#comment-17072812 ] Shangwen Tang commented on FLINK-16708: --- CC: [~lzljs3620320] [~jark] [~knaufk] Can someone help

[jira] [Commented] (FLINK-16793) Add jobName to log4j ConversionPattern

2020-04-01 Thread jinhai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072837#comment-17072837 ] jinhai commented on FLINK-16793: [~chesnay] Thank you. it works > Add jobName to log4j

[GitHub] [flink] walterddr commented on a change in pull request #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura…

2020-04-01 Thread GitBox
walterddr commented on a change in pull request #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura… URL: https://github.com/apache/flink/pull/11583#discussion_r401673498 ## File path: flink-dist/src/main/flink-bin/bin/flink-console.sh ## @@

[GitHub] [flink-statefun] alpinegizmo opened a new pull request #89: [FLINK-16925] remove unused CSE files

2020-04-01 Thread GitBox
alpinegizmo opened a new pull request #89: [FLINK-16925] remove unused CSE files URL: https://github.com/apache/flink-statefun/pull/89 docs/cse.xml and docs/annotations.xml aren't actually used, and their presence here might confuse someone.

[GitHub] [flink] walterddr commented on a change in pull request #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura…

2020-04-01 Thread GitBox
walterddr commented on a change in pull request #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura… URL: https://github.com/apache/flink/pull/11583#discussion_r401676216 ## File path: flink-dist/src/main/flink-bin/bin/flink-console.sh ## @@

[jira] [Updated] (FLINK-16925) remove Custom Search Engine files from statefun docs

2020-04-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16925: --- Labels: pull-request-available (was: ) > remove Custom Search Engine files from statefun

[GitHub] [flink] flinkbot commented on issue #11605: [BP-1.9][FLINK-14316] Properly manage rpcConnection in JobManagerLeaderListener under leader change

2020-04-01 Thread GitBox
flinkbot commented on issue #11605: [BP-1.9][FLINK-14316] Properly manage rpcConnection in JobManagerLeaderListener under leader change URL: https://github.com/apache/flink/pull/11605#issuecomment-607305586 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] dawidwys closed pull request #11527: [FLINK-16035] Updated Stream/BatchTableEnvironment.java to use Java's Expression DSL

2020-04-01 Thread GitBox
dawidwys closed pull request #11527: [FLINK-16035] Updated Stream/BatchTableEnvironment.java to use Java's Expression DSL URL: https://github.com/apache/flink/pull/11527 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

2020-04-01 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072846#comment-17072846 ] Timo Walther commented on FLINK-16924: -- I'm not aware that we are providing any concurrency

[jira] [Created] (FLINK-16928) Switch back to new scheduler in Stateful Functions

2020-04-01 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16928: --- Summary: Switch back to new scheduler in Stateful Functions Key: FLINK-16928 URL: https://issues.apache.org/jira/browse/FLINK-16928 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * d20feb41f2e2940f6d6c8766586876addd3e2e92

[jira] [Updated] (FLINK-16928) Switch back to new scheduler in Stateful Functions

2020-04-01 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-16928: Priority: Blocker (was: Major) > Switch back to new scheduler in Stateful

[GitHub] [flink] flinkbot commented on issue #11608: [FLINK-16560] Forward Configuration in PackagedProgramUtils#getPipelineFromProgram

2020-04-01 Thread GitBox
flinkbot commented on issue #11608: [FLINK-16560] Forward Configuration in PackagedProgramUtils#getPipelineFromProgram URL: https://github.com/apache/flink/pull/11608#issuecomment-607342131 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11598#issuecomment-607168470 ## CI report: * d81b0e98dc23cf9370cdfdd20b39dd8cfdab3f84 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11599: [FLINK-16919][Blink Planner]Parameter 'jobName' does not take effect in BatchTableEnvUtil

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11599: [FLINK-16919][Blink Planner]Parameter 'jobName' does not take effect in BatchTableEnvUtil URL: https://github.com/apache/flink/pull/11599#issuecomment-607176783 ## CI report: * 626c41346e89f48f72bec4ca911b7103b6e87dbe Travis:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-04-01 Thread GitBox
rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r401754717 ## File path:

[jira] [Updated] (FLINK-16929) Session Window produces sessions randomly

2020-04-01 Thread Ori Popowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ori Popowski updated FLINK-16929: - Attachment: image-2020-04-01-19-56-27-720.png > Session Window produces sessions randomly >

[jira] [Updated] (FLINK-16929) Session Window produces sessions randomly

2020-04-01 Thread Ori Popowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ori Popowski updated FLINK-16929: - Description:  We have a Flink job which keyBys session ID (sId), and uses a session window

[jira] [Updated] (FLINK-16929) Session Window produces sessions randomly

2020-04-01 Thread Ori Popowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ori Popowski updated FLINK-16929: - Attachment: image-2020-04-01-19-56-00-239.png > Session Window produces sessions randomly >

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2020-04-01 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072982#comment-17072982 ] Yun Tang commented on FLINK-16850: -- I prefer to promote {{flink-benchmarks}} to Apache project, as we

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-04-01 Thread GitBox
rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r401781584 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11290: [FLINK-16379][table] Introduce fromValues in TableEnvironment URL: https://github.com/apache/flink/pull/11290#issuecomment-593487396 ## CI report: * 49376ddf5708d3cf924b886de461222780128ba8 UNKNOWN *

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-04-01 Thread GitBox
zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r401427977 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task.

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-605967084 ## CI report: * 0019e8fea99d88be91751328615153bde4a80999 Travis:

[GitHub] [flink] flinkbot commented on issue #11591: [FLINK-15305][tests] Make BoundedDataTestBase#testGetSizeMultipleRegions respect system page size to avoid potential failure

2020-04-01 Thread GitBox
flinkbot commented on issue #11591: [FLINK-15305][tests] Make BoundedDataTestBase#testGetSizeMultipleRegions respect system page size to avoid potential failure URL: https://github.com/apache/flink/pull/11591#issuecomment-607098515 ## CI report: *

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-04-01 Thread GitBox
zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r401427977 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese URL: https://github.com/apache/flink/pull/11590#issuecomment-607068581 ## CI report: * 8d4774382b57353f1de2f37c23144f4f2321b443 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11589: [FLINK-15486][tests] Remove timeout of LocalInputChannelTest#testConcurrentConsumeMultiplePartitions to avoid potential timeout problem on s

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11589: [FLINK-15486][tests] Remove timeout of LocalInputChannelTest#testConcurrentConsumeMultiplePartitions to avoid potential timeout problem on slow machine. URL: https://github.com/apache/flink/pull/11589#issuecomment-607063006 ## CI report:

[jira] [Created] (FLINK-16906) TPC-DS end-to-end test (Blink planner) failed after 80 minutes

2020-04-01 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-16906: -- Summary: TPC-DS end-to-end test (Blink planner) failed after 80 minutes Key: FLINK-16906 URL: https://issues.apache.org/jira/browse/FLINK-16906 Project: Flink

[jira] [Created] (FLINK-16909) fix doc : The default value for params for HBase Connector

2020-04-01 Thread gkgkgk (Jira)
gkgkgk created FLINK-16909: -- Summary: fix doc : The default value for params for HBase Connector Key: FLINK-16909 URL: https://issues.apache.org/jira/browse/FLINK-16909 Project: Flink Issue Type:

[jira] [Updated] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

2020-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16908: --- Labels: test-stability (was: ) > FlinkKafkaProducerITCase testScaleUpAfterScalingDown

[GitHub] [flink] StephanEwen commented on issue #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura…

2020-04-01 Thread GitBox
StephanEwen commented on issue #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura… URL: https://github.com/apache/flink/pull/11583#issuecomment-607102434 These changes may break setup assumptions from some users. I am not sure. Maybe one of the users that

[jira] [Created] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

2020-04-01 Thread Jira
辛羿彤 created FLINK-16907: --- Summary: did not react to cancelling signal for 30 seconds, but is stuck in method: Key: FLINK-16907 URL: https://issues.apache.org/jira/browse/FLINK-16907 Project: Flink

[jira] [Created] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

2020-04-01 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-16908: -- Summary: FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 6ms. Key: FLINK-16908 URL:

[GitHub] [flink] zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

2020-04-01 Thread GitBox
zhijiangW commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r401434664 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-04-01 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r401435369 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-04-01 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r401435369 ## File path:

[jira] [Created] (FLINK-16910) The job running on agent Hosted Agent ran longer than the maximum time of 240 minutes

2020-04-01 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-16910: -- Summary: The job running on agent Hosted Agent ran longer than the maximum time of 240 minutes Key: FLINK-16910 URL: https://issues.apache.org/jira/browse/FLINK-16910

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-04-01 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r401427599 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-04-01 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r401426619 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-04-01 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r401421223 ## File path: flink-core/src/main/java/org/apache/flink/util/StringUtils.java ## @@

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-04-01 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r401435369 ## File path:

[jira] [Updated] (FLINK-16910) The job running on agent Hosted Agent ran longer than the maximum time of 240 minutes

2020-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16910: --- Labels: test-stability (was: ) > The job running on agent Hosted Agent ran longer than the

[GitHub] [flink-statefun] tzulitai commented on issue #88: Licensing final fixes / touches for 2.0.0

2020-04-01 Thread GitBox
tzulitai commented on issue #88: Licensing final fixes / touches for 2.0.0 URL: https://github.com/apache/flink-statefun/pull/88#issuecomment-607104767 Thanks a lot for the prompt reviews, merging this to `master` and `release-2.0`.

[jira] [Updated] (FLINK-16906) TPC-DS end-to-end test (Blink planner) failed after 80 minutes

2020-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16906: --- Priority: Critical (was: Major) > TPC-DS end-to-end test (Blink planner) failed after 80

[jira] [Updated] (FLINK-16906) Various tests failing with: Could not register mbeans javax.management.InstanceAlreadyExistsException

2020-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16906: --- Summary: Various tests failing with: Could not register mbeans

[GitHub] [flink-statefun] tzulitai closed pull request #88: Licensing final fixes / touches for 2.0.0

2020-04-01 Thread GitBox
tzulitai closed pull request #88: Licensing final fixes / touches for 2.0.0 URL: https://github.com/apache/flink-statefun/pull/88 This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-16906) TPC-DS end-to-end test (Blink planner) failed after 80 minutes

2020-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072506#comment-17072506 ] Piotr Nowojski commented on FLINK-16906: Another instance of the same exception in a different

[GitHub] [flink] jinglining commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

2020-04-01 Thread GitBox
jinglining commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r401437125 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11591: [FLINK-15305][tests] Make BoundedDataTestBase#testGetSizeMultipleRegions respect system page size to avoid potential failure

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11591: [FLINK-15305][tests] Make BoundedDataTestBase#testGetSizeMultipleRegions respect system page size to avoid potential failure URL: https://github.com/apache/flink/pull/11591#issuecomment-607098515 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11590: [FLINK-16102][docs-zh] Translate docs/dev/table/hive/scala_shell_hive.zh.md into Chinese URL: https://github.com/apache/flink/pull/11590#issuecomment-607068581 ## CI report: * 8d4774382b57353f1de2f37c23144f4f2321b443 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11589: [FLINK-15486][tests] Remove timeout of LocalInputChannelTest#testConcurrentConsumeMultiplePartitions to avoid potential timeout problem on s

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11589: [FLINK-15486][tests] Remove timeout of LocalInputChannelTest#testConcurrentConsumeMultiplePartitions to avoid potential timeout problem on slow machine. URL: https://github.com/apache/flink/pull/11589#issuecomment-607063006 ## CI report:

[jira] [Updated] (FLINK-16906) Various tests failing with: Could not register mbeans javax.management.InstanceAlreadyExistsException

2020-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16906: --- Description: *Probably it's better to analyse the issue not from this initially reported

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-04-01 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r401437686 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-04-01 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r401439424 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-04-01 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r401427599 ## File path:

[GitHub] [flink] klion26 commented on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata

2020-04-01 Thread GitBox
klion26 commented on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata URL: https://github.com/apache/flink/pull/11491#issuecomment-607109472 Thanks for the update, LGTM now. This is an

[jira] [Created] (FLINK-16911) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence

2020-04-01 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-16911: -- Summary: PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence Key: FLINK-16911 URL: https://issues.apache.org/jira/browse/FLINK-16911

[jira] [Updated] (FLINK-16911) PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails on checkPathExistence

2020-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16911: --- Labels: test-stability (was: ) > PrestoS3FileSystemITCase#testSimpleFileWriteAndRead fails

[jira] [Commented] (FLINK-16906) Various tests failing with: Could not register mbeans javax.management.InstanceAlreadyExistsException

2020-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072514#comment-17072514 ] Piotr Nowojski commented on FLINK-16906: Another instances:

[jira] [Updated] (FLINK-16906) Various tests failing with: Could not register mbeans javax.management.InstanceAlreadyExistsException

2020-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16906: --- Priority: Blocker (was: Critical) > Various tests failing with: Could not register mbeans

[jira] [Comment Edited] (FLINK-16906) Various tests failing with: Could not register mbeans javax.management.InstanceAlreadyExistsException

2020-04-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072514#comment-17072514 ] Piotr Nowojski edited comment on FLINK-16906 at 4/1/20, 8:31 AM: -

[jira] [Updated] (FLINK-16827) Kafka stream data sorted by time field throws null pointer exception under multiple concurrency

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16827: - Component/s: (was: API / Core) Table SQL / Runtime

[jira] [Commented] (FLINK-16827) Kafka stream data sorted by time field throws null pointer exception under multiple concurrency

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072516#comment-17072516 ] Aljoscha Krettek commented on FLINK-16827: -- [~jark] Fyi, the component was wrongly assigned

[GitHub] [flink] klion26 commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

2020-04-01 Thread GitBox
klion26 commented on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-607111363 @carp84 thanks for your review, have updated the pr, added unit tests to cover the logic in

[GitHub] [flink] nielsbasjes opened a new pull request #11592: [WIP] [FLINK-16871][runtime] Make more build time information available at runtime

2020-04-01 Thread GitBox
nielsbasjes opened a new pull request #11592: [WIP] [FLINK-16871][runtime] Make more build time information available at runtime URL: https://github.com/apache/flink/pull/11592 # [FLINK-16871](https://issues.apache.org/jira/browse/FLINK-16871): Make more build time information available

[jira] [Updated] (FLINK-16871) Make more build information available during runtime.

2020-04-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16871: --- Labels: pull-request-available (was: ) > Make more build information available during

[GitHub] [flink] lirui-apache commented on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe

2020-04-01 Thread GitBox
lirui-apache commented on issue #11579: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe URL: https://github.com/apache/flink/pull/11579#issuecomment-607113147 cc @JingsongLi This is an automated message from

[GitHub] [flink] jinglining commented on issue #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

2020-04-01 Thread GitBox
jinglining commented on issue #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#issuecomment-607112083 > For future reference, I think it would have been better to split this ticket into two: > > 1. Implement

[jira] [Commented] (FLINK-16860) TableException: Failed to push filter into table source! when upgrading flink to 1.9.2

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072518#comment-17072518 ] Aljoscha Krettek commented on FLINK-16860: -- [~twalthr] or [~jark], could you please take a look

[GitHub] [flink] flinkbot commented on issue #11592: [WIP] [FLINK-16871][runtime] Make more build time information available at runtime

2020-04-01 Thread GitBox
flinkbot commented on issue #11592: [WIP] [FLINK-16871][runtime] Make more build time information available at runtime URL: https://github.com/apache/flink/pull/11592#issuecomment-607113412 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Created] (FLINK-16912) Introduce table row write support for parquet writer

2020-04-01 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-16912: Summary: Introduce table row write support for parquet writer Key: FLINK-16912 URL: https://issues.apache.org/jira/browse/FLINK-16912 Project: Flink Issue

[jira] [Updated] (FLINK-16865) 【Flink Kafka Connector】Restore from Savepoint,if add new Kafka topic,Flink will consume the new topic from earlist,it may cause duplicate data sink

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16865: - Component/s: Connectors / Kafka > 【Flink Kafka Connector】Restore from Savepoint,if add

[jira] [Updated] (FLINK-16860) TableException: Failed to push filter into table source! when upgrading flink to 1.9.2

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16860: - Component/s: Table SQL / API > TableException: Failed to push filter into table source!

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014 ## CI report: * 90f2f05876e4eda952d512f5248dcd9bf0c6d913 Travis:

[jira] [Closed] (FLINK-16865) 【Flink Kafka Connector】Restore from Savepoint,if add new Kafka topic,Flink will consume the new topic from earlist,it may cause duplicate data sink

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-16865. Resolution: Duplicate > 【Flink Kafka Connector】Restore from Savepoint,if add new Kafka

[GitHub] [flink] flinkbot edited a comment on issue #11587: [FLINK-14126][test] Ensure elasticsearch version check

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11587: [FLINK-14126][test] Ensure elasticsearch version check URL: https://github.com/apache/flink/pull/11587#issuecomment-606986240 ## CI report: * 24e8fe074b128ca2a9b491ee61582e5e58fa9b50 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task.

2020-04-01 Thread GitBox
flinkbot edited a comment on issue #11564: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#issuecomment-605967084 ## CI report: * 5ad66720b750455263df2ccb345f46b298d62faa Travis:

[jira] [Updated] (FLINK-16871) Make more build information available during runtime.

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16871: - Component/s: Build System > Make more build information available during runtime. >

[jira] [Commented] (FLINK-16860) TableException: Failed to push filter into table source! when upgrading flink to 1.9.2

2020-04-01 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072521#comment-17072521 ] Jingsong Lee commented on FLINK-16860: -- Ah... Yes, after FLINK-12399. there are bugs in

[jira] [Updated] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16907: - Issue Type: Bug (was: Task) > did not react to cancelling signal for 30 seconds, but

[jira] [Updated] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16907: - Flags: (was: Important) > did not react to cancelling signal for 30 seconds, but is

[jira] [Updated] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16907: - Description: 接入kafka数据时在map方法卡住无响应 Google Translate: I get stuck in the map method

[jira] [Closed] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

2020-04-01 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-16907. Resolution: Invalid Closing for now until more information is provided. Please provide

[GitHub] [flink] mxm commented on a change in pull request #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura…

2020-04-01 Thread GitBox
mxm commented on a change in pull request #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura… URL: https://github.com/apache/flink/pull/11583#discussion_r401451263 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -645,3 +645,20 @@

[GitHub] [flink] mxm commented on a change in pull request #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura…

2020-04-01 Thread GitBox
mxm commented on a change in pull request #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura… URL: https://github.com/apache/flink/pull/11583#discussion_r401453912 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -645,3 +645,20 @@

[jira] [Created] (FLINK-16913) ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException

2020-04-01 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-16913: Summary: ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException Key: FLINK-16913 URL: https://issues.apache.org/jira/browse/FLINK-16913

[jira] [Updated] (FLINK-16913) ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException

2020-04-01 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16913: - Description: Steps to reproduce the issue: # Set flink-conf.yaml ** state.backend: rocksdb

[jira] [Updated] (FLINK-16909) fix doc : The default value for params for HBase Connector

2020-04-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16909: --- Labels: pull-request-available (was: ) > fix doc : The default value for params for HBase

[jira] [Updated] (FLINK-16913) ReadableConfigToConfigurationAdapter#getEnum throws UnsupportedOperationException

2020-04-01 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-16913: - Description: Steps to reproduce the issue: # Set flink-conf.yaml ** state.backend: rocksdb

[GitHub] [flink] mxm commented on a change in pull request #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura…

2020-04-01 Thread GitBox
mxm commented on a change in pull request #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura… URL: https://github.com/apache/flink/pull/11583#discussion_r401456463 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -645,3 +645,20 @@

[GitHub] [flink] uce edited a comment on issue #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura…

2020-04-01 Thread GitBox
uce edited a comment on issue #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura… URL: https://github.com/apache/flink/pull/11583#issuecomment-607122085 I'm also concerned about this. I'm afraid that it adds another layer of "magic" to the scripts. The

[GitHub] [flink] uce commented on issue #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura…

2020-04-01 Thread GitBox
uce commented on issue #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura… URL: https://github.com/apache/flink/pull/11583#issuecomment-607122085 I'm also concerned with this. I'm afraid that it adds another layer of "magic" to the scripts. The original

[GitHub] [flink] gk0916 opened a new pull request #11593: [FLINK-16909][doc] fix doc : The default value for params for HBase Connector

2020-04-01 Thread GitBox
gk0916 opened a new pull request #11593: [FLINK-16909][doc] fix doc : The default value for params for HBase Connector URL: https://github.com/apache/flink/pull/11593 ## What is the purpose of the change *This pull request fixes the Hbase Connector doc: The default value for

[GitHub] [flink] uce edited a comment on issue #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura…

2020-04-01 Thread GitBox
uce edited a comment on issue #11583: [FLINK-16883] Scan FLINK_CONF directory for available log4j configura… URL: https://github.com/apache/flink/pull/11583#issuecomment-607122085 I'm also concerned about this. I'm afraid that it adds another layer of "magic" to the scripts. The

  1   2   3   4   5   6   7   8   >