{"push_id":1254565243,"size":120,"distinct_size":6,"ref":"refs/heads/FLINK-4402","head":"3d22950493abfdb8caae72447bb71bd6fcb8f709","before":"19dae21b00cfbf68ee64af80672d25974a3cd346","commits":[{"sha":"78af1e97d64f7989f9640767b43f53f7e058f7fc","author":{"name":"Stefan Richter","email":"f4fa93155523de454f7719daac3d15e33e599d43@data-artisans.com"},"message":"[FLINK-4230] [DataStreamAPI] Add Session Windowing ITCase","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/78af1e97d64f7989f9640767b43f53f7e058f7fc"},{"sha":"ccd4fd9d5c4be66d19de01dd616042180ba46cc3","author":{"name":"Stefan Richter","email":"f4fa93155523de454f7719daac3d15e33e599d43@data-artisans.com"},"message":"[FLINK-4230] [DataStreamAPI] PR feedback on Session Windowing ITCase","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/ccd4fd9d5c4be66d19de01dd616042180ba46cc3"},{"sha":"f81cda38b216a3eeec7f124de5e44ddbb361f4ad","author":{"name":"Ufuk Celebi","email":"78b56ba69f8ee462da352d0ec4ccfd5661b9c331@apache.org"},"message":"[FLINK-4237] [runtime] Cancel savepoints on declined snapshots","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/f81cda38b216a3eeec7f124de5e44ddbb361f4ad"},{"sha":"d3bc5563b26c2cf10052dda742790ddf73adc00e","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-4238] Only allow/require query for Tuple Stream in CassandraSink","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/d3bc5563b26c2cf10052dda742790ddf73adc00e"},{"sha":"5dd85e2867a639e10891209dd59be0136a19ecfa","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-4202] Add restarting time JM metric\n\nThis PR adds a JM metric which shows the time it took to restart a job. The time is\nmeasured between entering the JobStatus.RESTARTING and reaching the JobStatus.RUNNING\nstate. During this time, the restarting time is continuously updated. The metric only\nshows the time for the last restart attempt. The metric is published in the job metric\ngroup under the name of \"restartingTime\".\n\nThis closes #2271.","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/5dd85e2867a639e10891209dd59be0136a19ecfa"},{"sha":"73836f7ac07399e47c506db6c1ef5c0a61437e9e","author":{"name":"Aljoscha Krettek","email":"c8544d459372f968393afb8d6d2063138033b23f@gmail.com"},"message":"[FLINK-4229] [metrics] Only start JMX server when port is specified\n\nThis closes #2279","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/73836f7ac07399e47c506db6c1ef5c0a61437e9e"},{"sha":"b3fa459d4c9657e95fdc875d2566b57d48a0a027","author":{"name":"Till Rohrmann","email":"9006f1940e337c648feb3df40b3beb29c822bbfc@apache.org"},"message":"[FLINK-4202] [metrics] Update restarting time metric documentation\n\nThis closes #2284.","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/b3fa459d4c9657e95fdc875d2566b57d48a0a027"},{"sha":"54f02ec7bae56a0559a61b981d0c88885090b128","author":{"name":"Ufuk Celebi","email":"78b56ba69f8ee462da352d0ec4ccfd5661b9c331@apache.org"},"message":"[FLINK-4201] [runtime] Forward suspend to checkpoint coordinator\n\nSuspended jobs were leading to shutdown of the checkpoint coordinator\nand hence removal of checkpoint state. For standalone recovery mode\nthis is OK as no state can be recovered anyways (unchanged in this PR).\nFor HA though this lead to removal of checkpoint state, which we\nactually want to keep for recovery.\n\nWe have the following behaviour now:\n\n-----------+------------+-------------------\n           | Standalone | High Availability\n-----------+------------+-------------------\n SUSPENDED |  Discard   |       Keep\n-----------+------------+-------------------\n FINISHED/ |  Discard   |     Discard\n FAILED/   |            |\n CANCELED  |            |\n-----------+------------+-------------------\n\nThis closes #2276.","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/54f02ec7bae56a0559a61b981d0c88885090b128"},{"sha":"e2ef74ea5a854555f86aefbd8a6b1889ef188ff1","author":{"name":"Greg Hogan","email":"ab3bf20a456957ab3c21b104b37d8a70f0061e3c@greghogan.com"},"message":"[FLINK-4213] [gelly] Provide CombineHint in Gelly algorithms\n\nThis closes #2248","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/e2ef74ea5a854555f86aefbd8a6b1889ef188ff1"},{"sha":"b71ac354d19dccdd8bfa837b92f6bc814c9d29c6","author":{"name":"Greg Hogan","email":"ab3bf20a456957ab3c21b104b37d8a70f0061e3c@greghogan.com"},"message":"[FLINK-4217] [gelly] Gelly drivers should read CSV values as strings\n\nThe user must now specify the ID type as \"integer\" or \"string\" when\nreading a graph from a CSV file.\n\nThis closes #2250","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/b71ac354d19dccdd8bfa837b92f6bc814c9d29c6"},{"sha":"2818ee00974da917785074812e6e994b98ff52f2","author":{"name":"zentol","email":"4fcb55ae66982ee2ad3d3ada8286b6a0f75a1e86@apache.org"},"message":"[hotfix] Prevent CheckpointCommitter from failing job\n\nPrevents the CheckpointCommitter from failing a job, if either\ncommitCheckpoint() or isCheckpointCommitter() failed. Instead, we will\ntry again on the next notify().\n\nThis closes #2287","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/2818ee00974da917785074812e6e994b98ff52f2"},{"sha":"32130160bcc5ef2edb7d03c398dd506ffb4291c6","author":{"name":"Ufuk Celebi","email":"78b56ba69f8ee462da352d0ec4ccfd5661b9c331@apache.org"},"message":"[FLINK-4150] [runtime] Don't clean up BlobStore on BlobServer shut down\n\nThe `BlobServer` acts as a local cache for uploaded BLOBs. The life-cycle of\neach BLOB is bound to the life-cycle of the `BlobServer`. If the BlobServer\nshuts down (on JobManager shut down), all local files will be removed.\n\nWith HA, BLOBs are persisted to another file system (e.g. HDFS) via the\n`BlobStore` in order to have BLOBs available after a JobManager failure (or\nshut down). These BLOBs are only allowed to be removed when the job that\nrequires them enters a globally terminal state (`FINISHED`, `CANCELLED`,\n`FAILED`).\n\nThis commit removes the `BlobStore` clean up call from the `BlobServer`\nshutdown. The `BlobStore` files will only be cleaned up via the\n`BlobLibraryCacheManager`'s' clean up task (periodically or on\nBlobLibraryCacheManager shutdown). This means that there is a chance that\nBLOBs will linger around after the job has terminated, if the job manager\nfails before the clean up.\n\nThis closes #2256.","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/32130160bcc5ef2edb7d03c398dd506ffb4291c6"},{"sha":"c5d1d1232a2693e2f672159064f9eebdb912aca1","author":{"name":"Flavio Pompermaier","email":"7f9e56c067aecba6b22ad1f6124f74485048b427@gmail.com"},"message":"[FLINK-3901] [table] Create a RowCsvInputFormat to use as default CSV IF in Table API","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/c5d1d1232a2693e2f672159064f9eebdb912aca1"},{"sha":"2f9a28ae113f0e941b8bf3676ab84e1492fbf26f","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-3901] [table] Convert Java implementation to Scala and fix bugs\n\nThis closes #2283.","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/2f9a28ae113f0e941b8bf3676ab84e1492fbf26f"},{"sha":"b6f9308c9841db1e775358da50a8498409cde298","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-3891] [table] Add a class containing all supported Table API types\n\nThis closes #2292.","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/b6f9308c9841db1e775358da50a8498409cde298"},{"sha":"588830aaaa9470bf36a0c9011fe07d1a9c48368f","author":{"name":"Jark Wu","email":"1a633f7c3371953c5e5011280efaa0eb236c73fb@alibaba-inc.com"},"message":"[FLINK-4244] [docs] Field names for union operator do not have to be equal\n\nThis closes #2280.","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/588830aaaa9470bf36a0c9011fe07d1a9c48368f"},{"sha":"177168b2fdefc3ca961e9615ffe04d5fe08eca08","author":{"name":"erli ding","email":"6927140559b8444c71bea0dc28faffe15dde882c@us.ibm.com"},"message":"[FLINK-2125][streaming] Delimiter change from char to string\n\nThis closes #2233","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/177168b2fdefc3ca961e9615ffe04d5fe08eca08"},{"sha":"0360fb968378b3439c9c8724e5f3183de06d3c80","author":{"name":"Greg Hogan","email":"ab3bf20a456957ab3c21b104b37d8a70f0061e3c@greghogan.com"},"message":"[hotfix] [gelly] Reduce maximum number of generator blocks\n\nThe default maximum akka transfer size is 10 MB. This commit reduces the\nnumber of generator blocks from 2^20 to 2^15 which removes the limit on\ngraph size. The original limit of one millions blocks was intended to\nfuture-proof scalability.\n\nThis is a temporary fix as graph generation will be reworked in FLINK-3997.","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/0360fb968378b3439c9c8724e5f3183de06d3c80"},{"sha":"7e309eeb5f0c6977c5c62028bfd15dd8927c62aa","author":{"name":"smarthi","email":"460fb680219190d7266e67382bd0cb7298d502a9@apache.org"},"message":"[FLINK-4103] [table] Modify CsvTableSource to implement StreamTableSource\n\nThis closes #2162.","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/7e309eeb5f0c6977c5c62028bfd15dd8927c62aa"},{"sha":"110bba386a3ac89a8f312cd4d1405571eee9d4b5","author":{"name":"twalthr","email":"3b937f4608445891ad01c55897b04eb069f446af@apache.org"},"message":"[FLINK-4103] [table] Add CsvTableSource docs and Java accessibility","distinct":false,"url":"https://api.github.com/repos/nssalian/flink/commits/110bba386a3ac89a8f312cd4d1405571eee9d4b5"}]}
{"actor":{"display_login":"nssalian"}}